Lines Matching refs:server
40 AllocMidQEntry(const struct smb_hdr *smb_buffer, struct TCP_Server_Info *server) in AllocMidQEntry() argument
44 if (server == NULL) { in AllocMidQEntry()
65 list_add_tail(&temp->qhead, &server->pending_mid_q); in AllocMidQEntry()
158 smb_sendv(struct TCP_Server_Info *server, struct kvec *iov, int n_vec) in smb_sendv() argument
168 struct socket *ssocket = server->ssocket; in smb_sendv()
173 smb_msg.msg_name = (struct sockaddr *) &server->addr.sockAddr; in smb_sendv()
177 if (server->noblocksnd) in smb_sendv()
220 if ((i >= 14) || (!server->noblocksnd && (i > 2))) { in smb_sendv()
272 server->tcpStatus = CifsNeedReconnect; in smb_sendv()
288 smb_send(struct TCP_Server_Info *server, struct smb_hdr *smb_buffer, in smb_send() argument
296 return smb_sendv(server, &iov, 1); in smb_send()
303 atomic_inc(&ses->server->inFlight); in wait_for_free_request()
309 if (atomic_read(&ses->server->inFlight) >= in wait_for_free_request()
313 atomic_inc(&ses->server->num_waiters); in wait_for_free_request()
315 wait_event(ses->server->request_q, in wait_for_free_request()
316 atomic_read(&ses->server->inFlight) in wait_for_free_request()
319 atomic_dec(&ses->server->num_waiters); in wait_for_free_request()
323 if (ses->server->tcpStatus == CifsExiting) { in wait_for_free_request()
333 atomic_inc(&ses->server->inFlight); in wait_for_free_request()
344 if (ses->server->tcpStatus == CifsExiting) { in allocate_mid()
348 if (ses->server->tcpStatus == CifsNeedReconnect) { in allocate_mid()
360 *ppmidQ = AllocMidQEntry(in_buf, ses->server); in allocate_mid()
375 wait_event_timeout(ses->server->response_q, in wait_for_response()
380 ((ses->server->tcpStatus == CifsGood) || in wait_for_response()
381 (ses->server->tcpStatus == CifsNew))) { in wait_for_response()
388 lrt = ses->server->lstrp; in wait_for_response()
453 if ((ses == NULL) || (ses->server == NULL)) { in SendReceive2()
459 if (ses->server->tcpStatus == CifsExiting) { in SendReceive2()
478 mutex_lock(&ses->server->srv_mutex); in SendReceive2()
482 mutex_unlock(&ses->server->srv_mutex); in SendReceive2()
485 atomic_dec(&ses->server->inFlight); in SendReceive2()
486 wake_up(&ses->server->request_q); in SendReceive2()
489 rc = cifs_sign_smb2(iov, n_vec, ses->server, &midQ->sequence_number); in SendReceive2()
491 mutex_unlock(&ses->server->srv_mutex); in SendReceive2()
498 atomic_inc(&ses->server->inSend); in SendReceive2()
500 rc = smb_sendv(ses->server, iov, n_vec); in SendReceive2()
502 atomic_dec(&ses->server->inSend); in SendReceive2()
506 mutex_unlock(&ses->server->srv_mutex); in SendReceive2()
546 if (ses->server->tcpStatus == CifsExiting) in SendReceive2()
549 ses->server->tcpStatus = CifsNeedReconnect; in SendReceive2()
565 atomic_dec(&ses->server->inFlight); in SendReceive2()
566 wake_up(&ses->server->request_q); in SendReceive2()
595 (ses->server->secMode & (SECMODE_SIGN_REQUIRED | in SendReceive2()
598 &ses->server->mac_signing_key, in SendReceive2()
627 atomic_dec(&ses->server->inFlight); in SendReceive2()
628 wake_up(&ses->server->request_q); in SendReceive2()
647 if (ses->server == NULL) { in SendReceive()
652 if (ses->server->tcpStatus == CifsExiting) in SendReceive()
673 mutex_lock(&ses->server->srv_mutex); in SendReceive()
677 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
679 atomic_dec(&ses->server->inFlight); in SendReceive()
680 wake_up(&ses->server->request_q); in SendReceive()
684 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceive()
686 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
692 atomic_inc(&ses->server->inSend); in SendReceive()
694 rc = smb_send(ses->server, in_buf, in_buf->smb_buf_length); in SendReceive()
696 atomic_dec(&ses->server->inSend); in SendReceive()
699 mutex_unlock(&ses->server->srv_mutex); in SendReceive()
737 if (ses->server->tcpStatus == CifsExiting) in SendReceive()
740 ses->server->tcpStatus = CifsNeedReconnect; in SendReceive()
756 atomic_dec(&ses->server->inFlight); in SendReceive()
757 wake_up(&ses->server->request_q); in SendReceive()
783 (ses->server->secMode & (SECMODE_SIGN_REQUIRED | in SendReceive()
786 &ses->server->mac_signing_key, in SendReceive()
811 atomic_dec(&ses->server->inFlight); in SendReceive()
812 wake_up(&ses->server->request_q); in SendReceive()
829 mutex_lock(&ses->server->srv_mutex); in send_nt_cancel()
830 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in send_nt_cancel()
832 mutex_unlock(&ses->server->srv_mutex); in send_nt_cancel()
835 rc = smb_send(ses->server, in_buf, in_buf->smb_buf_length); in send_nt_cancel()
836 mutex_unlock(&ses->server->srv_mutex); in send_nt_cancel()
859 pSMB->hdr.Mid = GetNextMid(ses->server); in send_lock_cancel()
882 if (ses->server == NULL) { in SendReceiveBlockingLock()
887 if (ses->server->tcpStatus == CifsExiting) in SendReceiveBlockingLock()
908 mutex_lock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
912 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
916 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number); in SendReceiveBlockingLock()
919 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
925 atomic_inc(&ses->server->inSend); in SendReceiveBlockingLock()
927 rc = smb_send(ses->server, in_buf, in_buf->smb_buf_length); in SendReceiveBlockingLock()
929 atomic_dec(&ses->server->inSend); in SendReceiveBlockingLock()
932 mutex_unlock(&ses->server->srv_mutex); in SendReceiveBlockingLock()
940 rc = wait_event_interruptible(ses->server->response_q, in SendReceiveBlockingLock()
942 ((ses->server->tcpStatus != CifsGood) && in SendReceiveBlockingLock()
943 (ses->server->tcpStatus != CifsNew))); in SendReceiveBlockingLock()
948 ((ses->server->tcpStatus == CifsGood) || in SendReceiveBlockingLock()
949 (ses->server->tcpStatus == CifsNew))) { in SendReceiveBlockingLock()
989 if (ses->server->tcpStatus == CifsExiting) in SendReceiveBlockingLock()
992 ses->server->tcpStatus = CifsNeedReconnect; in SendReceiveBlockingLock()
1033 (ses->server->secMode & (SECMODE_SIGN_REQUIRED | in SendReceiveBlockingLock()
1036 &ses->server->mac_signing_key, in SendReceiveBlockingLock()