Lines Matching full:operations
100 struct hmdfs_cmd operations) in msg_init() argument
105 ret = hmdfs_alloc_msg_idr(con, MSG_IDR_MESSAGE_SYNC, msg_wq, operations); in msg_init()
133 head->operations.command); in hmdfs_sendmessage()
139 head->operations.command); in hmdfs_sendmessage()
151 node->device_id, head->operations.command); in hmdfs_sendmessage()
168 node->device_id, head->operations.command); in hmdfs_sendmessage()
193 statistic_con_sb_dirty(node, &head->operations); in hmdfs_sendmessage()
195 if (head->operations.cmd_flag == C_REQUEST) in hmdfs_sendmessage()
197 head->operations.command, ret); in hmdfs_sendmessage()
198 else if (head->operations.cmd_flag == C_RESPONSE) in hmdfs_sendmessage()
200 head->operations.command, ret); in hmdfs_sendmessage()
215 head.operations = cmd->operations; in hmdfs_sendmessage_response()
216 head.operations.cmd_flag = C_RESPONSE; in hmdfs_sendmessage_response()
264 mp->req.operations.command, in async_request_cb_on_wakeup_fn()
267 cbs = g_async_req_callbacks[mp->req.operations.command]; in async_request_cb_on_wakeup_fn()
284 req->operations); in mp_alloc()
322 timeout = get_cmd_timeout(peer->sbi, req->operations.command); in hmdfs_send_async_request()
327 req->operations.command); in hmdfs_send_async_request()
340 head.operations = mp->req.operations; in hmdfs_send_async_request()
406 get_cmd_timeout(con->sbi, sm->operations.command); in hmdfs_sendmessage_request()
417 sm->operations.command); in hmdfs_sendmessage_request()
431 head->operations = sm->operations; in hmdfs_sendmessage_request()
442 ret = msg_init(con, msg_wq, sm->operations); in hmdfs_sendmessage_request()
450 if (sm->operations.command == F_ITERATE) in hmdfs_sendmessage_request()
472 if (sm->operations.command == F_ITERATE) { in hmdfs_sendmessage_request()
484 if (sm->operations.command == F_ITERATE) in hmdfs_sendmessage_request()
490 head->operations.command); in hmdfs_sendmessage_request()
491 if (sm->operations.command == F_ITERATE) in hmdfs_sendmessage_request()
494 hmdfs_client_resp_statis(con->sbi, sm->operations.command, in hmdfs_sendmessage_request()
530 head.operations = cmd->operations; in hmdfs_send_slice()
531 head.operations.cmd_flag = C_RESPONSE; in hmdfs_send_slice()
644 timeout = get_cmd_timeout(con->sbi, sm->operations.command); in hmdfs_sendpage_request()
647 sm->operations.command); in hmdfs_sendpage_request()
660 head.operations = sm->operations; in hmdfs_sendpage_request()
679 ret = hmdfs_alloc_msg_idr(con, MSG_IDR_PAGE, async_work, sm->operations); in hmdfs_sendpage_request()
735 s_recv_callbacks[head->operations.command](con, head, buf); in hmdfs_request_handle_sync()
736 hmdfs_statistic(con->sbi, head->operations.command, jiffies - start); in hmdfs_request_handle_sync()
817 if (head->operations.command >= F_SIZE || in hmdfs_request_recv()
818 !s_recv_callbacks[head->operations.command]) { in hmdfs_request_recv()
821 head->operations.command); in hmdfs_request_recv()
825 switch (head->operations.command) { in hmdfs_request_recv()
855 head->operations.command); in hmdfs_request_recv()
916 u8 cmd = desp->head->operations.command; in hmdfs_file_response_work_fn()
921 le32_to_cpu(desp->head->msg_id), desp->head->operations); in hmdfs_file_response_work_fn()
971 u8 cmd = head->operations.command; in hmdfs_response_handle_sync()
973 msg_head = hmdfs_find_msg_head(con, msg_id, head->operations); in hmdfs_response_handle_sync()
1026 __u16 command = head->operations.command; in hmdfs_response_recv()
1034 switch (head->operations.command) { in hmdfs_response_recv()
1064 head->operations.command); in hmdfs_response_recv()
1082 switch (hmdfs_head->operations.cmd_flag) { in hmdfs_recv_mesg_callback()
1095 hmdfs_head->operations.cmd_flag); in hmdfs_recv_mesg_callback()
1109 mp->head.msg_id, mp->req.operations.command); in hmdfs_wakeup_parasite()