837 	struct processqueue_entry *pentry;  in new_processqueue_entry()  local
839 	pentry = kmalloc(sizeof(*pentry), GFP_NOFS);  in new_processqueue_entry()
840 	if (!pentry)  in new_processqueue_entry()
843 	pentry->buf = kmalloc(buflen, GFP_NOFS);  in new_processqueue_entry()
844 	if (!pentry->buf) {  in new_processqueue_entry()
845 		kfree(pentry);  in new_processqueue_entry()
849 	pentry->nodeid = nodeid;  in new_processqueue_entry()
850 	return pentry;  in new_processqueue_entry()
853 static void free_processqueue_entry(struct processqueue_entry *pentry)  in free_processqueue_entry()  argument
855 	kfree(pentry->buf);  in free_processqueue_entry()
856 	kfree(pentry);  in free_processqueue_entry()
861 	struct processqueue_entry *pentry;  in process_dlm_messages()  local
864 	pentry = list_first_entry_or_null(&processqueue,  in process_dlm_messages()
866 	if (WARN_ON_ONCE(!pentry)) {  in process_dlm_messages()
872 	list_del(&pentry->list);  in process_dlm_messages()
878 		dlm_process_incoming_buffer(pentry->nodeid, pentry->buf,  in process_dlm_messages()
879 					    pentry->buflen);  in process_dlm_messages()
880 		free_processqueue_entry(pentry);  in process_dlm_messages()
883 		pentry = list_first_entry_or_null(&processqueue,  in process_dlm_messages()
885 		if (!pentry) {  in process_dlm_messages()
891 		list_del(&pentry->list);  in process_dlm_messages()
901 	struct processqueue_entry *pentry;  in receive_from_sock()  local
906 	pentry = new_processqueue_entry(con->nodeid, buflen);  in receive_from_sock()
907 	if (!pentry)  in receive_from_sock()
910 	memcpy(pentry->buf, con->rx_leftover_buf, con->rx_leftover);  in receive_from_sock()
915 	iov.iov_base = pentry->buf + con->rx_leftover;  in receive_from_sock()
934 		free_processqueue_entry(pentry);  in receive_from_sock()
938 		free_processqueue_entry(pentry);  in receive_from_sock()
941 		free_processqueue_entry(pentry);  in receive_from_sock()
947 	ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf,  in receive_from_sock()
950 		free_processqueue_entry(pentry);  in receive_from_sock()
954 	pentry->buflen = ret;  in receive_from_sock()
961 	memmove(con->rx_leftover_buf, pentry->buf + ret,  in receive_from_sock()
966 	list_add_tail(&pentry->list, &processqueue);  in receive_from_sock()