| /fs/reiserfs/ |
| D | hashes.c | 44 u32 keyed_hash(const signed char *msg, int len) in keyed_hash() argument
59 a = (u32) msg[0] | in keyed_hash()
60 (u32) msg[1] << 8 | (u32) msg[2] << 16 | (u32) msg[3] << 24; in keyed_hash()
61 b = (u32) msg[4] | in keyed_hash()
62 (u32) msg[5] << 8 | (u32) msg[6] << 16 | (u32) msg[7] << 24; in keyed_hash()
63 c = (u32) msg[8] | in keyed_hash()
64 (u32) msg[9] << 8 | in keyed_hash()
65 (u32) msg[10] << 16 | (u32) msg[11] << 24; in keyed_hash()
66 d = (u32) msg[12] | in keyed_hash()
67 (u32) msg[13] << 8 | in keyed_hash()
[all …]
|
| /fs/nfs/ |
| D | proc.c | 59 struct rpc_message msg = { in nfs_proc_get_root() local
68 status = rpc_call_sync(server->client, &msg, 0); in nfs_proc_get_root()
71 status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0); in nfs_proc_get_root()
76 msg.rpc_proc = &nfs_procedures[NFSPROC_STATFS]; in nfs_proc_get_root()
77 msg.rpc_resp = &fsinfo; in nfs_proc_get_root()
78 status = rpc_call_sync(server->client, &msg, 0); in nfs_proc_get_root()
81 status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0); in nfs_proc_get_root()
105 struct rpc_message msg = { in nfs_proc_getattr() local
119 status = rpc_call_sync(server->client, &msg, task_flags); in nfs_proc_getattr()
133 struct rpc_message msg = { in nfs_proc_setattr() local
[all …]
|
| D | nfs3proc.c | 32 nfs3_rpc_wrapper(struct rpc_clnt *clnt, struct rpc_message *msg, int flags) in nfs3_rpc_wrapper() argument
36 res = rpc_call_sync(clnt, msg, flags); in nfs3_rpc_wrapper()
45 #define rpc_call_sync(clnt, msg, flags) nfs3_rpc_wrapper(clnt, msg, flags) argument
64 struct rpc_message msg = { in do_proc_get_root() local
73 status = rpc_call_sync(client, &msg, 0); in do_proc_get_root()
76 msg.rpc_proc = &nfs3_procedures[NFS3PROC_GETATTR]; in do_proc_get_root()
77 msg.rpc_resp = info->fattr; in do_proc_get_root()
78 status = rpc_call_sync(client, &msg, 0); in do_proc_get_root()
107 struct rpc_message msg = { in nfs3_proc_getattr() local
121 status = rpc_call_sync(server->client, &msg, task_flags); in nfs3_proc_getattr()
[all …]
|
| D | nfs42proc.c | 44 static int _nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep, in _nfs42_proc_fallocate() argument
61 msg->rpc_argp = &args; in _nfs42_proc_fallocate()
62 msg->rpc_resp = &res; in _nfs42_proc_fallocate()
80 status = nfs4_call_sync(server->client, server, msg, in _nfs42_proc_fallocate()
90 static int nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep, in nfs42_proc_fallocate() argument
111 err = _nfs42_proc_fallocate(msg, filep, lock, offset, len); in nfs42_proc_fallocate()
125 struct rpc_message msg = { in nfs42_proc_allocate() local
136 err = nfs42_proc_fallocate(&msg, filep, offset, len); in nfs42_proc_allocate()
146 struct rpc_message msg = { in nfs42_proc_deallocate() local
157 err = nfs42_proc_fallocate(&msg, filep, offset, len); in nfs42_proc_deallocate()
[all …]
|
| D | nfs4proc.c | 1147 struct rpc_message *msg, in nfs4_do_call_sync() argument
1160 .rpc_message = msg, in nfs4_do_call_sync()
1171 struct rpc_message *msg, in nfs4_call_sync_sequence() argument
1175 return nfs4_do_call_sync(clnt, server, msg, args, res, 0); in nfs4_call_sync_sequence()
1181 struct rpc_message *msg, in nfs4_call_sync() argument
1187 return nfs4_call_sync_sequence(clnt, server, msg, args, res); in nfs4_call_sync()
2386 struct rpc_message msg = { in _nfs4_proc_open_confirm() local
2394 .rpc_message = &msg, in _nfs4_proc_open_confirm()
2551 struct rpc_message msg = { in nfs4_run_open_task() local
2559 .rpc_message = &msg, in nfs4_run_open_task()
[all …]
|
| D | unlink.c | 91 struct rpc_message msg = { in nfs_do_call_unlink() local
97 .rpc_message = &msg, in nfs_do_call_unlink()
109 NFS_PROTO(dir)->unlink_setup(&msg, data->dentry, inode); in nfs_do_call_unlink()
338 struct rpc_message msg = { }; in nfs_async_rename() local
340 .rpc_message = &msg, in nfs_async_rename()
354 msg.rpc_argp = &data->args; in nfs_async_rename()
355 msg.rpc_resp = &data->res; in nfs_async_rename()
356 msg.rpc_cred = data->cred; in nfs_async_rename()
381 NFS_PROTO(data->old_dir)->rename_setup(&msg, old_dentry, new_dentry); in nfs_async_rename()
|
| D | nfs3acl.c | 59 struct rpc_message msg = { in nfs3_get_acl() local
86 msg.rpc_proc = &server->client_acl->cl_procinfo[ACLPROC3_GETACL]; in nfs3_get_acl()
96 status = rpc_call_sync(server->client_acl, &msg, 0); in nfs3_get_acl()
170 struct rpc_message msg = { in __nfs3_proc_setacls() local
215 msg.rpc_proc = &server->client_acl->cl_procinfo[ACLPROC3_SETACL]; in __nfs3_proc_setacls()
216 msg.rpc_resp = fattr; in __nfs3_proc_setacls()
217 status = rpc_call_sync(server->client_acl, &msg, 0); in __nfs3_proc_setacls()
|
| D | mount_clnt.c | 152 struct rpc_message msg = { in nfs_mount() local
185 msg.rpc_proc = &mnt_clnt->cl_procinfo[MOUNTPROC3_MNT]; in nfs_mount()
187 msg.rpc_proc = &mnt_clnt->cl_procinfo[MOUNTPROC_MNT]; in nfs_mount()
189 status = rpc_call_sync(mnt_clnt, &msg, RPC_TASK_SOFT|RPC_TASK_TIMEOUT); in nfs_mount()
254 struct rpc_message msg = { in nfs_umount() local
274 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC3_UMNT]; in nfs_umount()
276 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC_UMNT]; in nfs_umount()
278 status = rpc_call_sync(clnt, &msg, 0); in nfs_umount()
|
| D | nfs4idmap.c | 513 struct rpc_pipe_msg *msg) in nfs_idmap_prepare_message() argument
545 msg->data = im; in nfs_idmap_prepare_message()
546 msg->len = sizeof(struct idmap_msg); in nfs_idmap_prepare_message()
584 struct rpc_pipe_msg *msg; in nfs_idmap_legacy_upcall() local
599 msg = &data->pipe_msg; in nfs_idmap_legacy_upcall()
604 ret = nfs_idmap_prepare_message(key->description, idmap, im, msg); in nfs_idmap_legacy_upcall()
612 ret = rpc_queue_upcall(idmap->idmap_pipe, msg); in nfs_idmap_legacy_upcall()
722 idmap_pipe_destroy_msg(struct rpc_pipe_msg *msg) in idmap_pipe_destroy_msg() argument
724 struct idmap_legacy_upcalldata *data = container_of(msg, in idmap_pipe_destroy_msg()
729 if (msg->errno) in idmap_pipe_destroy_msg()
[all …]
|
| D | nfs4_fs.h | 362 struct rpc_clnt **clntp, struct rpc_message *msg) in _nfs4_state_protect() argument
378 msg->rpc_cred = rpc_machine_cred(); in _nfs4_state_protect()
398 struct rpc_clnt **clntp, struct rpc_message *msg) in nfs4_state_protect() argument
400 _nfs4_state_protect(clp, sp4_mode, clntp, msg); in nfs4_state_protect()
410 struct rpc_message *msg, struct nfs_pgio_header *hdr) in nfs4_state_protect_write() argument
412 if (_nfs4_state_protect(clp, NFS_SP4_MACH_CRED_WRITE, clntp, msg) && in nfs4_state_protect_write()
431 struct rpc_clnt **clntp, struct rpc_message *msg) in nfs4_state_protect() argument
437 struct rpc_message *msg, struct nfs_pgio_header *hdr) in nfs4_state_protect_write() argument
|
| /fs/ecryptfs/ |
| D | miscdev.c | 150 struct ecryptfs_message *msg; in ecryptfs_send_miscdev() local
152 msg = kmalloc((sizeof(*msg) + data_size), GFP_KERNEL); in ecryptfs_send_miscdev()
153 if (!msg) in ecryptfs_send_miscdev()
157 msg_ctx->msg = msg; in ecryptfs_send_miscdev()
158 msg_ctx->msg->index = msg_ctx->index; in ecryptfs_send_miscdev()
159 msg_ctx->msg->data_len = data_size; in ecryptfs_send_miscdev()
161 memcpy(msg_ctx->msg->data, data, data_size); in ecryptfs_send_miscdev()
162 msg_ctx->msg_size = (sizeof(*msg_ctx->msg) + data_size); in ecryptfs_send_miscdev()
259 if (msg_ctx->msg) { in ecryptfs_miscdev_read()
289 if (msg_ctx->msg) { in ecryptfs_miscdev_read()
[all …]
|
| D | messaging.c | 87 kfree(msg_ctx->msg); in ecryptfs_msg_ctx_alloc_to_free()
88 msg_ctx->msg = NULL; in ecryptfs_msg_ctx_alloc_to_free()
206 struct ecryptfs_message *msg, u32 seq) in ecryptfs_process_response() argument
212 if (msg->index >= ecryptfs_message_buf_len) { in ecryptfs_process_response()
216 "allowable is [%d]\n", __func__, msg->index, in ecryptfs_process_response()
220 msg_ctx = &ecryptfs_msg_ctx_arr[msg->index]; in ecryptfs_process_response()
234 msg_size = (sizeof(*msg) + msg->data_len); in ecryptfs_process_response()
235 msg_ctx->msg = kmemdup(msg, msg_size, GFP_KERNEL); in ecryptfs_process_response()
236 if (!msg_ctx->msg) { in ecryptfs_process_response()
325 struct ecryptfs_message **msg) in ecryptfs_wait_for_response() argument
[all …]
|
| /fs/ocfs2/ |
| D | stack_user.c | 361 struct ocfs2_control_message_setn *msg) in ocfs2_control_do_setnode_msg() argument
371 if (strncmp(msg->tag, OCFS2_CONTROL_MESSAGE_SETNODE_OP, in ocfs2_control_do_setnode_msg()
375 if ((msg->space != ' ') || (msg->newline != '\n')) in ocfs2_control_do_setnode_msg()
377 msg->space = msg->newline = '\0'; in ocfs2_control_do_setnode_msg()
379 nodenum = simple_strtol(msg->nodestr, &ptr, 16); in ocfs2_control_do_setnode_msg()
392 struct ocfs2_control_message_setv *msg) in ocfs2_control_do_setversion_msg() argument
404 if (strncmp(msg->tag, OCFS2_CONTROL_MESSAGE_SETVERSION_OP, in ocfs2_control_do_setversion_msg()
408 if ((msg->space1 != ' ') || (msg->space2 != ' ') || in ocfs2_control_do_setversion_msg()
409 (msg->newline != '\n')) in ocfs2_control_do_setversion_msg()
411 msg->space1 = msg->space2 = msg->newline = '\0'; in ocfs2_control_do_setversion_msg()
[all …]
|
| /fs/afs/ |
| D | rxrpc.c | 279 static void afs_load_bvec(struct afs_call *call, struct msghdr *msg, in afs_load_bvec() argument
291 msg->msg_flags |= MSG_MORE; in afs_load_bvec()
296 msg->msg_flags &= ~MSG_MORE; in afs_load_bvec()
305 iov_iter_bvec(&msg->msg_iter, WRITE, bv, nr, bytes); in afs_load_bvec()
323 static int afs_send_pages(struct afs_call *call, struct msghdr *msg) in afs_send_pages() argument
335 afs_load_bvec(call, msg, bv, first, last, offset); in afs_send_pages()
336 trace_afs_send_pages(call, msg, first, last, offset); in afs_send_pages()
339 bytes = msg->msg_iter.count; in afs_send_pages()
340 nr = msg->msg_iter.nr_segs; in afs_send_pages()
342 ret = rxrpc_kernel_send_data(op->net->socket, call->rxcall, msg, in afs_send_pages()
[all …]
|
| /fs/nfs/blocklayout/ |
| D | rpc_pipefs.c | 60 struct rpc_pipe_msg *msg = &bl_pipe_msg.msg; in bl_resolve_deviceid() local
75 memset(msg, 0, sizeof(*msg)); in bl_resolve_deviceid()
76 msg->len = sizeof(*bl_msg) + b->simple.len; in bl_resolve_deviceid()
77 msg->data = kzalloc(msg->len, gfp_mask); in bl_resolve_deviceid()
78 if (!msg->data) in bl_resolve_deviceid()
81 bl_msg = msg->data; in bl_resolve_deviceid()
84 nfs4_encode_simple(msg->data + sizeof(*bl_msg), b); in bl_resolve_deviceid()
88 rc = rpc_queue_upcall(nn->bl_device_pipe, msg); in bl_resolve_deviceid()
106 kfree(msg->data); in bl_resolve_deviceid()
129 static void bl_pipe_destroy_msg(struct rpc_pipe_msg *msg) in bl_pipe_destroy_msg() argument
[all …]
|
| /fs/ceph/ |
| D | mds_client.c | 576 static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg, in parse_reply_info() argument
584 info->head = msg->front.iov_base; in parse_reply_info()
585 p = msg->front.iov_base + sizeof(struct ceph_mds_reply_head); in parse_reply_info()
586 end = p + msg->front.iov_len - sizeof(struct ceph_mds_reply_head); in parse_reply_info()
1189 struct ceph_msg *msg; in ceph_create_session_msg() local
1192 msg = ceph_msg_new(CEPH_MSG_CLIENT_SESSION, sizeof(*h), GFP_NOFS, in ceph_create_session_msg()
1194 if (!msg) { in ceph_create_session_msg()
1199 h = msg->front.iov_base; in ceph_create_session_msg()
1203 return msg; in ceph_create_session_msg()
1285 struct ceph_msg *msg; in create_session_open_msg() local
[all …]
|
| D | metric.c | 21 struct ceph_msg *msg; in ceph_mdsc_send_metrics() local
30 msg = ceph_msg_new(CEPH_MSG_CLIENT_METRICS, len, GFP_NOFS, true); in ceph_mdsc_send_metrics()
31 if (!msg) { in ceph_mdsc_send_metrics()
37 head = msg->front.iov_base; in ceph_mdsc_send_metrics()
87 msg->front.iov_len = len; in ceph_mdsc_send_metrics()
88 msg->hdr.version = cpu_to_le16(1); in ceph_mdsc_send_metrics()
89 msg->hdr.compat_version = cpu_to_le16(1); in ceph_mdsc_send_metrics()
90 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_mdsc_send_metrics()
93 ceph_con_send(&s->s_con, msg); in ceph_mdsc_send_metrics()
|
| /fs/ |
| D | userfaultfd.c | 90 struct uffd_msg msg; member
122 if (len && (start > uwq->msg.arg.pagefault.address || in userfaultfd_wake_function()
123 start + len <= uwq->msg.arg.pagefault.address)) in userfaultfd_wake_function()
190 static inline void msg_init(struct uffd_msg *msg) in msg_init() argument
197 memset(msg, 0, sizeof(struct uffd_msg)); in msg_init()
205 struct uffd_msg msg; in userfault_msg() local
206 msg_init(&msg); in userfault_msg()
207 msg.event = UFFD_EVENT_PAGEFAULT; in userfault_msg()
208 msg.arg.pagefault.address = address; in userfault_msg()
219 msg.arg.pagefault.flags |= UFFD_PAGEFAULT_FLAG_WRITE; in userfault_msg()
[all …]
|
| /fs/lockd/ |
| D | clntproc.c | 267 struct rpc_message msg = { in nlmclnt_call() local
284 msg.rpc_proc = &clnt->cl_procinfo[proc]; in nlmclnt_call()
287 if ((status = rpc_call_sync(clnt, &msg, 0)) < 0) { in nlmclnt_call()
339 static struct rpc_task *__nlm_async_call(struct nlm_rqst *req, u32 proc, struct rpc_message *msg, c… in __nlm_async_call() argument
344 .rpc_message = msg, in __nlm_async_call()
357 msg->rpc_proc = &clnt->cl_procinfo[proc]; in __nlm_async_call()
367 static int nlm_do_async_call(struct nlm_rqst *req, u32 proc, struct rpc_message *msg, const struct … in nlm_do_async_call() argument
371 task = __nlm_async_call(req, proc, msg, tk_ops); in nlm_do_async_call()
383 struct rpc_message msg = { in nlm_async_call() local
387 return nlm_do_async_call(req, proc, &msg, tk_ops); in nlm_async_call()
[all …]
|
| D | svcsubs.c | 36 static inline void nlm_debug_print_fh(char *msg, struct nfs_fh *f) in nlm_debug_print_fh() argument
42 msg, fhp[0], fhp[1], fhp[2], fhp[3], in nlm_debug_print_fh()
46 static inline void nlm_debug_print_file(char *msg, struct nlm_file *file) in nlm_debug_print_file() argument
51 msg, inode->i_sb->s_id, inode->i_ino); in nlm_debug_print_file()
54 static inline void nlm_debug_print_fh(char *msg, struct nfs_fh *f) in nlm_debug_print_fh() argument
59 static inline void nlm_debug_print_file(char *msg, struct nlm_file *file) in nlm_debug_print_file() argument
|
| /fs/ocfs2/dlm/ |
| D | dlmcommon.h | 823 int dlm_create_lock_handler(struct o2net_msg *msg, u32 len, void *data,
825 int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data,
827 int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,
835 int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data,
959 int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data,
961 int dlm_assert_master_handler(struct o2net_msg *msg, u32 len, void *data,
964 int dlm_deref_lockres_handler(struct o2net_msg *msg, u32 len, void *data,
966 int dlm_deref_lockres_done_handler(struct o2net_msg *msg, u32 len, void *data,
968 int dlm_migrate_request_handler(struct o2net_msg *msg, u32 len, void *data,
970 int dlm_mig_lockres_handler(struct o2net_msg *msg, u32 len, void *data,
[all …]
|
| D | dlmdomain.c | 132 static int dlm_query_join_handler(struct o2net_msg *msg, u32 len, void *data,
134 static int dlm_assert_joined_handler(struct o2net_msg *msg, u32 len, void *data,
136 static int dlm_cancel_join_handler(struct o2net_msg *msg, u32 len, void *data,
138 static int dlm_query_region_handler(struct o2net_msg *msg, u32 len,
140 static int dlm_exit_domain_handler(struct o2net_msg *msg, u32 len, void *data,
486 static int dlm_begin_exit_domain_handler(struct o2net_msg *msg, u32 len, in dlm_begin_exit_domain_handler() argument
491 struct dlm_exit_domain *exit_msg = (struct dlm_exit_domain *) msg->buf; in dlm_begin_exit_domain_handler()
546 static int dlm_exit_domain_handler(struct o2net_msg *msg, u32 len, void *data, in dlm_exit_domain_handler() argument
551 struct dlm_exit_domain *exit_msg = (struct dlm_exit_domain *) msg->buf; in dlm_exit_domain_handler()
553 mlog(0, "%p %u %p", msg, len, data); in dlm_exit_domain_handler()
[all …]
|
| /fs/cifs/ |
| D | cifs_spnego.c | 178 struct cifs_spnego_msg *msg = spnego_key->payload.data[0]; in cifs_get_spnego_key() local
179 cifs_dump_mem("SPNEGO reply blob:", msg->data, min(1024U, in cifs_get_spnego_key()
180 msg->secblob_len + msg->sesskey_len)); in cifs_get_spnego_key()
|
| /fs/ocfs2/cluster/ |
| D | tcp.c | 904 struct msghdr msg = { .msg_flags = MSG_DONTWAIT, }; in o2net_recv_tcp_msg() local
905 iov_iter_kvec(&msg.msg_iter, READ, &vec, 1, len); in o2net_recv_tcp_msg()
906 return sock_recvmsg(sock, &msg, MSG_DONTWAIT); in o2net_recv_tcp_msg()
913 struct msghdr msg = {.msg_flags = 0,}; in o2net_send_tcp_msg() local
920 ret = kernel_sendmsg(sock, &msg, vec, veclen, total); in o2net_send_tcp_msg()
960 static void o2net_init_msg(struct o2net_msg *msg, u16 data_len, u16 msg_type, u32 key) in o2net_init_msg() argument
962 memset(msg, 0, sizeof(struct o2net_msg)); in o2net_init_msg()
963 msg->magic = cpu_to_be16(O2NET_MSG_MAGIC); in o2net_init_msg()
964 msg->data_len = cpu_to_be16(data_len); in o2net_init_msg()
965 msg->msg_type = cpu_to_be16(msg_type); in o2net_init_msg()
[all …]
|
| /fs/nilfs2/ |
| D | recovery.c | 50 const char *msg = NULL; in nilfs_warn_segment_error() local
57 msg = "Magic number mismatch"; in nilfs_warn_segment_error()
60 msg = "Sequence number mismatch"; in nilfs_warn_segment_error()
63 msg = "Checksum error in super root"; in nilfs_warn_segment_error()
66 msg = "Checksum error in segment payload"; in nilfs_warn_segment_error()
69 msg = "Inconsistency found"; in nilfs_warn_segment_error()
72 msg = "No super root in the last segment"; in nilfs_warn_segment_error()
78 nilfs_warn(sb, "invalid segment: %s", msg); in nilfs_warn_segment_error()
|