Lines Matching refs:writequeue_entry

125 struct writequeue_entry {  struct
139 struct writequeue_entry *entry; argument
235 struct writequeue_entry *entry = data; in writequeue_entry_ctor()
242 return kmem_cache_create("dlm_writequeue", sizeof(struct writequeue_entry), in dlm_lowcomms_writequeue_cache_create()
252 static struct writequeue_entry *con_next_wq(struct connection *con) in con_next_wq()
254 struct writequeue_entry *e; in con_next_wq()
256 e = list_first_entry_or_null(&con->writequeue, struct writequeue_entry, in con_next_wq()
680 struct writequeue_entry *e = container_of(kref, struct writequeue_entry, in dlm_page_release()
695 static void free_entry(struct writequeue_entry *e) in free_entry()
754 struct writequeue_entry *e; in close_connection()
780 e = list_first_entry(&con->writequeue, struct writequeue_entry, in close_connection()
1106 static void writequeue_entry_complete(struct writequeue_entry *e, int completed) in writequeue_entry_complete()
1159 static struct writequeue_entry *new_writequeue_entry(struct connection *con) in new_writequeue_entry()
1161 struct writequeue_entry *entry; in new_writequeue_entry()
1183 static struct writequeue_entry *new_wq_entry(struct connection *con, int len, in new_wq_entry()
1187 struct writequeue_entry *e; in new_wq_entry()
1191 e = list_last_entry(&con->writequeue, struct writequeue_entry, list); in new_wq_entry()
1227 struct writequeue_entry *e; in dlm_lowcomms_new_msg_con()
1294 struct writequeue_entry *e = msg->entry; in _dlm_lowcomms_commit_msg()
1361 struct writequeue_entry *e; in send_to_sock()
1420 struct writequeue_entry *e, *safe; in clean_one_writequeue()