Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 68) sorted by relevance

123

/fs/reiserfs/
Dhashes.c44 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/
Dproc.c59 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
114 status = rpc_call_sync(server->client, &msg, 0); in nfs_proc_getattr()
128 struct rpc_message msg = { in nfs_proc_setattr() local
[all …]
Dnfs3proc.c32 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
116 status = rpc_call_sync(server->client, &msg, 0); in nfs3_proc_getattr()
[all …]
Dnfs42proc.c22 static int _nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep, in _nfs42_proc_fallocate() argument
38 msg->rpc_argp = &args; in _nfs42_proc_fallocate()
39 msg->rpc_resp = &res; in _nfs42_proc_fallocate()
50 status = nfs4_call_sync(server->client, server, msg, in _nfs42_proc_fallocate()
59 static int nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep, in nfs42_proc_fallocate() argument
75 err = _nfs42_proc_fallocate(msg, filep, lock, offset, len); in nfs42_proc_fallocate()
89 struct rpc_message msg = { in nfs42_proc_allocate() local
100 err = nfs42_proc_fallocate(&msg, filep, offset, len); in nfs42_proc_allocate()
110 struct rpc_message msg = { in nfs42_proc_deallocate() local
124 err = nfs42_proc_fallocate(&msg, filep, offset, len); in nfs42_proc_deallocate()
[all …]
Dnfs4proc.c1102 struct rpc_message *msg, in nfs4_call_sync_sequence() argument
1114 .rpc_message = msg, in nfs4_call_sync_sequence()
1124 struct rpc_message *msg, in nfs4_call_sync() argument
1130 return nfs4_call_sync_sequence(clnt, server, msg, args, res); in nfs4_call_sync()
2325 struct rpc_message msg = { in _nfs4_proc_open_confirm() local
2333 .rpc_message = &msg, in _nfs4_proc_open_confirm()
2490 struct rpc_message msg = { in nfs4_run_open_task() local
2498 .rpc_message = &msg, in nfs4_run_open_task()
3210 struct rpc_message msg = { in _nfs4_do_setattr() local
3247 msg.rpc_cred = delegation_cred; in _nfs4_do_setattr()
[all …]
Dunlink.c91 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()
Dnfs3acl.c59 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()
Dmount_clnt.c153 struct rpc_message msg = { in nfs_mount() local
186 msg.rpc_proc = &mnt_clnt->cl_procinfo[MOUNTPROC3_MNT]; in nfs_mount()
188 msg.rpc_proc = &mnt_clnt->cl_procinfo[MOUNTPROC_MNT]; in nfs_mount()
190 status = rpc_call_sync(mnt_clnt, &msg, RPC_TASK_SOFT|RPC_TASK_TIMEOUT); in nfs_mount()
255 struct rpc_message msg = { in nfs_umount() local
275 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC3_UMNT]; in nfs_umount()
277 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC_UMNT]; in nfs_umount()
279 status = rpc_call_sync(clnt, &msg, 0); in nfs_umount()
Dnfs4idmap.c512 struct rpc_pipe_msg *msg) in nfs_idmap_prepare_message() argument
544 msg->data = im; in nfs_idmap_prepare_message()
545 msg->len = sizeof(struct idmap_msg); in nfs_idmap_prepare_message()
585 struct rpc_pipe_msg *msg; in nfs_idmap_legacy_upcall() local
600 msg = &data->pipe_msg; in nfs_idmap_legacy_upcall()
605 ret = nfs_idmap_prepare_message(key->description, idmap, im, msg); in nfs_idmap_legacy_upcall()
613 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 …]
Dnfs4_fs.h341 struct rpc_clnt **clntp, struct rpc_message *msg) in _nfs4_state_protect() argument
357 msg->rpc_cred = rpc_machine_cred(); in _nfs4_state_protect()
377 struct rpc_clnt **clntp, struct rpc_message *msg) in nfs4_state_protect() argument
379 _nfs4_state_protect(clp, sp4_mode, clntp, msg); in nfs4_state_protect()
389 struct rpc_message *msg, struct nfs_pgio_header *hdr) in nfs4_state_protect_write() argument
391 if (_nfs4_state_protect(clp, NFS_SP4_MACH_CRED_WRITE, clntp, msg) && in nfs4_state_protect_write()
410 struct rpc_clnt **clntp, struct rpc_message *msg) in nfs4_state_protect() argument
416 struct rpc_message *msg, struct nfs_pgio_header *hdr) in nfs4_state_protect_write() argument
/fs/ecryptfs/
Dmiscdev.c150 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 …]
Dmessaging.c87 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/
Dstack_user.c361 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/nfs/blocklayout/
Drpc_pipefs.c60 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/afs/
Drxrpc.c283 static void afs_load_bvec(struct afs_call *call, struct msghdr *msg, in afs_load_bvec() argument
294 msg->msg_flags |= MSG_MORE; in afs_load_bvec()
299 msg->msg_flags &= ~MSG_MORE; in afs_load_bvec()
308 iov_iter_bvec(&msg->msg_iter, WRITE, bv, nr, bytes); in afs_load_bvec()
326 static int afs_send_pages(struct afs_call *call, struct msghdr *msg) in afs_send_pages() argument
337 afs_load_bvec(call, msg, bv, first, last, offset); in afs_send_pages()
338 trace_afs_send_pages(call, msg, first, last, offset); in afs_send_pages()
341 bytes = msg->msg_iter.count; in afs_send_pages()
342 nr = msg->msg_iter.nr_segs; in afs_send_pages()
344 ret = rxrpc_kernel_send_data(call->net->socket, call->rxcall, msg, in afs_send_pages()
[all …]
/fs/ceph/
Dmds_client.c467 static int parse_reply_info(struct ceph_msg *msg, in parse_reply_info() argument
475 info->head = msg->front.iov_base; in parse_reply_info()
476 p = msg->front.iov_base + sizeof(struct ceph_mds_reply_head); in parse_reply_info()
477 end = p + msg->front.iov_len - sizeof(struct ceph_mds_reply_head); in parse_reply_info()
1032 struct ceph_msg *msg; in create_session_msg() local
1035 msg = ceph_msg_new(CEPH_MSG_CLIENT_SESSION, sizeof(*h), GFP_NOFS, in create_session_msg()
1037 if (!msg) { in create_session_msg()
1041 h = msg->front.iov_base; in create_session_msg()
1045 return msg; in create_session_msg()
1075 struct ceph_msg *msg; in create_session_open_msg() local
[all …]
Dquota.c39 struct ceph_msg *msg) in ceph_handle_quota() argument
42 struct ceph_mds_quota *h = msg->front.iov_base; in ceph_handle_quota()
47 if (msg->front.iov_len < sizeof(*h)) { in ceph_handle_quota()
49 session->s_mds, (int)msg->front.iov_len); in ceph_handle_quota()
50 ceph_msg_dump(msg); in ceph_handle_quota()
/fs/
Duserfaultfd.c95 struct uffd_msg msg; member
119 if (len && (start > uwq->msg.arg.pagefault.address || in userfaultfd_wake_function()
120 start + len <= uwq->msg.arg.pagefault.address)) in userfaultfd_wake_function()
180 static inline void msg_init(struct uffd_msg *msg) in msg_init() argument
187 memset(msg, 0, sizeof(struct uffd_msg)); in msg_init()
195 struct uffd_msg msg; in userfault_msg() local
196 msg_init(&msg); in userfault_msg()
197 msg.event = UFFD_EVENT_PAGEFAULT; in userfault_msg()
198 msg.arg.pagefault.address = address; in userfault_msg()
207 msg.arg.pagefault.flags |= UFFD_PAGEFAULT_FLAG_WRITE; in userfault_msg()
[all …]
/fs/lockd/
Dclntproc.c267 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 …]
Dsvcsubs.c36 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/
Ddlmcommon.h827 int dlm_create_lock_handler(struct o2net_msg *msg, u32 len, void *data,
829 int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data,
831 int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,
839 int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data,
963 int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data,
965 int dlm_assert_master_handler(struct o2net_msg *msg, u32 len, void *data,
968 int dlm_deref_lockres_handler(struct o2net_msg *msg, u32 len, void *data,
970 int dlm_deref_lockres_done_handler(struct o2net_msg *msg, u32 len, void *data,
972 int dlm_migrate_request_handler(struct o2net_msg *msg, u32 len, void *data,
974 int dlm_mig_lockres_handler(struct o2net_msg *msg, u32 len, void *data,
[all …]
Ddlmdomain.c132 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/
Dcifs_spnego.c178 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/
Dtcp.c904 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/
Drecovery.c50 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_msg(sb, KERN_WARNING, "invalid segment: %s", msg); in nilfs_warn_segment_error()

123