Lines Matching refs:e
1036 static void free_entry(struct writequeue_entry *e) in free_entry() argument
1038 __free_page(e->page); in free_entry()
1039 kfree(e); in free_entry()
1049 static void writequeue_entry_complete(struct writequeue_entry *e, int completed) in writequeue_entry_complete() argument
1051 e->offset += completed; in writequeue_entry_complete()
1052 e->len -= completed; in writequeue_entry_complete()
1054 if (e->len == 0 && e->users == 0) { in writequeue_entry_complete()
1055 list_del(&e->list); in writequeue_entry_complete()
1056 free_entry(e); in writequeue_entry_complete()
1073 struct writequeue_entry *e; in sctp_init_assoc() local
1107 e = list_first_entry(&con->writequeue, struct writequeue_entry, list); in sctp_init_assoc()
1108 len = e->len; in sctp_init_assoc()
1109 offset = e->offset; in sctp_init_assoc()
1112 iov[0].iov_base = page_address(e->page)+offset; in sctp_init_assoc()
1145 writequeue_entry_complete(e, ret); in sctp_init_assoc()
1493 struct writequeue_entry *e; in dlm_lowcomms_get_buffer() local
1501 e = list_entry(con->writequeue.prev, struct writequeue_entry, list); in dlm_lowcomms_get_buffer()
1502 if ((&e->list == &con->writequeue) || in dlm_lowcomms_get_buffer()
1503 (PAGE_CACHE_SIZE - e->end < len)) { in dlm_lowcomms_get_buffer()
1504 e = NULL; in dlm_lowcomms_get_buffer()
1506 offset = e->end; in dlm_lowcomms_get_buffer()
1507 e->end += len; in dlm_lowcomms_get_buffer()
1508 e->users++; in dlm_lowcomms_get_buffer()
1512 if (e) { in dlm_lowcomms_get_buffer()
1514 *ppc = page_address(e->page) + offset; in dlm_lowcomms_get_buffer()
1515 return e; in dlm_lowcomms_get_buffer()
1518 e = new_writequeue_entry(con, allocation); in dlm_lowcomms_get_buffer()
1519 if (e) { in dlm_lowcomms_get_buffer()
1521 offset = e->end; in dlm_lowcomms_get_buffer()
1522 e->end += len; in dlm_lowcomms_get_buffer()
1523 e->users++; in dlm_lowcomms_get_buffer()
1524 list_add_tail(&e->list, &con->writequeue); in dlm_lowcomms_get_buffer()
1533 struct writequeue_entry *e = (struct writequeue_entry *)mh; in dlm_lowcomms_commit_buffer() local
1534 struct connection *con = e->con; in dlm_lowcomms_commit_buffer()
1538 users = --e->users; in dlm_lowcomms_commit_buffer()
1541 e->len = e->end - e->offset; in dlm_lowcomms_commit_buffer()
1559 struct writequeue_entry *e; in send_to_sock() local
1569 e = list_entry(con->writequeue.next, struct writequeue_entry, in send_to_sock()
1571 if ((struct list_head *) e == &con->writequeue) in send_to_sock()
1574 len = e->len; in send_to_sock()
1575 offset = e->offset; in send_to_sock()
1576 BUG_ON(len == 0 && e->users == 0); in send_to_sock()
1581 ret = kernel_sendpage(con->sock, e->page, offset, len, in send_to_sock()
1606 writequeue_entry_complete(e, ret); in send_to_sock()
1627 struct writequeue_entry *e, *safe; in clean_one_writequeue() local
1630 list_for_each_entry_safe(e, safe, &con->writequeue, list) { in clean_one_writequeue()
1631 list_del(&e->list); in clean_one_writequeue()
1632 free_entry(e); in clean_one_writequeue()