111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert/**************************************************************************** 211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert **************************************************************************** 311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert *** 411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert *** This header was automatically generated from a Linux kernel header 511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert *** of the same name, to make information necessary for userspace to 611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert *** call into the kernel available to libc. It contains only constants, 711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert *** structures, and macros generated from the original header, and thus, 811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert *** contains no copyrightable information. 911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert *** 1011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert **************************************************************************** 1111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert ****************************************************************************/ 1211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#ifndef _LINUX_SUNRPC_SCHED_H_ 1311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define _LINUX_SUNRPC_SCHED_H_ 1411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 1511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#include <linux/timer.h> 1611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#include <linux/sunrpc/types.h> 1711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#include <linux/spinlock.h> 1811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#include <linux/wait.h> 1911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#include <linux/workqueue.h> 2011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#include <linux/sunrpc/xdr.h> 2111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 2211cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_procinfo; 2311cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_message { 2411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct rpc_procinfo * rpc_proc; 2511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void * rpc_argp; 2611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void * rpc_resp; 2711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct rpc_cred * rpc_cred; 2811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert}; 2911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 3011cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_call_ops; 3111cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_wait_queue; 3211cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_wait { 3311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct list_head list; 3411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct list_head links; 3511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct rpc_wait_queue * rpc_waitq; 3611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert}; 3711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 3811cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_task { 3911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#ifdef RPC_DEBUG 4011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned long tk_magic; 4111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#endif 4211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert atomic_t tk_count; 4311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct list_head tk_task; 4411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct rpc_clnt * tk_client; 4511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct rpc_rqst * tk_rqstp; 4611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert int tk_status; 4711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 4811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct rpc_message tk_msg; 4911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert __u8 tk_garb_retry; 5011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert __u8 tk_cred_retry; 5111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 5211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned long tk_cookie; 5311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 5411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void (*tk_timeout_fn)(struct rpc_task *); 5511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void (*tk_callback)(struct rpc_task *); 5611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void (*tk_action)(struct rpc_task *); 5711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert const struct rpc_call_ops *tk_ops; 5811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void * tk_calldata; 5911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 6011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct timer_list tk_timer; 6111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned long tk_timeout; 6211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned short tk_flags; 6311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned char tk_priority : 2; 6411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned long tk_runstate; 6511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct workqueue_struct *tk_workqueue; 6611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert union { 6711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct work_struct tk_work; 6811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct rpc_wait tk_wait; 6911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert } u; 7011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 7111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned short tk_timeouts; 7211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert size_t tk_bytes_sent; 7311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned long tk_start; 7411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert long tk_rtt; 7511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 7611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#ifdef RPC_DEBUG 7711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned short tk_pid; 7811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#endif 7911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert}; 8011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define tk_auth tk_client->cl_auth 8111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define tk_xprt tk_client->cl_xprt 8211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 8311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define task_for_each(task, pos, head) list_for_each(pos, head) if ((task=list_entry(pos, struct rpc_task, u.tk_wait.list)),1) 8411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 8511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define task_for_first(task, head) if (!list_empty(head) && ((task=list_entry((head)->next, struct rpc_task, u.tk_wait.list)),1)) 8611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 8711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define alltask_for_each(task, pos, head) list_for_each(pos, head) if ((task=list_entry(pos, struct rpc_task, tk_task)),1) 8811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 8911cd02dfb91661c65134cac258cf5924270e9d2Dan Alberttypedef void (*rpc_action)(struct rpc_task *); 9011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 9111cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_call_ops { 9211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void (*rpc_call_prepare)(struct rpc_task *, void *); 9311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void (*rpc_call_done)(struct rpc_task *, void *); 9411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert void (*rpc_release)(void *); 9511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert}; 9611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 9711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_ASYNC 0x0001 9811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_SWAPPER 0x0002 9911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_CHILD 0x0008 10011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_CALL_MAJORSEEN 0x0020 10111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_ROOTCREDS 0x0040 10211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_DYNAMIC 0x0080 10311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_KILLED 0x0100 10411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_SOFT 0x0200 10511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_NOINTR 0x0400 10611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 10711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_ASYNC(t) ((t)->tk_flags & RPC_TASK_ASYNC) 10811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_CHILD(t) ((t)->tk_flags & RPC_TASK_CHILD) 10911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_SWAPPER(t) ((t)->tk_flags & RPC_TASK_SWAPPER) 11011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_DO_ROOTOVERRIDE(t) ((t)->tk_flags & RPC_TASK_ROOTCREDS) 11111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_ASSASSINATED(t) ((t)->tk_flags & RPC_TASK_KILLED) 11211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_DO_CALLBACK(t) ((t)->tk_callback != NULL) 11311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_SOFT(t) ((t)->tk_flags & RPC_TASK_SOFT) 11411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_UNINTERRUPTIBLE(t) ((t)->tk_flags & RPC_TASK_NOINTR) 11511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 11611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_RUNNING 0 11711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_QUEUED 1 11811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_WAKEUP 2 11911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_HAS_TIMER 3 12011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_TASK_ACTIVE 4 12111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 12211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_RUNNING(t) (test_bit(RPC_TASK_RUNNING, &(t)->tk_runstate)) 12311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_set_running(t) (set_bit(RPC_TASK_RUNNING, &(t)->tk_runstate)) 12411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_test_and_set_running(t) (test_and_set_bit(RPC_TASK_RUNNING, &(t)->tk_runstate)) 12511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_clear_running(t) do { smp_mb__before_clear_bit(); clear_bit(RPC_TASK_RUNNING, &(t)->tk_runstate); smp_mb__after_clear_bit(); } while (0) 12611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 12711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_QUEUED(t) (test_bit(RPC_TASK_QUEUED, &(t)->tk_runstate)) 12811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_set_queued(t) (set_bit(RPC_TASK_QUEUED, &(t)->tk_runstate)) 12911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_clear_queued(t) do { smp_mb__before_clear_bit(); clear_bit(RPC_TASK_QUEUED, &(t)->tk_runstate); smp_mb__after_clear_bit(); } while (0) 13011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 13111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_start_wakeup(t) (test_and_set_bit(RPC_TASK_WAKEUP, &(t)->tk_runstate) == 0) 13211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_finish_wakeup(t) do { smp_mb__before_clear_bit(); clear_bit(RPC_TASK_WAKEUP, &(t)->tk_runstate); smp_mb__after_clear_bit(); } while (0) 13311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 13411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_ACTIVATED(t) (test_bit(RPC_TASK_ACTIVE, &(t)->tk_runstate)) 13511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_set_active(t) (set_bit(RPC_TASK_ACTIVE, &(t)->tk_runstate)) 13611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define rpc_clear_active(t) do { smp_mb__before_clear_bit(); clear_bit(RPC_TASK_ACTIVE, &(t)->tk_runstate); smp_mb__after_clear_bit(); } while(0) 13711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 13811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_PRIORITY_LOW 0 13911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_PRIORITY_NORMAL 1 14011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_PRIORITY_HIGH 2 14111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_NR_PRIORITY (RPC_PRIORITY_HIGH+1) 14211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 14311cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_wait_queue { 14411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert spinlock_t lock; 14511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert struct list_head tasks[RPC_NR_PRIORITY]; 14611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned long cookie; 14711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned char maxpriority; 14811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned char priority; 14911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned char count; 15011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned char nr; 15111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert unsigned short qlen; 15211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#ifdef RPC_DEBUG 15311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert const char * name; 15411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#endif 15511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert}; 15611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 15711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_BATCH_COUNT 16 15811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 15911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#ifndef RPC_DEBUG 16011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, } 16111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#else 16211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, .name = qname, } 16311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#endif 16411cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_WAITQ(var,qname) struct rpc_wait_queue var = RPC_WAITQ_INIT(var,qname) 16511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 16611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#define RPC_IS_PRIORITY(q) ((q)->maxpriority > 0) 16711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 16811cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_task *rpc_new_task(struct rpc_clnt *, int flags, 16911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert const struct rpc_call_ops *ops, void *data); 17011cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_task *rpc_run_task(struct rpc_clnt *clnt, int flags, 17111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert const struct rpc_call_ops *ops, void *data); 17211cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_task *rpc_new_child(struct rpc_clnt *, struct rpc_task *parent); 17311cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 17411cd02dfb91661c65134cac258cf5924270e9d2Dan Albertstruct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *); 17511cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 17611cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#ifdef RPC_DEBUG 17711cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 17811cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#endif 17911cd02dfb91661c65134cac258cf5924270e9d2Dan Albert 18011cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#ifdef RPC_DEBUG 18111cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#endif 18211cd02dfb91661c65134cac258cf5924270e9d2Dan Albert#endif 183