Loading net/sunrpc/auth.c +8 −0 Original line number Diff line number Diff line Loading @@ -51,6 +51,7 @@ rpcauth_register(const struct rpc_authops *ops) spin_unlock(&rpc_authflavor_lock); return ret; } EXPORT_SYMBOL(rpcauth_register); int rpcauth_unregister(const struct rpc_authops *ops) Loading @@ -68,6 +69,7 @@ rpcauth_unregister(const struct rpc_authops *ops) spin_unlock(&rpc_authflavor_lock); return ret; } EXPORT_SYMBOL(rpcauth_unregister); struct rpc_auth * rpcauth_create(rpc_authflavor_t pseudoflavor, struct rpc_clnt *clnt) Loading Loading @@ -102,6 +104,7 @@ rpcauth_create(rpc_authflavor_t pseudoflavor, struct rpc_clnt *clnt) out: return auth; } EXPORT_SYMBOL(rpcauth_create); void rpcauth_release(struct rpc_auth *auth) Loading Loading @@ -151,6 +154,7 @@ rpcauth_init_credcache(struct rpc_auth *auth) auth->au_credcache = new; return 0; } EXPORT_SYMBOL(rpcauth_init_credcache); /* * Destroy a list of credentials Loading Loading @@ -213,6 +217,7 @@ rpcauth_destroy_credcache(struct rpc_auth *auth) kfree(cache); } } EXPORT_SYMBOL(rpcauth_destroy_credcache); /* * Remove stale credentials. Avoid sleeping inside the loop. Loading Loading @@ -332,6 +337,7 @@ rpcauth_lookup_credcache(struct rpc_auth *auth, struct auth_cred * acred, out: return cred; } EXPORT_SYMBOL(rpcauth_lookup_credcache); struct rpc_cred * rpcauth_lookupcred(struct rpc_auth *auth, int flags) Loading @@ -350,6 +356,7 @@ rpcauth_lookupcred(struct rpc_auth *auth, int flags) put_group_info(acred.group_info); return ret; } EXPORT_SYMBOL(rpcauth_lookupcred); void rpcauth_init_cred(struct rpc_cred *cred, const struct auth_cred *acred, Loading Loading @@ -435,6 +442,7 @@ put_rpccred(struct rpc_cred *cred) out_destroy: cred->cr_ops->crdestroy(cred); } EXPORT_SYMBOL(put_rpccred); void rpcauth_unbindcred(struct rpc_task *task) Loading net/sunrpc/clnt.c +10 −0 Original line number Diff line number Diff line Loading @@ -345,6 +345,7 @@ rpc_clone_client(struct rpc_clnt *clnt) dprintk("RPC: %s: returned error %d\n", __FUNCTION__, err); return ERR_PTR(err); } EXPORT_SYMBOL(rpc_clone_client); /* * Properly shut down an RPC client, terminating all outstanding Loading @@ -363,6 +364,7 @@ void rpc_shutdown_client(struct rpc_clnt *clnt) rpc_release_client(clnt); } EXPORT_SYMBOL(rpc_shutdown_client); /* * Free an RPC client Loading Loading @@ -467,6 +469,7 @@ struct rpc_clnt *rpc_bind_new_program(struct rpc_clnt *old, out: return clnt; } EXPORT_SYMBOL(rpc_bind_new_program); /* * Default callback for async RPC calls Loading Loading @@ -512,11 +515,13 @@ void rpc_clnt_sigmask(struct rpc_clnt *clnt, sigset_t *oldset) { rpc_save_sigmask(oldset, clnt->cl_intr); } EXPORT_SYMBOL(rpc_clnt_sigmask); void rpc_clnt_sigunmask(struct rpc_clnt *clnt, sigset_t *oldset) { rpc_restore_sigmask(oldset); } EXPORT_SYMBOL(rpc_clnt_sigunmask); static struct rpc_task *rpc_do_run_task(struct rpc_clnt *clnt, Loading Loading @@ -572,6 +577,7 @@ int rpc_call_sync(struct rpc_clnt *clnt, struct rpc_message *msg, int flags) rpc_put_task(task); return status; } EXPORT_SYMBOL(rpc_call_sync); /** * rpc_call_async - Perform an asynchronous RPC call Loading @@ -593,6 +599,7 @@ rpc_call_async(struct rpc_clnt *clnt, struct rpc_message *msg, int flags, rpc_put_task(task); return 0; } EXPORT_SYMBOL(rpc_call_async); /** * rpc_run_task - Allocate a new RPC task, then run rpc_execute against it Loading Loading @@ -625,6 +632,7 @@ rpc_call_setup(struct rpc_task *task, struct rpc_message *msg, int flags) else task->tk_action = rpc_exit_task; } EXPORT_SYMBOL(rpc_call_setup); /** * rpc_peeraddr - extract remote peer address from clnt's xprt Loading Loading @@ -671,6 +679,7 @@ rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize if (xprt->ops->set_buffer_size) xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); } EXPORT_SYMBOL(rpc_setbufsize); /* * Return size of largest payload RPC client can support, in bytes Loading Loading @@ -710,6 +719,7 @@ rpc_restart_call(struct rpc_task *task) task->tk_action = call_start; } EXPORT_SYMBOL(rpc_restart_call); /* * 0. Initial state Loading net/sunrpc/rpc_pipe.c +3 −0 Original line number Diff line number Diff line Loading @@ -113,6 +113,7 @@ rpc_queue_upcall(struct inode *inode, struct rpc_pipe_msg *msg) wake_up(&rpci->waitq); return res; } EXPORT_SYMBOL(rpc_queue_upcall); static inline void rpc_inode_setowner(struct inode *inode, void *private) Loading Loading @@ -805,6 +806,7 @@ rpc_mkpipe(struct dentry *parent, const char *name, void *private, struct rpc_pi -ENOMEM); goto out; } EXPORT_SYMBOL(rpc_mkpipe); /** * rpc_unlink - remove a pipe Loading Loading @@ -835,6 +837,7 @@ rpc_unlink(struct dentry *dentry) dput(parent); return error; } EXPORT_SYMBOL(rpc_unlink); /* * populate the filesystem Loading net/sunrpc/sched.c +9 −0 Original line number Diff line number Diff line Loading @@ -373,6 +373,7 @@ void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, __rpc_sleep_on(q, task, action, timer); spin_unlock_bh(&q->lock); } EXPORT_SYMBOL(rpc_sleep_on); /** * __rpc_do_wake_up_task - wake up a single rpc_task Loading Loading @@ -444,6 +445,7 @@ void rpc_wake_up_task(struct rpc_task *task) } rcu_read_unlock_bh(); } EXPORT_SYMBOL(rpc_wake_up_task); /* * Wake up the next task on a priority queue. Loading Loading @@ -519,6 +521,7 @@ struct rpc_task * rpc_wake_up_next(struct rpc_wait_queue *queue) return task; } EXPORT_SYMBOL(rpc_wake_up_next); /** * rpc_wake_up - wake up all rpc_tasks Loading @@ -544,6 +547,7 @@ void rpc_wake_up(struct rpc_wait_queue *queue) spin_unlock(&queue->lock); rcu_read_unlock_bh(); } EXPORT_SYMBOL(rpc_wake_up); /** * rpc_wake_up_status - wake up all rpc_tasks and set their status value. Loading Loading @@ -572,6 +576,7 @@ void rpc_wake_up_status(struct rpc_wait_queue *queue, int status) spin_unlock(&queue->lock); rcu_read_unlock_bh(); } EXPORT_SYMBOL(rpc_wake_up_status); static void __rpc_atrun(struct rpc_task *task) { Loading @@ -586,6 +591,7 @@ void rpc_delay(struct rpc_task *task, unsigned long delay) task->tk_timeout = delay; rpc_sleep_on(&delay_queue, task, NULL, __rpc_atrun); } EXPORT_SYMBOL(rpc_delay); /* * Helper to call task->tk_ops->rpc_call_prepare Loading Loading @@ -731,6 +737,7 @@ void rpc_execute(struct rpc_task *task) rpc_set_running(task); __rpc_execute(task); } EXPORT_SYMBOL(rpc_execute); static void rpc_async_schedule(struct work_struct *work) { Loading Loading @@ -848,6 +855,7 @@ void rpc_init_task(struct rpc_task *task, struct rpc_clnt *clnt, int flags, cons dprintk("RPC: new task initialized, procpid %u\n", task_pid_nr(current)); } EXPORT_SYMBOL(rpc_init_task); static struct rpc_task * rpc_alloc_task(void) Loading Loading @@ -959,6 +967,7 @@ void rpc_killall_tasks(struct rpc_clnt *clnt) } spin_unlock(&clnt->cl_lock); } EXPORT_SYMBOL(rpc_killall_tasks); int rpciod_up(void) { Loading net/sunrpc/stats.c +2 −0 Original line number Diff line number Diff line Loading @@ -241,12 +241,14 @@ rpc_proc_register(struct rpc_stat *statp) { return do_register(statp->program->name, statp, &rpc_proc_fops); } EXPORT_SYMBOL(rpc_proc_register); void rpc_proc_unregister(const char *name) { remove_proc_entry(name, proc_net_rpc); } EXPORT_SYMBOL(rpc_proc_unregister); struct proc_dir_entry * svc_proc_register(struct svc_stat *statp, const struct file_operations *fops) Loading Loading
net/sunrpc/auth.c +8 −0 Original line number Diff line number Diff line Loading @@ -51,6 +51,7 @@ rpcauth_register(const struct rpc_authops *ops) spin_unlock(&rpc_authflavor_lock); return ret; } EXPORT_SYMBOL(rpcauth_register); int rpcauth_unregister(const struct rpc_authops *ops) Loading @@ -68,6 +69,7 @@ rpcauth_unregister(const struct rpc_authops *ops) spin_unlock(&rpc_authflavor_lock); return ret; } EXPORT_SYMBOL(rpcauth_unregister); struct rpc_auth * rpcauth_create(rpc_authflavor_t pseudoflavor, struct rpc_clnt *clnt) Loading Loading @@ -102,6 +104,7 @@ rpcauth_create(rpc_authflavor_t pseudoflavor, struct rpc_clnt *clnt) out: return auth; } EXPORT_SYMBOL(rpcauth_create); void rpcauth_release(struct rpc_auth *auth) Loading Loading @@ -151,6 +154,7 @@ rpcauth_init_credcache(struct rpc_auth *auth) auth->au_credcache = new; return 0; } EXPORT_SYMBOL(rpcauth_init_credcache); /* * Destroy a list of credentials Loading Loading @@ -213,6 +217,7 @@ rpcauth_destroy_credcache(struct rpc_auth *auth) kfree(cache); } } EXPORT_SYMBOL(rpcauth_destroy_credcache); /* * Remove stale credentials. Avoid sleeping inside the loop. Loading Loading @@ -332,6 +337,7 @@ rpcauth_lookup_credcache(struct rpc_auth *auth, struct auth_cred * acred, out: return cred; } EXPORT_SYMBOL(rpcauth_lookup_credcache); struct rpc_cred * rpcauth_lookupcred(struct rpc_auth *auth, int flags) Loading @@ -350,6 +356,7 @@ rpcauth_lookupcred(struct rpc_auth *auth, int flags) put_group_info(acred.group_info); return ret; } EXPORT_SYMBOL(rpcauth_lookupcred); void rpcauth_init_cred(struct rpc_cred *cred, const struct auth_cred *acred, Loading Loading @@ -435,6 +442,7 @@ put_rpccred(struct rpc_cred *cred) out_destroy: cred->cr_ops->crdestroy(cred); } EXPORT_SYMBOL(put_rpccred); void rpcauth_unbindcred(struct rpc_task *task) Loading
net/sunrpc/clnt.c +10 −0 Original line number Diff line number Diff line Loading @@ -345,6 +345,7 @@ rpc_clone_client(struct rpc_clnt *clnt) dprintk("RPC: %s: returned error %d\n", __FUNCTION__, err); return ERR_PTR(err); } EXPORT_SYMBOL(rpc_clone_client); /* * Properly shut down an RPC client, terminating all outstanding Loading @@ -363,6 +364,7 @@ void rpc_shutdown_client(struct rpc_clnt *clnt) rpc_release_client(clnt); } EXPORT_SYMBOL(rpc_shutdown_client); /* * Free an RPC client Loading Loading @@ -467,6 +469,7 @@ struct rpc_clnt *rpc_bind_new_program(struct rpc_clnt *old, out: return clnt; } EXPORT_SYMBOL(rpc_bind_new_program); /* * Default callback for async RPC calls Loading Loading @@ -512,11 +515,13 @@ void rpc_clnt_sigmask(struct rpc_clnt *clnt, sigset_t *oldset) { rpc_save_sigmask(oldset, clnt->cl_intr); } EXPORT_SYMBOL(rpc_clnt_sigmask); void rpc_clnt_sigunmask(struct rpc_clnt *clnt, sigset_t *oldset) { rpc_restore_sigmask(oldset); } EXPORT_SYMBOL(rpc_clnt_sigunmask); static struct rpc_task *rpc_do_run_task(struct rpc_clnt *clnt, Loading Loading @@ -572,6 +577,7 @@ int rpc_call_sync(struct rpc_clnt *clnt, struct rpc_message *msg, int flags) rpc_put_task(task); return status; } EXPORT_SYMBOL(rpc_call_sync); /** * rpc_call_async - Perform an asynchronous RPC call Loading @@ -593,6 +599,7 @@ rpc_call_async(struct rpc_clnt *clnt, struct rpc_message *msg, int flags, rpc_put_task(task); return 0; } EXPORT_SYMBOL(rpc_call_async); /** * rpc_run_task - Allocate a new RPC task, then run rpc_execute against it Loading Loading @@ -625,6 +632,7 @@ rpc_call_setup(struct rpc_task *task, struct rpc_message *msg, int flags) else task->tk_action = rpc_exit_task; } EXPORT_SYMBOL(rpc_call_setup); /** * rpc_peeraddr - extract remote peer address from clnt's xprt Loading Loading @@ -671,6 +679,7 @@ rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize if (xprt->ops->set_buffer_size) xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); } EXPORT_SYMBOL(rpc_setbufsize); /* * Return size of largest payload RPC client can support, in bytes Loading Loading @@ -710,6 +719,7 @@ rpc_restart_call(struct rpc_task *task) task->tk_action = call_start; } EXPORT_SYMBOL(rpc_restart_call); /* * 0. Initial state Loading
net/sunrpc/rpc_pipe.c +3 −0 Original line number Diff line number Diff line Loading @@ -113,6 +113,7 @@ rpc_queue_upcall(struct inode *inode, struct rpc_pipe_msg *msg) wake_up(&rpci->waitq); return res; } EXPORT_SYMBOL(rpc_queue_upcall); static inline void rpc_inode_setowner(struct inode *inode, void *private) Loading Loading @@ -805,6 +806,7 @@ rpc_mkpipe(struct dentry *parent, const char *name, void *private, struct rpc_pi -ENOMEM); goto out; } EXPORT_SYMBOL(rpc_mkpipe); /** * rpc_unlink - remove a pipe Loading Loading @@ -835,6 +837,7 @@ rpc_unlink(struct dentry *dentry) dput(parent); return error; } EXPORT_SYMBOL(rpc_unlink); /* * populate the filesystem Loading
net/sunrpc/sched.c +9 −0 Original line number Diff line number Diff line Loading @@ -373,6 +373,7 @@ void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, __rpc_sleep_on(q, task, action, timer); spin_unlock_bh(&q->lock); } EXPORT_SYMBOL(rpc_sleep_on); /** * __rpc_do_wake_up_task - wake up a single rpc_task Loading Loading @@ -444,6 +445,7 @@ void rpc_wake_up_task(struct rpc_task *task) } rcu_read_unlock_bh(); } EXPORT_SYMBOL(rpc_wake_up_task); /* * Wake up the next task on a priority queue. Loading Loading @@ -519,6 +521,7 @@ struct rpc_task * rpc_wake_up_next(struct rpc_wait_queue *queue) return task; } EXPORT_SYMBOL(rpc_wake_up_next); /** * rpc_wake_up - wake up all rpc_tasks Loading @@ -544,6 +547,7 @@ void rpc_wake_up(struct rpc_wait_queue *queue) spin_unlock(&queue->lock); rcu_read_unlock_bh(); } EXPORT_SYMBOL(rpc_wake_up); /** * rpc_wake_up_status - wake up all rpc_tasks and set their status value. Loading Loading @@ -572,6 +576,7 @@ void rpc_wake_up_status(struct rpc_wait_queue *queue, int status) spin_unlock(&queue->lock); rcu_read_unlock_bh(); } EXPORT_SYMBOL(rpc_wake_up_status); static void __rpc_atrun(struct rpc_task *task) { Loading @@ -586,6 +591,7 @@ void rpc_delay(struct rpc_task *task, unsigned long delay) task->tk_timeout = delay; rpc_sleep_on(&delay_queue, task, NULL, __rpc_atrun); } EXPORT_SYMBOL(rpc_delay); /* * Helper to call task->tk_ops->rpc_call_prepare Loading Loading @@ -731,6 +737,7 @@ void rpc_execute(struct rpc_task *task) rpc_set_running(task); __rpc_execute(task); } EXPORT_SYMBOL(rpc_execute); static void rpc_async_schedule(struct work_struct *work) { Loading Loading @@ -848,6 +855,7 @@ void rpc_init_task(struct rpc_task *task, struct rpc_clnt *clnt, int flags, cons dprintk("RPC: new task initialized, procpid %u\n", task_pid_nr(current)); } EXPORT_SYMBOL(rpc_init_task); static struct rpc_task * rpc_alloc_task(void) Loading Loading @@ -959,6 +967,7 @@ void rpc_killall_tasks(struct rpc_clnt *clnt) } spin_unlock(&clnt->cl_lock); } EXPORT_SYMBOL(rpc_killall_tasks); int rpciod_up(void) { Loading
net/sunrpc/stats.c +2 −0 Original line number Diff line number Diff line Loading @@ -241,12 +241,14 @@ rpc_proc_register(struct rpc_stat *statp) { return do_register(statp->program->name, statp, &rpc_proc_fops); } EXPORT_SYMBOL(rpc_proc_register); void rpc_proc_unregister(const char *name) { remove_proc_entry(name, proc_net_rpc); } EXPORT_SYMBOL(rpc_proc_unregister); struct proc_dir_entry * svc_proc_register(struct svc_stat *statp, const struct file_operations *fops) Loading