Lines Matching defs:midQ
731 wait_for_response(struct TCP_Server_Info *server, struct mid_q_entry *midQ)
736 midQ->mid_state != MID_REQUEST_SUBMITTED);
1036 struct mid_q_entry *midQ[MAX_COMPOUND];
1098 midQ[i] = server->ops->setup_request(ses, server, &rqst[i]);
1099 if (IS_ERR(midQ[i])) {
1102 cifs_delete_mid(midQ[j]);
1108 return PTR_ERR(midQ[i]);
1111 midQ[i]->mid_state = MID_REQUEST_SUBMITTED;
1112 midQ[i]->optype = optype;
1119 midQ[i]->callback = cifs_compound_callback;
1121 midQ[i]->callback = cifs_compound_last_callback;
1126 cifs_save_when_sent(midQ[i]);
1164 rc = wait_for_response(server, midQ[i]);
1171 midQ[i]->mid, le16_to_cpu(midQ[i]->command));
1172 send_cancel(server, &rqst[i], midQ[i]);
1174 midQ[i]->mid_flags |= MID_WAIT_CANCELLED;
1175 if (midQ[i]->mid_state == MID_REQUEST_SUBMITTED) {
1176 midQ[i]->callback = cifs_cancelled_callback;
1188 rc = cifs_sync_mid_result(midQ[i], server);
1195 if (!midQ[i]->resp_buf ||
1196 midQ[i]->mid_state != MID_RESPONSE_RECEIVED) {
1202 buf = (char *)midQ[i]->resp_buf;
1204 resp_iov[i].iov_len = midQ[i]->resp_buf_size +
1207 if (midQ[i]->large_buf)
1212 rc = server->ops->check_receive(midQ[i], server,
1217 midQ[i]->resp_buf = NULL;
1243 cifs_delete_mid(midQ[i]);
1304 struct mid_q_entry *midQ;
1344 rc = allocate_mid(ses, in_buf, &midQ);
1352 rc = cifs_sign_smb(in_buf, server, &midQ->sequence_number);
1358 midQ->mid_state = MID_REQUEST_SUBMITTED;
1361 cifs_save_when_sent(midQ);
1371 rc = wait_for_response(server, midQ);
1373 send_cancel(server, &rqst, midQ);
1375 if (midQ->mid_state == MID_REQUEST_SUBMITTED) {
1377 midQ->callback = DeleteMidQEntry;
1385 rc = cifs_sync_mid_result(midQ, server);
1391 if (!midQ->resp_buf || !out_buf ||
1392 midQ->mid_state != MID_RESPONSE_RECEIVED) {
1398 *pbytes_returned = get_rfc1002_length(midQ->resp_buf);
1399 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4);
1400 rc = cifs_check_receive(midQ, server, 0);
1402 cifs_delete_mid(midQ);
1440 struct mid_q_entry *midQ;
1483 rc = allocate_mid(ses, in_buf, &midQ);
1489 rc = cifs_sign_smb(in_buf, server, &midQ->sequence_number);
1491 cifs_delete_mid(midQ);
1496 midQ->mid_state = MID_REQUEST_SUBMITTED;
1498 cifs_save_when_sent(midQ);
1506 cifs_delete_mid(midQ);
1512 (!(midQ->mid_state == MID_REQUEST_SUBMITTED)) ||
1518 (midQ->mid_state == MID_REQUEST_SUBMITTED) &&
1525 rc = send_cancel(server, &rqst, midQ);
1527 cifs_delete_mid(midQ);
1539 cifs_delete_mid(midQ);
1544 rc = wait_for_response(server, midQ);
1546 send_cancel(server, &rqst, midQ);
1548 if (midQ->mid_state == MID_REQUEST_SUBMITTED) {
1550 midQ->callback = DeleteMidQEntry;
1561 rc = cifs_sync_mid_result(midQ, server);
1566 if (out_buf == NULL || midQ->mid_state != MID_RESPONSE_RECEIVED) {
1572 *pbytes_returned = get_rfc1002_length(midQ->resp_buf);
1573 memcpy(out_buf, midQ->resp_buf, *pbytes_returned + 4);
1574 rc = cifs_check_receive(midQ, server, 0);
1576 cifs_delete_mid(midQ);