Lines Matching refs:midQ

549 wait_for_response(struct TCP_Server_Info *server, struct mid_q_entry *midQ)  in wait_for_response()  argument
554 midQ->mid_state != MID_REQUEST_SUBMITTED); in wait_for_response()
788 struct mid_q_entry *midQ[MAX_COMPOUND]; in compound_send_recv() local
824 midQ[i] = ses->server->ops->setup_request(ses, &rqst[i]); in compound_send_recv()
825 if (IS_ERR(midQ[i])) { in compound_send_recv()
827 cifs_delete_mid(midQ[j]); in compound_send_recv()
831 return PTR_ERR(midQ[i]); in compound_send_recv()
834 midQ[i]->mid_state = MID_REQUEST_SUBMITTED; in compound_send_recv()
840 midQ[i]->callback = cifs_noop_callback; in compound_send_recv()
847 cifs_save_when_sent(midQ[i]); in compound_send_recv()
865 rc = wait_for_response(ses->server, midQ[i]); in compound_send_recv()
868 midQ[i]->mid); in compound_send_recv()
869 send_cancel(ses->server, &rqst[i], midQ[i]); in compound_send_recv()
871 if (midQ[i]->mid_state == MID_REQUEST_SUBMITTED) { in compound_send_recv()
872 midQ[i]->mid_flags |= MID_WAIT_CANCELLED; in compound_send_recv()
873 midQ[i]->callback = DeleteMidQEntry; in compound_send_recv()
881 rc = cifs_sync_mid_result(midQ[i], ses->server); in compound_send_recv()
887 if (!midQ[i]->resp_buf || in compound_send_recv()
888 midQ[i]->mid_state != MID_RESPONSE_RECEIVED) { in compound_send_recv()
894 buf = (char *)midQ[i]->resp_buf; in compound_send_recv()
896 resp_iov[i].iov_len = midQ[i]->resp_buf_size + in compound_send_recv()
899 if (midQ[i]->large_buf) in compound_send_recv()
912 credits = ses->server->ops->get_credits(midQ[i]); in compound_send_recv()
914 rc = ses->server->ops->check_receive(midQ[i], ses->server, in compound_send_recv()
919 midQ[i]->resp_buf = NULL; in compound_send_recv()
929 cifs_delete_mid(midQ[i]); in compound_send_recv()
988 struct mid_q_entry *midQ; in SendReceive() local
1025 rc = allocate_mid(ses, in_buf, &midQ); in SendReceive()
1033 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceive()
1039 midQ->mid_state = MID_REQUEST_SUBMITTED; in SendReceive()
1044 cifs_save_when_sent(midQ); in SendReceive()
1057 rc = wait_for_response(ses->server, midQ); in SendReceive()
1059 send_cancel(ses->server, &rqst, midQ); in SendReceive()
1061 if (midQ->mid_state == MID_REQUEST_SUBMITTED) { in SendReceive()
1063 midQ->callback = DeleteMidQEntry; in SendReceive()
1071 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceive()
1077 if (!midQ->resp_buf || !out_buf || in SendReceive()
1078 midQ->mid_state != MID_RESPONSE_RECEIVED) { in SendReceive()
1084 *pbytes_returned = get_rfc1002_length(midQ->resp_buf); in SendReceive()
1085 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4); in SendReceive()
1086 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceive()
1088 cifs_delete_mid(midQ); in SendReceive()
1126 struct mid_q_entry *midQ; in SendReceiveBlockingLock() local
1166 rc = allocate_mid(ses, in_buf, &midQ); in SendReceiveBlockingLock()
1172 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceiveBlockingLock()
1174 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1179 midQ->mid_state = MID_REQUEST_SUBMITTED; in SendReceiveBlockingLock()
1183 cifs_save_when_sent(midQ); in SendReceiveBlockingLock()
1191 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1197 (!(midQ->mid_state == MID_REQUEST_SUBMITTED)) || in SendReceiveBlockingLock()
1203 (midQ->mid_state == MID_REQUEST_SUBMITTED) && in SendReceiveBlockingLock()
1210 rc = send_cancel(ses->server, &rqst, midQ); in SendReceiveBlockingLock()
1212 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1224 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1229 rc = wait_for_response(ses->server, midQ); in SendReceiveBlockingLock()
1231 send_cancel(ses->server, &rqst, midQ); in SendReceiveBlockingLock()
1233 if (midQ->mid_state == MID_REQUEST_SUBMITTED) { in SendReceiveBlockingLock()
1235 midQ->callback = DeleteMidQEntry; in SendReceiveBlockingLock()
1246 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceiveBlockingLock()
1251 if (out_buf == NULL || midQ->mid_state != MID_RESPONSE_RECEIVED) { in SendReceiveBlockingLock()
1257 *pbytes_returned = get_rfc1002_length(midQ->resp_buf); in SendReceiveBlockingLock()
1258 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4); in SendReceiveBlockingLock()
1259 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceiveBlockingLock()
1261 cifs_delete_mid(midQ); in SendReceiveBlockingLock()