113 static struct o2net_msg *o2net_keep_req, *o2net_keep_resp;
958 static void o2net_init_msg(struct o2net_msg *msg, u16 data_len, u16 msg_type, u32 key)  in o2net_init_msg()
960 	memset(msg, 0, sizeof(struct o2net_msg));  in o2net_init_msg()
1016 	struct o2net_msg *msg = NULL;  in o2net_send_message_vec()
1070 	msg = kmalloc(sizeof(struct o2net_msg), GFP_ATOMIC);  in o2net_send_message_vec()
1079 	vec[0].iov_len = sizeof(struct o2net_msg);  in o2net_send_message_vec()
1096 				 sizeof(struct o2net_msg) + caller_bytes);  in o2net_send_message_vec()
1142 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr,  in o2net_send_status_magic()
1147 		.iov_len = sizeof(struct o2net_msg),  in o2net_send_status_magic()
1161 	return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg));  in o2net_send_status_magic()
1167 				 struct o2net_msg *hdr)  in o2net_process_message()
1223 	handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) +  in o2net_process_message()
1333 	struct o2net_msg *hdr;  in o2net_advance_rx()
1359 	if (sc->sc_page_off < sizeof(struct o2net_msg)) {  in o2net_advance_rx()
1361 		datalen = sizeof(struct o2net_msg) - sc->sc_page_off;  in o2net_advance_rx()
1368 			if (sc->sc_page_off == sizeof(struct o2net_msg)) {  in o2net_advance_rx()
1379 	if (sc->sc_page_off < sizeof(struct o2net_msg)) {  in o2net_advance_rx()
1390 	if (sc->sc_page_off - sizeof(struct o2net_msg) < be16_to_cpu(hdr->data_len)) {  in o2net_advance_rx()
1393 		datalen = (sizeof(struct o2net_msg) + be16_to_cpu(hdr->data_len)) -  in o2net_advance_rx()
1402 	if (sc->sc_page_off - sizeof(struct o2net_msg) == be16_to_cpu(hdr->data_len)) {  in o2net_advance_rx()
2093 	o2net_keep_req = kzalloc(sizeof(struct o2net_msg), GFP_KERNEL);  in o2net_init()
2094 	o2net_keep_resp = kzalloc(sizeof(struct o2net_msg), GFP_KERNEL);  in o2net_init()