| /fs/smbfs/ |
| D | request.c | 30 static int smb_request_send_req(struct smb_request *req);
61 struct smb_request *req; in smb_do_alloc_request() local
64 req = kmem_cache_zalloc(req_cachep, GFP_KERNEL); in smb_do_alloc_request()
65 VERBOSE("allocating request: %p\n", req); in smb_do_alloc_request()
66 if (!req) in smb_do_alloc_request()
72 kmem_cache_free(req_cachep, req); in smb_do_alloc_request()
77 req->rq_buffer = buf; in smb_do_alloc_request()
78 req->rq_bufsize = bufsize; in smb_do_alloc_request()
79 req->rq_server = server; in smb_do_alloc_request()
80 init_waitqueue_head(&req->rq_wait); in smb_do_alloc_request()
[all …]
|
| D | proc.c | 413 static int smb_simple_encode_path(struct smb_request *req, char **p, in smb_simple_encode_path() argument
416 struct smb_sb_info *server = req->rq_server; in smb_simple_encode_path()
419 int maxlen = ((char *)req->rq_buffer + req->rq_bufsize) - s; in smb_simple_encode_path()
431 int align = s - (char *)req->rq_buffer; in smb_simple_encode_path()
691 smb_errno(struct smb_request *req) in smb_errno() argument
693 int errcls = req->rq_rcls; in smb_errno()
694 int error = req->rq_err; in smb_errno()
698 errcls, error, SMB_CMD(req->rq_header)); in smb_errno()
810 class, error, SMB_CMD(req->rq_header)); in smb_errno()
820 smb_request_ok(struct smb_request *req, int command, int wct, int bcc) in smb_request_ok() argument
[all …]
|
| D | smbiod.c | 126 struct smb_request *req; in smbiod_flush() local
129 req = list_entry(tmp, struct smb_request, rq_queue); in smbiod_flush()
130 req->rq_errno = -EIO; in smbiod_flush()
131 list_del_init(&req->rq_queue); in smbiod_flush()
132 smb_rput(req); in smbiod_flush()
133 wake_up_interruptible(&req->rq_wait); in smbiod_flush()
136 req = list_entry(tmp, struct smb_request, rq_queue); in smbiod_flush()
137 req->rq_errno = -EIO; in smbiod_flush()
138 list_del_init(&req->rq_queue); in smbiod_flush()
139 smb_rput(req); in smbiod_flush()
[all …]
|
| D | sock.c | 308 smb_receive(struct smb_sb_info *server, struct smb_request *req) in smb_receive() argument
313 struct kvec *p = req->rq_iov; in smb_receive()
314 size_t num = req->rq_iovlen; in smb_receive()
332 rlen = min_t(int, smb_move_iov(&p, &num, iov, req->rq_bytes_recvd), in smb_receive()
333 (req->rq_rlen - req->rq_bytes_recvd)); in smb_receive()
342 req->rq_bytes_recvd += result; in smb_receive()
356 smb_send_request(struct smb_request *req) in smb_send_request() argument
358 struct smb_sb_info *server = req->rq_server; in smb_send_request()
361 int slen = req->rq_slen - req->rq_bytes_sent; in smb_send_request()
364 struct kvec *p = req->rq_iov; in smb_send_request()
[all …]
|
| /fs/fuse/ |
| D | dev.c | 33 static void fuse_request_init(struct fuse_req *req) in fuse_request_init() argument
35 memset(req, 0, sizeof(*req)); in fuse_request_init()
36 INIT_LIST_HEAD(&req->list); in fuse_request_init()
37 INIT_LIST_HEAD(&req->intr_entry); in fuse_request_init()
38 init_waitqueue_head(&req->waitq); in fuse_request_init()
39 atomic_set(&req->count, 1); in fuse_request_init()
44 struct fuse_req *req = kmem_cache_alloc(fuse_req_cachep, GFP_KERNEL); in fuse_request_alloc() local
45 if (req) in fuse_request_alloc()
46 fuse_request_init(req); in fuse_request_alloc()
47 return req; in fuse_request_alloc()
[all …]
|
| D | dir.c | 115 static void fuse_lookup_init(struct fuse_conn *fc, struct fuse_req *req, in fuse_lookup_init() argument
120 req->in.h.opcode = FUSE_LOOKUP; in fuse_lookup_init()
121 req->in.h.nodeid = nodeid; in fuse_lookup_init()
122 req->in.numargs = 1; in fuse_lookup_init()
123 req->in.args[0].size = name->len + 1; in fuse_lookup_init()
124 req->in.args[0].value = name->name; in fuse_lookup_init()
125 req->out.numargs = 1; in fuse_lookup_init()
127 req->out.args[0].size = FUSE_COMPAT_ENTRY_OUT_SIZE; in fuse_lookup_init()
129 req->out.args[0].size = sizeof(struct fuse_entry_out); in fuse_lookup_init()
130 req->out.args[0].value = outarg; in fuse_lookup_init()
[all …]
|
| D | file.c | 23 struct fuse_req *req; in fuse_send_open() local
26 req = fuse_get_req(fc); in fuse_send_open()
27 if (IS_ERR(req)) in fuse_send_open()
28 return PTR_ERR(req); in fuse_send_open()
34 req->in.h.opcode = isdir ? FUSE_OPENDIR : FUSE_OPEN; in fuse_send_open()
35 req->in.h.nodeid = get_node_id(inode); in fuse_send_open()
36 req->in.numargs = 1; in fuse_send_open()
37 req->in.args[0].size = sizeof(inarg); in fuse_send_open()
38 req->in.args[0].value = &inarg; in fuse_send_open()
39 req->out.numargs = 1; in fuse_send_open()
[all …]
|
| D | inode.c | 87 void fuse_send_forget(struct fuse_conn *fc, struct fuse_req *req, in fuse_send_forget() argument
90 struct fuse_forget_in *inarg = &req->misc.forget_in; in fuse_send_forget()
92 req->in.h.opcode = FUSE_FORGET; in fuse_send_forget()
93 req->in.h.nodeid = nodeid; in fuse_send_forget()
94 req->in.numargs = 1; in fuse_send_forget()
95 req->in.args[0].size = sizeof(struct fuse_forget_in); in fuse_send_forget()
96 req->in.args[0].value = inarg; in fuse_send_forget()
97 fuse_request_send_noreply(fc, req); in fuse_send_forget()
267 struct fuse_req *req = fc->destroy_req; in fuse_send_destroy() local
268 if (req && fc->conn_init) { in fuse_send_destroy()
[all …]
|
| /fs/nfs/ |
| D | pagelist.c | 61 struct nfs_page *req; in nfs_create_request() local
65 req = nfs_page_alloc(); in nfs_create_request()
66 if (req != NULL) in nfs_create_request()
77 req->wb_page = page; in nfs_create_request()
78 atomic_set(&req->wb_complete, 0); in nfs_create_request()
79 req->wb_index = page->index; in nfs_create_request()
84 req->wb_offset = offset; in nfs_create_request()
85 req->wb_pgbase = offset; in nfs_create_request()
86 req->wb_bytes = count; in nfs_create_request()
87 req->wb_context = get_nfs_open_context(ctx); in nfs_create_request()
[all …]
|
| D | write.c | 39 static void nfs_redirty_request(struct nfs_page *req);
111 struct nfs_page *req = NULL; in nfs_page_find_request_locked() local
114 req = (struct nfs_page *)page_private(page); in nfs_page_find_request_locked()
115 if (req != NULL) in nfs_page_find_request_locked()
116 kref_get(&req->wb_kref); in nfs_page_find_request_locked()
118 return req; in nfs_page_find_request_locked()
124 struct nfs_page *req = NULL; in nfs_page_find_request() local
127 req = nfs_page_find_request_locked(page); in nfs_page_find_request()
129 return req; in nfs_page_find_request()
226 struct nfs_page *req; in nfs_page_async_flush() local
[all …]
|
| D | nfs3xdr.c | 272 nfs3_xdr_fhandle(struct rpc_rqst *req, __be32 *p, struct nfs_fh *fh) in nfs3_xdr_fhandle() argument
275 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs3_xdr_fhandle()
283 nfs3_xdr_sattrargs(struct rpc_rqst *req, __be32 *p, struct nfs3_sattrargs *args) in nfs3_xdr_sattrargs() argument
290 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs3_xdr_sattrargs()
298 nfs3_xdr_diropargs(struct rpc_rqst *req, __be32 *p, struct nfs3_diropargs *args) in nfs3_xdr_diropargs() argument
302 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs3_xdr_diropargs()
310 nfs3_xdr_removeargs(struct rpc_rqst *req, __be32 *p, const struct nfs_removeargs *args) in nfs3_xdr_removeargs() argument
314 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs3_xdr_removeargs()
322 nfs3_xdr_accessargs(struct rpc_rqst *req, __be32 *p, struct nfs3_accessargs *args) in nfs3_xdr_accessargs() argument
326 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs3_xdr_accessargs()
[all …]
|
| D | nfs2xdr.c | 187 nfs_xdr_fhandle(struct rpc_rqst *req, __be32 *p, struct nfs_fh *fh) in nfs_xdr_fhandle() argument
190 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs_xdr_fhandle()
198 nfs_xdr_sattrargs(struct rpc_rqst *req, __be32 *p, struct nfs_sattrargs *args) in nfs_xdr_sattrargs() argument
202 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs_xdr_sattrargs()
211 nfs_xdr_diropargs(struct rpc_rqst *req, __be32 *p, struct nfs_diropargs *args) in nfs_xdr_diropargs() argument
215 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs_xdr_diropargs()
223 nfs_xdr_removeargs(struct rpc_rqst *req, __be32 *p, const struct nfs_removeargs *args) in nfs_xdr_removeargs() argument
227 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nfs_xdr_removeargs()
237 nfs_xdr_readargs(struct rpc_rqst *req, __be32 *p, struct nfs_readargs *args) in nfs_xdr_readargs() argument
239 struct rpc_auth *auth = req->rq_task->tk_msg.rpc_cred->cr_auth; in nfs_xdr_readargs()
[all …]
|
| D | read.c | 140 static void nfs_readpage_release(struct nfs_page *req) in nfs_readpage_release() argument
142 unlock_page(req->wb_page); in nfs_readpage_release()
145 req->wb_context->path.dentry->d_inode->i_sb->s_id, in nfs_readpage_release()
146 (long long)NFS_FILEID(req->wb_context->path.dentry->d_inode), in nfs_readpage_release()
147 req->wb_bytes, in nfs_readpage_release()
148 (long long)req_offset(req)); in nfs_readpage_release()
149 nfs_clear_request(req); in nfs_readpage_release()
150 nfs_release_request(req); in nfs_readpage_release()
156 static int nfs_read_rpcsetup(struct nfs_page *req, struct nfs_read_data *data, in nfs_read_rpcsetup() argument
160 struct inode *inode = req->wb_context->path.dentry->d_inode; in nfs_read_rpcsetup()
[all …]
|
| D | nfs4xdr.c | 1161 … xdr_stream *xdr, const struct nfs4_readdir_arg *readdir, struct rpc_rqst *req, struct compound_hd… in encode_readdir() argument
1193 …ct xdr_stream *xdr, const struct nfs4_readlink *readlink, struct rpc_rqst *req, struct compound_hd… in encode_readlink() argument
1353 static int nfs4_xdr_enc_access(struct rpc_rqst *req, __be32 *p, const struct nfs4_accessargs *args) in nfs4_xdr_enc_access() argument
1360 xdr_init_encode(&xdr, &req->rq_snd_buf, p); in nfs4_xdr_enc_access()
1372 static int nfs4_xdr_enc_lookup(struct rpc_rqst *req, __be32 *p, const struct nfs4_lookup_arg *args) in nfs4_xdr_enc_lookup() argument
1379 xdr_init_encode(&xdr, &req->rq_snd_buf, p); in nfs4_xdr_enc_lookup()
1392 static int nfs4_xdr_enc_lookup_root(struct rpc_rqst *req, __be32 *p, const struct nfs4_lookup_root_… in nfs4_xdr_enc_lookup_root() argument
1399 xdr_init_encode(&xdr, &req->rq_snd_buf, p); in nfs4_xdr_enc_lookup_root()
1411 static int nfs4_xdr_enc_remove(struct rpc_rqst *req, __be32 *p, const struct nfs_removeargs *args) in nfs4_xdr_enc_remove() argument
1418 xdr_init_encode(&xdr, &req->rq_snd_buf, p); in nfs4_xdr_enc_remove()
[all …]
|
| /fs/ncpfs/ |
| D | sock.c | 57 struct list_head req; member
74 struct ncp_request_reply *req; in ncp_alloc_req() local
76 req = kmalloc(sizeof(struct ncp_request_reply), GFP_KERNEL); in ncp_alloc_req()
77 if (!req) in ncp_alloc_req()
80 init_waitqueue_head(&req->wq); in ncp_alloc_req()
81 atomic_set(&req->refs, (1)); in ncp_alloc_req()
82 req->status = RQ_IDLE; in ncp_alloc_req()
84 return req; in ncp_alloc_req()
87 static void ncp_req_get(struct ncp_request_reply *req) in ncp_req_get() argument
89 atomic_inc(&req->refs); in ncp_req_get()
[all …]
|
| /fs/ecryptfs/ |
| D | kthread.c | 54 struct ecryptfs_open_req *req; in ecryptfs_threadfn() local
66 req = list_first_entry(&ecryptfs_kthread_ctl.req_list, in ecryptfs_threadfn()
69 mutex_lock(&req->mux); in ecryptfs_threadfn()
70 list_del(&req->kthread_ctl_list); in ecryptfs_threadfn()
71 if (!(req->flags & ECRYPTFS_REQ_ZOMBIE)) { in ecryptfs_threadfn()
72 dget(req->lower_dentry); in ecryptfs_threadfn()
73 mntget(req->lower_mnt); in ecryptfs_threadfn()
74 (*req->lower_file) = dentry_open( in ecryptfs_threadfn()
75 req->lower_dentry, req->lower_mnt, in ecryptfs_threadfn()
77 req->flags |= ECRYPTFS_REQ_PROCESSED; in ecryptfs_threadfn()
[all …]
|
| /fs/ubifs/ |
| D | budget.c | 404 const struct ubifs_budget_req *req) in calc_idx_growth() argument
408 znodes = req->new_ino + (req->new_page << UBIFS_BLOCKS_PER_PAGE_SHIFT) + in calc_idx_growth()
409 req->new_dent; in calc_idx_growth()
420 const struct ubifs_budget_req *req) in calc_data_growth() argument
424 data_growth = req->new_ino ? c->inode_budget : 0; in calc_data_growth()
425 if (req->new_page) in calc_data_growth()
427 if (req->new_dent) in calc_data_growth()
429 data_growth += req->new_ino_d; in calc_data_growth()
440 const struct ubifs_budget_req *req) in calc_dd_growth() argument
444 dd_growth = req->dirtied_page ? c->page_budget : 0; in calc_dd_growth()
[all …]
|
| D | dir.c | 267 struct ubifs_budget_req req = { .new_ino = 1, .new_dent = 1, in ubifs_create() local
279 err = ubifs_budget_space(c, &req); in ubifs_create()
298 ubifs_release_budget(c, &req); in ubifs_create()
310 ubifs_release_budget(c, &req); in ubifs_create()
518 struct ubifs_budget_req req = { .new_dent = 1, .dirtied_ino = 2, in ubifs_link() local
535 err = ubifs_budget_space(c, &req); in ubifs_link()
551 ubifs_release_budget(c, &req); in ubifs_link()
560 ubifs_release_budget(c, &req); in ubifs_link()
572 struct ubifs_budget_req req = { .mod_dent = 1, .dirtied_ino = 2 }; in ubifs_unlink() local
590 err = ubifs_budget_space(c, &req); in ubifs_unlink()
[all …]
|
| /fs/lockd/ |
| D | clntproc.c | 123 static void nlmclnt_setlockargs(struct nlm_rqst *req, struct file_lock *fl) in nlmclnt_setlockargs() argument
125 struct nlm_args *argp = &req->a_args; in nlmclnt_setlockargs()
132 lock->oh.data = req->a_owner; in nlmclnt_setlockargs()
133 lock->oh.len = snprintf(req->a_owner, sizeof(req->a_owner), "%u@%s", in nlmclnt_setlockargs()
142 static void nlmclnt_release_lockargs(struct nlm_rqst *req) in nlmclnt_release_lockargs() argument
144 BUG_ON(req->a_args.lock.fl.fl_ops != NULL); in nlmclnt_release_lockargs()
251 nlmclnt_call(struct rpc_cred *cred, struct nlm_rqst *req, u32 proc) in nlmclnt_call() argument
253 struct nlm_host *host = req->a_host; in nlmclnt_call()
255 struct nlm_args *argp = &req->a_args; in nlmclnt_call()
256 struct nlm_res *resp = &req->a_res; in nlmclnt_call()
[all …]
|
| D | xdr.c | 382 nlmclt_decode_void(struct rpc_rqst *req, u32 *p, void *ptr) in nlmclt_decode_void() argument
389 nlmclt_encode_testargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlmclt_encode_testargs() argument
398 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlmclt_encode_testargs()
403 nlmclt_decode_testres(struct rpc_rqst *req, __be32 *p, struct nlm_res *resp) in nlmclt_decode_testres() argument
438 nlmclt_encode_lockargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlmclt_encode_lockargs() argument
450 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlmclt_encode_lockargs()
455 nlmclt_encode_cancargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlmclt_encode_cancargs() argument
465 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlmclt_encode_cancargs()
470 nlmclt_encode_unlockargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlmclt_encode_unlockargs() argument
478 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlmclt_encode_unlockargs()
[all …]
|
| D | xdr4.c | 389 nlm4clt_decode_void(struct rpc_rqst *req, __be32 *p, void *ptr) in nlm4clt_decode_void() argument
396 nlm4clt_encode_testargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlm4clt_encode_testargs() argument
405 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlm4clt_encode_testargs()
410 nlm4clt_decode_testres(struct rpc_rqst *req, __be32 *p, struct nlm_res *resp) in nlm4clt_decode_testres() argument
446 nlm4clt_encode_lockargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlm4clt_encode_lockargs() argument
458 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlm4clt_encode_lockargs()
463 nlm4clt_encode_cancargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlm4clt_encode_cancargs() argument
473 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlm4clt_encode_cancargs()
478 nlm4clt_encode_unlockargs(struct rpc_rqst *req, __be32 *p, nlm_args *argp) in nlm4clt_encode_unlockargs() argument
486 req->rq_slen = xdr_adjust_iovec(req->rq_svec, p); in nlm4clt_encode_unlockargs()
[all …]
|
| /fs/coda/ |
| D | psdev.c | 99 struct upc_req *req = NULL; in coda_psdev_write() local
159 req = tmp; in coda_psdev_write()
160 list_del(&req->uc_chain); in coda_psdev_write()
166 if (!req) { in coda_psdev_write()
174 if (req->uc_outSize < nbytes) { in coda_psdev_write()
176 req->uc_outSize, (long)nbytes, hdr.opcode, hdr.unique); in coda_psdev_write()
177 nbytes = req->uc_outSize; /* don't have more space! */ in coda_psdev_write()
179 if (copy_from_user(req->uc_data, buf, nbytes)) { in coda_psdev_write()
180 req->uc_flags |= REQ_ABORT; in coda_psdev_write()
181 wake_up(&req->uc_sleep); in coda_psdev_write()
[all …]
|
| D | upcall.c | 608 static inline void coda_waitfor_upcall(struct upc_req *req) in coda_waitfor_upcall() argument
618 add_wait_queue(&req->uc_sleep, &wait); in coda_waitfor_upcall()
620 if (CODA_INTERRUPTIBLE(req)) in coda_waitfor_upcall()
626 if (req->uc_flags & (REQ_WRITE | REQ_ABORT)) in coda_waitfor_upcall()
630 CODA_INTERRUPTIBLE(req)) in coda_waitfor_upcall()
637 list_del(&req->uc_chain); in coda_waitfor_upcall()
649 remove_wait_queue(&req->uc_sleep, &wait); in coda_waitfor_upcall()
669 struct upc_req *req, *sig_req; in coda_upcall() local
678 req = kmalloc(sizeof(struct upc_req), GFP_KERNEL); in coda_upcall()
679 if (!req) in coda_upcall()
[all …]
|
| /fs/ |
| D | aio.c | 428 struct kiocb *req = NULL; in __aio_get_req() local
432 req = kmem_cache_alloc(kiocb_cachep, GFP_KERNEL); in __aio_get_req()
433 if (unlikely(!req)) in __aio_get_req()
436 req->ki_flags = 0; in __aio_get_req()
437 req->ki_users = 2; in __aio_get_req()
438 req->ki_key = 0; in __aio_get_req()
439 req->ki_ctx = ctx; in __aio_get_req()
440 req->ki_cancel = NULL; in __aio_get_req()
441 req->ki_retry = NULL; in __aio_get_req()
442 req->ki_dtor = NULL; in __aio_get_req()
[all …]
|
| /fs/gfs2/locking/dlm/ |
| D | lock.c | 89 lp->req = lp->cur; in process_complete()
106 lp->req = DLM_LOCK_IV; in process_complete()
120 if (lp->req == DLM_LOCK_PR) in process_complete()
121 lp->req = DLM_LOCK_CW; in process_complete()
122 else if (lp->req == DLM_LOCK_CW) in process_complete()
123 lp->req = DLM_LOCK_PR; in process_complete()
135 lp->req = lp->cur; in process_complete()
148 lp->req = lp->cur; in process_complete()
178 gdlm_assert(lp->req == DLM_LOCK_NL, "%x,%llx", in process_complete()
186 lp->req = lp->prev_req; in process_complete()
[all …]
|