Lines Matching refs:work
116 void ksmbd_conn_enqueue_request(struct ksmbd_work *work) in ksmbd_conn_enqueue_request() argument
118 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_enqueue_request()
121 if (conn->ops->get_cmd_val(work) != SMB2_CANCEL_HE) in ksmbd_conn_enqueue_request()
127 list_add_tail(&work->request_entry, requests_queue); in ksmbd_conn_enqueue_request()
132 void ksmbd_conn_try_dequeue_request(struct ksmbd_work *work) in ksmbd_conn_try_dequeue_request() argument
134 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_try_dequeue_request()
140 if (list_empty(&work->request_entry) && in ksmbd_conn_try_dequeue_request()
141 list_empty(&work->async_request_entry)) in ksmbd_conn_try_dequeue_request()
145 list_del_init(&work->request_entry); in ksmbd_conn_try_dequeue_request()
147 if (work->asynchronous) in ksmbd_conn_try_dequeue_request()
148 release_async_work(work); in ksmbd_conn_try_dequeue_request()
212 int ksmbd_conn_write(struct ksmbd_work *work) in ksmbd_conn_write() argument
214 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_write()
217 if (!work->response_buf) { in ksmbd_conn_write()
222 if (work->send_no_response) in ksmbd_conn_write()
225 if (!work->iov_idx) in ksmbd_conn_write()
229 sent = conn->transport->ops->writev(conn->transport, work->iov, in ksmbd_conn_write()
230 work->iov_cnt, in ksmbd_conn_write()
231 get_rfc1002_len(work->iov[0].iov_base) + 4, in ksmbd_conn_write()
232 work->need_invalidate_rkey, in ksmbd_conn_write()
233 work->remote_key); in ksmbd_conn_write()