835 	struct processqueue_entry *pentry;  in new_processqueue_entry()  local
837 	pentry = kmalloc(sizeof(*pentry), GFP_NOFS);  in new_processqueue_entry()
838 	if (!pentry)  in new_processqueue_entry()
841 	pentry->buf = kmalloc(buflen, GFP_NOFS);  in new_processqueue_entry()
842 	if (!pentry->buf) {  in new_processqueue_entry()
843 		kfree(pentry);  in new_processqueue_entry()
847 	pentry->nodeid = nodeid;  in new_processqueue_entry()
848 	return pentry;  in new_processqueue_entry()
851 static void free_processqueue_entry(struct processqueue_entry *pentry)  in free_processqueue_entry()  argument
853 	kfree(pentry->buf);  in free_processqueue_entry()
854 	kfree(pentry);  in free_processqueue_entry()
865 	struct processqueue_entry *pentry;  in process_dlm_messages()  local
868 	pentry = list_first_entry_or_null(&processqueue,  in process_dlm_messages()
870 	if (WARN_ON_ONCE(!pentry)) {  in process_dlm_messages()
876 	list_del(&pentry->list);  in process_dlm_messages()
880 		dlm_process_incoming_buffer(pentry->nodeid, pentry->buf,  in process_dlm_messages()
881 					    pentry->buflen);  in process_dlm_messages()
882 		free_processqueue_entry(pentry);  in process_dlm_messages()
885 		pentry = list_first_entry_or_null(&processqueue,  in process_dlm_messages()
887 		if (!pentry) {  in process_dlm_messages()
893 		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()
965 	list_add_tail(&pentry->list, &processqueue);  in receive_from_sock()