Lines Matching refs:o2net_msg
114 static struct o2net_msg *o2net_keep_req, *o2net_keep_resp;
964 static void o2net_init_msg(struct o2net_msg *msg, u16 data_len, u16 msg_type, u32 key) in o2net_init_msg()
966 memset(msg, 0, sizeof(struct o2net_msg)); in o2net_init_msg()
1020 struct o2net_msg *msg = NULL; in o2net_send_message_vec()
1074 msg = kmalloc(sizeof(struct o2net_msg), GFP_ATOMIC); in o2net_send_message_vec()
1083 vec[0].iov_len = sizeof(struct o2net_msg); in o2net_send_message_vec()
1100 sizeof(struct o2net_msg) + caller_bytes); in o2net_send_message_vec()
1146 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr, in o2net_send_status_magic()
1151 .iov_len = sizeof(struct o2net_msg), in o2net_send_status_magic()
1165 return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg)); in o2net_send_status_magic()
1171 struct o2net_msg *hdr) in o2net_process_message()
1227 handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) + in o2net_process_message()
1337 struct o2net_msg *hdr; in o2net_advance_rx()
1363 if (sc->sc_page_off < sizeof(struct o2net_msg)) { in o2net_advance_rx()
1365 datalen = sizeof(struct o2net_msg) - sc->sc_page_off; in o2net_advance_rx()
1372 if (sc->sc_page_off == sizeof(struct o2net_msg)) { in o2net_advance_rx()
1383 if (sc->sc_page_off < sizeof(struct o2net_msg)) { in o2net_advance_rx()
1394 if (sc->sc_page_off - sizeof(struct o2net_msg) < be16_to_cpu(hdr->data_len)) { in o2net_advance_rx()
1397 datalen = (sizeof(struct o2net_msg) + be16_to_cpu(hdr->data_len)) - in o2net_advance_rx()
1406 if (sc->sc_page_off - sizeof(struct o2net_msg) == be16_to_cpu(hdr->data_len)) { in o2net_advance_rx()
2108 p += sizeof(struct o2net_msg); in o2net_init()