Lines Matching defs:midQ
736 wait_for_response(struct TCP_Server_Info *server, struct mid_q_entry *midQ)
741 midQ->mid_state != MID_REQUEST_SUBMITTED &&
742 midQ->mid_state != MID_RESPONSE_RECEIVED,
1072 struct mid_q_entry *midQ[MAX_COMPOUND];
1138 midQ[i] = server->ops->setup_request(ses, server, &rqst[i]);
1139 if (IS_ERR(midQ[i])) {
1142 delete_mid(midQ[j]);
1148 return PTR_ERR(midQ[i]);
1151 midQ[i]->mid_state = MID_REQUEST_SUBMITTED;
1152 midQ[i]->optype = optype;
1159 midQ[i]->callback = cifs_compound_callback;
1161 midQ[i]->callback = cifs_compound_last_callback;
1166 cifs_save_when_sent(midQ[i]);
1209 rc = wait_for_response(server, midQ[i]);
1216 midQ[i]->mid, le16_to_cpu(midQ[i]->command));
1217 send_cancel(server, &rqst[i], midQ[i]);
1219 midQ[i]->mid_flags |= MID_WAIT_CANCELLED;
1220 if (midQ[i]->mid_state == MID_REQUEST_SUBMITTED ||
1221 midQ[i]->mid_state == MID_RESPONSE_RECEIVED) {
1222 midQ[i]->callback = cifs_cancelled_callback;
1234 rc = cifs_sync_mid_result(midQ[i], server);
1241 if (!midQ[i]->resp_buf ||
1242 midQ[i]->mid_state != MID_RESPONSE_READY) {
1248 buf = (char *)midQ[i]->resp_buf;
1250 resp_iov[i].iov_len = midQ[i]->resp_buf_size +
1253 if (midQ[i]->large_buf)
1258 rc = server->ops->check_receive(midQ[i], server,
1263 midQ[i]->resp_buf = NULL;
1293 delete_mid(midQ[i]);
1354 struct mid_q_entry *midQ;
1398 rc = allocate_mid(ses, in_buf, &midQ);
1406 rc = cifs_sign_smb(in_buf, server, &midQ->sequence_number);
1412 midQ->mid_state = MID_REQUEST_SUBMITTED;
1415 cifs_save_when_sent(midQ);
1425 rc = wait_for_response(server, midQ);
1427 send_cancel(server, &rqst, midQ);
1429 if (midQ->mid_state == MID_REQUEST_SUBMITTED ||
1430 midQ->mid_state == MID_RESPONSE_RECEIVED) {
1432 midQ->callback = release_mid;
1440 rc = cifs_sync_mid_result(midQ, server);
1446 if (!midQ->resp_buf || !out_buf ||
1447 midQ->mid_state != MID_RESPONSE_READY) {
1453 *pbytes_returned = get_rfc1002_length(midQ->resp_buf);
1454 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4);
1455 rc = cifs_check_receive(midQ, server, 0);
1457 delete_mid(midQ);
1495 struct mid_q_entry *midQ;
1542 rc = allocate_mid(ses, in_buf, &midQ);
1548 rc = cifs_sign_smb(in_buf, server, &midQ->sequence_number);
1550 delete_mid(midQ);
1555 midQ->mid_state = MID_REQUEST_SUBMITTED;
1557 cifs_save_when_sent(midQ);
1565 delete_mid(midQ);
1571 (!(midQ->mid_state == MID_REQUEST_SUBMITTED ||
1572 midQ->mid_state == MID_RESPONSE_RECEIVED)) ||
1579 (midQ->mid_state == MID_REQUEST_SUBMITTED ||
1580 midQ->mid_state == MID_RESPONSE_RECEIVED) &&
1588 rc = send_cancel(server, &rqst, midQ);
1590 delete_mid(midQ);
1602 delete_mid(midQ);
1607 rc = wait_for_response(server, midQ);
1609 send_cancel(server, &rqst, midQ);
1611 if (midQ->mid_state == MID_REQUEST_SUBMITTED ||
1612 midQ->mid_state == MID_RESPONSE_RECEIVED) {
1614 midQ->callback = release_mid;
1627 rc = cifs_sync_mid_result(midQ, server);
1632 if (out_buf == NULL || midQ->mid_state != MID_RESPONSE_READY) {
1638 *pbytes_returned = get_rfc1002_length(midQ->resp_buf);
1639 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4);
1640 rc = cifs_check_receive(midQ, server, 0);
1642 delete_mid(midQ);