Lines Matching refs:midQ
496 wait_for_response(struct TCP_Server_Info *server, struct mid_q_entry *midQ) in wait_for_response() argument
501 midQ->mid_state != MID_REQUEST_SUBMITTED); in wait_for_response()
716 struct mid_q_entry *midQ; in SendReceive2() local
758 midQ = ses->server->ops->setup_request(ses, &rqst); in SendReceive2()
759 if (IS_ERR(midQ)) { in SendReceive2()
764 return PTR_ERR(midQ); in SendReceive2()
767 midQ->mid_state = MID_REQUEST_SUBMITTED; in SendReceive2()
771 cifs_save_when_sent(midQ); in SendReceive2()
787 rc = wait_for_response(ses->server, midQ); in SendReceive2()
789 send_cancel(ses->server, buf, midQ); in SendReceive2()
791 if (midQ->mid_state == MID_REQUEST_SUBMITTED) { in SendReceive2()
792 midQ->callback = DeleteMidQEntry; in SendReceive2()
803 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceive2()
809 if (!midQ->resp_buf || midQ->mid_state != MID_RESPONSE_RECEIVED) { in SendReceive2()
815 buf = (char *)midQ->resp_buf; in SendReceive2()
818 if (midQ->large_buf) in SendReceive2()
823 credits = ses->server->ops->get_credits(midQ); in SendReceive2()
825 rc = ses->server->ops->check_receive(midQ, ses->server, in SendReceive2()
830 midQ->resp_buf = NULL; in SendReceive2()
832 cifs_delete_mid(midQ); in SendReceive2()
844 struct mid_q_entry *midQ; in SendReceive() local
879 rc = allocate_mid(ses, in_buf, &midQ); in SendReceive()
887 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceive()
893 midQ->mid_state = MID_REQUEST_SUBMITTED; in SendReceive()
898 cifs_save_when_sent(midQ); in SendReceive()
911 rc = wait_for_response(ses->server, midQ); in SendReceive()
913 send_cancel(ses->server, in_buf, midQ); in SendReceive()
915 if (midQ->mid_state == MID_REQUEST_SUBMITTED) { in SendReceive()
917 midQ->callback = DeleteMidQEntry; in SendReceive()
925 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceive()
931 if (!midQ->resp_buf || !out_buf || in SendReceive()
932 midQ->mid_state != MID_RESPONSE_RECEIVED) { in SendReceive()
938 *pbytes_returned = get_rfc1002_length(midQ->resp_buf); in SendReceive()
939 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4); in SendReceive()
940 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceive()
942 cifs_delete_mid(midQ); in SendReceive()
980 struct mid_q_entry *midQ; in SendReceiveBlockingLock() local
1018 rc = allocate_mid(ses, in_buf, &midQ); in SendReceiveBlockingLock()
1024 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceiveBlockingLock()
1026 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1031 midQ->mid_state = MID_REQUEST_SUBMITTED; in SendReceiveBlockingLock()
1035 cifs_save_when_sent(midQ); in SendReceiveBlockingLock()
1043 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1049 (!(midQ->mid_state == MID_REQUEST_SUBMITTED)) || in SendReceiveBlockingLock()
1055 (midQ->mid_state == MID_REQUEST_SUBMITTED) && in SendReceiveBlockingLock()
1062 rc = send_cancel(ses->server, in_buf, midQ); in SendReceiveBlockingLock()
1064 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1076 cifs_delete_mid(midQ); in SendReceiveBlockingLock()
1081 rc = wait_for_response(ses->server, midQ); in SendReceiveBlockingLock()
1083 send_cancel(ses->server, in_buf, midQ); in SendReceiveBlockingLock()
1085 if (midQ->mid_state == MID_REQUEST_SUBMITTED) { in SendReceiveBlockingLock()
1087 midQ->callback = DeleteMidQEntry; in SendReceiveBlockingLock()
1098 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceiveBlockingLock()
1103 if (out_buf == NULL || midQ->mid_state != MID_RESPONSE_RECEIVED) { in SendReceiveBlockingLock()
1109 *pbytes_returned = get_rfc1002_length(midQ->resp_buf); in SendReceiveBlockingLock()
1110 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4); in SendReceiveBlockingLock()
1111 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceiveBlockingLock()
1113 cifs_delete_mid(midQ); in SendReceiveBlockingLock()