4 * Copyright (C) International Business Machines Corp., 2002,2005
5 * Author(s): Steve French (sfrench@us.ibm.com)
7 * This library is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU Lesser General Public License as published
9 * by the Free Software Foundation; either version 2.1 of the License, or
10 * (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See
15 * the GNU Lesser General Public License for more details.
17 * You should have received a copy of the GNU Lesser General Public License
18 * along with this library; if not, write to the Free Software
19 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
23 #include <linux/list.h>
24 #include <linux/wait.h>
25 #include <linux/net.h>
26 #include <linux/delay.h>
27 #include <asm/uaccess.h>
28 #include <asm/processor.h>
29 #include <linux/mempool.h>
32 #include "cifsproto.h"
33 #include "cifs_debug.h"
35 extern mempool_t
*cifs_mid_poolp
;
36 extern kmem_cache_t
*cifs_oplock_cachep
;
38 static struct mid_q_entry
*
39 AllocMidQEntry(struct smb_hdr
*smb_buffer
, struct cifsSesInfo
*ses
)
41 struct mid_q_entry
*temp
;
44 cERROR(1, ("Null session passed in to AllocMidQEntry"));
47 if (ses
->server
== NULL
) {
48 cERROR(1, ("Null TCP session in AllocMidQEntry"));
52 temp
= (struct mid_q_entry
*) mempool_alloc(cifs_mid_poolp
,
53 SLAB_KERNEL
| SLAB_NOFS
);
57 memset(temp
, 0, sizeof (struct mid_q_entry
));
58 temp
->mid
= smb_buffer
->Mid
; /* always LE */
59 temp
->pid
= current
->pid
;
60 temp
->command
= smb_buffer
->Command
;
61 cFYI(1, ("For smb_command %d", temp
->command
));
62 /* do_gettimeofday(&temp->when_sent);*/ /* easier to use jiffies */
63 /* when mid allocated can be before when sent */
64 temp
->when_alloc
= jiffies
;
69 spin_lock(&GlobalMid_Lock
);
70 list_add_tail(&temp
->qhead
, &ses
->server
->pending_mid_q
);
71 atomic_inc(&midCount
);
72 temp
->midState
= MID_REQUEST_ALLOCATED
;
73 spin_unlock(&GlobalMid_Lock
);
78 DeleteMidQEntry(struct mid_q_entry
*midEntry
)
80 #ifdef CONFIG_CIFS_STATS2
83 spin_lock(&GlobalMid_Lock
);
84 midEntry
->midState
= MID_FREE
;
85 list_del(&midEntry
->qhead
);
86 atomic_dec(&midCount
);
87 spin_unlock(&GlobalMid_Lock
);
88 if(midEntry
->largeBuf
)
89 cifs_buf_release(midEntry
->resp_buf
);
91 cifs_small_buf_release(midEntry
->resp_buf
);
92 #ifdef CONFIG_CIFS_STATS2
94 /* commands taking longer than one second are indications that
95 something is wrong, unless it is quite a slow link or server */
96 if((now
- midEntry
->when_alloc
) > HZ
) {
97 if((cifsFYI
& CIFS_TIMER
) &&
98 (midEntry
->command
!= SMB_COM_LOCKING_ANDX
)) {
99 printk(KERN_DEBUG
" CIFS slow rsp: cmd %d mid %d",
100 midEntry
->command
, midEntry
->mid
);
101 printk(" A: 0x%lx S: 0x%lx R: 0x%lx\n",
102 now
- midEntry
->when_alloc
,
103 now
- midEntry
->when_sent
,
104 now
- midEntry
->when_received
);
108 mempool_free(midEntry
, cifs_mid_poolp
);
111 struct oplock_q_entry
*
112 AllocOplockQEntry(struct inode
* pinode
, __u16 fid
, struct cifsTconInfo
* tcon
)
114 struct oplock_q_entry
*temp
;
115 if ((pinode
== NULL
) || (tcon
== NULL
)) {
116 cERROR(1, ("Null parms passed to AllocOplockQEntry"));
119 temp
= (struct oplock_q_entry
*) kmem_cache_alloc(cifs_oplock_cachep
,
124 temp
->pinode
= pinode
;
127 spin_lock(&GlobalMid_Lock
);
128 list_add_tail(&temp
->qhead
, &GlobalOplock_Q
);
129 spin_unlock(&GlobalMid_Lock
);
135 void DeleteOplockQEntry(struct oplock_q_entry
* oplockEntry
)
137 spin_lock(&GlobalMid_Lock
);
138 /* should we check if list empty first? */
139 list_del(&oplockEntry
->qhead
);
140 spin_unlock(&GlobalMid_Lock
);
141 kmem_cache_free(cifs_oplock_cachep
, oplockEntry
);
145 smb_send(struct socket
*ssocket
, struct smb_hdr
*smb_buffer
,
146 unsigned int smb_buf_length
, struct sockaddr
*sin
)
150 struct msghdr smb_msg
;
152 unsigned len
= smb_buf_length
+ 4;
155 return -ENOTSOCK
; /* BB eventually add reconnect code here */
156 iov
.iov_base
= smb_buffer
;
159 smb_msg
.msg_name
= sin
;
160 smb_msg
.msg_namelen
= sizeof (struct sockaddr
);
161 smb_msg
.msg_control
= NULL
;
162 smb_msg
.msg_controllen
= 0;
163 smb_msg
.msg_flags
= MSG_DONTWAIT
+ MSG_NOSIGNAL
; /* BB add more flags?*/
165 /* smb header is converted in header_assemble. bcc and rest of SMB word
166 area, and byte area if necessary, is converted to littleendian in
167 cifssmb.c and RFC1001 len is converted to bigendian in smb_send
168 Flags2 is converted in SendReceive */
170 smb_buffer
->smb_buf_length
= cpu_to_be32(smb_buffer
->smb_buf_length
);
171 cFYI(1, ("Sending smb of length %d", smb_buf_length
));
172 dump_smb(smb_buffer
, len
);
175 rc
= kernel_sendmsg(ssocket
, &smb_msg
, &iov
, 1, len
);
176 if ((rc
== -ENOSPC
) || (rc
== -EAGAIN
)) {
178 /* smaller timeout here than send2 since smaller size */
179 /* Although it may not be required, this also is smaller
183 ("sends on sock %p stuck for 7 seconds",
194 i
= 0; /* reset i after each successful send */
201 cERROR(1,("Error %d sending data on socket to server", rc
));
210 smb_send2(struct socket
*ssocket
, struct kvec
*iov
, int n_vec
,
211 struct sockaddr
*sin
)
215 struct msghdr smb_msg
;
216 struct smb_hdr
*smb_buffer
= iov
[0].iov_base
;
217 unsigned int len
= iov
[0].iov_len
;
218 unsigned int total_len
;
222 return -ENOTSOCK
; /* BB eventually add reconnect code here */
224 smb_msg
.msg_name
= sin
;
225 smb_msg
.msg_namelen
= sizeof (struct sockaddr
);
226 smb_msg
.msg_control
= NULL
;
227 smb_msg
.msg_controllen
= 0;
228 smb_msg
.msg_flags
= MSG_DONTWAIT
+ MSG_NOSIGNAL
; /* BB add more flags?*/
230 /* smb header is converted in header_assemble. bcc and rest of SMB word
231 area, and byte area if necessary, is converted to littleendian in
232 cifssmb.c and RFC1001 len is converted to bigendian in smb_send
233 Flags2 is converted in SendReceive */
237 for (i
= 0; i
< n_vec
; i
++)
238 total_len
+= iov
[i
].iov_len
;
240 smb_buffer
->smb_buf_length
= cpu_to_be32(smb_buffer
->smb_buf_length
);
241 cFYI(1, ("Sending smb: total_len %d", total_len
));
242 dump_smb(smb_buffer
, len
);
245 rc
= kernel_sendmsg(ssocket
, &smb_msg
, &iov
[first_vec
],
246 n_vec
- first_vec
, total_len
);
247 if ((rc
== -ENOSPC
) || (rc
== -EAGAIN
)) {
251 ("sends on sock %p stuck for 15 seconds",
262 if (rc
>= total_len
) {
263 WARN_ON(rc
> total_len
);
267 /* should never happen, letting socket clear before
268 retrying is our only obvious option here */
269 cERROR(1,("tcp sent no data"));
274 /* the line below resets i */
275 for (i
= first_vec
; i
< n_vec
; i
++) {
276 if (iov
[i
].iov_len
) {
277 if (rc
> iov
[i
].iov_len
) {
278 rc
-= iov
[i
].iov_len
;
281 iov
[i
].iov_base
+= rc
;
282 iov
[i
].iov_len
-= rc
;
288 i
= 0; /* in case we get ENOSPC on the next send */
292 cERROR(1,("Error %d sending data on socket to server", rc
));
300 SendReceive2(const unsigned int xid
, struct cifsSesInfo
*ses
,
301 struct kvec
*iov
, int n_vec
, int * pRespBufType
/* ret */,
305 unsigned int receive_len
;
306 unsigned long timeout
;
307 struct mid_q_entry
*midQ
;
308 struct smb_hdr
*in_buf
= iov
[0].iov_base
;
310 *pRespBufType
= CIFS_NO_BUFFER
; /* no response buf yet */
313 cERROR(1,("Null smb session"));
316 if(ses
->server
== NULL
) {
317 cERROR(1,("Null tcp session"));
321 if(ses
->server
->tcpStatus
== CifsExiting
)
324 /* Ensure that we do not send more than 50 overlapping requests
325 to the same server. We may make this configurable later or
328 /* oplock breaks must not be held up */
329 atomic_inc(&ses
->server
->inFlight
);
331 spin_lock(&GlobalMid_Lock
);
333 if(atomic_read(&ses
->server
->inFlight
) >=
335 spin_unlock(&GlobalMid_Lock
);
336 #ifdef CONFIG_CIFS_STATS2
337 atomic_inc(&ses
->server
->num_waiters
);
339 wait_event(ses
->server
->request_q
,
340 atomic_read(&ses
->server
->inFlight
)
342 #ifdef CONFIG_CIFS_STATS2
343 atomic_dec(&ses
->server
->num_waiters
);
345 spin_lock(&GlobalMid_Lock
);
347 if(ses
->server
->tcpStatus
== CifsExiting
) {
348 spin_unlock(&GlobalMid_Lock
);
352 /* can not count locking commands against total since
353 they are allowed to block on server */
356 /* update # of requests on the wire to server */
357 atomic_inc(&ses
->server
->inFlight
);
359 spin_unlock(&GlobalMid_Lock
);
364 /* make sure that we sign in the same order that we send on this socket
365 and avoid races inside tcp sendmsg code that could cause corruption
368 down(&ses
->server
->tcpSem
);
370 if (ses
->server
->tcpStatus
== CifsExiting
) {
373 } else if (ses
->server
->tcpStatus
== CifsNeedReconnect
) {
374 cFYI(1,("tcp session dead - return to caller to retry"));
377 } else if (ses
->status
!= CifsGood
) {
378 /* check if SMB session is bad because we are setting it up */
379 if((in_buf
->Command
!= SMB_COM_SESSION_SETUP_ANDX
) &&
380 (in_buf
->Command
!= SMB_COM_NEGOTIATE
)) {
383 } /* else ok - we are setting up session */
385 midQ
= AllocMidQEntry(in_buf
, ses
);
387 up(&ses
->server
->tcpSem
);
388 /* If not lock req, update # of requests on wire to server */
390 atomic_dec(&ses
->server
->inFlight
);
391 wake_up(&ses
->server
->request_q
);
396 rc
= cifs_sign_smb2(iov
, n_vec
, ses
->server
, &midQ
->sequence_number
);
398 midQ
->midState
= MID_REQUEST_SUBMITTED
;
399 #ifdef CONFIG_CIFS_STATS2
400 atomic_inc(&ses
->server
->inSend
);
402 rc
= smb_send2(ses
->server
->ssocket
, iov
, n_vec
,
403 (struct sockaddr
*) &(ses
->server
->addr
.sockAddr
));
404 #ifdef CONFIG_CIFS_STATS2
405 atomic_dec(&ses
->server
->inSend
);
406 midQ
->when_sent
= jiffies
;
409 DeleteMidQEntry(midQ
);
410 up(&ses
->server
->tcpSem
);
411 /* If not lock req, update # of requests on wire to server */
413 atomic_dec(&ses
->server
->inFlight
);
414 wake_up(&ses
->server
->request_q
);
418 up(&ses
->server
->tcpSem
);
420 goto cifs_no_response_exit2
;
421 else if (long_op
== 2) /* writes past end of file can take loong time */
423 else if (long_op
== 1)
424 timeout
= 45 * HZ
; /* should be greater than
425 servers oplock break timeout (about 43 seconds) */
426 else if (long_op
> 2) {
427 timeout
= MAX_SCHEDULE_TIMEOUT
;
430 /* wait for 15 seconds or until woken up due to response arriving or
431 due to last connection to this server being unmounted */
432 if (signal_pending(current
)) {
433 /* if signal pending do not hold up user for full smb timeout
434 but we still give response a change to complete */
438 /* No user interrupts in wait - wreaks havoc with performance */
439 if(timeout
!= MAX_SCHEDULE_TIMEOUT
) {
441 wait_event(ses
->server
->response_q
,
442 (!(midQ
->midState
& MID_REQUEST_SUBMITTED
)) ||
443 time_after(jiffies
, timeout
) ||
444 ((ses
->server
->tcpStatus
!= CifsGood
) &&
445 (ses
->server
->tcpStatus
!= CifsNew
)));
447 wait_event(ses
->server
->response_q
,
448 (!(midQ
->midState
& MID_REQUEST_SUBMITTED
)) ||
449 ((ses
->server
->tcpStatus
!= CifsGood
) &&
450 (ses
->server
->tcpStatus
!= CifsNew
)));
453 spin_lock(&GlobalMid_Lock
);
454 if (midQ
->resp_buf
) {
455 spin_unlock(&GlobalMid_Lock
);
456 receive_len
= midQ
->resp_buf
->smb_buf_length
;
458 cERROR(1,("No response to cmd %d mid %d",
459 midQ
->command
, midQ
->mid
));
460 if(midQ
->midState
== MID_REQUEST_SUBMITTED
) {
461 if(ses
->server
->tcpStatus
== CifsExiting
)
464 ses
->server
->tcpStatus
= CifsNeedReconnect
;
465 midQ
->midState
= MID_RETRY_NEEDED
;
469 if (rc
!= -EHOSTDOWN
) {
470 if(midQ
->midState
== MID_RETRY_NEEDED
) {
472 cFYI(1,("marking request for retry"));
477 spin_unlock(&GlobalMid_Lock
);
478 DeleteMidQEntry(midQ
);
479 /* If not lock req, update # of requests on wire to server */
481 atomic_dec(&ses
->server
->inFlight
);
482 wake_up(&ses
->server
->request_q
);
487 if (receive_len
> CIFSMaxBufSize
+ MAX_CIFS_HDR_SIZE
) {
488 cERROR(1, ("Frame too large received. Length: %d Xid: %d",
491 } else { /* rcvd frame is ok */
492 if (midQ
->resp_buf
&&
493 (midQ
->midState
== MID_RESPONSE_RECEIVED
)) {
495 iov
[0].iov_base
= (char *)midQ
->resp_buf
;
497 *pRespBufType
= CIFS_LARGE_BUFFER
;
499 *pRespBufType
= CIFS_SMALL_BUFFER
;
500 iov
[0].iov_len
= receive_len
+ 4;
503 dump_smb(midQ
->resp_buf
, 80);
504 /* convert the length into a more usable form */
505 if((receive_len
> 24) &&
506 (ses
->server
->secMode
& (SECMODE_SIGN_REQUIRED
|
507 SECMODE_SIGN_ENABLED
))) {
508 rc
= cifs_verify_signature(midQ
->resp_buf
,
509 ses
->server
->mac_signing_key
,
510 midQ
->sequence_number
+1);
512 cERROR(1,("Unexpected SMB signature"));
513 /* BB FIXME add code to kill session */
517 /* BB special case reconnect tid and uid here? */
518 /* BB special case Errbadpassword and pwdexpired here */
519 rc
= map_smb_to_linux_error(midQ
->resp_buf
);
521 /* convert ByteCount if necessary */
523 sizeof (struct smb_hdr
) -
524 4 /* do not count RFC1001 header */ +
525 (2 * midQ
->resp_buf
->WordCount
) + 2 /* bcc */ )
526 BCC(midQ
->resp_buf
) =
527 le16_to_cpu(BCC_LE(midQ
->resp_buf
));
528 midQ
->resp_buf
= NULL
; /* mark it so will not be freed
529 by DeleteMidQEntry */
532 cFYI(1,("Bad MID state?"));
535 cifs_no_response_exit2
:
536 DeleteMidQEntry(midQ
);
539 atomic_dec(&ses
->server
->inFlight
);
540 wake_up(&ses
->server
->request_q
);
546 up(&ses
->server
->tcpSem
);
547 /* If not lock req, update # of requests on wire to server */
549 atomic_dec(&ses
->server
->inFlight
);
550 wake_up(&ses
->server
->request_q
);
557 SendReceive(const unsigned int xid
, struct cifsSesInfo
*ses
,
558 struct smb_hdr
*in_buf
, struct smb_hdr
*out_buf
,
559 int *pbytes_returned
, const int long_op
)
562 unsigned int receive_len
;
563 unsigned long timeout
;
564 struct mid_q_entry
*midQ
;
567 cERROR(1,("Null smb session"));
570 if(ses
->server
== NULL
) {
571 cERROR(1,("Null tcp session"));
575 if(ses
->server
->tcpStatus
== CifsExiting
)
578 /* Ensure that we do not send more than 50 overlapping requests
579 to the same server. We may make this configurable later or
582 /* oplock breaks must not be held up */
583 atomic_inc(&ses
->server
->inFlight
);
585 spin_lock(&GlobalMid_Lock
);
587 if(atomic_read(&ses
->server
->inFlight
) >=
589 spin_unlock(&GlobalMid_Lock
);
590 #ifdef CONFIG_CIFS_STATS2
591 atomic_inc(&ses
->server
->num_waiters
);
593 wait_event(ses
->server
->request_q
,
594 atomic_read(&ses
->server
->inFlight
)
596 #ifdef CONFIG_CIFS_STATS2
597 atomic_dec(&ses
->server
->num_waiters
);
599 spin_lock(&GlobalMid_Lock
);
601 if(ses
->server
->tcpStatus
== CifsExiting
) {
602 spin_unlock(&GlobalMid_Lock
);
606 /* can not count locking commands against total since
607 they are allowed to block on server */
610 /* update # of requests on the wire to server */
611 atomic_inc(&ses
->server
->inFlight
);
613 spin_unlock(&GlobalMid_Lock
);
618 /* make sure that we sign in the same order that we send on this socket
619 and avoid races inside tcp sendmsg code that could cause corruption
622 down(&ses
->server
->tcpSem
);
624 if (ses
->server
->tcpStatus
== CifsExiting
) {
627 } else if (ses
->server
->tcpStatus
== CifsNeedReconnect
) {
628 cFYI(1,("tcp session dead - return to caller to retry"));
631 } else if (ses
->status
!= CifsGood
) {
632 /* check if SMB session is bad because we are setting it up */
633 if((in_buf
->Command
!= SMB_COM_SESSION_SETUP_ANDX
) &&
634 (in_buf
->Command
!= SMB_COM_NEGOTIATE
)) {
637 } /* else ok - we are setting up session */
639 midQ
= AllocMidQEntry(in_buf
, ses
);
641 up(&ses
->server
->tcpSem
);
642 /* If not lock req, update # of requests on wire to server */
644 atomic_dec(&ses
->server
->inFlight
);
645 wake_up(&ses
->server
->request_q
);
650 if (in_buf
->smb_buf_length
> CIFSMaxBufSize
+ MAX_CIFS_HDR_SIZE
- 4) {
651 up(&ses
->server
->tcpSem
);
653 ("Illegal length, greater than maximum frame, %d ",
654 in_buf
->smb_buf_length
));
655 DeleteMidQEntry(midQ
);
656 /* If not lock req, update # of requests on wire to server */
658 atomic_dec(&ses
->server
->inFlight
);
659 wake_up(&ses
->server
->request_q
);
664 rc
= cifs_sign_smb(in_buf
, ses
->server
, &midQ
->sequence_number
);
666 midQ
->midState
= MID_REQUEST_SUBMITTED
;
667 #ifdef CONFIG_CIFS_STATS2
668 atomic_inc(&ses
->server
->inSend
);
670 rc
= smb_send(ses
->server
->ssocket
, in_buf
, in_buf
->smb_buf_length
,
671 (struct sockaddr
*) &(ses
->server
->addr
.sockAddr
));
672 #ifdef CONFIG_CIFS_STATS2
673 atomic_dec(&ses
->server
->inSend
);
674 midQ
->when_sent
= jiffies
;
677 DeleteMidQEntry(midQ
);
678 up(&ses
->server
->tcpSem
);
679 /* If not lock req, update # of requests on wire to server */
681 atomic_dec(&ses
->server
->inFlight
);
682 wake_up(&ses
->server
->request_q
);
686 up(&ses
->server
->tcpSem
);
688 goto cifs_no_response_exit
;
689 else if (long_op
== 2) /* writes past end of file can take loong time */
691 else if (long_op
== 1)
692 timeout
= 45 * HZ
; /* should be greater than
693 servers oplock break timeout (about 43 seconds) */
694 else if (long_op
> 2) {
695 timeout
= MAX_SCHEDULE_TIMEOUT
;
698 /* wait for 15 seconds or until woken up due to response arriving or
699 due to last connection to this server being unmounted */
700 if (signal_pending(current
)) {
701 /* if signal pending do not hold up user for full smb timeout
702 but we still give response a change to complete */
706 /* No user interrupts in wait - wreaks havoc with performance */
707 if(timeout
!= MAX_SCHEDULE_TIMEOUT
) {
709 wait_event(ses
->server
->response_q
,
710 (!(midQ
->midState
& MID_REQUEST_SUBMITTED
)) ||
711 time_after(jiffies
, timeout
) ||
712 ((ses
->server
->tcpStatus
!= CifsGood
) &&
713 (ses
->server
->tcpStatus
!= CifsNew
)));
715 wait_event(ses
->server
->response_q
,
716 (!(midQ
->midState
& MID_REQUEST_SUBMITTED
)) ||
717 ((ses
->server
->tcpStatus
!= CifsGood
) &&
718 (ses
->server
->tcpStatus
!= CifsNew
)));
721 spin_lock(&GlobalMid_Lock
);
722 if (midQ
->resp_buf
) {
723 spin_unlock(&GlobalMid_Lock
);
724 receive_len
= midQ
->resp_buf
->smb_buf_length
;
726 cERROR(1,("No response for cmd %d mid %d",
727 midQ
->command
, midQ
->mid
));
728 if(midQ
->midState
== MID_REQUEST_SUBMITTED
) {
729 if(ses
->server
->tcpStatus
== CifsExiting
)
732 ses
->server
->tcpStatus
= CifsNeedReconnect
;
733 midQ
->midState
= MID_RETRY_NEEDED
;
737 if (rc
!= -EHOSTDOWN
) {
738 if(midQ
->midState
== MID_RETRY_NEEDED
) {
740 cFYI(1,("marking request for retry"));
745 spin_unlock(&GlobalMid_Lock
);
746 DeleteMidQEntry(midQ
);
747 /* If not lock req, update # of requests on wire to server */
749 atomic_dec(&ses
->server
->inFlight
);
750 wake_up(&ses
->server
->request_q
);
755 if (receive_len
> CIFSMaxBufSize
+ MAX_CIFS_HDR_SIZE
) {
756 cERROR(1, ("Frame too large received. Length: %d Xid: %d",
759 } else { /* rcvd frame is ok */
761 if (midQ
->resp_buf
&& out_buf
762 && (midQ
->midState
== MID_RESPONSE_RECEIVED
)) {
763 out_buf
->smb_buf_length
= receive_len
;
764 memcpy((char *)out_buf
+ 4,
765 (char *)midQ
->resp_buf
+ 4,
768 dump_smb(out_buf
, 92);
769 /* convert the length into a more usable form */
770 if((receive_len
> 24) &&
771 (ses
->server
->secMode
& (SECMODE_SIGN_REQUIRED
|
772 SECMODE_SIGN_ENABLED
))) {
773 rc
= cifs_verify_signature(out_buf
,
774 ses
->server
->mac_signing_key
,
775 midQ
->sequence_number
+1);
777 cERROR(1,("Unexpected SMB signature"));
778 /* BB FIXME add code to kill session */
782 *pbytes_returned
= out_buf
->smb_buf_length
;
784 /* BB special case reconnect tid and uid here? */
785 rc
= map_smb_to_linux_error(out_buf
);
787 /* convert ByteCount if necessary */
789 sizeof (struct smb_hdr
) -
790 4 /* do not count RFC1001 header */ +
791 (2 * out_buf
->WordCount
) + 2 /* bcc */ )
792 BCC(out_buf
) = le16_to_cpu(BCC_LE(out_buf
));
795 cERROR(1,("Bad MID state?"));
798 cifs_no_response_exit
:
799 DeleteMidQEntry(midQ
);
802 atomic_dec(&ses
->server
->inFlight
);
803 wake_up(&ses
->server
->request_q
);
809 up(&ses
->server
->tcpSem
);
810 /* If not lock req, update # of requests on wire to server */
812 atomic_dec(&ses
->server
->inFlight
);
813 wake_up(&ses
->server
->request_q
);