836 	struct processqueue_entry *pentry;  in new_processqueue_entry()  local
838 	pentry = kmalloc(sizeof(*pentry), GFP_NOFS);  in new_processqueue_entry()
839 	if (!pentry)  in new_processqueue_entry()
842 	pentry->buf = kmalloc(buflen, GFP_NOFS);  in new_processqueue_entry()
843 	if (!pentry->buf) {  in new_processqueue_entry()
844 		kfree(pentry);  in new_processqueue_entry()
848 	pentry->nodeid = nodeid;  in new_processqueue_entry()
849 	return pentry;  in new_processqueue_entry()
852 static void free_processqueue_entry(struct processqueue_entry *pentry)  in free_processqueue_entry()  argument
854 	kfree(pentry->buf);  in free_processqueue_entry()
855 	kfree(pentry);  in free_processqueue_entry()
866 	struct processqueue_entry *pentry;  in process_dlm_messages()  local
869 	pentry = list_first_entry_or_null(&processqueue,  in process_dlm_messages()
871 	if (WARN_ON_ONCE(!pentry)) {  in process_dlm_messages()
877 	list_del(&pentry->list);  in process_dlm_messages()
881 		dlm_process_incoming_buffer(pentry->nodeid, pentry->buf,  in process_dlm_messages()
882 					    pentry->buflen);  in process_dlm_messages()
883 		free_processqueue_entry(pentry);  in process_dlm_messages()
886 		pentry = list_first_entry_or_null(&processqueue,  in process_dlm_messages()
888 		if (!pentry) {  in process_dlm_messages()
894 		list_del(&pentry->list);  in process_dlm_messages()
902 	struct processqueue_entry *pentry;  in receive_from_sock()  local
907 	pentry = new_processqueue_entry(con->nodeid, buflen);  in receive_from_sock()
908 	if (!pentry)  in receive_from_sock()
911 	memcpy(pentry->buf, con->rx_leftover_buf, con->rx_leftover);  in receive_from_sock()
916 	iov.iov_base = pentry->buf + con->rx_leftover;  in receive_from_sock()
935 		free_processqueue_entry(pentry);  in receive_from_sock()
939 		free_processqueue_entry(pentry);  in receive_from_sock()
942 		free_processqueue_entry(pentry);  in receive_from_sock()
948 	ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf,  in receive_from_sock()
951 		free_processqueue_entry(pentry);  in receive_from_sock()
955 	pentry->buflen = ret;  in receive_from_sock()
962 	memmove(con->rx_leftover_buf, pentry->buf + ret,  in receive_from_sock()
966 	list_add_tail(&pentry->list, &processqueue);  in receive_from_sock()