Lines Matching refs:pentry
835 struct processqueue_entry *pentry;
837 pentry = kmalloc(sizeof(*pentry), GFP_NOFS);
838 if (!pentry)
841 pentry->buf = kmalloc(buflen, GFP_NOFS);
842 if (!pentry->buf) {
843 kfree(pentry);
847 pentry->nodeid = nodeid;
848 return pentry;
851 static void free_processqueue_entry(struct processqueue_entry *pentry)
853 kfree(pentry->buf);
854 kfree(pentry);
865 struct processqueue_entry *pentry;
868 pentry = list_first_entry_or_null(&processqueue,
870 if (WARN_ON_ONCE(!pentry)) {
876 list_del(&pentry->list);
880 dlm_process_incoming_buffer(pentry->nodeid, pentry->buf,
881 pentry->buflen);
882 free_processqueue_entry(pentry);
885 pentry = list_first_entry_or_null(&processqueue,
887 if (!pentry) {
893 list_del(&pentry->list);
901 struct processqueue_entry *pentry;
906 pentry = new_processqueue_entry(con->nodeid, buflen);
907 if (!pentry)
910 memcpy(pentry->buf, con->rx_leftover_buf, con->rx_leftover);
915 iov.iov_base = pentry->buf + con->rx_leftover;
934 free_processqueue_entry(pentry);
938 free_processqueue_entry(pentry);
941 free_processqueue_entry(pentry);
947 ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf,
950 free_processqueue_entry(pentry);
954 pentry->buflen = ret;
961 memmove(con->rx_leftover_buf, pentry->buf + ret,
965 list_add_tail(&pentry->list, &processqueue);