Lines Matching refs:o2net_msg

129 static struct o2net_msg *o2net_keep_req, *o2net_keep_resp;
974 static void o2net_init_msg(struct o2net_msg *msg, u16 data_len, u16 msg_type, u32 key) in o2net_init_msg()
976 memset(msg, 0, sizeof(struct o2net_msg)); in o2net_init_msg()
1032 struct o2net_msg *msg = NULL; in o2net_send_message_vec()
1086 msg = kmalloc(sizeof(struct o2net_msg), GFP_ATOMIC); in o2net_send_message_vec()
1095 vec[0].iov_len = sizeof(struct o2net_msg); in o2net_send_message_vec()
1112 sizeof(struct o2net_msg) + caller_bytes); in o2net_send_message_vec()
1158 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr, in o2net_send_status_magic()
1163 .iov_len = sizeof(struct o2net_msg), in o2net_send_status_magic()
1177 return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg)); in o2net_send_status_magic()
1183 struct o2net_msg *hdr) in o2net_process_message()
1240 handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) + in o2net_process_message()
1350 struct o2net_msg *hdr; in o2net_advance_rx()
1376 if (sc->sc_page_off < sizeof(struct o2net_msg)) { in o2net_advance_rx()
1378 datalen = sizeof(struct o2net_msg) - sc->sc_page_off; in o2net_advance_rx()
1385 if (sc->sc_page_off == sizeof(struct o2net_msg)) { in o2net_advance_rx()
1396 if (sc->sc_page_off < sizeof(struct o2net_msg)) { in o2net_advance_rx()
1407 if (sc->sc_page_off - sizeof(struct o2net_msg) < be16_to_cpu(hdr->data_len)) { in o2net_advance_rx()
1410 datalen = (sizeof(struct o2net_msg) + be16_to_cpu(hdr->data_len)) - in o2net_advance_rx()
1419 if (sc->sc_page_off - sizeof(struct o2net_msg) == be16_to_cpu(hdr->data_len)) { in o2net_advance_rx()
2150 o2net_keep_req = kzalloc(sizeof(struct o2net_msg), GFP_KERNEL); in o2net_init()
2151 o2net_keep_resp = kzalloc(sizeof(struct o2net_msg), GFP_KERNEL); in o2net_init()