Lines Matching refs:o2net_msg
128 static struct o2net_msg *o2net_keep_req, *o2net_keep_resp;
975 static void o2net_init_msg(struct o2net_msg *msg, u16 data_len, u16 msg_type, u32 key) in o2net_init_msg()
977 memset(msg, 0, sizeof(struct o2net_msg)); in o2net_init_msg()
1033 struct o2net_msg *msg = NULL; in o2net_send_message_vec()
1087 msg = kmalloc(sizeof(struct o2net_msg), GFP_ATOMIC); in o2net_send_message_vec()
1096 vec[0].iov_len = sizeof(struct o2net_msg); in o2net_send_message_vec()
1113 sizeof(struct o2net_msg) + caller_bytes); in o2net_send_message_vec()
1159 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr, in o2net_send_status_magic()
1164 .iov_len = sizeof(struct o2net_msg), in o2net_send_status_magic()
1178 return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg)); in o2net_send_status_magic()
1184 struct o2net_msg *hdr) in o2net_process_message()
1241 handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) + in o2net_process_message()
1351 struct o2net_msg *hdr; in o2net_advance_rx()
1377 if (sc->sc_page_off < sizeof(struct o2net_msg)) { in o2net_advance_rx()
1379 datalen = sizeof(struct o2net_msg) - sc->sc_page_off; in o2net_advance_rx()
1386 if (sc->sc_page_off == sizeof(struct o2net_msg)) { in o2net_advance_rx()
1397 if (sc->sc_page_off < sizeof(struct o2net_msg)) { in o2net_advance_rx()
1408 if (sc->sc_page_off - sizeof(struct o2net_msg) < be16_to_cpu(hdr->data_len)) { in o2net_advance_rx()
1411 datalen = (sizeof(struct o2net_msg) + be16_to_cpu(hdr->data_len)) - in o2net_advance_rx()
1420 if (sc->sc_page_off - sizeof(struct o2net_msg) == be16_to_cpu(hdr->data_len)) { in o2net_advance_rx()
2174 o2net_keep_req = kzalloc(sizeof(struct o2net_msg), GFP_KERNEL); in o2net_init()
2175 o2net_keep_resp = kzalloc(sizeof(struct o2net_msg), GFP_KERNEL); in o2net_init()