Lines Matching refs:ses

513 static int allocate_mid(struct cifs_ses *ses, struct smb_hdr *in_buf,  in allocate_mid()  argument
516 if (ses->server->tcpStatus == CifsExiting) { in allocate_mid()
520 if (ses->server->tcpStatus == CifsNeedReconnect) { in allocate_mid()
525 if (ses->status == CifsNew) { in allocate_mid()
532 if (ses->status == CifsExiting) { in allocate_mid()
539 *ppmidQ = AllocMidQEntry(in_buf, ses->server); in allocate_mid()
543 list_add_tail(&(*ppmidQ)->qhead, &ses->server->pending_mid_q); in allocate_mid()
664 SendReceiveNoRsp(const unsigned int xid, struct cifs_ses *ses, in SendReceiveNoRsp() argument
675 rc = SendReceive2(xid, ses, iov, 1, &resp_buf_type, flags, &rsp_iov); in SendReceiveNoRsp()
755 cifs_setup_request(struct cifs_ses *ses, struct smb_rqst *rqst) in cifs_setup_request() argument
765 rc = allocate_mid(ses, hdr, &mid); in cifs_setup_request()
768 rc = cifs_sign_rqst(rqst, ses->server, &mid->sequence_number); in cifs_setup_request()
782 compound_send_recv(const unsigned int xid, struct cifs_ses *ses, in compound_send_recv() argument
798 if ((ses == NULL) || (ses->server == NULL)) { in compound_send_recv()
803 if (ses->server->tcpStatus == CifsExiting) in compound_send_recv()
811 rc = wait_for_free_request(ses->server, timeout, optype); in compound_send_recv()
821 mutex_lock(&ses->server->srv_mutex); in compound_send_recv()
824 midQ[i] = ses->server->ops->setup_request(ses, &rqst[i]); in compound_send_recv()
828 mutex_unlock(&ses->server->srv_mutex); in compound_send_recv()
830 add_credits(ses->server, 1, optype); in compound_send_recv()
842 cifs_in_send_inc(ses->server); in compound_send_recv()
843 rc = smb_send_rqst(ses->server, num_rqst, rqst, flags); in compound_send_recv()
844 cifs_in_send_dec(ses->server); in compound_send_recv()
850 ses->server->sequence_number -= 2; in compound_send_recv()
852 mutex_unlock(&ses->server->srv_mutex); in compound_send_recv()
858 if ((ses->status == CifsNew) || (optype & CIFS_NEG_OP)) in compound_send_recv()
859 smb311_update_preauth_hash(ses, rqst[i].rq_iov, in compound_send_recv()
865 rc = wait_for_response(ses->server, midQ[i]); in compound_send_recv()
869 send_cancel(ses->server, &rqst[i], midQ[i]); in compound_send_recv()
875 add_credits(ses->server, 1, optype); in compound_send_recv()
881 rc = cifs_sync_mid_result(midQ[i], ses->server); in compound_send_recv()
883 add_credits(ses->server, 1, optype); in compound_send_recv()
897 ses->server->vals->header_preamble_size; in compound_send_recv()
904 if ((ses->status == CifsNew) || (optype & CIFS_NEG_OP)) { in compound_send_recv()
909 smb311_update_preauth_hash(ses, &iov, 1); 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()
930 add_credits(ses->server, credits, optype); in compound_send_recv()
936 cifs_send_recv(const unsigned int xid, struct cifs_ses *ses, in cifs_send_recv() argument
940 return compound_send_recv(xid, ses, flags, 1, rqst, resp_buf_type, in cifs_send_recv()
945 SendReceive2(const unsigned int xid, struct cifs_ses *ses, in SendReceive2() argument
976 rc = cifs_send_recv(xid, ses, &rqst, resp_buf_type, flags, resp_iov); in SendReceive2()
983 SendReceive(const unsigned int xid, struct cifs_ses *ses, in SendReceive() argument
993 if (ses == NULL) { in SendReceive()
997 if (ses->server == NULL) { in SendReceive()
1002 if (ses->server->tcpStatus == CifsExiting) in SendReceive()
1015 rc = wait_for_free_request(ses->server, timeout, 0); in SendReceive()
1023 mutex_lock(&ses->server->srv_mutex); in SendReceive()
1025 rc = allocate_mid(ses, in_buf, &midQ); in SendReceive()
1027 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
1029 add_credits(ses->server, 1, 0); in SendReceive()
1033 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceive()
1035 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
1041 cifs_in_send_inc(ses->server); in SendReceive()
1042 rc = smb_send(ses->server, in_buf, len); in SendReceive()
1043 cifs_in_send_dec(ses->server); in SendReceive()
1047 ses->server->sequence_number -= 2; in SendReceive()
1049 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
1057 rc = wait_for_response(ses->server, midQ); in SendReceive()
1059 send_cancel(ses->server, &rqst, midQ); in SendReceive()
1065 add_credits(ses->server, 1, 0); in SendReceive()
1071 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceive()
1073 add_credits(ses->server, 1, 0); in SendReceive()
1086 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceive()
1089 add_credits(ses->server, 1, 0); in SendReceive()
1103 struct cifs_ses *ses = tcon->ses; in send_lock_cancel() local
1113 pSMB->hdr.Mid = get_next_mid(ses->server); in send_lock_cancel()
1115 return SendReceive(xid, ses, in_buf, out_buf, in send_lock_cancel()
1127 struct cifs_ses *ses; in SendReceiveBlockingLock() local
1132 if (tcon == NULL || tcon->ses == NULL) { in SendReceiveBlockingLock()
1136 ses = tcon->ses; in SendReceiveBlockingLock()
1138 if (ses->server == NULL) { in SendReceiveBlockingLock()
1143 if (ses->server->tcpStatus == CifsExiting) in SendReceiveBlockingLock()
1156 rc = wait_for_free_request(ses->server, CIFS_BLOCKING_OP, 0); in SendReceiveBlockingLock()
1164 mutex_lock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1166 rc = allocate_mid(ses, in_buf, &midQ); in SendReceiveBlockingLock()
1168 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1172 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceiveBlockingLock()
1175 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1180 cifs_in_send_inc(ses->server); in SendReceiveBlockingLock()
1181 rc = smb_send(ses->server, in_buf, len); in SendReceiveBlockingLock()
1182 cifs_in_send_dec(ses->server); in SendReceiveBlockingLock()
1186 ses->server->sequence_number -= 2; in SendReceiveBlockingLock()
1188 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1196 rc = wait_event_interruptible(ses->server->response_q, in SendReceiveBlockingLock()
1198 ((ses->server->tcpStatus != CifsGood) && in SendReceiveBlockingLock()
1199 (ses->server->tcpStatus != CifsNew))); in SendReceiveBlockingLock()
1204 ((ses->server->tcpStatus == CifsGood) || in SendReceiveBlockingLock()
1205 (ses->server->tcpStatus == CifsNew))) { in SendReceiveBlockingLock()
1210 rc = send_cancel(ses->server, &rqst, midQ); in SendReceiveBlockingLock()
1229 rc = wait_for_response(ses->server, midQ); in SendReceiveBlockingLock()
1231 send_cancel(ses->server, &rqst, midQ); in SendReceiveBlockingLock()
1246 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceiveBlockingLock()
1259 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceiveBlockingLock()