Lines Matching refs:e
917 static void free_entry(struct writequeue_entry *e) in free_entry() argument
919 __free_page(e->page); in free_entry()
920 kfree(e); in free_entry()
930 static void writequeue_entry_complete(struct writequeue_entry *e, int completed) in writequeue_entry_complete() argument
932 e->offset += completed; in writequeue_entry_complete()
933 e->len -= completed; in writequeue_entry_complete()
935 if (e->len == 0 && e->users == 0) { in writequeue_entry_complete()
936 list_del(&e->list); in writequeue_entry_complete()
937 free_entry(e); in writequeue_entry_complete()
1359 struct writequeue_entry *e; in dlm_lowcomms_get_buffer() local
1367 e = list_entry(con->writequeue.prev, struct writequeue_entry, list); in dlm_lowcomms_get_buffer()
1368 if ((&e->list == &con->writequeue) || in dlm_lowcomms_get_buffer()
1369 (PAGE_CACHE_SIZE - e->end < len)) { in dlm_lowcomms_get_buffer()
1370 e = NULL; in dlm_lowcomms_get_buffer()
1372 offset = e->end; in dlm_lowcomms_get_buffer()
1373 e->end += len; in dlm_lowcomms_get_buffer()
1374 e->users++; in dlm_lowcomms_get_buffer()
1378 if (e) { in dlm_lowcomms_get_buffer()
1380 *ppc = page_address(e->page) + offset; in dlm_lowcomms_get_buffer()
1381 return e; in dlm_lowcomms_get_buffer()
1384 e = new_writequeue_entry(con, allocation); in dlm_lowcomms_get_buffer()
1385 if (e) { in dlm_lowcomms_get_buffer()
1387 offset = e->end; in dlm_lowcomms_get_buffer()
1388 e->end += len; in dlm_lowcomms_get_buffer()
1389 e->users++; in dlm_lowcomms_get_buffer()
1390 list_add_tail(&e->list, &con->writequeue); in dlm_lowcomms_get_buffer()
1399 struct writequeue_entry *e = (struct writequeue_entry *)mh; in dlm_lowcomms_commit_buffer() local
1400 struct connection *con = e->con; in dlm_lowcomms_commit_buffer()
1404 users = --e->users; in dlm_lowcomms_commit_buffer()
1407 e->len = e->end - e->offset; in dlm_lowcomms_commit_buffer()
1425 struct writequeue_entry *e; in send_to_sock() local
1435 e = list_entry(con->writequeue.next, struct writequeue_entry, in send_to_sock()
1437 if ((struct list_head *) e == &con->writequeue) in send_to_sock()
1440 len = e->len; in send_to_sock()
1441 offset = e->offset; in send_to_sock()
1442 BUG_ON(len == 0 && e->users == 0); in send_to_sock()
1447 ret = kernel_sendpage(con->sock, e->page, offset, len, in send_to_sock()
1472 writequeue_entry_complete(e, ret); in send_to_sock()
1492 struct writequeue_entry *e, *safe; in clean_one_writequeue() local
1495 list_for_each_entry_safe(e, safe, &con->writequeue, list) { in clean_one_writequeue()
1496 list_del(&e->list); in clean_one_writequeue()
1497 free_entry(e); in clean_one_writequeue()