Lines Matching defs:ses
40 AllocMidQEntry(const struct smb_hdr *smb_buffer, struct cifsSesInfo *ses)
44 if (ses == NULL) {
48 if (ses->server == NULL) {
66 temp->ses = ses;
71 list_add_tail(&temp->qhead, &ses->server->pending_mid_q);
309 static int wait_for_free_request(struct cifsSesInfo *ses, const int long_op)
313 atomic_inc(&ses->server->inFlight);
317 if(atomic_read(&ses->server->inFlight) >=
321 atomic_inc(&ses->server->num_waiters);
323 wait_event(ses->server->request_q,
324 atomic_read(&ses->server->inFlight)
327 atomic_dec(&ses->server->num_waiters);
331 if(ses->server->tcpStatus == CifsExiting) {
341 atomic_inc(&ses->server->inFlight);
350 static int allocate_mid(struct cifsSesInfo *ses, struct smb_hdr *in_buf,
353 if (ses->server->tcpStatus == CifsExiting) {
355 } else if (ses->server->tcpStatus == CifsNeedReconnect) {
358 } else if (ses->status != CifsGood) {
365 *ppmidQ = AllocMidQEntry(in_buf, ses);
372 static int wait_for_response(struct cifsSesInfo *ses,
381 wait_event(ses->server->response_q,
384 ((ses->server->tcpStatus != CifsGood) &&
385 (ses->server->tcpStatus != CifsNew)));
389 ((ses->server->tcpStatus == CifsGood) ||
390 (ses->server->tcpStatus == CifsNew))) {
397 lrt = ses->server->lstrp;
420 SendReceive2(const unsigned int xid, struct cifsSesInfo *ses,
432 if ((ses == NULL) || (ses->server == NULL)) {
438 if(ses->server->tcpStatus == CifsExiting) {
445 use ses->maxReq */
447 rc = wait_for_free_request(ses, long_op);
457 down(&ses->server->tcpSem);
459 rc = allocate_mid(ses, in_buf, &midQ);
461 up(&ses->server->tcpSem);
464 atomic_dec(&ses->server->inFlight);
465 wake_up(&ses->server->request_q);
469 rc = cifs_sign_smb2(iov, n_vec, ses->server, &midQ->sequence_number);
473 atomic_inc(&ses->server->inSend);
475 rc = smb_send2(ses->server->ssocket, iov, n_vec,
476 (struct sockaddr *) &(ses->server->addr.sockAddr));
478 atomic_dec(&ses->server->inSend);
482 up(&ses->server->tcpSem);
507 wait_for_response(ses, midQ, timeout, 10 * HZ);
517 if(ses->server->tcpStatus == CifsExiting)
520 ses->server->tcpStatus = CifsNeedReconnect;
536 atomic_dec(&ses->server->inFlight);
537 wake_up(&ses->server->request_q);
559 (ses->server->secMode & (SECMODE_SIGN_REQUIRED |
562 ses->server->mac_signing_key,
590 atomic_dec(&ses->server->inFlight);
591 wake_up(&ses->server->request_q);
597 SendReceive(const unsigned int xid, struct cifsSesInfo *ses,
606 if (ses == NULL) {
610 if(ses->server == NULL) {
615 if(ses->server->tcpStatus == CifsExiting)
620 use ses->maxReq */
622 rc = wait_for_free_request(ses, long_op);
630 down(&ses->server->tcpSem);
632 rc = allocate_mid(ses, in_buf, &midQ);
634 up(&ses->server->tcpSem);
636 atomic_dec(&ses->server->inFlight);
637 wake_up(&ses->server->request_q);
645 up(&ses->server->tcpSem);
647 atomic_dec(&ses->server->inFlight);
648 wake_up(&ses->server->request_q);
652 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number);
656 atomic_inc(&ses->server->inSend);
658 rc = smb_send(ses->server->ssocket, in_buf, in_buf->smb_buf_length,
659 (struct sockaddr *) &(ses->server->addr.sockAddr));
661 atomic_dec(&ses->server->inSend);
664 up(&ses->server->tcpSem);
687 wait_for_response(ses, midQ, timeout, 10 * HZ);
697 if(ses->server->tcpStatus == CifsExiting)
700 ses->server->tcpStatus = CifsNeedReconnect;
716 atomic_dec(&ses->server->inFlight);
717 wake_up(&ses->server->request_q);
737 (ses->server->secMode & (SECMODE_SIGN_REQUIRED |
740 ses->server->mac_signing_key,
766 atomic_dec(&ses->server->inFlight);
767 wake_up(&ses->server->request_q);
779 struct cifsSesInfo *ses = tcon->ses;
784 down(&ses->server->tcpSem);
785 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number);
787 up(&ses->server->tcpSem);
790 rc = smb_send(ses->server->ssocket, in_buf, in_buf->smb_buf_length,
791 (struct sockaddr *) &(ses->server->addr.sockAddr));
792 up(&ses->server->tcpSem);
805 struct cifsSesInfo *ses = tcon->ses;
815 pSMB->hdr.Mid = GetNextMid(ses->server);
817 return SendReceive(xid, ses, in_buf, out_buf,
830 struct cifsSesInfo *ses;
832 if (tcon == NULL || tcon->ses == NULL) {
836 ses = tcon->ses;
838 if(ses->server == NULL) {
843 if(ses->server->tcpStatus == CifsExiting)
848 use ses->maxReq */
850 rc = wait_for_free_request(ses, 3);
858 down(&ses->server->tcpSem);
860 rc = allocate_mid(ses, in_buf, &midQ);
862 up(&ses->server->tcpSem);
867 up(&ses->server->tcpSem);
874 rc = cifs_sign_smb(in_buf, ses->server, &midQ->sequence_number);
878 atomic_inc(&ses->server->inSend);
880 rc = smb_send(ses->server->ssocket, in_buf, in_buf->smb_buf_length,
881 (struct sockaddr *) &(ses->server->addr.sockAddr));
883 atomic_dec(&ses->server->inSend);
886 up(&ses->server->tcpSem);
894 rc = wait_event_interruptible(ses->server->response_q,
896 ((ses->server->tcpStatus != CifsGood) &&
897 (ses->server->tcpStatus != CifsNew)));
902 ((ses->server->tcpStatus == CifsGood) ||
903 (ses->server->tcpStatus == CifsNew))) {
929 if (wait_for_response(ses, midQ, 5 * HZ, 5 * HZ)==0) {
943 if(ses->server->tcpStatus == CifsExiting)
946 ses->server->tcpStatus = CifsNeedReconnect;
980 (ses->server->secMode & (SECMODE_SIGN_REQUIRED |
983 ses->server->mac_signing_key,