Lines Matching refs:ses

460 static int allocate_mid(struct cifs_ses *ses, struct smb_hdr *in_buf,  in allocate_mid()  argument
463 if (ses->server->tcpStatus == CifsExiting) { in allocate_mid()
467 if (ses->server->tcpStatus == CifsNeedReconnect) { in allocate_mid()
472 if (ses->status == CifsNew) { in allocate_mid()
479 if (ses->status == CifsExiting) { in allocate_mid()
486 *ppmidQ = AllocMidQEntry(in_buf, ses->server); in allocate_mid()
490 list_add_tail(&(*ppmidQ)->qhead, &ses->server->pending_mid_q); in allocate_mid()
603 SendReceiveNoRsp(const unsigned int xid, struct cifs_ses *ses, in SendReceiveNoRsp() argument
613 rc = SendReceive2(xid, ses, iov, 1, &resp_buf_type, flags); in SendReceiveNoRsp()
692 cifs_setup_request(struct cifs_ses *ses, struct smb_rqst *rqst) in cifs_setup_request() argument
698 rc = allocate_mid(ses, hdr, &mid); in cifs_setup_request()
701 rc = cifs_sign_rqst(rqst, ses->server, &mid->sequence_number); in cifs_setup_request()
710 SendReceive2(const unsigned int xid, struct cifs_ses *ses, in SendReceive2() argument
727 if ((ses == NULL) || (ses->server == NULL)) { in SendReceive2()
733 if (ses->server->tcpStatus == CifsExiting) { in SendReceive2()
744 rc = wait_for_free_request(ses->server, timeout, optype); in SendReceive2()
756 mutex_lock(&ses->server->srv_mutex); in SendReceive2()
758 midQ = ses->server->ops->setup_request(ses, &rqst); in SendReceive2()
760 mutex_unlock(&ses->server->srv_mutex); in SendReceive2()
763 add_credits(ses->server, 1, optype); in SendReceive2()
768 cifs_in_send_inc(ses->server); in SendReceive2()
769 rc = smb_sendv(ses->server, iov, n_vec); in SendReceive2()
770 cifs_in_send_dec(ses->server); in SendReceive2()
774 ses->server->sequence_number -= 2; in SendReceive2()
775 mutex_unlock(&ses->server->srv_mutex); in SendReceive2()
787 rc = wait_for_response(ses->server, midQ); in SendReceive2()
789 send_cancel(ses->server, buf, midQ); in SendReceive2()
795 add_credits(ses->server, 1, optype); in SendReceive2()
803 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceive2()
805 add_credits(ses->server, 1, optype); in SendReceive2()
823 credits = ses->server->ops->get_credits(midQ); in SendReceive2()
825 rc = ses->server->ops->check_receive(midQ, ses->server, in SendReceive2()
833 add_credits(ses->server, credits, optype); in SendReceive2()
839 SendReceive(const unsigned int xid, struct cifs_ses *ses, in SendReceive() argument
846 if (ses == NULL) { in SendReceive()
850 if (ses->server == NULL) { in SendReceive()
855 if (ses->server->tcpStatus == CifsExiting) in SendReceive()
869 rc = wait_for_free_request(ses->server, timeout, 0); in SendReceive()
877 mutex_lock(&ses->server->srv_mutex); in SendReceive()
879 rc = allocate_mid(ses, in_buf, &midQ); in SendReceive()
881 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
883 add_credits(ses->server, 1, 0); in SendReceive()
887 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceive()
889 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
895 cifs_in_send_inc(ses->server); in SendReceive()
896 rc = smb_send(ses->server, in_buf, be32_to_cpu(in_buf->smb_buf_length)); in SendReceive()
897 cifs_in_send_dec(ses->server); in SendReceive()
901 ses->server->sequence_number -= 2; in SendReceive()
903 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
911 rc = wait_for_response(ses->server, midQ); in SendReceive()
913 send_cancel(ses->server, in_buf, midQ); in SendReceive()
919 add_credits(ses->server, 1, 0); in SendReceive()
925 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceive()
927 add_credits(ses->server, 1, 0); in SendReceive()
940 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceive()
943 add_credits(ses->server, 1, 0); in SendReceive()
957 struct cifs_ses *ses = tcon->ses; in send_lock_cancel() local
967 pSMB->hdr.Mid = get_next_mid(ses->server); in send_lock_cancel()
969 return SendReceive(xid, ses, in_buf, out_buf, in send_lock_cancel()
981 struct cifs_ses *ses; in SendReceiveBlockingLock() local
983 if (tcon == NULL || tcon->ses == NULL) { in SendReceiveBlockingLock()
987 ses = tcon->ses; in SendReceiveBlockingLock()
989 if (ses->server == NULL) { in SendReceiveBlockingLock()
994 if (ses->server->tcpStatus == CifsExiting) in SendReceiveBlockingLock()
1008 rc = wait_for_free_request(ses->server, CIFS_BLOCKING_OP, 0); in SendReceiveBlockingLock()
1016 mutex_lock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1018 rc = allocate_mid(ses, in_buf, &midQ); in SendReceiveBlockingLock()
1020 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1024 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceiveBlockingLock()
1027 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1032 cifs_in_send_inc(ses->server); in SendReceiveBlockingLock()
1033 rc = smb_send(ses->server, in_buf, be32_to_cpu(in_buf->smb_buf_length)); in SendReceiveBlockingLock()
1034 cifs_in_send_dec(ses->server); in SendReceiveBlockingLock()
1038 ses->server->sequence_number -= 2; in SendReceiveBlockingLock()
1040 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
1048 rc = wait_event_interruptible(ses->server->response_q, in SendReceiveBlockingLock()
1050 ((ses->server->tcpStatus != CifsGood) && in SendReceiveBlockingLock()
1051 (ses->server->tcpStatus != CifsNew))); in SendReceiveBlockingLock()
1056 ((ses->server->tcpStatus == CifsGood) || in SendReceiveBlockingLock()
1057 (ses->server->tcpStatus == CifsNew))) { in SendReceiveBlockingLock()
1062 rc = send_cancel(ses->server, in_buf, midQ); in SendReceiveBlockingLock()
1081 rc = wait_for_response(ses->server, midQ); in SendReceiveBlockingLock()
1083 send_cancel(ses->server, in_buf, midQ); in SendReceiveBlockingLock()
1098 rc = cifs_sync_mid_result(midQ, ses->server); in SendReceiveBlockingLock()
1111 rc = cifs_check_receive(midQ, ses->server, 0); in SendReceiveBlockingLock()