Lines Matching refs:msg
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()
966 msg->sys_status = cpu_to_be32(O2NET_ERR_NONE); in o2net_init_msg()
967 msg->status = 0; in o2net_init_msg()
968 msg->key = cpu_to_be32(key); in o2net_init_msg()
1018 struct o2net_msg *msg = NULL; in o2net_send_message_vec() local
1072 msg = kmalloc(sizeof(struct o2net_msg), GFP_ATOMIC); in o2net_send_message_vec()
1073 if (!msg) { in o2net_send_message_vec()
1079 o2net_init_msg(msg, caller_bytes, msg_type, key); in o2net_send_message_vec()
1082 vec[0].iov_base = msg; in o2net_send_message_vec()
1089 msg->msg_num = cpu_to_be32(nsw.ns_id); in o2net_send_message_vec()
1100 msglog(msg, "sending returned %d\n", ret); in o2net_send_message_vec()
1126 kfree(msg); in o2net_send_message_vec()