Lines Matching defs:msg
527 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_recvmsg() local
545 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_recvpage() local
563 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_sendmsg() local
593 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_sendpage() local
655 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
664 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list() local
1126 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1226 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1563 struct ceph_msg *msg = con->out_msg; in write_partial_message_data() local
2316 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data() local
2519 struct ceph_msg *msg = con->in_msg; in process_message() local
3064 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
3088 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
3128 void ceph_msg_revoke(struct ceph_msg *msg) in ceph_msg_revoke()
3174 void ceph_msg_revoke_incoming(struct ceph_msg *msg) in ceph_msg_revoke_incoming()
3267 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages, in ceph_msg_data_add_pages()
3286 void ceph_msg_data_add_pagelist(struct ceph_msg *msg, in ceph_msg_data_add_pagelist()
3304 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct bio *bio, in ceph_msg_data_add_bio()
3381 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
3416 struct ceph_msg *msg; in ceph_con_in_msg_alloc() local
3498 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg) in ceph_msg_get()
3507 void ceph_msg_put(struct ceph_msg *msg) in ceph_msg_put()
3515 void ceph_msg_dump(struct ceph_msg *msg) in ceph_msg_dump()