Lines Matching refs:pentry
839 struct processqueue_entry *pentry; in new_processqueue_entry() local
841 pentry = kmalloc(sizeof(*pentry), GFP_NOFS); in new_processqueue_entry()
842 if (!pentry) in new_processqueue_entry()
845 pentry->buf = kmalloc(buflen, GFP_NOFS); in new_processqueue_entry()
846 if (!pentry->buf) { in new_processqueue_entry()
847 kfree(pentry); in new_processqueue_entry()
851 pentry->nodeid = nodeid; in new_processqueue_entry()
852 return pentry; in new_processqueue_entry()
855 static void free_processqueue_entry(struct processqueue_entry *pentry) in free_processqueue_entry() argument
857 kfree(pentry->buf); in free_processqueue_entry()
858 kfree(pentry); in free_processqueue_entry()
863 struct processqueue_entry *pentry; in process_dlm_messages() local
866 pentry = list_first_entry_or_null(&processqueue, in process_dlm_messages()
868 if (WARN_ON_ONCE(!pentry)) { in process_dlm_messages()
874 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()
903 struct processqueue_entry *pentry; in receive_from_sock() local
908 pentry = new_processqueue_entry(con->nodeid, buflen); in receive_from_sock()
909 if (!pentry) in receive_from_sock()
912 memcpy(pentry->buf, con->rx_leftover_buf, con->rx_leftover); in receive_from_sock()
917 iov.iov_base = pentry->buf + con->rx_leftover; in receive_from_sock()
936 free_processqueue_entry(pentry); in receive_from_sock()
940 free_processqueue_entry(pentry); in receive_from_sock()
943 free_processqueue_entry(pentry); in receive_from_sock()
949 ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf, in receive_from_sock()
952 free_processqueue_entry(pentry); in receive_from_sock()
956 pentry->buflen = ret; in receive_from_sock()
963 memmove(con->rx_leftover_buf, pentry->buf + ret, in receive_from_sock()
968 list_add_tail(&pentry->list, &processqueue); in receive_from_sock()