Lines Matching refs:e
122 #define DLM_WQ_REMAIN_BYTES(e) (PAGE_SIZE - e->end) argument
123 #define DLM_WQ_LENGTH_BYTES(e) (e->end - e->offset) argument
257 struct writequeue_entry *e; in con_next_wq() local
259 e = list_first_entry_or_null(&con->writequeue, struct writequeue_entry, in con_next_wq()
264 if (!e || e->users || e->len == 0) in con_next_wq()
267 return e; in con_next_wq()
684 struct writequeue_entry *e = container_of(kref, struct writequeue_entry, in dlm_page_release() local
687 __free_page(e->page); in dlm_page_release()
688 dlm_free_writequeue(e); in dlm_page_release()
699 static void free_entry(struct writequeue_entry *e) in free_entry() argument
703 list_for_each_entry_safe(msg, tmp, &e->msgs, list) { in free_entry()
713 list_del(&e->list); in free_entry()
714 kref_put(&e->ref, dlm_page_release); in free_entry()
758 struct writequeue_entry *e; in close_connection() local
784 e = list_first_entry(&con->writequeue, struct writequeue_entry, in close_connection()
786 if (e->dirty) in close_connection()
787 free_entry(e); in close_connection()
1112 static void writequeue_entry_complete(struct writequeue_entry *e, int completed) in writequeue_entry_complete() argument
1114 e->offset += completed; in writequeue_entry_complete()
1115 e->len -= completed; in writequeue_entry_complete()
1117 e->dirty = true; in writequeue_entry_complete()
1119 if (e->len == 0 && e->users == 0) in writequeue_entry_complete()
1120 free_entry(e); in writequeue_entry_complete()
1193 struct writequeue_entry *e; in new_wq_entry() local
1197 e = list_last_entry(&con->writequeue, struct writequeue_entry, list); in new_wq_entry()
1198 if (DLM_WQ_REMAIN_BYTES(e) >= len) { in new_wq_entry()
1199 kref_get(&e->ref); in new_wq_entry()
1201 *ppc = page_address(e->page) + e->end; in new_wq_entry()
1205 e->end += len; in new_wq_entry()
1206 e->users++; in new_wq_entry()
1211 e = new_writequeue_entry(con); in new_wq_entry()
1212 if (!e) in new_wq_entry()
1215 kref_get(&e->ref); in new_wq_entry()
1216 *ppc = page_address(e->page); in new_wq_entry()
1217 e->end += len; in new_wq_entry()
1221 list_add_tail(&e->list, &con->writequeue); in new_wq_entry()
1225 return e; in new_wq_entry()
1232 struct writequeue_entry *e; in dlm_lowcomms_new_msg_con() local
1241 e = new_wq_entry(con, len, ppc, cb, data); in dlm_lowcomms_new_msg_con()
1242 if (!e) { in dlm_lowcomms_new_msg_con()
1251 msg->entry = e; in dlm_lowcomms_new_msg_con()
1298 struct writequeue_entry *e = msg->entry; in _dlm_lowcomms_commit_msg() local
1299 struct connection *con = e->con; in _dlm_lowcomms_commit_msg()
1304 list_add(&msg->list, &e->msgs); in _dlm_lowcomms_commit_msg()
1306 users = --e->users; in _dlm_lowcomms_commit_msg()
1310 e->len = DLM_WQ_LENGTH_BYTES(e); in _dlm_lowcomms_commit_msg()
1365 struct writequeue_entry *e; in send_to_sock() local
1373 e = con_next_wq(con); in send_to_sock()
1374 if (!e) { in send_to_sock()
1380 len = e->len; in send_to_sock()
1381 offset = e->offset; in send_to_sock()
1382 WARN_ON_ONCE(len == 0 && e->users == 0); in send_to_sock()
1385 bvec_set_page(&bvec, e->page, len, offset); in send_to_sock()
1416 writequeue_entry_complete(e, ret); in send_to_sock()
1424 struct writequeue_entry *e, *safe; in clean_one_writequeue() local
1427 list_for_each_entry_safe(e, safe, &con->writequeue, list) { in clean_one_writequeue()
1428 free_entry(e); in clean_one_writequeue()