Home
last modified time | relevance | path

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

1234

/fs/smb/server/
A Dtransport_ipc.c248 if (msg) in ipc_msg_alloc()
465 ret = nla_put(skb, msg->type, msg->sz, msg->payload); in ipc_msg_send()
573 if (!msg) in ksmbd_ipc_heartbeat_request()
592 if (!msg) in ksmbd_ipc_login_request()
616 if (!msg) in ksmbd_ipc_login_request_ext()
641 if (!msg) in ksmbd_ipc_spnego_authen_request()
673 if (!msg) in ksmbd_ipc_tree_connect_request()
706 if (!msg) in ksmbd_ipc_tree_disconnect_request()
729 if (!msg) in ksmbd_ipc_logout_request()
753 if (!msg) in ksmbd_ipc_share_config_request()
[all …]
A Dtransport_rdma.c446 if (!msg) in smb_direct_alloc_sendmsg()
461 msg->sge[0].addr, msg->sge[0].length, in smb_direct_free_sendmsg()
465 msg->sge[i].addr, msg->sge[i].length, in smb_direct_free_sendmsg()
1112 msg->sge[i].addr, msg->sge[i].length, in post_sendmsg()
1117 msg->wr.sg_list = &msg->sge[0]; in post_sendmsg()
1118 msg->wr.num_sge = msg->num_sge; in post_sendmsg()
1137 msg->wr.wr_cqe = &msg->cqe; in post_sendmsg()
1189 sge = &msg->sge[msg->num_sge]; in smb_direct_post_send_data()
1302 msg->sgt.sgl, msg->sgt.nents, dir); in smb_direct_free_rdma_rw_msg()
1402 msg->sgt.sgl = &msg->sg_list[0]; in smb_direct_rdma_xmit()
[all …]
/fs/nfs/
A Dproc.c59 struct rpc_message msg = { in nfs_proc_get_root() local
77 msg.rpc_resp = &fsinfo; in nfs_proc_get_root()
106 struct rpc_message msg = { in nfs_proc_getattr() local
134 struct rpc_message msg = { in nfs_proc_setattr() local
168 struct rpc_message msg = { in nfs_proc_lookup() local
196 struct rpc_message msg = { in nfs_proc_readlink() local
245 struct rpc_message msg = { in nfs_proc_create() local
254 msg.rpc_argp = &data->arg; in nfs_proc_create()
255 msg.rpc_resp = &data->res; in nfs_proc_create()
274 struct rpc_message msg = { in nfs_proc_mknod() local
[all …]
A Dnfs3proc.c46 #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
77 msg.rpc_resp = info->fattr; in do_proc_get_root()
106 struct rpc_message msg = { in nfs3_proc_getattr() local
134 struct rpc_message msg = { in nfs3_proc_setattr() local
169 struct rpc_message msg = { in __nfs3_proc_lookup() local
185 msg.rpc_argp = fhandle; in __nfs3_proc_lookup()
186 msg.rpc_resp = fattr; in __nfs3_proc_lookup()
274 msg.rpc_resp = fattr; in nfs3_proc_readlink()
285 struct rpc_message msg; member
[all …]
A Dnfs42proc.c63 msg->rpc_argp = &args; in _nfs42_proc_fallocate()
64 msg->rpc_resp = &res; in _nfs42_proc_fallocate()
136 struct rpc_message msg = { in nfs42_proc_allocate() local
158 struct rpc_message msg = { in nfs42_proc_deallocate() local
182 struct rpc_message msg = { in nfs42_proc_zero_range() local
394 struct rpc_message msg = { in _nfs42_proc_copy() local
627 .rpc_message = &msg, in nfs42_do_offload_cancel_async()
1038 .rpc_message = &msg, in nfs42_proc_layoutstats_generic()
1194 .rpc_message = &msg, in nfs42_proc_layouterror()
1247 msg->rpc_argp = &args; in _nfs42_proc_clone()
[all …]
A Dnfs4proc.c1222 .rpc_message = msg, in nfs4_do_call_sync()
2507 .rpc_message = &msg, in _nfs4_proc_open_confirm()
2678 .rpc_message = &msg, in nfs4_run_open_task()
3848 .rpc_message = &msg, in nfs4_do_close()
6644 .rpc_message = &msg, in nfs4_proc_setclientid()
6889 .rpc_message = &msg, in _nfs4_proc_delegreturn()
7231 .rpc_message = &msg, in nfs4_do_unlck()
7512 .rpc_message = &msg, in _nfs4_do_setlk()
8388 .rpc_message = &msg, in _nfs41_proc_get_locations()
8613 .rpc_message = &msg, in _nfs4_proc_secinfo()
[all …]
A Dnfs3acl.c58 struct rpc_message msg = { in nfs3_get_acl() local
88 msg.rpc_proc = &server->client_acl->cl_procinfo[ACLPROC3_GETACL]; in nfs3_get_acl()
98 status = rpc_call_sync(server->client_acl, &msg, 0); in nfs3_get_acl()
173 struct rpc_message msg = { in __nfs3_proc_setacls() local
218 msg.rpc_proc = &server->client_acl->cl_procinfo[ACLPROC3_SETACL]; in __nfs3_proc_setacls()
219 msg.rpc_resp = fattr; in __nfs3_proc_setacls()
220 status = rpc_call_sync(server->client_acl, &msg, 0); in __nfs3_proc_setacls()
A Dunlink.c91 struct rpc_message msg = { in nfs_do_call_unlink() local
97 .rpc_message = &msg, in nfs_do_call_unlink()
113 NFS_PROTO(dir)->unlink_setup(&msg, data->dentry, inode); in nfs_do_call_unlink()
345 struct rpc_message msg = { }; in nfs_async_rename() local
347 .rpc_message = &msg, in nfs_async_rename()
366 msg.rpc_argp = &data->args; in nfs_async_rename()
367 msg.rpc_resp = &data->res; in nfs_async_rename()
368 msg.rpc_cred = data->cred; in nfs_async_rename()
393 NFS_PROTO(data->old_dir)->rename_setup(&msg, old_dentry, new_dentry); in nfs_async_rename()
/fs/afs/
A Drxrpc.c340 struct msghdr msg; in afs_make_call() local
400 msg.msg_name = NULL; in afs_make_call()
401 msg.msg_namelen = 0; in afs_make_call()
487 const char *msg; in afs_log_error() local
852 struct msghdr msg; in afs_send_empty_reply() local
858 msg.msg_name = NULL; in afs_send_empty_reply()
859 msg.msg_namelen = 0; in afs_send_empty_reply()
863 msg.msg_flags = 0; in afs_send_empty_reply()
889 struct msghdr msg; in afs_send_simple_reply() local
899 msg.msg_name = NULL; in afs_send_simple_reply()
[all …]
/fs/ecryptfs/
A 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()
159 msg_ctx->msg->data_len = data_size; in ecryptfs_send_miscdev()
259 if (msg_ctx->msg) { in ecryptfs_miscdev_read()
289 if (msg_ctx->msg) { in ecryptfs_miscdev_read()
299 kfree(msg_ctx->msg); in ecryptfs_miscdev_read()
300 msg_ctx->msg = NULL; in ecryptfs_miscdev_read()
328 if ((sizeof(*msg) + msg->data_len) != data_size) { in ecryptfs_miscdev_response()
[all …]
A 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()
221 msg_ctx = &ecryptfs_msg_ctx_arr[msg->index]; in ecryptfs_process_response()
235 msg_size = (sizeof(*msg) + msg->data_len); in ecryptfs_process_response()
236 msg_ctx->msg = kmemdup(msg, msg_size, GFP_KERNEL); in ecryptfs_process_response()
237 if (!msg_ctx->msg) { in ecryptfs_process_response()
327 struct ecryptfs_message **msg) in ecryptfs_wait_for_response() argument
344 *msg = msg_ctx->msg; in ecryptfs_wait_for_response()
345 msg_ctx->msg = NULL; in ecryptfs_wait_for_response()
398 ecryptfs_msg_ctx_arr[i].msg = NULL; in ecryptfs_init_messaging()
[all …]
/fs/ocfs2/
A Dstack_user.c373 if ((msg->space != ' ') || (msg->newline != '\n')) in ocfs2_control_do_setnode_msg()
375 msg->space = msg->newline = '\0'; in ocfs2_control_do_setnode_msg()
404 if ((msg->space1 != ' ') || (msg->space2 != ' ') || in ocfs2_control_do_setversion_msg()
405 (msg->newline != '\n')) in ocfs2_control_do_setversion_msg()
407 msg->space1 = msg->space2 = msg->newline = '\0'; in ocfs2_control_do_setversion_msg()
409 if (kstrtol(msg->major, 16, &major)) in ocfs2_control_do_setversion_msg()
448 if ((msg->space1 != ' ') || (msg->space2 != ' ') || in ocfs2_control_do_down_msg()
449 (msg->newline != '\n')) in ocfs2_control_do_down_msg()
451 msg->space1 = msg->space2 = msg->newline = '\0'; in ocfs2_control_do_down_msg()
470 union ocfs2_control_message msg; in ocfs2_control_message() local
[all …]
/fs/nfs/blocklayout/
A Drpc_pipefs.c59 struct rpc_pipe_msg *msg = &bl_pipe_msg.msg; in bl_resolve_deviceid() local
74 memset(msg, 0, sizeof(*msg)); in bl_resolve_deviceid()
75 msg->len = sizeof(*bl_msg) + b->simple.len; in bl_resolve_deviceid()
76 msg->data = kzalloc(msg->len, gfp_mask); in bl_resolve_deviceid()
77 if (!msg->data) in bl_resolve_deviceid()
80 bl_msg = msg->data; in bl_resolve_deviceid()
83 nfs4_encode_simple(msg->data + sizeof(*bl_msg), b); in bl_resolve_deviceid()
87 rc = rpc_queue_upcall(nn->bl_device_pipe, msg); in bl_resolve_deviceid()
105 kfree(msg->data); in bl_resolve_deviceid()
131 container_of(msg, struct bl_pipe_msg, msg); in bl_pipe_destroy_msg()
[all …]
/fs/dlm/
A Dlowcomms.c696 dlm_free_msg(msg); in dlm_msg_release()
920 memset(&msg, 0, sizeof(msg)); in receive_from_sock()
1236 if (!msg) in dlm_lowcomms_new_msg_con()
1249 msg->ppc = *ppc; in dlm_lowcomms_new_msg_con()
1250 msg->len = len; in dlm_lowcomms_new_msg_con()
1251 msg->entry = e; in dlm_lowcomms_new_msg_con()
1253 return msg; in dlm_lowcomms_new_msg_con()
1283 if (!msg) { in dlm_lowcomms_new_msg()
1291 msg->idx = idx; in dlm_lowcomms_new_msg()
1292 return msg; in dlm_lowcomms_new_msg()
[all …]
A Dmidcomms.c202 struct dlm_msg *msg; member
379 struct dlm_msg *msg; in dlm_send_ack() local
383 if (!msg) in dlm_send_ack()
981 struct dlm_msg *msg; in dlm_midcomms_get_msg_3_2() local
985 if (!msg) in dlm_midcomms_get_msg_3_2()
996 return msg; in dlm_midcomms_get_msg_3_2()
1007 struct dlm_msg *msg; in dlm_midcomms_get_mhandle() local
1030 if (!msg) { in dlm_midcomms_get_mhandle()
1041 if (!msg) { in dlm_midcomms_get_mhandle()
1052 mh->msg = msg; in dlm_midcomms_get_mhandle()
[all …]
A Drcom.c75 struct dlm_msg *msg; in create_rcom_stateless() local
79 if (!msg) { in create_rcom_stateless()
86 *msg_ret = msg; in create_rcom_stateless()
97 dlm_lowcomms_commit_msg(msg); in send_rcom_stateless()
98 dlm_lowcomms_put_msg(msg); in send_rcom_stateless()
175 struct dlm_msg *msg; in dlm_rcom_status() local
188 sizeof(struct rcom_status), &rc, &msg, in dlm_rcom_status()
198 send_rcom_stateless(msg, rc); in dlm_rcom_status()
232 struct dlm_msg *msg; in receive_rcom_status() local
256 len, &rc, &msg, seq); in receive_rcom_status()
[all …]
A Dlowcomms.h44 void dlm_lowcomms_commit_msg(struct dlm_msg *msg);
45 void dlm_lowcomms_put_msg(struct dlm_msg *msg);
46 int dlm_lowcomms_resend_msg(struct dlm_msg *msg);
A Dmemory.c44 goto msg; in dlm_memory_init()
63 msg: in dlm_memory_init()
164 void dlm_free_msg(struct dlm_msg *msg) in dlm_free_msg() argument
166 kmem_cache_free(msg_cache, msg); in dlm_free_msg()
/fs/ceph/
A Dmds_client.c1448 if (!msg) { in ceph_create_session_msg()
1650 msg->front.iov_len = p - msg->front.iov_base; in create_session_full_msg()
1651 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_session_full_msg()
2054 if (!msg) in send_flushmsg_ack()
2110 if (!msg) in request_close_session()
2353 item = msg->front.iov_base + msg->front.iov_len; in ceph_send_cap_releases()
2382 if (msg) { in ceph_send_cap_releases()
3146 end = msg->front.iov_base + msg->front.iov_len; in create_request_message()
3207 msg->front.iov_len = p - msg->front.iov_base; in create_request_message()
3327 msg->front.iov_len = p - msg->front.iov_base; in __prepare_send_request()
[all …]
A Dmetric.c35 struct ceph_msg *msg; in ceph_mdsc_send_metrics() local
53 msg = ceph_msg_new(CEPH_MSG_CLIENT_METRICS, len, GFP_NOFS, true); in ceph_mdsc_send_metrics()
54 if (!msg) { in ceph_mdsc_send_metrics()
60 head = msg->front.iov_base; in ceph_mdsc_send_metrics()
176 msg->front.iov_len = len; in ceph_mdsc_send_metrics()
177 msg->hdr.version = cpu_to_le16(1); in ceph_mdsc_send_metrics()
178 msg->hdr.compat_version = cpu_to_le16(1); in ceph_mdsc_send_metrics()
179 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_mdsc_send_metrics()
180 ceph_con_send(&s->s_con, msg); in ceph_mdsc_send_metrics()
/fs/
A Duserfaultfd.c68 struct uffd_msg msg; member
197 struct uffd_msg msg; in userfault_msg() local
199 msg_init(&msg); in userfault_msg()
222 return msg; in userfault_msg()
611 ewq->msg.event = 0; in userfaultfd_event_complete()
674 msg_init(&ewq.msg); in dup_fctx()
753 msg_init(&ewq.msg); in mremap_userfaultfd_complete()
790 msg_init(&ewq.msg); in userfaultfd_remove()
1033 *msg = uwq->msg; in userfaultfd_ctx_read()
1043 *msg = uwq->msg; in userfaultfd_ctx_read()
[all …]
/fs/cachefiles/
A Dondemand.c43 if (req->msg.object_id == object_id && in cachefiles_ondemand_fd_release()
44 req->msg.opcode == CACHEFILES_OP_CLOSE) { in cachefiles_ondemand_fd_release()
335 load = (void *)req->msg.data; in cachefiles_ondemand_get_fd()
417 struct cachefiles_msg *msg; in cachefiles_ondemand_daemon_read() local
439 msg = &req->msg; in cachefiles_ondemand_daemon_read()
440 n = msg->len; in cachefiles_ondemand_daemon_read()
453 if (msg->opcode == CACHEFILES_OP_OPEN) { in cachefiles_ondemand_daemon_read()
459 msg->msg_id = xas.xa_index; in cachefiles_ondemand_daemon_read()
462 if (copy_to_user(_buffer, msg, n) != 0) in cachefiles_ondemand_daemon_read()
465 if (msg->opcode == CACHEFILES_OP_OPEN) { in cachefiles_ondemand_daemon_read()
[all …]
/fs/ocfs2/dlm/
A Ddlmcommon.h818 int dlm_create_lock_handler(struct o2net_msg *msg, u32 len, void *data,
820 int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data,
822 int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,
830 int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data,
953 int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data,
955 int dlm_assert_master_handler(struct o2net_msg *msg, u32 len, void *data,
958 int dlm_deref_lockres_handler(struct o2net_msg *msg, u32 len, void *data,
964 int dlm_mig_lockres_handler(struct o2net_msg *msg, u32 len, void *data,
966 int dlm_master_requery_handler(struct o2net_msg *msg, u32 len, void *data,
972 int dlm_begin_reco_handler(struct o2net_msg *msg, u32 len, void *data,
[all …]
/fs/lockd/
A Dclntproc.c271 struct rpc_message msg = { in nlmclnt_call() local
288 msg.rpc_proc = &clnt->cl_procinfo[proc]; in nlmclnt_call()
348 .rpc_message = msg, in __nlm_async_call()
361 msg->rpc_proc = &clnt->cl_procinfo[proc]; in __nlm_async_call()
375 task = __nlm_async_call(req, proc, msg, tk_ops); in nlm_do_async_call()
387 struct rpc_message msg = { in nlm_async_call() local
391 return nlm_do_async_call(req, proc, &msg, tk_ops); in nlm_async_call()
396 struct rpc_message msg = { in nlm_async_reply() local
399 return nlm_do_async_call(req, proc, &msg, tk_ops); in nlm_async_reply()
412 struct rpc_message msg = { in nlmclnt_async_call() local
[all …]
/fs/bcachefs/
A Drecovery.c37 struct printbuf *msg, in bch2_btree_lost_data() argument
47 prt_printf(msg, "flagging btree "); in bch2_btree_lost_data()
48 bch2_btree_id_to_text(msg, btree); in bch2_btree_lost_data()
49 prt_printf(msg, " lost data\n"); in bch2_btree_lost_data()
55 ret = __bch2_run_explicit_recovery_pass(c, msg, BCH_RECOVERY_PASS_check_topology, 0) ?: ret; in bch2_btree_lost_data()
59 ret = __bch2_run_explicit_recovery_pass(c, msg, BCH_RECOVERY_PASS_check_allocations, 0) ?: ret; in bch2_btree_lost_data()
66 ret = __bch2_run_explicit_recovery_pass(c, msg, BCH_RECOVERY_PASS_check_lrus, 0) ?: ret; in bch2_btree_lost_data()
72 ret = __bch2_run_explicit_recovery_pass(c, msg, BCH_RECOVERY_PASS_check_alloc_info, 0) ?: ret; in bch2_btree_lost_data()
86 ret = __bch2_run_explicit_recovery_pass(c, msg, BCH_RECOVERY_PASS_check_alloc_info, 0) ?: ret; in bch2_btree_lost_data()
102 ret = __bch2_run_explicit_recovery_pass(c, msg, BCH_RECOVERY_PASS_check_topology, 0) ?: ret; in bch2_btree_lost_data()
[all …]

Completed in 734 milliseconds

1234