[SCSI] fix CONFIG_SCSI_WAIT_SCAN=m
[linux-2.6/kmemtrace.git] / fs / cifs / connect.c
blob216fb625843f4b29feb6011e8fe71a14f223a996
1 /*
2 * fs/cifs/connect.c
4 * Copyright (C) International Business Machines Corp., 2002,2006
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
21 #include <linux/fs.h>
22 #include <linux/net.h>
23 #include <linux/string.h>
24 #include <linux/list.h>
25 #include <linux/wait.h>
26 #include <linux/ipv6.h>
27 #include <linux/pagemap.h>
28 #include <linux/ctype.h>
29 #include <linux/utsname.h>
30 #include <linux/mempool.h>
31 #include <linux/delay.h>
32 #include <linux/completion.h>
33 #include <linux/kthread.h>
34 #include <linux/pagevec.h>
35 #include <linux/freezer.h>
36 #include <asm/uaccess.h>
37 #include <asm/processor.h>
38 #include "cifspdu.h"
39 #include "cifsglob.h"
40 #include "cifsproto.h"
41 #include "cifs_unicode.h"
42 #include "cifs_debug.h"
43 #include "cifs_fs_sb.h"
44 #include "ntlmssp.h"
45 #include "nterr.h"
46 #include "rfc1002pdu.h"
47 #include "cn_cifs.h"
49 #define CIFS_PORT 445
50 #define RFC1001_PORT 139
52 static DECLARE_COMPLETION(cifsd_complete);
54 extern void SMBNTencrypt(unsigned char *passwd, unsigned char *c8,
55 unsigned char *p24);
57 extern mempool_t *cifs_req_poolp;
59 struct smb_vol {
60 char *username;
61 char *password;
62 char *domainname;
63 char *UNC;
64 char *UNCip;
65 char *in6_addr; /* ipv6 address as human readable form of in6_addr */
66 char *iocharset; /* local code page for mapping to and from Unicode */
67 char source_rfc1001_name[16]; /* netbios name of client */
68 char target_rfc1001_name[16]; /* netbios name of server for Win9x/ME */
69 uid_t linux_uid;
70 gid_t linux_gid;
71 mode_t file_mode;
72 mode_t dir_mode;
73 unsigned secFlg;
74 unsigned rw:1;
75 unsigned retry:1;
76 unsigned intr:1;
77 unsigned setuids:1;
78 unsigned override_uid:1;
79 unsigned override_gid:1;
80 unsigned noperm:1;
81 unsigned no_psx_acl:1; /* set if posix acl support should be disabled */
82 unsigned cifs_acl:1;
83 unsigned no_xattr:1; /* set if xattr (EA) support should be disabled*/
84 unsigned server_ino:1; /* use inode numbers from server ie UniqueId */
85 unsigned direct_io:1;
86 unsigned remap:1; /* set to remap seven reserved chars in filenames */
87 unsigned posix_paths:1; /* unset to not ask for posix pathnames. */
88 unsigned sfu_emul:1;
89 unsigned nullauth:1; /* attempt to authenticate with null user */
90 unsigned nocase; /* request case insensitive filenames */
91 unsigned nobrl; /* disable sending byte range locks to srv */
92 unsigned int rsize;
93 unsigned int wsize;
94 unsigned int sockopt;
95 unsigned short int port;
96 char * prepath;
99 static int ipv4_connect(struct sockaddr_in *psin_server,
100 struct socket **csocket,
101 char * netb_name,
102 char * server_netb_name);
103 static int ipv6_connect(struct sockaddr_in6 *psin_server,
104 struct socket **csocket);
108 * cifs tcp session reconnection
110 * mark tcp session as reconnecting so temporarily locked
111 * mark all smb sessions as reconnecting for tcp session
112 * reconnect tcp session
113 * wake up waiters on reconnection? - (not needed currently)
116 static int
117 cifs_reconnect(struct TCP_Server_Info *server)
119 int rc = 0;
120 struct list_head *tmp;
121 struct cifsSesInfo *ses;
122 struct cifsTconInfo *tcon;
123 struct mid_q_entry * mid_entry;
125 spin_lock(&GlobalMid_Lock);
126 if( kthread_should_stop() ) {
127 /* the demux thread will exit normally
128 next time through the loop */
129 spin_unlock(&GlobalMid_Lock);
130 return rc;
131 } else
132 server->tcpStatus = CifsNeedReconnect;
133 spin_unlock(&GlobalMid_Lock);
134 server->maxBuf = 0;
136 cFYI(1, ("Reconnecting tcp session"));
138 /* before reconnecting the tcp session, mark the smb session (uid)
139 and the tid bad so they are not used until reconnected */
140 read_lock(&GlobalSMBSeslock);
141 list_for_each(tmp, &GlobalSMBSessionList) {
142 ses = list_entry(tmp, struct cifsSesInfo, cifsSessionList);
143 if (ses->server) {
144 if (ses->server == server) {
145 ses->status = CifsNeedReconnect;
146 ses->ipc_tid = 0;
149 /* else tcp and smb sessions need reconnection */
151 list_for_each(tmp, &GlobalTreeConnectionList) {
152 tcon = list_entry(tmp, struct cifsTconInfo, cifsConnectionList);
153 if((tcon) && (tcon->ses) && (tcon->ses->server == server)) {
154 tcon->tidStatus = CifsNeedReconnect;
157 read_unlock(&GlobalSMBSeslock);
158 /* do not want to be sending data on a socket we are freeing */
159 down(&server->tcpSem);
160 if(server->ssocket) {
161 cFYI(1,("State: 0x%x Flags: 0x%lx", server->ssocket->state,
162 server->ssocket->flags));
163 server->ssocket->ops->shutdown(server->ssocket,SEND_SHUTDOWN);
164 cFYI(1,("Post shutdown state: 0x%x Flags: 0x%lx", server->ssocket->state,
165 server->ssocket->flags));
166 sock_release(server->ssocket);
167 server->ssocket = NULL;
170 spin_lock(&GlobalMid_Lock);
171 list_for_each(tmp, &server->pending_mid_q) {
172 mid_entry = list_entry(tmp, struct
173 mid_q_entry,
174 qhead);
175 if(mid_entry) {
176 if(mid_entry->midState == MID_REQUEST_SUBMITTED) {
177 /* Mark other intransit requests as needing
178 retry so we do not immediately mark the
179 session bad again (ie after we reconnect
180 below) as they timeout too */
181 mid_entry->midState = MID_RETRY_NEEDED;
185 spin_unlock(&GlobalMid_Lock);
186 up(&server->tcpSem);
188 while ( (!kthread_should_stop()) && (server->tcpStatus != CifsGood))
190 try_to_freeze();
191 if(server->protocolType == IPV6) {
192 rc = ipv6_connect(&server->addr.sockAddr6,&server->ssocket);
193 } else {
194 rc = ipv4_connect(&server->addr.sockAddr,
195 &server->ssocket,
196 server->workstation_RFC1001_name,
197 server->server_RFC1001_name);
199 if(rc) {
200 cFYI(1,("reconnect error %d",rc));
201 msleep(3000);
202 } else {
203 atomic_inc(&tcpSesReconnectCount);
204 spin_lock(&GlobalMid_Lock);
205 if( !kthread_should_stop() )
206 server->tcpStatus = CifsGood;
207 server->sequence_number = 0;
208 spin_unlock(&GlobalMid_Lock);
209 /* atomic_set(&server->inFlight,0);*/
210 wake_up(&server->response_q);
213 return rc;
217 return codes:
218 0 not a transact2, or all data present
219 >0 transact2 with that much data missing
220 -EINVAL = invalid transact2
223 static int check2ndT2(struct smb_hdr * pSMB, unsigned int maxBufSize)
225 struct smb_t2_rsp * pSMBt;
226 int total_data_size;
227 int data_in_this_rsp;
228 int remaining;
230 if(pSMB->Command != SMB_COM_TRANSACTION2)
231 return 0;
233 /* check for plausible wct, bcc and t2 data and parm sizes */
234 /* check for parm and data offset going beyond end of smb */
235 if(pSMB->WordCount != 10) { /* coalesce_t2 depends on this */
236 cFYI(1,("invalid transact2 word count"));
237 return -EINVAL;
240 pSMBt = (struct smb_t2_rsp *)pSMB;
242 total_data_size = le16_to_cpu(pSMBt->t2_rsp.TotalDataCount);
243 data_in_this_rsp = le16_to_cpu(pSMBt->t2_rsp.DataCount);
245 remaining = total_data_size - data_in_this_rsp;
247 if(remaining == 0)
248 return 0;
249 else if(remaining < 0) {
250 cFYI(1,("total data %d smaller than data in frame %d",
251 total_data_size, data_in_this_rsp));
252 return -EINVAL;
253 } else {
254 cFYI(1,("missing %d bytes from transact2, check next response",
255 remaining));
256 if(total_data_size > maxBufSize) {
257 cERROR(1,("TotalDataSize %d is over maximum buffer %d",
258 total_data_size,maxBufSize));
259 return -EINVAL;
261 return remaining;
265 static int coalesce_t2(struct smb_hdr * psecond, struct smb_hdr *pTargetSMB)
267 struct smb_t2_rsp *pSMB2 = (struct smb_t2_rsp *)psecond;
268 struct smb_t2_rsp *pSMBt = (struct smb_t2_rsp *)pTargetSMB;
269 int total_data_size;
270 int total_in_buf;
271 int remaining;
272 int total_in_buf2;
273 char * data_area_of_target;
274 char * data_area_of_buf2;
275 __u16 byte_count;
277 total_data_size = le16_to_cpu(pSMBt->t2_rsp.TotalDataCount);
279 if(total_data_size != le16_to_cpu(pSMB2->t2_rsp.TotalDataCount)) {
280 cFYI(1,("total data sizes of primary and secondary t2 differ"));
283 total_in_buf = le16_to_cpu(pSMBt->t2_rsp.DataCount);
285 remaining = total_data_size - total_in_buf;
287 if(remaining < 0)
288 return -EINVAL;
290 if(remaining == 0) /* nothing to do, ignore */
291 return 0;
293 total_in_buf2 = le16_to_cpu(pSMB2->t2_rsp.DataCount);
294 if(remaining < total_in_buf2) {
295 cFYI(1,("transact2 2nd response contains too much data"));
298 /* find end of first SMB data area */
299 data_area_of_target = (char *)&pSMBt->hdr.Protocol +
300 le16_to_cpu(pSMBt->t2_rsp.DataOffset);
301 /* validate target area */
303 data_area_of_buf2 = (char *) &pSMB2->hdr.Protocol +
304 le16_to_cpu(pSMB2->t2_rsp.DataOffset);
306 data_area_of_target += total_in_buf;
308 /* copy second buffer into end of first buffer */
309 memcpy(data_area_of_target,data_area_of_buf2,total_in_buf2);
310 total_in_buf += total_in_buf2;
311 pSMBt->t2_rsp.DataCount = cpu_to_le16(total_in_buf);
312 byte_count = le16_to_cpu(BCC_LE(pTargetSMB));
313 byte_count += total_in_buf2;
314 BCC_LE(pTargetSMB) = cpu_to_le16(byte_count);
316 byte_count = pTargetSMB->smb_buf_length;
317 byte_count += total_in_buf2;
319 /* BB also add check that we are not beyond maximum buffer size */
321 pTargetSMB->smb_buf_length = byte_count;
323 if(remaining == total_in_buf2) {
324 cFYI(1,("found the last secondary response"));
325 return 0; /* we are done */
326 } else /* more responses to go */
327 return 1;
331 static int
332 cifs_demultiplex_thread(struct TCP_Server_Info *server)
334 int length;
335 unsigned int pdu_length, total_read;
336 struct smb_hdr *smb_buffer = NULL;
337 struct smb_hdr *bigbuf = NULL;
338 struct smb_hdr *smallbuf = NULL;
339 struct msghdr smb_msg;
340 struct kvec iov;
341 struct socket *csocket = server->ssocket;
342 struct list_head *tmp;
343 struct cifsSesInfo *ses;
344 struct task_struct *task_to_wake = NULL;
345 struct mid_q_entry *mid_entry;
346 char temp;
347 int isLargeBuf = FALSE;
348 int isMultiRsp;
349 int reconnect;
351 allow_signal(SIGKILL);
352 current->flags |= PF_MEMALLOC;
353 server->tsk = current; /* save process info to wake at shutdown */
354 cFYI(1, ("Demultiplex PID: %d", current->pid));
355 write_lock(&GlobalSMBSeslock);
356 atomic_inc(&tcpSesAllocCount);
357 length = tcpSesAllocCount.counter;
358 write_unlock(&GlobalSMBSeslock);
359 complete(&cifsd_complete);
360 if(length > 1) {
361 mempool_resize(cifs_req_poolp,
362 length + cifs_min_rcv,
363 GFP_KERNEL);
366 while (!kthread_should_stop()) {
367 if (try_to_freeze())
368 continue;
369 if (bigbuf == NULL) {
370 bigbuf = cifs_buf_get();
371 if (!bigbuf) {
372 cERROR(1, ("No memory for large SMB response"));
373 msleep(3000);
374 /* retry will check if exiting */
375 continue;
377 } else if (isLargeBuf) {
378 /* we are reusing a dirty large buf, clear its start */
379 memset(bigbuf, 0, sizeof (struct smb_hdr));
382 if (smallbuf == NULL) {
383 smallbuf = cifs_small_buf_get();
384 if (!smallbuf) {
385 cERROR(1, ("No memory for SMB response"));
386 msleep(1000);
387 /* retry will check if exiting */
388 continue;
390 /* beginning of smb buffer is cleared in our buf_get */
391 } else /* if existing small buf clear beginning */
392 memset(smallbuf, 0, sizeof (struct smb_hdr));
394 isLargeBuf = FALSE;
395 isMultiRsp = FALSE;
396 smb_buffer = smallbuf;
397 iov.iov_base = smb_buffer;
398 iov.iov_len = 4;
399 smb_msg.msg_control = NULL;
400 smb_msg.msg_controllen = 0;
401 length =
402 kernel_recvmsg(csocket, &smb_msg,
403 &iov, 1, 4, 0 /* BB see socket.h flags */);
405 if ( kthread_should_stop() ) {
406 break;
407 } else if (server->tcpStatus == CifsNeedReconnect) {
408 cFYI(1, ("Reconnect after server stopped responding"));
409 cifs_reconnect(server);
410 cFYI(1, ("call to reconnect done"));
411 csocket = server->ssocket;
412 continue;
413 } else if ((length == -ERESTARTSYS) || (length == -EAGAIN)) {
414 msleep(1); /* minimum sleep to prevent looping
415 allowing socket to clear and app threads to set
416 tcpStatus CifsNeedReconnect if server hung */
417 continue;
418 } else if (length <= 0) {
419 if (server->tcpStatus == CifsNew) {
420 cFYI(1, ("tcp session abend after SMBnegprot"));
421 /* some servers kill the TCP session rather than
422 returning an SMB negprot error, in which
423 case reconnecting here is not going to help,
424 and so simply return error to mount */
425 break;
427 if (!try_to_freeze() && (length == -EINTR)) {
428 cFYI(1,("cifsd thread killed"));
429 break;
431 cFYI(1,("Reconnect after unexpected peek error %d",
432 length));
433 cifs_reconnect(server);
434 csocket = server->ssocket;
435 wake_up(&server->response_q);
436 continue;
437 } else if (length < 4) {
438 cFYI(1,
439 ("Frame under four bytes received (%d bytes long)",
440 length));
441 cifs_reconnect(server);
442 csocket = server->ssocket;
443 wake_up(&server->response_q);
444 continue;
447 /* The right amount was read from socket - 4 bytes */
448 /* so we can now interpret the length field */
450 /* the first byte big endian of the length field,
451 is actually not part of the length but the type
452 with the most common, zero, as regular data */
453 temp = *((char *) smb_buffer);
455 /* Note that FC 1001 length is big endian on the wire,
456 but we convert it here so it is always manipulated
457 as host byte order */
458 pdu_length = ntohl(smb_buffer->smb_buf_length);
459 smb_buffer->smb_buf_length = pdu_length;
461 cFYI(1,("rfc1002 length 0x%x)", pdu_length+4));
463 if (temp == (char) RFC1002_SESSION_KEEP_ALIVE) {
464 continue;
465 } else if (temp == (char)RFC1002_POSITIVE_SESSION_RESPONSE) {
466 cFYI(1,("Good RFC 1002 session rsp"));
467 continue;
468 } else if (temp == (char)RFC1002_NEGATIVE_SESSION_RESPONSE) {
469 /* we get this from Windows 98 instead of
470 an error on SMB negprot response */
471 cFYI(1,("Negative RFC1002 Session Response Error 0x%x)",
472 pdu_length));
473 if(server->tcpStatus == CifsNew) {
474 /* if nack on negprot (rather than
475 ret of smb negprot error) reconnecting
476 not going to help, ret error to mount */
477 break;
478 } else {
479 /* give server a second to
480 clean up before reconnect attempt */
481 msleep(1000);
482 /* always try 445 first on reconnect
483 since we get NACK on some if we ever
484 connected to port 139 (the NACK is
485 since we do not begin with RFC1001
486 session initialize frame) */
487 server->addr.sockAddr.sin_port =
488 htons(CIFS_PORT);
489 cifs_reconnect(server);
490 csocket = server->ssocket;
491 wake_up(&server->response_q);
492 continue;
494 } else if (temp != (char) 0) {
495 cERROR(1,("Unknown RFC 1002 frame"));
496 cifs_dump_mem(" Received Data: ", (char *)smb_buffer,
497 length);
498 cifs_reconnect(server);
499 csocket = server->ssocket;
500 continue;
503 /* else we have an SMB response */
504 if((pdu_length > CIFSMaxBufSize + MAX_CIFS_HDR_SIZE - 4) ||
505 (pdu_length < sizeof (struct smb_hdr) - 1 - 4)) {
506 cERROR(1, ("Invalid size SMB length %d pdu_length %d",
507 length, pdu_length+4));
508 cifs_reconnect(server);
509 csocket = server->ssocket;
510 wake_up(&server->response_q);
511 continue;
514 /* else length ok */
515 reconnect = 0;
517 if(pdu_length > MAX_CIFS_SMALL_BUFFER_SIZE - 4) {
518 isLargeBuf = TRUE;
519 memcpy(bigbuf, smallbuf, 4);
520 smb_buffer = bigbuf;
522 length = 0;
523 iov.iov_base = 4 + (char *)smb_buffer;
524 iov.iov_len = pdu_length;
525 for (total_read = 0; total_read < pdu_length;
526 total_read += length) {
527 length = kernel_recvmsg(csocket, &smb_msg, &iov, 1,
528 pdu_length - total_read, 0);
529 if( kthread_should_stop() ||
530 (length == -EINTR)) {
531 /* then will exit */
532 reconnect = 2;
533 break;
534 } else if (server->tcpStatus == CifsNeedReconnect) {
535 cifs_reconnect(server);
536 csocket = server->ssocket;
537 /* Reconnect wakes up rspns q */
538 /* Now we will reread sock */
539 reconnect = 1;
540 break;
541 } else if ((length == -ERESTARTSYS) ||
542 (length == -EAGAIN)) {
543 msleep(1); /* minimum sleep to prevent looping,
544 allowing socket to clear and app
545 threads to set tcpStatus
546 CifsNeedReconnect if server hung*/
547 continue;
548 } else if (length <= 0) {
549 cERROR(1,("Received no data, expecting %d",
550 pdu_length - total_read));
551 cifs_reconnect(server);
552 csocket = server->ssocket;
553 reconnect = 1;
554 break;
557 if(reconnect == 2)
558 break;
559 else if(reconnect == 1)
560 continue;
562 length += 4; /* account for rfc1002 hdr */
565 dump_smb(smb_buffer, length);
566 if (checkSMB(smb_buffer, smb_buffer->Mid, total_read+4)) {
567 cifs_dump_mem("Bad SMB: ", smb_buffer, 48);
568 continue;
572 task_to_wake = NULL;
573 spin_lock(&GlobalMid_Lock);
574 list_for_each(tmp, &server->pending_mid_q) {
575 mid_entry = list_entry(tmp, struct mid_q_entry, qhead);
577 if ((mid_entry->mid == smb_buffer->Mid) &&
578 (mid_entry->midState == MID_REQUEST_SUBMITTED) &&
579 (mid_entry->command == smb_buffer->Command)) {
580 if(check2ndT2(smb_buffer,server->maxBuf) > 0) {
581 /* We have a multipart transact2 resp */
582 isMultiRsp = TRUE;
583 if(mid_entry->resp_buf) {
584 /* merge response - fix up 1st*/
585 if(coalesce_t2(smb_buffer,
586 mid_entry->resp_buf)) {
587 mid_entry->multiRsp = 1;
588 break;
589 } else {
590 /* all parts received */
591 mid_entry->multiEnd = 1;
592 goto multi_t2_fnd;
594 } else {
595 if(!isLargeBuf) {
596 cERROR(1,("1st trans2 resp needs bigbuf"));
597 /* BB maybe we can fix this up, switch
598 to already allocated large buffer? */
599 } else {
600 /* Have first buffer */
601 mid_entry->resp_buf =
602 smb_buffer;
603 mid_entry->largeBuf = 1;
604 bigbuf = NULL;
607 break;
609 mid_entry->resp_buf = smb_buffer;
610 if(isLargeBuf)
611 mid_entry->largeBuf = 1;
612 else
613 mid_entry->largeBuf = 0;
614 multi_t2_fnd:
615 task_to_wake = mid_entry->tsk;
616 mid_entry->midState = MID_RESPONSE_RECEIVED;
617 #ifdef CONFIG_CIFS_STATS2
618 mid_entry->when_received = jiffies;
619 #endif
620 /* so we do not time out requests to server
621 which is still responding (since server could
622 be busy but not dead) */
623 server->lstrp = jiffies;
624 break;
627 spin_unlock(&GlobalMid_Lock);
628 if (task_to_wake) {
629 /* Was previous buf put in mpx struct for multi-rsp? */
630 if(!isMultiRsp) {
631 /* smb buffer will be freed by user thread */
632 if(isLargeBuf) {
633 bigbuf = NULL;
634 } else
635 smallbuf = NULL;
637 wake_up_process(task_to_wake);
638 } else if ((is_valid_oplock_break(smb_buffer, server) == FALSE)
639 && (isMultiRsp == FALSE)) {
640 cERROR(1, ("No task to wake, unknown frame rcvd! NumMids %d", midCount.counter));
641 cifs_dump_mem("Received Data is: ",(char *)smb_buffer,
642 sizeof(struct smb_hdr));
643 #ifdef CONFIG_CIFS_DEBUG2
644 cifs_dump_detail(smb_buffer);
645 cifs_dump_mids(server);
646 #endif /* CIFS_DEBUG2 */
649 } /* end while !EXITING */
651 spin_lock(&GlobalMid_Lock);
652 server->tcpStatus = CifsExiting;
653 server->tsk = NULL;
654 /* check if we have blocked requests that need to free */
655 /* Note that cifs_max_pending is normally 50, but
656 can be set at module install time to as little as two */
657 if(atomic_read(&server->inFlight) >= cifs_max_pending)
658 atomic_set(&server->inFlight, cifs_max_pending - 1);
659 /* We do not want to set the max_pending too low or we
660 could end up with the counter going negative */
661 spin_unlock(&GlobalMid_Lock);
662 /* Although there should not be any requests blocked on
663 this queue it can not hurt to be paranoid and try to wake up requests
664 that may haven been blocked when more than 50 at time were on the wire
665 to the same server - they now will see the session is in exit state
666 and get out of SendReceive. */
667 wake_up_all(&server->request_q);
668 /* give those requests time to exit */
669 msleep(125);
671 if(server->ssocket) {
672 sock_release(csocket);
673 server->ssocket = NULL;
675 /* buffer usuallly freed in free_mid - need to free it here on exit */
676 if (bigbuf != NULL)
677 cifs_buf_release(bigbuf);
678 if (smallbuf != NULL)
679 cifs_small_buf_release(smallbuf);
681 read_lock(&GlobalSMBSeslock);
682 if (list_empty(&server->pending_mid_q)) {
683 /* loop through server session structures attached to this and
684 mark them dead */
685 list_for_each(tmp, &GlobalSMBSessionList) {
686 ses =
687 list_entry(tmp, struct cifsSesInfo,
688 cifsSessionList);
689 if (ses->server == server) {
690 ses->status = CifsExiting;
691 ses->server = NULL;
694 read_unlock(&GlobalSMBSeslock);
695 } else {
696 /* although we can not zero the server struct pointer yet,
697 since there are active requests which may depnd on them,
698 mark the corresponding SMB sessions as exiting too */
699 list_for_each(tmp, &GlobalSMBSessionList) {
700 ses = list_entry(tmp, struct cifsSesInfo,
701 cifsSessionList);
702 if (ses->server == server) {
703 ses->status = CifsExiting;
707 spin_lock(&GlobalMid_Lock);
708 list_for_each(tmp, &server->pending_mid_q) {
709 mid_entry = list_entry(tmp, struct mid_q_entry, qhead);
710 if (mid_entry->midState == MID_REQUEST_SUBMITTED) {
711 cFYI(1,
712 ("Clearing Mid 0x%x - waking up ",mid_entry->mid));
713 task_to_wake = mid_entry->tsk;
714 if(task_to_wake) {
715 wake_up_process(task_to_wake);
719 spin_unlock(&GlobalMid_Lock);
720 read_unlock(&GlobalSMBSeslock);
721 /* 1/8th of sec is more than enough time for them to exit */
722 msleep(125);
725 if (!list_empty(&server->pending_mid_q)) {
726 /* mpx threads have not exited yet give them
727 at least the smb send timeout time for long ops */
728 /* due to delays on oplock break requests, we need
729 to wait at least 45 seconds before giving up
730 on a request getting a response and going ahead
731 and killing cifsd */
732 cFYI(1, ("Wait for exit from demultiplex thread"));
733 msleep(46000);
734 /* if threads still have not exited they are probably never
735 coming home not much else we can do but free the memory */
738 write_lock(&GlobalSMBSeslock);
739 atomic_dec(&tcpSesAllocCount);
740 length = tcpSesAllocCount.counter;
742 /* last chance to mark ses pointers invalid
743 if there are any pointing to this (e.g
744 if a crazy root user tried to kill cifsd
745 kernel thread explicitly this might happen) */
746 list_for_each(tmp, &GlobalSMBSessionList) {
747 ses = list_entry(tmp, struct cifsSesInfo,
748 cifsSessionList);
749 if (ses->server == server) {
750 ses->server = NULL;
753 write_unlock(&GlobalSMBSeslock);
755 kfree(server);
756 if(length > 0) {
757 mempool_resize(cifs_req_poolp,
758 length + cifs_min_rcv,
759 GFP_KERNEL);
762 return 0;
765 static int
766 cifs_parse_mount_options(char *options, const char *devname,struct smb_vol *vol)
768 char *value;
769 char *data;
770 unsigned int temp_len, i, j;
771 char separator[2];
773 separator[0] = ',';
774 separator[1] = 0;
776 if (Local_System_Name[0] != 0)
777 memcpy(vol->source_rfc1001_name, Local_System_Name,15);
778 else {
779 char *nodename = utsname()->nodename;
780 int n = strnlen(nodename,15);
781 memset(vol->source_rfc1001_name,0x20,15);
782 for(i=0 ; i < n ; i++) {
783 /* does not have to be perfect mapping since field is
784 informational, only used for servers that do not support
785 port 445 and it can be overridden at mount time */
786 vol->source_rfc1001_name[i] = toupper(nodename[i]);
789 vol->source_rfc1001_name[15] = 0;
790 /* null target name indicates to use *SMBSERVR default called name
791 if we end up sending RFC1001 session initialize */
792 vol->target_rfc1001_name[0] = 0;
793 vol->linux_uid = current->uid; /* current->euid instead? */
794 vol->linux_gid = current->gid;
795 vol->dir_mode = S_IRWXUGO;
796 /* 2767 perms indicate mandatory locking support */
797 vol->file_mode = S_IALLUGO & ~(S_ISUID | S_IXGRP);
799 /* vol->retry default is 0 (i.e. "soft" limited retry not hard retry) */
800 vol->rw = TRUE;
801 /* default is always to request posix paths. */
802 vol->posix_paths = 1;
804 if (!options)
805 return 1;
807 if(strncmp(options,"sep=",4) == 0) {
808 if(options[4] != 0) {
809 separator[0] = options[4];
810 options += 5;
811 } else {
812 cFYI(1,("Null separator not allowed"));
816 while ((data = strsep(&options, separator)) != NULL) {
817 if (!*data)
818 continue;
819 if ((value = strchr(data, '=')) != NULL)
820 *value++ = '\0';
822 if (strnicmp(data, "user_xattr",10) == 0) {/*parse before user*/
823 vol->no_xattr = 0;
824 } else if (strnicmp(data, "nouser_xattr",12) == 0) {
825 vol->no_xattr = 1;
826 } else if (strnicmp(data, "user", 4) == 0) {
827 if (!value) {
828 printk(KERN_WARNING
829 "CIFS: invalid or missing username\n");
830 return 1; /* needs_arg; */
831 } else if(!*value) {
832 /* null user, ie anonymous, authentication */
833 vol->nullauth = 1;
835 if (strnlen(value, 200) < 200) {
836 vol->username = value;
837 } else {
838 printk(KERN_WARNING "CIFS: username too long\n");
839 return 1;
841 } else if (strnicmp(data, "pass", 4) == 0) {
842 if (!value) {
843 vol->password = NULL;
844 continue;
845 } else if(value[0] == 0) {
846 /* check if string begins with double comma
847 since that would mean the password really
848 does start with a comma, and would not
849 indicate an empty string */
850 if(value[1] != separator[0]) {
851 vol->password = NULL;
852 continue;
855 temp_len = strlen(value);
856 /* removed password length check, NTLM passwords
857 can be arbitrarily long */
859 /* if comma in password, the string will be
860 prematurely null terminated. Commas in password are
861 specified across the cifs mount interface by a double
862 comma ie ,, and a comma used as in other cases ie ','
863 as a parameter delimiter/separator is single and due
864 to the strsep above is temporarily zeroed. */
866 /* NB: password legally can have multiple commas and
867 the only illegal character in a password is null */
869 if ((value[temp_len] == 0) &&
870 (value[temp_len+1] == separator[0])) {
871 /* reinsert comma */
872 value[temp_len] = separator[0];
873 temp_len+=2; /* move after the second comma */
874 while(value[temp_len] != 0) {
875 if (value[temp_len] == separator[0]) {
876 if (value[temp_len+1] ==
877 separator[0]) {
878 /* skip second comma */
879 temp_len++;
880 } else {
881 /* single comma indicating start
882 of next parm */
883 break;
886 temp_len++;
888 if(value[temp_len] == 0) {
889 options = NULL;
890 } else {
891 value[temp_len] = 0;
892 /* point option to start of next parm */
893 options = value + temp_len + 1;
895 /* go from value to value + temp_len condensing
896 double commas to singles. Note that this ends up
897 allocating a few bytes too many, which is ok */
898 vol->password = kzalloc(temp_len, GFP_KERNEL);
899 if(vol->password == NULL) {
900 printk("CIFS: no memory for pass\n");
901 return 1;
903 for(i=0,j=0;i<temp_len;i++,j++) {
904 vol->password[j] = value[i];
905 if(value[i] == separator[0]
906 && value[i+1] == separator[0]) {
907 /* skip second comma */
908 i++;
911 vol->password[j] = 0;
912 } else {
913 vol->password = kzalloc(temp_len+1, GFP_KERNEL);
914 if(vol->password == NULL) {
915 printk("CIFS: no memory for pass\n");
916 return 1;
918 strcpy(vol->password, value);
920 } else if (strnicmp(data, "ip", 2) == 0) {
921 if (!value || !*value) {
922 vol->UNCip = NULL;
923 } else if (strnlen(value, 35) < 35) {
924 vol->UNCip = value;
925 } else {
926 printk(KERN_WARNING "CIFS: ip address too long\n");
927 return 1;
929 } else if (strnicmp(data, "sec", 3) == 0) {
930 if (!value || !*value) {
931 cERROR(1,("no security value specified"));
932 continue;
933 } else if (strnicmp(value, "krb5i", 5) == 0) {
934 vol->secFlg |= CIFSSEC_MAY_KRB5 |
935 CIFSSEC_MUST_SIGN;
936 } else if (strnicmp(value, "krb5p", 5) == 0) {
937 /* vol->secFlg |= CIFSSEC_MUST_SEAL |
938 CIFSSEC_MAY_KRB5; */
939 cERROR(1,("Krb5 cifs privacy not supported"));
940 return 1;
941 } else if (strnicmp(value, "krb5", 4) == 0) {
942 vol->secFlg |= CIFSSEC_MAY_KRB5;
943 } else if (strnicmp(value, "ntlmv2i", 7) == 0) {
944 vol->secFlg |= CIFSSEC_MAY_NTLMV2 |
945 CIFSSEC_MUST_SIGN;
946 } else if (strnicmp(value, "ntlmv2", 6) == 0) {
947 vol->secFlg |= CIFSSEC_MAY_NTLMV2;
948 } else if (strnicmp(value, "ntlmi", 5) == 0) {
949 vol->secFlg |= CIFSSEC_MAY_NTLM |
950 CIFSSEC_MUST_SIGN;
951 } else if (strnicmp(value, "ntlm", 4) == 0) {
952 /* ntlm is default so can be turned off too */
953 vol->secFlg |= CIFSSEC_MAY_NTLM;
954 } else if (strnicmp(value, "nontlm", 6) == 0) {
955 /* BB is there a better way to do this? */
956 vol->secFlg |= CIFSSEC_MAY_NTLMV2;
957 #ifdef CONFIG_CIFS_WEAK_PW_HASH
958 } else if (strnicmp(value, "lanman", 6) == 0) {
959 vol->secFlg |= CIFSSEC_MAY_LANMAN;
960 #endif
961 } else if (strnicmp(value, "none", 4) == 0) {
962 vol->nullauth = 1;
963 } else {
964 cERROR(1,("bad security option: %s", value));
965 return 1;
967 } else if ((strnicmp(data, "unc", 3) == 0)
968 || (strnicmp(data, "target", 6) == 0)
969 || (strnicmp(data, "path", 4) == 0)) {
970 if (!value || !*value) {
971 printk(KERN_WARNING
972 "CIFS: invalid path to network resource\n");
973 return 1; /* needs_arg; */
975 if ((temp_len = strnlen(value, 300)) < 300) {
976 vol->UNC = kmalloc(temp_len+1,GFP_KERNEL);
977 if (vol->UNC == NULL)
978 return 1;
979 strcpy(vol->UNC,value);
980 if (strncmp(vol->UNC, "//", 2) == 0) {
981 vol->UNC[0] = '\\';
982 vol->UNC[1] = '\\';
983 } else if (strncmp(vol->UNC, "\\\\", 2) != 0) {
984 printk(KERN_WARNING
985 "CIFS: UNC Path does not begin with // or \\\\ \n");
986 return 1;
988 } else {
989 printk(KERN_WARNING "CIFS: UNC name too long\n");
990 return 1;
992 } else if ((strnicmp(data, "domain", 3) == 0)
993 || (strnicmp(data, "workgroup", 5) == 0)) {
994 if (!value || !*value) {
995 printk(KERN_WARNING "CIFS: invalid domain name\n");
996 return 1; /* needs_arg; */
998 /* BB are there cases in which a comma can be valid in
999 a domain name and need special handling? */
1000 if (strnlen(value, 256) < 256) {
1001 vol->domainname = value;
1002 cFYI(1, ("Domain name set"));
1003 } else {
1004 printk(KERN_WARNING "CIFS: domain name too long\n");
1005 return 1;
1007 } else if (strnicmp(data, "prefixpath", 10) == 0) {
1008 if (!value || !*value) {
1009 printk(KERN_WARNING
1010 "CIFS: invalid path prefix\n");
1011 return 1; /* needs_arg; */
1013 if ((temp_len = strnlen(value, 1024)) < 1024) {
1014 if (value[0] != '/')
1015 temp_len++; /* missing leading slash */
1016 vol->prepath = kmalloc(temp_len+1,GFP_KERNEL);
1017 if (vol->prepath == NULL)
1018 return 1;
1019 if (value[0] != '/') {
1020 vol->prepath[0] = '/';
1021 strcpy(vol->prepath+1,value);
1022 } else
1023 strcpy(vol->prepath,value);
1024 cFYI(1,("prefix path %s",vol->prepath));
1025 } else {
1026 printk(KERN_WARNING "CIFS: prefix too long\n");
1027 return 1;
1029 } else if (strnicmp(data, "iocharset", 9) == 0) {
1030 if (!value || !*value) {
1031 printk(KERN_WARNING "CIFS: invalid iocharset specified\n");
1032 return 1; /* needs_arg; */
1034 if (strnlen(value, 65) < 65) {
1035 if (strnicmp(value,"default",7))
1036 vol->iocharset = value;
1037 /* if iocharset not set load_nls_default used by caller */
1038 cFYI(1, ("iocharset set to %s",value));
1039 } else {
1040 printk(KERN_WARNING "CIFS: iocharset name too long.\n");
1041 return 1;
1043 } else if (strnicmp(data, "uid", 3) == 0) {
1044 if (value && *value) {
1045 vol->linux_uid =
1046 simple_strtoul(value, &value, 0);
1047 vol->override_uid = 1;
1049 } else if (strnicmp(data, "gid", 3) == 0) {
1050 if (value && *value) {
1051 vol->linux_gid =
1052 simple_strtoul(value, &value, 0);
1053 vol->override_gid = 1;
1055 } else if (strnicmp(data, "file_mode", 4) == 0) {
1056 if (value && *value) {
1057 vol->file_mode =
1058 simple_strtoul(value, &value, 0);
1060 } else if (strnicmp(data, "dir_mode", 4) == 0) {
1061 if (value && *value) {
1062 vol->dir_mode =
1063 simple_strtoul(value, &value, 0);
1065 } else if (strnicmp(data, "dirmode", 4) == 0) {
1066 if (value && *value) {
1067 vol->dir_mode =
1068 simple_strtoul(value, &value, 0);
1070 } else if (strnicmp(data, "port", 4) == 0) {
1071 if (value && *value) {
1072 vol->port =
1073 simple_strtoul(value, &value, 0);
1075 } else if (strnicmp(data, "rsize", 5) == 0) {
1076 if (value && *value) {
1077 vol->rsize =
1078 simple_strtoul(value, &value, 0);
1080 } else if (strnicmp(data, "wsize", 5) == 0) {
1081 if (value && *value) {
1082 vol->wsize =
1083 simple_strtoul(value, &value, 0);
1085 } else if (strnicmp(data, "sockopt", 5) == 0) {
1086 if (value && *value) {
1087 vol->sockopt =
1088 simple_strtoul(value, &value, 0);
1090 } else if (strnicmp(data, "netbiosname", 4) == 0) {
1091 if (!value || !*value || (*value == ' ')) {
1092 cFYI(1,("invalid (empty) netbiosname specified"));
1093 } else {
1094 memset(vol->source_rfc1001_name,0x20,15);
1095 for(i=0;i<15;i++) {
1096 /* BB are there cases in which a comma can be
1097 valid in this workstation netbios name (and need
1098 special handling)? */
1100 /* We do not uppercase netbiosname for user */
1101 if (value[i]==0)
1102 break;
1103 else
1104 vol->source_rfc1001_name[i] = value[i];
1106 /* The string has 16th byte zero still from
1107 set at top of the function */
1108 if ((i==15) && (value[i] != 0))
1109 printk(KERN_WARNING "CIFS: netbiosname longer than 15 truncated.\n");
1111 } else if (strnicmp(data, "servern", 7) == 0) {
1112 /* servernetbiosname specified override *SMBSERVER */
1113 if (!value || !*value || (*value == ' ')) {
1114 cFYI(1,("empty server netbiosname specified"));
1115 } else {
1116 /* last byte, type, is 0x20 for servr type */
1117 memset(vol->target_rfc1001_name,0x20,16);
1119 for(i=0;i<15;i++) {
1120 /* BB are there cases in which a comma can be
1121 valid in this workstation netbios name (and need
1122 special handling)? */
1124 /* user or mount helper must uppercase netbiosname */
1125 if (value[i]==0)
1126 break;
1127 else
1128 vol->target_rfc1001_name[i] = value[i];
1130 /* The string has 16th byte zero still from
1131 set at top of the function */
1132 if ((i==15) && (value[i] != 0))
1133 printk(KERN_WARNING "CIFS: server netbiosname longer than 15 truncated.\n");
1135 } else if (strnicmp(data, "credentials", 4) == 0) {
1136 /* ignore */
1137 } else if (strnicmp(data, "version", 3) == 0) {
1138 /* ignore */
1139 } else if (strnicmp(data, "guest",5) == 0) {
1140 /* ignore */
1141 } else if (strnicmp(data, "rw", 2) == 0) {
1142 vol->rw = TRUE;
1143 } else if ((strnicmp(data, "suid", 4) == 0) ||
1144 (strnicmp(data, "nosuid", 6) == 0) ||
1145 (strnicmp(data, "exec", 4) == 0) ||
1146 (strnicmp(data, "noexec", 6) == 0) ||
1147 (strnicmp(data, "nodev", 5) == 0) ||
1148 (strnicmp(data, "noauto", 6) == 0) ||
1149 (strnicmp(data, "dev", 3) == 0)) {
1150 /* The mount tool or mount.cifs helper (if present)
1151 uses these opts to set flags, and the flags are read
1152 by the kernel vfs layer before we get here (ie
1153 before read super) so there is no point trying to
1154 parse these options again and set anything and it
1155 is ok to just ignore them */
1156 continue;
1157 } else if (strnicmp(data, "ro", 2) == 0) {
1158 vol->rw = FALSE;
1159 } else if (strnicmp(data, "hard", 4) == 0) {
1160 vol->retry = 1;
1161 } else if (strnicmp(data, "soft", 4) == 0) {
1162 vol->retry = 0;
1163 } else if (strnicmp(data, "perm", 4) == 0) {
1164 vol->noperm = 0;
1165 } else if (strnicmp(data, "noperm", 6) == 0) {
1166 vol->noperm = 1;
1167 } else if (strnicmp(data, "mapchars", 8) == 0) {
1168 vol->remap = 1;
1169 } else if (strnicmp(data, "nomapchars", 10) == 0) {
1170 vol->remap = 0;
1171 } else if (strnicmp(data, "sfu", 3) == 0) {
1172 vol->sfu_emul = 1;
1173 } else if (strnicmp(data, "nosfu", 5) == 0) {
1174 vol->sfu_emul = 0;
1175 } else if (strnicmp(data, "posixpaths", 10) == 0) {
1176 vol->posix_paths = 1;
1177 } else if (strnicmp(data, "noposixpaths", 12) == 0) {
1178 vol->posix_paths = 0;
1179 } else if ((strnicmp(data, "nocase", 6) == 0) ||
1180 (strnicmp(data, "ignorecase", 10) == 0)) {
1181 vol->nocase = 1;
1182 } else if (strnicmp(data, "brl", 3) == 0) {
1183 vol->nobrl = 0;
1184 } else if ((strnicmp(data, "nobrl", 5) == 0) ||
1185 (strnicmp(data, "nolock", 6) == 0)) {
1186 vol->nobrl = 1;
1187 /* turn off mandatory locking in mode
1188 if remote locking is turned off since the
1189 local vfs will do advisory */
1190 if(vol->file_mode == (S_IALLUGO & ~(S_ISUID | S_IXGRP)))
1191 vol->file_mode = S_IALLUGO;
1192 } else if (strnicmp(data, "setuids", 7) == 0) {
1193 vol->setuids = 1;
1194 } else if (strnicmp(data, "nosetuids", 9) == 0) {
1195 vol->setuids = 0;
1196 } else if (strnicmp(data, "nohard", 6) == 0) {
1197 vol->retry = 0;
1198 } else if (strnicmp(data, "nosoft", 6) == 0) {
1199 vol->retry = 1;
1200 } else if (strnicmp(data, "nointr", 6) == 0) {
1201 vol->intr = 0;
1202 } else if (strnicmp(data, "intr", 4) == 0) {
1203 vol->intr = 1;
1204 } else if (strnicmp(data, "serverino",7) == 0) {
1205 vol->server_ino = 1;
1206 } else if (strnicmp(data, "noserverino",9) == 0) {
1207 vol->server_ino = 0;
1208 } else if (strnicmp(data, "cifsacl",7) == 0) {
1209 vol->cifs_acl = 1;
1210 } else if (strnicmp(data, "nocifsacl", 9) == 0) {
1211 vol->cifs_acl = 0;
1212 } else if (strnicmp(data, "acl",3) == 0) {
1213 vol->no_psx_acl = 0;
1214 } else if (strnicmp(data, "noacl",5) == 0) {
1215 vol->no_psx_acl = 1;
1216 } else if (strnicmp(data, "sign",4) == 0) {
1217 vol->secFlg |= CIFSSEC_MUST_SIGN;
1218 /* } else if (strnicmp(data, "seal",4) == 0) {
1219 vol->secFlg |= CIFSSEC_MUST_SEAL; */
1220 } else if (strnicmp(data, "direct",6) == 0) {
1221 vol->direct_io = 1;
1222 } else if (strnicmp(data, "forcedirectio",13) == 0) {
1223 vol->direct_io = 1;
1224 } else if (strnicmp(data, "in6_addr",8) == 0) {
1225 if (!value || !*value) {
1226 vol->in6_addr = NULL;
1227 } else if (strnlen(value, 49) == 48) {
1228 vol->in6_addr = value;
1229 } else {
1230 printk(KERN_WARNING "CIFS: ip v6 address not 48 characters long\n");
1231 return 1;
1233 } else if (strnicmp(data, "noac", 4) == 0) {
1234 printk(KERN_WARNING "CIFS: Mount option noac not supported. Instead set /proc/fs/cifs/LookupCacheEnabled to 0\n");
1235 } else
1236 printk(KERN_WARNING "CIFS: Unknown mount option %s\n",data);
1238 if (vol->UNC == NULL) {
1239 if (devname == NULL) {
1240 printk(KERN_WARNING "CIFS: Missing UNC name for mount target\n");
1241 return 1;
1243 if ((temp_len = strnlen(devname, 300)) < 300) {
1244 vol->UNC = kmalloc(temp_len+1,GFP_KERNEL);
1245 if (vol->UNC == NULL)
1246 return 1;
1247 strcpy(vol->UNC,devname);
1248 if (strncmp(vol->UNC, "//", 2) == 0) {
1249 vol->UNC[0] = '\\';
1250 vol->UNC[1] = '\\';
1251 } else if (strncmp(vol->UNC, "\\\\", 2) != 0) {
1252 printk(KERN_WARNING "CIFS: UNC Path does not begin with // or \\\\ \n");
1253 return 1;
1255 } else {
1256 printk(KERN_WARNING "CIFS: UNC name too long\n");
1257 return 1;
1260 if(vol->UNCip == NULL)
1261 vol->UNCip = &vol->UNC[2];
1263 return 0;
1266 static struct cifsSesInfo *
1267 cifs_find_tcp_session(struct in_addr * target_ip_addr,
1268 struct in6_addr *target_ip6_addr,
1269 char *userName, struct TCP_Server_Info **psrvTcp)
1271 struct list_head *tmp;
1272 struct cifsSesInfo *ses;
1273 *psrvTcp = NULL;
1274 read_lock(&GlobalSMBSeslock);
1276 list_for_each(tmp, &GlobalSMBSessionList) {
1277 ses = list_entry(tmp, struct cifsSesInfo, cifsSessionList);
1278 if (ses->server) {
1279 if((target_ip_addr &&
1280 (ses->server->addr.sockAddr.sin_addr.s_addr
1281 == target_ip_addr->s_addr)) || (target_ip6_addr
1282 && memcmp(&ses->server->addr.sockAddr6.sin6_addr,
1283 target_ip6_addr,sizeof(*target_ip6_addr)))){
1284 /* BB lock server and tcp session and increment use count here?? */
1285 *psrvTcp = ses->server; /* found a match on the TCP session */
1286 /* BB check if reconnection needed */
1287 if (strncmp
1288 (ses->userName, userName,
1289 MAX_USERNAME_SIZE) == 0){
1290 read_unlock(&GlobalSMBSeslock);
1291 return ses; /* found exact match on both tcp and SMB sessions */
1295 /* else tcp and smb sessions need reconnection */
1297 read_unlock(&GlobalSMBSeslock);
1298 return NULL;
1301 static struct cifsTconInfo *
1302 find_unc(__be32 new_target_ip_addr, char *uncName, char *userName)
1304 struct list_head *tmp;
1305 struct cifsTconInfo *tcon;
1307 read_lock(&GlobalSMBSeslock);
1308 list_for_each(tmp, &GlobalTreeConnectionList) {
1309 cFYI(1, ("Next tcon"));
1310 tcon = list_entry(tmp, struct cifsTconInfo, cifsConnectionList);
1311 if (tcon->ses) {
1312 if (tcon->ses->server) {
1313 cFYI(1,
1314 ("old ip addr: %x == new ip %x ?",
1315 tcon->ses->server->addr.sockAddr.sin_addr.
1316 s_addr, new_target_ip_addr));
1317 if (tcon->ses->server->addr.sockAddr.sin_addr.
1318 s_addr == new_target_ip_addr) {
1319 /* BB lock tcon, server and tcp session and increment use count here? */
1320 /* found a match on the TCP session */
1321 /* BB check if reconnection needed */
1322 cFYI(1,("IP match, old UNC: %s new: %s",
1323 tcon->treeName, uncName));
1324 if (strncmp
1325 (tcon->treeName, uncName,
1326 MAX_TREE_SIZE) == 0) {
1327 cFYI(1,
1328 ("and old usr: %s new: %s",
1329 tcon->treeName, uncName));
1330 if (strncmp
1331 (tcon->ses->userName,
1332 userName,
1333 MAX_USERNAME_SIZE) == 0) {
1334 read_unlock(&GlobalSMBSeslock);
1335 /* matched smb session
1336 (user name */
1337 return tcon;
1344 read_unlock(&GlobalSMBSeslock);
1345 return NULL;
1349 connect_to_dfs_path(int xid, struct cifsSesInfo *pSesInfo,
1350 const char *old_path, const struct nls_table *nls_codepage,
1351 int remap)
1353 unsigned char *referrals = NULL;
1354 unsigned int num_referrals;
1355 int rc = 0;
1357 rc = get_dfs_path(xid, pSesInfo,old_path, nls_codepage,
1358 &num_referrals, &referrals, remap);
1360 /* BB Add in code to: if valid refrl, if not ip address contact
1361 the helper that resolves tcp names, mount to it, try to
1362 tcon to it unmount it if fail */
1364 kfree(referrals);
1366 return rc;
1370 get_dfs_path(int xid, struct cifsSesInfo *pSesInfo,
1371 const char *old_path, const struct nls_table *nls_codepage,
1372 unsigned int *pnum_referrals,
1373 unsigned char ** preferrals, int remap)
1375 char *temp_unc;
1376 int rc = 0;
1378 *pnum_referrals = 0;
1380 if (pSesInfo->ipc_tid == 0) {
1381 temp_unc = kmalloc(2 /* for slashes */ +
1382 strnlen(pSesInfo->serverName,SERVER_NAME_LEN_WITH_NULL * 2)
1383 + 1 + 4 /* slash IPC$ */ + 2,
1384 GFP_KERNEL);
1385 if (temp_unc == NULL)
1386 return -ENOMEM;
1387 temp_unc[0] = '\\';
1388 temp_unc[1] = '\\';
1389 strcpy(temp_unc + 2, pSesInfo->serverName);
1390 strcpy(temp_unc + 2 + strlen(pSesInfo->serverName), "\\IPC$");
1391 rc = CIFSTCon(xid, pSesInfo, temp_unc, NULL, nls_codepage);
1392 cFYI(1,
1393 ("CIFS Tcon rc = %d ipc_tid = %d", rc,pSesInfo->ipc_tid));
1394 kfree(temp_unc);
1396 if (rc == 0)
1397 rc = CIFSGetDFSRefer(xid, pSesInfo, old_path, preferrals,
1398 pnum_referrals, nls_codepage, remap);
1400 return rc;
1403 /* See RFC1001 section 14 on representation of Netbios names */
1404 static void rfc1002mangle(char * target,char * source, unsigned int length)
1406 unsigned int i,j;
1408 for(i=0,j=0;i<(length);i++) {
1409 /* mask a nibble at a time and encode */
1410 target[j] = 'A' + (0x0F & (source[i] >> 4));
1411 target[j+1] = 'A' + (0x0F & source[i]);
1412 j+=2;
1418 static int
1419 ipv4_connect(struct sockaddr_in *psin_server, struct socket **csocket,
1420 char * netbios_name, char * target_name)
1422 int rc = 0;
1423 int connected = 0;
1424 __be16 orig_port = 0;
1426 if(*csocket == NULL) {
1427 rc = sock_create_kern(PF_INET, SOCK_STREAM, IPPROTO_TCP, csocket);
1428 if (rc < 0) {
1429 cERROR(1, ("Error %d creating socket",rc));
1430 *csocket = NULL;
1431 return rc;
1432 } else {
1433 /* BB other socket options to set KEEPALIVE, NODELAY? */
1434 cFYI(1,("Socket created"));
1435 (*csocket)->sk->sk_allocation = GFP_NOFS;
1439 psin_server->sin_family = AF_INET;
1440 if(psin_server->sin_port) { /* user overrode default port */
1441 rc = (*csocket)->ops->connect(*csocket,
1442 (struct sockaddr *) psin_server,
1443 sizeof (struct sockaddr_in),0);
1444 if (rc >= 0)
1445 connected = 1;
1448 if(!connected) {
1449 /* save original port so we can retry user specified port
1450 later if fall back ports fail this time */
1451 orig_port = psin_server->sin_port;
1453 /* do not retry on the same port we just failed on */
1454 if(psin_server->sin_port != htons(CIFS_PORT)) {
1455 psin_server->sin_port = htons(CIFS_PORT);
1457 rc = (*csocket)->ops->connect(*csocket,
1458 (struct sockaddr *) psin_server,
1459 sizeof (struct sockaddr_in),0);
1460 if (rc >= 0)
1461 connected = 1;
1464 if (!connected) {
1465 psin_server->sin_port = htons(RFC1001_PORT);
1466 rc = (*csocket)->ops->connect(*csocket, (struct sockaddr *)
1467 psin_server, sizeof (struct sockaddr_in),0);
1468 if (rc >= 0)
1469 connected = 1;
1472 /* give up here - unless we want to retry on different
1473 protocol families some day */
1474 if (!connected) {
1475 if(orig_port)
1476 psin_server->sin_port = orig_port;
1477 cFYI(1,("Error %d connecting to server via ipv4",rc));
1478 sock_release(*csocket);
1479 *csocket = NULL;
1480 return rc;
1482 /* Eventually check for other socket options to change from
1483 the default. sock_setsockopt not used because it expects
1484 user space buffer */
1485 cFYI(1,("sndbuf %d rcvbuf %d rcvtimeo 0x%lx",(*csocket)->sk->sk_sndbuf,
1486 (*csocket)->sk->sk_rcvbuf, (*csocket)->sk->sk_rcvtimeo));
1487 (*csocket)->sk->sk_rcvtimeo = 7 * HZ;
1488 /* make the bufsizes depend on wsize/rsize and max requests */
1489 if((*csocket)->sk->sk_sndbuf < (200 * 1024))
1490 (*csocket)->sk->sk_sndbuf = 200 * 1024;
1491 if((*csocket)->sk->sk_rcvbuf < (140 * 1024))
1492 (*csocket)->sk->sk_rcvbuf = 140 * 1024;
1494 /* send RFC1001 sessinit */
1495 if(psin_server->sin_port == htons(RFC1001_PORT)) {
1496 /* some servers require RFC1001 sessinit before sending
1497 negprot - BB check reconnection in case where second
1498 sessinit is sent but no second negprot */
1499 struct rfc1002_session_packet * ses_init_buf;
1500 struct smb_hdr * smb_buf;
1501 ses_init_buf = kzalloc(sizeof(struct rfc1002_session_packet), GFP_KERNEL);
1502 if(ses_init_buf) {
1503 ses_init_buf->trailer.session_req.called_len = 32;
1504 if(target_name && (target_name[0] != 0)) {
1505 rfc1002mangle(ses_init_buf->trailer.session_req.called_name,
1506 target_name, 16);
1507 } else {
1508 rfc1002mangle(ses_init_buf->trailer.session_req.called_name,
1509 DEFAULT_CIFS_CALLED_NAME,16);
1512 ses_init_buf->trailer.session_req.calling_len = 32;
1513 /* calling name ends in null (byte 16) from old smb
1514 convention. */
1515 if(netbios_name && (netbios_name[0] !=0)) {
1516 rfc1002mangle(ses_init_buf->trailer.session_req.calling_name,
1517 netbios_name,16);
1518 } else {
1519 rfc1002mangle(ses_init_buf->trailer.session_req.calling_name,
1520 "LINUX_CIFS_CLNT",16);
1522 ses_init_buf->trailer.session_req.scope1 = 0;
1523 ses_init_buf->trailer.session_req.scope2 = 0;
1524 smb_buf = (struct smb_hdr *)ses_init_buf;
1525 /* sizeof RFC1002_SESSION_REQUEST with no scope */
1526 smb_buf->smb_buf_length = 0x81000044;
1527 rc = smb_send(*csocket, smb_buf, 0x44,
1528 (struct sockaddr *)psin_server);
1529 kfree(ses_init_buf);
1530 msleep(1); /* RFC1001 layer in at least one server
1531 requires very short break before negprot
1532 presumably because not expecting negprot
1533 to follow so fast. This is a simple
1534 solution that works without
1535 complicating the code and causes no
1536 significant slowing down on mount
1537 for everyone else */
1539 /* else the negprot may still work without this
1540 even though malloc failed */
1544 return rc;
1547 static int
1548 ipv6_connect(struct sockaddr_in6 *psin_server, struct socket **csocket)
1550 int rc = 0;
1551 int connected = 0;
1552 __be16 orig_port = 0;
1554 if(*csocket == NULL) {
1555 rc = sock_create_kern(PF_INET6, SOCK_STREAM, IPPROTO_TCP, csocket);
1556 if (rc < 0) {
1557 cERROR(1, ("Error %d creating ipv6 socket",rc));
1558 *csocket = NULL;
1559 return rc;
1560 } else {
1561 /* BB other socket options to set KEEPALIVE, NODELAY? */
1562 cFYI(1,("ipv6 Socket created"));
1563 (*csocket)->sk->sk_allocation = GFP_NOFS;
1567 psin_server->sin6_family = AF_INET6;
1569 if(psin_server->sin6_port) { /* user overrode default port */
1570 rc = (*csocket)->ops->connect(*csocket,
1571 (struct sockaddr *) psin_server,
1572 sizeof (struct sockaddr_in6),0);
1573 if (rc >= 0)
1574 connected = 1;
1577 if(!connected) {
1578 /* save original port so we can retry user specified port
1579 later if fall back ports fail this time */
1581 orig_port = psin_server->sin6_port;
1582 /* do not retry on the same port we just failed on */
1583 if(psin_server->sin6_port != htons(CIFS_PORT)) {
1584 psin_server->sin6_port = htons(CIFS_PORT);
1586 rc = (*csocket)->ops->connect(*csocket,
1587 (struct sockaddr *) psin_server,
1588 sizeof (struct sockaddr_in6),0);
1589 if (rc >= 0)
1590 connected = 1;
1593 if (!connected) {
1594 psin_server->sin6_port = htons(RFC1001_PORT);
1595 rc = (*csocket)->ops->connect(*csocket, (struct sockaddr *)
1596 psin_server, sizeof (struct sockaddr_in6),0);
1597 if (rc >= 0)
1598 connected = 1;
1601 /* give up here - unless we want to retry on different
1602 protocol families some day */
1603 if (!connected) {
1604 if(orig_port)
1605 psin_server->sin6_port = orig_port;
1606 cFYI(1,("Error %d connecting to server via ipv6",rc));
1607 sock_release(*csocket);
1608 *csocket = NULL;
1609 return rc;
1611 /* Eventually check for other socket options to change from
1612 the default. sock_setsockopt not used because it expects
1613 user space buffer */
1614 (*csocket)->sk->sk_rcvtimeo = 7 * HZ;
1616 return rc;
1619 void reset_cifs_unix_caps(int xid, struct cifsTconInfo * tcon,
1620 struct super_block * sb, struct smb_vol * vol_info)
1622 /* if we are reconnecting then should we check to see if
1623 * any requested capabilities changed locally e.g. via
1624 * remount but we can not do much about it here
1625 * if they have (even if we could detect it by the following)
1626 * Perhaps we could add a backpointer to array of sb from tcon
1627 * or if we change to make all sb to same share the same
1628 * sb as NFS - then we only have one backpointer to sb.
1629 * What if we wanted to mount the server share twice once with
1630 * and once without posixacls or posix paths? */
1631 __u64 saved_cap = le64_to_cpu(tcon->fsUnixInfo.Capability);
1634 if(!CIFSSMBQFSUnixInfo(xid, tcon)) {
1635 __u64 cap = le64_to_cpu(tcon->fsUnixInfo.Capability);
1637 /* check for reconnect case in which we do not
1638 want to change the mount behavior if we can avoid it */
1639 if(vol_info == NULL) {
1640 /* turn off POSIX ACL and PATHNAMES if not set
1641 originally at mount time */
1642 if ((saved_cap & CIFS_UNIX_POSIX_ACL_CAP) == 0)
1643 cap &= ~CIFS_UNIX_POSIX_ACL_CAP;
1644 if ((saved_cap & CIFS_UNIX_POSIX_PATHNAMES_CAP) == 0)
1645 cap &= ~CIFS_UNIX_POSIX_PATHNAMES_CAP;
1652 cap &= CIFS_UNIX_CAP_MASK;
1653 if(vol_info && vol_info->no_psx_acl)
1654 cap &= ~CIFS_UNIX_POSIX_ACL_CAP;
1655 else if(CIFS_UNIX_POSIX_ACL_CAP & cap) {
1656 cFYI(1,("negotiated posix acl support"));
1657 if(sb)
1658 sb->s_flags |= MS_POSIXACL;
1661 if(vol_info && vol_info->posix_paths == 0)
1662 cap &= ~CIFS_UNIX_POSIX_PATHNAMES_CAP;
1663 else if(cap & CIFS_UNIX_POSIX_PATHNAMES_CAP) {
1664 cFYI(1,("negotiate posix pathnames"));
1665 if(sb)
1666 CIFS_SB(sb)->mnt_cifs_flags |=
1667 CIFS_MOUNT_POSIX_PATHS;
1670 /* We might be setting the path sep back to a different
1671 form if we are reconnecting and the server switched its
1672 posix path capability for this share */
1673 if(sb && (CIFS_SB(sb)->prepathlen > 0))
1674 CIFS_SB(sb)->prepath[0] = CIFS_DIR_SEP(CIFS_SB(sb));
1676 cFYI(1,("Negotiate caps 0x%x",(int)cap));
1677 #ifdef CONFIG_CIFS_DEBUG2
1678 if(cap & CIFS_UNIX_FCNTL_CAP)
1679 cFYI(1,("FCNTL cap"));
1680 if(cap & CIFS_UNIX_EXTATTR_CAP)
1681 cFYI(1,("EXTATTR cap"));
1682 if(cap & CIFS_UNIX_POSIX_PATHNAMES_CAP)
1683 cFYI(1,("POSIX path cap"));
1684 if(cap & CIFS_UNIX_XATTR_CAP)
1685 cFYI(1,("XATTR cap"));
1686 if(cap & CIFS_UNIX_POSIX_ACL_CAP)
1687 cFYI(1,("POSIX ACL cap"));
1688 #endif /* CIFS_DEBUG2 */
1689 if (CIFSSMBSetFSUnixInfo(xid, tcon, cap)) {
1690 cFYI(1,("setting capabilities failed"));
1696 cifs_mount(struct super_block *sb, struct cifs_sb_info *cifs_sb,
1697 char *mount_data, const char *devname)
1699 int rc = 0;
1700 int xid;
1701 int address_type = AF_INET;
1702 struct socket *csocket = NULL;
1703 struct sockaddr_in sin_server;
1704 struct sockaddr_in6 sin_server6;
1705 struct smb_vol volume_info;
1706 struct cifsSesInfo *pSesInfo = NULL;
1707 struct cifsSesInfo *existingCifsSes = NULL;
1708 struct cifsTconInfo *tcon = NULL;
1709 struct TCP_Server_Info *srvTcp = NULL;
1711 xid = GetXid();
1713 /* cFYI(1, ("Entering cifs_mount. Xid: %d with: %s", xid, mount_data)); */
1715 memset(&volume_info,0,sizeof(struct smb_vol));
1716 if (cifs_parse_mount_options(mount_data, devname, &volume_info)) {
1717 kfree(volume_info.UNC);
1718 kfree(volume_info.password);
1719 kfree(volume_info.prepath);
1720 FreeXid(xid);
1721 return -EINVAL;
1724 if (volume_info.nullauth) {
1725 cFYI(1,("null user"));
1726 volume_info.username = NULL;
1727 } else if (volume_info.username) {
1728 /* BB fixme parse for domain name here */
1729 cFYI(1, ("Username: %s ", volume_info.username));
1730 } else {
1731 cifserror("No username specified");
1732 /* In userspace mount helper we can get user name from alternate
1733 locations such as env variables and files on disk */
1734 kfree(volume_info.UNC);
1735 kfree(volume_info.password);
1736 kfree(volume_info.prepath);
1737 FreeXid(xid);
1738 return -EINVAL;
1741 if (volume_info.UNCip && volume_info.UNC) {
1742 rc = cifs_inet_pton(AF_INET, volume_info.UNCip,&sin_server.sin_addr.s_addr);
1744 if(rc <= 0) {
1745 /* not ipv4 address, try ipv6 */
1746 rc = cifs_inet_pton(AF_INET6,volume_info.UNCip,&sin_server6.sin6_addr.in6_u);
1747 if(rc > 0)
1748 address_type = AF_INET6;
1749 } else {
1750 address_type = AF_INET;
1753 if(rc <= 0) {
1754 /* we failed translating address */
1755 kfree(volume_info.UNC);
1756 kfree(volume_info.password);
1757 kfree(volume_info.prepath);
1758 FreeXid(xid);
1759 return -EINVAL;
1762 cFYI(1, ("UNC: %s ip: %s", volume_info.UNC, volume_info.UNCip));
1763 /* success */
1764 rc = 0;
1765 } else if (volume_info.UNCip){
1766 /* BB using ip addr as server name connect to the DFS root below */
1767 cERROR(1,("Connecting to DFS root not implemented yet"));
1768 kfree(volume_info.UNC);
1769 kfree(volume_info.password);
1770 kfree(volume_info.prepath);
1771 FreeXid(xid);
1772 return -EINVAL;
1773 } else /* which servers DFS root would we conect to */ {
1774 cERROR(1,
1775 ("CIFS mount error: No UNC path (e.g. -o unc=//192.168.1.100/public) specified"));
1776 kfree(volume_info.UNC);
1777 kfree(volume_info.password);
1778 kfree(volume_info.prepath);
1779 FreeXid(xid);
1780 return -EINVAL;
1783 /* this is needed for ASCII cp to Unicode converts */
1784 if(volume_info.iocharset == NULL) {
1785 cifs_sb->local_nls = load_nls_default();
1786 /* load_nls_default can not return null */
1787 } else {
1788 cifs_sb->local_nls = load_nls(volume_info.iocharset);
1789 if(cifs_sb->local_nls == NULL) {
1790 cERROR(1,("CIFS mount error: iocharset %s not found",volume_info.iocharset));
1791 kfree(volume_info.UNC);
1792 kfree(volume_info.password);
1793 kfree(volume_info.prepath);
1794 FreeXid(xid);
1795 return -ELIBACC;
1799 if(address_type == AF_INET)
1800 existingCifsSes = cifs_find_tcp_session(&sin_server.sin_addr,
1801 NULL /* no ipv6 addr */,
1802 volume_info.username, &srvTcp);
1803 else if(address_type == AF_INET6) {
1804 cFYI(1,("looking for ipv6 address"));
1805 existingCifsSes = cifs_find_tcp_session(NULL /* no ipv4 addr */,
1806 &sin_server6.sin6_addr,
1807 volume_info.username, &srvTcp);
1808 } else {
1809 kfree(volume_info.UNC);
1810 kfree(volume_info.password);
1811 kfree(volume_info.prepath);
1812 FreeXid(xid);
1813 return -EINVAL;
1817 if (srvTcp) {
1818 cFYI(1, ("Existing tcp session with server found"));
1819 } else { /* create socket */
1820 if (volume_info.port)
1821 sin_server.sin_port = htons(volume_info.port);
1822 else
1823 sin_server.sin_port = 0;
1824 if (address_type == AF_INET6) {
1825 cFYI(1,("attempting ipv6 connect"));
1826 /* BB should we allow ipv6 on port 139? */
1827 /* other OS never observed in Wild doing 139 with v6 */
1828 rc = ipv6_connect(&sin_server6,&csocket);
1829 } else
1830 rc = ipv4_connect(&sin_server,&csocket,
1831 volume_info.source_rfc1001_name,
1832 volume_info.target_rfc1001_name);
1833 if (rc < 0) {
1834 cERROR(1,
1835 ("Error connecting to IPv4 socket. Aborting operation"));
1836 if (csocket != NULL)
1837 sock_release(csocket);
1838 kfree(volume_info.UNC);
1839 kfree(volume_info.password);
1840 kfree(volume_info.prepath);
1841 FreeXid(xid);
1842 return rc;
1845 srvTcp = kmalloc(sizeof (struct TCP_Server_Info), GFP_KERNEL);
1846 if (srvTcp == NULL) {
1847 rc = -ENOMEM;
1848 sock_release(csocket);
1849 kfree(volume_info.UNC);
1850 kfree(volume_info.password);
1851 kfree(volume_info.prepath);
1852 FreeXid(xid);
1853 return rc;
1854 } else {
1855 memset(srvTcp, 0, sizeof (struct TCP_Server_Info));
1856 memcpy(&srvTcp->addr.sockAddr, &sin_server, sizeof (struct sockaddr_in));
1857 atomic_set(&srvTcp->inFlight,0);
1858 /* BB Add code for ipv6 case too */
1859 srvTcp->ssocket = csocket;
1860 srvTcp->protocolType = IPV4;
1861 init_waitqueue_head(&srvTcp->response_q);
1862 init_waitqueue_head(&srvTcp->request_q);
1863 INIT_LIST_HEAD(&srvTcp->pending_mid_q);
1864 /* at this point we are the only ones with the pointer
1865 to the struct since the kernel thread not created yet
1866 so no need to spinlock this init of tcpStatus */
1867 srvTcp->tcpStatus = CifsNew;
1868 init_MUTEX(&srvTcp->tcpSem);
1869 srvTcp->tsk = kthread_run((void *)(void *)cifs_demultiplex_thread, srvTcp, "cifsd");
1870 if ( IS_ERR(srvTcp->tsk) ) {
1871 rc = PTR_ERR(srvTcp->tsk);
1872 cERROR(1,("error %d create cifsd thread", rc));
1873 srvTcp->tsk = NULL;
1874 sock_release(csocket);
1875 kfree(volume_info.UNC);
1876 kfree(volume_info.password);
1877 kfree(volume_info.prepath);
1878 FreeXid(xid);
1879 return rc;
1881 wait_for_completion(&cifsd_complete);
1882 rc = 0;
1883 memcpy(srvTcp->workstation_RFC1001_name, volume_info.source_rfc1001_name,16);
1884 memcpy(srvTcp->server_RFC1001_name, volume_info.target_rfc1001_name,16);
1885 srvTcp->sequence_number = 0;
1889 if (existingCifsSes) {
1890 pSesInfo = existingCifsSes;
1891 cFYI(1, ("Existing smb sess found"));
1892 kfree(volume_info.password);
1893 /* volume_info.UNC freed at end of function */
1894 } else if (!rc) {
1895 cFYI(1, ("Existing smb sess not found"));
1896 pSesInfo = sesInfoAlloc();
1897 if (pSesInfo == NULL)
1898 rc = -ENOMEM;
1899 else {
1900 pSesInfo->server = srvTcp;
1901 sprintf(pSesInfo->serverName, "%u.%u.%u.%u",
1902 NIPQUAD(sin_server.sin_addr.s_addr));
1905 if (!rc){
1906 /* volume_info.password freed at unmount */
1907 if (volume_info.password)
1908 pSesInfo->password = volume_info.password;
1909 if (volume_info.username)
1910 strncpy(pSesInfo->userName,
1911 volume_info.username,MAX_USERNAME_SIZE);
1912 if (volume_info.domainname) {
1913 int len = strlen(volume_info.domainname);
1914 pSesInfo->domainName =
1915 kmalloc(len + 1, GFP_KERNEL);
1916 if (pSesInfo->domainName)
1917 strcpy(pSesInfo->domainName,
1918 volume_info.domainname);
1920 pSesInfo->linux_uid = volume_info.linux_uid;
1921 pSesInfo->overrideSecFlg = volume_info.secFlg;
1922 down(&pSesInfo->sesSem);
1923 /* BB FIXME need to pass vol->secFlgs BB */
1924 rc = cifs_setup_session(xid,pSesInfo, cifs_sb->local_nls);
1925 up(&pSesInfo->sesSem);
1926 if (!rc)
1927 atomic_inc(&srvTcp->socketUseCount);
1928 } else
1929 kfree(volume_info.password);
1932 /* search for existing tcon to this server share */
1933 if (!rc) {
1934 if (volume_info.rsize > CIFSMaxBufSize) {
1935 cERROR(1,("rsize %d too large, using MaxBufSize",
1936 volume_info.rsize));
1937 cifs_sb->rsize = CIFSMaxBufSize;
1938 } else if((volume_info.rsize) && (volume_info.rsize <= CIFSMaxBufSize))
1939 cifs_sb->rsize = volume_info.rsize;
1940 else /* default */
1941 cifs_sb->rsize = CIFSMaxBufSize;
1943 if (volume_info.wsize > PAGEVEC_SIZE * PAGE_CACHE_SIZE) {
1944 cERROR(1,("wsize %d too large using 4096 instead",
1945 volume_info.wsize));
1946 cifs_sb->wsize = 4096;
1947 } else if (volume_info.wsize)
1948 cifs_sb->wsize = volume_info.wsize;
1949 else
1950 cifs_sb->wsize =
1951 min_t(const int, PAGEVEC_SIZE * PAGE_CACHE_SIZE,
1952 127*1024);
1953 /* old default of CIFSMaxBufSize was too small now
1954 that SMB Write2 can send multiple pages in kvec.
1955 RFC1001 does not describe what happens when frame
1956 bigger than 128K is sent so use that as max in
1957 conjunction with 52K kvec constraint on arch with 4K
1958 page size */
1960 if (cifs_sb->rsize < 2048) {
1961 cifs_sb->rsize = 2048;
1962 /* Windows ME may prefer this */
1963 cFYI(1,("readsize set to minimum 2048"));
1965 /* calculate prepath */
1966 cifs_sb->prepath = volume_info.prepath;
1967 if (cifs_sb->prepath) {
1968 cifs_sb->prepathlen = strlen(cifs_sb->prepath);
1969 cifs_sb->prepath[0] = CIFS_DIR_SEP(cifs_sb);
1970 volume_info.prepath = NULL;
1971 } else
1972 cifs_sb->prepathlen = 0;
1973 cifs_sb->mnt_uid = volume_info.linux_uid;
1974 cifs_sb->mnt_gid = volume_info.linux_gid;
1975 cifs_sb->mnt_file_mode = volume_info.file_mode;
1976 cifs_sb->mnt_dir_mode = volume_info.dir_mode;
1977 cFYI(1,("file mode: 0x%x dir mode: 0x%x",
1978 cifs_sb->mnt_file_mode,cifs_sb->mnt_dir_mode));
1980 if (volume_info.noperm)
1981 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NO_PERM;
1982 if (volume_info.setuids)
1983 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_SET_UID;
1984 if (volume_info.server_ino)
1985 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_SERVER_INUM;
1986 if (volume_info.remap)
1987 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_MAP_SPECIAL_CHR;
1988 if (volume_info.no_xattr)
1989 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NO_XATTR;
1990 if (volume_info.sfu_emul)
1991 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_UNX_EMUL;
1992 if (volume_info.nobrl)
1993 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NO_BRL;
1994 if (volume_info.cifs_acl)
1995 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_CIFS_ACL;
1996 if (volume_info.override_uid)
1997 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_OVERR_UID;
1998 if (volume_info.override_gid)
1999 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_OVERR_GID;
2000 if (volume_info.direct_io) {
2001 cFYI(1,("mounting share using direct i/o"));
2002 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_DIRECT_IO;
2005 tcon =
2006 find_unc(sin_server.sin_addr.s_addr, volume_info.UNC,
2007 volume_info.username);
2008 if (tcon) {
2009 cFYI(1, ("Found match on UNC path"));
2010 /* we can have only one retry value for a connection
2011 to a share so for resources mounted more than once
2012 to the same server share the last value passed in
2013 for the retry flag is used */
2014 tcon->retry = volume_info.retry;
2015 tcon->nocase = volume_info.nocase;
2016 } else {
2017 tcon = tconInfoAlloc();
2018 if (tcon == NULL)
2019 rc = -ENOMEM;
2020 else {
2021 /* check for null share name ie connecting to
2022 * dfs root */
2024 /* BB check if this works for exactly length
2025 * three strings */
2026 if ((strchr(volume_info.UNC + 3, '\\') == NULL)
2027 && (strchr(volume_info.UNC + 3, '/') ==
2028 NULL)) {
2029 rc = connect_to_dfs_path(xid, pSesInfo,
2030 "", cifs_sb->local_nls,
2031 cifs_sb->mnt_cifs_flags &
2032 CIFS_MOUNT_MAP_SPECIAL_CHR);
2033 kfree(volume_info.UNC);
2034 FreeXid(xid);
2035 return -ENODEV;
2036 } else {
2037 /* BB Do we need to wrap sesSem around
2038 * this TCon call and Unix SetFS as
2039 * we do on SessSetup and reconnect? */
2040 rc = CIFSTCon(xid, pSesInfo,
2041 volume_info.UNC,
2042 tcon, cifs_sb->local_nls);
2043 cFYI(1, ("CIFS Tcon rc = %d", rc));
2045 if (!rc) {
2046 atomic_inc(&pSesInfo->inUse);
2047 tcon->retry = volume_info.retry;
2048 tcon->nocase = volume_info.nocase;
2053 if (pSesInfo) {
2054 if (pSesInfo->capabilities & CAP_LARGE_FILES) {
2055 sb->s_maxbytes = (u64) 1 << 63;
2056 } else
2057 sb->s_maxbytes = (u64) 1 << 31; /* 2 GB */
2060 /* BB FIXME fix time_gran to be larger for LANMAN sessions */
2061 sb->s_time_gran = 100;
2063 /* on error free sesinfo and tcon struct if needed */
2064 if (rc) {
2065 /* if session setup failed, use count is zero but
2066 we still need to free cifsd thread */
2067 if (atomic_read(&srvTcp->socketUseCount) == 0) {
2068 spin_lock(&GlobalMid_Lock);
2069 srvTcp->tcpStatus = CifsExiting;
2070 spin_unlock(&GlobalMid_Lock);
2071 if (srvTcp->tsk) {
2072 send_sig(SIGKILL,srvTcp->tsk,1);
2073 kthread_stop(srvTcp->tsk);
2076 /* If find_unc succeeded then rc == 0 so we can not end */
2077 if (tcon) /* up accidently freeing someone elses tcon struct */
2078 tconInfoFree(tcon);
2079 if (existingCifsSes == NULL) {
2080 if (pSesInfo) {
2081 if ((pSesInfo->server) &&
2082 (pSesInfo->status == CifsGood)) {
2083 int temp_rc;
2084 temp_rc = CIFSSMBLogoff(xid, pSesInfo);
2085 /* if the socketUseCount is now zero */
2086 if ((temp_rc == -ESHUTDOWN) &&
2087 (pSesInfo->server) && (pSesInfo->server->tsk)) {
2088 send_sig(SIGKILL,pSesInfo->server->tsk,1);
2089 kthread_stop(pSesInfo->server->tsk);
2091 } else
2092 cFYI(1, ("No session or bad tcon"));
2093 sesInfoFree(pSesInfo);
2094 /* pSesInfo = NULL; */
2097 } else {
2098 atomic_inc(&tcon->useCount);
2099 cifs_sb->tcon = tcon;
2100 tcon->ses = pSesInfo;
2102 /* do not care if following two calls succeed - informational */
2103 CIFSSMBQFSDeviceInfo(xid, tcon);
2104 CIFSSMBQFSAttributeInfo(xid, tcon);
2106 /* tell server which Unix caps we support */
2107 if (tcon->ses->capabilities & CAP_UNIX)
2108 reset_cifs_unix_caps(xid, tcon, sb, &volume_info);
2110 if (!(tcon->ses->capabilities & CAP_LARGE_WRITE_X))
2111 cifs_sb->wsize = min(cifs_sb->wsize,
2112 (tcon->ses->server->maxBuf -
2113 MAX_CIFS_HDR_SIZE));
2114 if (!(tcon->ses->capabilities & CAP_LARGE_READ_X))
2115 cifs_sb->rsize = min(cifs_sb->rsize,
2116 (tcon->ses->server->maxBuf -
2117 MAX_CIFS_HDR_SIZE));
2120 /* volume_info.password is freed above when existing session found
2121 (in which case it is not needed anymore) but when new sesion is created
2122 the password ptr is put in the new session structure (in which case the
2123 password will be freed at unmount time) */
2124 kfree(volume_info.UNC);
2125 kfree(volume_info.prepath);
2126 FreeXid(xid);
2127 return rc;
2130 static int
2131 CIFSSessSetup(unsigned int xid, struct cifsSesInfo *ses,
2132 char session_key[CIFS_SESS_KEY_SIZE],
2133 const struct nls_table *nls_codepage)
2135 struct smb_hdr *smb_buffer;
2136 struct smb_hdr *smb_buffer_response;
2137 SESSION_SETUP_ANDX *pSMB;
2138 SESSION_SETUP_ANDX *pSMBr;
2139 char *bcc_ptr;
2140 char *user;
2141 char *domain;
2142 int rc = 0;
2143 int remaining_words = 0;
2144 int bytes_returned = 0;
2145 int len;
2146 __u32 capabilities;
2147 __u16 count;
2149 cFYI(1, ("In sesssetup"));
2150 if (ses == NULL)
2151 return -EINVAL;
2152 user = ses->userName;
2153 domain = ses->domainName;
2154 smb_buffer = cifs_buf_get();
2155 if (smb_buffer == NULL) {
2156 return -ENOMEM;
2158 smb_buffer_response = smb_buffer;
2159 pSMBr = pSMB = (SESSION_SETUP_ANDX *) smb_buffer;
2161 /* send SMBsessionSetup here */
2162 header_assemble(smb_buffer, SMB_COM_SESSION_SETUP_ANDX,
2163 NULL /* no tCon exists yet */ , 13 /* wct */ );
2165 smb_buffer->Mid = GetNextMid(ses->server);
2166 pSMB->req_no_secext.AndXCommand = 0xFF;
2167 pSMB->req_no_secext.MaxBufferSize = cpu_to_le16(ses->server->maxBuf);
2168 pSMB->req_no_secext.MaxMpxCount = cpu_to_le16(ses->server->maxReq);
2170 if(ses->server->secMode & (SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED))
2171 smb_buffer->Flags2 |= SMBFLG2_SECURITY_SIGNATURE;
2173 capabilities = CAP_LARGE_FILES | CAP_NT_SMBS | CAP_LEVEL_II_OPLOCKS |
2174 CAP_LARGE_WRITE_X | CAP_LARGE_READ_X;
2175 if (ses->capabilities & CAP_UNICODE) {
2176 smb_buffer->Flags2 |= SMBFLG2_UNICODE;
2177 capabilities |= CAP_UNICODE;
2179 if (ses->capabilities & CAP_STATUS32) {
2180 smb_buffer->Flags2 |= SMBFLG2_ERR_STATUS;
2181 capabilities |= CAP_STATUS32;
2183 if (ses->capabilities & CAP_DFS) {
2184 smb_buffer->Flags2 |= SMBFLG2_DFS;
2185 capabilities |= CAP_DFS;
2187 pSMB->req_no_secext.Capabilities = cpu_to_le32(capabilities);
2189 pSMB->req_no_secext.CaseInsensitivePasswordLength =
2190 cpu_to_le16(CIFS_SESS_KEY_SIZE);
2192 pSMB->req_no_secext.CaseSensitivePasswordLength =
2193 cpu_to_le16(CIFS_SESS_KEY_SIZE);
2194 bcc_ptr = pByteArea(smb_buffer);
2195 memcpy(bcc_ptr, (char *) session_key, CIFS_SESS_KEY_SIZE);
2196 bcc_ptr += CIFS_SESS_KEY_SIZE;
2197 memcpy(bcc_ptr, (char *) session_key, CIFS_SESS_KEY_SIZE);
2198 bcc_ptr += CIFS_SESS_KEY_SIZE;
2200 if (ses->capabilities & CAP_UNICODE) {
2201 if ((long) bcc_ptr % 2) { /* must be word aligned for Unicode */
2202 *bcc_ptr = 0;
2203 bcc_ptr++;
2205 if (user == NULL)
2206 bytes_returned = 0; /* skip null user */
2207 else
2208 bytes_returned =
2209 cifs_strtoUCS((__le16 *) bcc_ptr, user, 100,
2210 nls_codepage);
2211 /* convert number of 16 bit words to bytes */
2212 bcc_ptr += 2 * bytes_returned;
2213 bcc_ptr += 2; /* trailing null */
2214 if (domain == NULL)
2215 bytes_returned =
2216 cifs_strtoUCS((__le16 *) bcc_ptr,
2217 "CIFS_LINUX_DOM", 32, nls_codepage);
2218 else
2219 bytes_returned =
2220 cifs_strtoUCS((__le16 *) bcc_ptr, domain, 64,
2221 nls_codepage);
2222 bcc_ptr += 2 * bytes_returned;
2223 bcc_ptr += 2;
2224 bytes_returned =
2225 cifs_strtoUCS((__le16 *) bcc_ptr, "Linux version ",
2226 32, nls_codepage);
2227 bcc_ptr += 2 * bytes_returned;
2228 bytes_returned =
2229 cifs_strtoUCS((__le16 *) bcc_ptr, utsname()->release,
2230 32, nls_codepage);
2231 bcc_ptr += 2 * bytes_returned;
2232 bcc_ptr += 2;
2233 bytes_returned =
2234 cifs_strtoUCS((__le16 *) bcc_ptr, CIFS_NETWORK_OPSYS,
2235 64, nls_codepage);
2236 bcc_ptr += 2 * bytes_returned;
2237 bcc_ptr += 2;
2238 } else {
2239 if (user != NULL) {
2240 strncpy(bcc_ptr, user, 200);
2241 bcc_ptr += strnlen(user, 200);
2243 *bcc_ptr = 0;
2244 bcc_ptr++;
2245 if (domain == NULL) {
2246 strcpy(bcc_ptr, "CIFS_LINUX_DOM");
2247 bcc_ptr += strlen("CIFS_LINUX_DOM") + 1;
2248 } else {
2249 strncpy(bcc_ptr, domain, 64);
2250 bcc_ptr += strnlen(domain, 64);
2251 *bcc_ptr = 0;
2252 bcc_ptr++;
2254 strcpy(bcc_ptr, "Linux version ");
2255 bcc_ptr += strlen("Linux version ");
2256 strcpy(bcc_ptr, utsname()->release);
2257 bcc_ptr += strlen(utsname()->release) + 1;
2258 strcpy(bcc_ptr, CIFS_NETWORK_OPSYS);
2259 bcc_ptr += strlen(CIFS_NETWORK_OPSYS) + 1;
2261 count = (long) bcc_ptr - (long) pByteArea(smb_buffer);
2262 smb_buffer->smb_buf_length += count;
2263 pSMB->req_no_secext.ByteCount = cpu_to_le16(count);
2265 rc = SendReceive(xid, ses, smb_buffer, smb_buffer_response,
2266 &bytes_returned, 1);
2267 if (rc) {
2268 /* rc = map_smb_to_linux_error(smb_buffer_response); now done in SendReceive */
2269 } else if ((smb_buffer_response->WordCount == 3)
2270 || (smb_buffer_response->WordCount == 4)) {
2271 __u16 action = le16_to_cpu(pSMBr->resp.Action);
2272 __u16 blob_len = le16_to_cpu(pSMBr->resp.SecurityBlobLength);
2273 if (action & GUEST_LOGIN)
2274 cFYI(1, (" Guest login")); /* do we want to mark SesInfo struct ? */
2275 ses->Suid = smb_buffer_response->Uid; /* UID left in wire format (le) */
2276 cFYI(1, ("UID = %d ", ses->Suid));
2277 /* response can have either 3 or 4 word count - Samba sends 3 */
2278 bcc_ptr = pByteArea(smb_buffer_response);
2279 if ((pSMBr->resp.hdr.WordCount == 3)
2280 || ((pSMBr->resp.hdr.WordCount == 4)
2281 && (blob_len < pSMBr->resp.ByteCount))) {
2282 if (pSMBr->resp.hdr.WordCount == 4)
2283 bcc_ptr += blob_len;
2285 if (smb_buffer->Flags2 & SMBFLG2_UNICODE) {
2286 if ((long) (bcc_ptr) % 2) {
2287 remaining_words =
2288 (BCC(smb_buffer_response) - 1) /2;
2289 bcc_ptr++; /* Unicode strings must be word aligned */
2290 } else {
2291 remaining_words =
2292 BCC(smb_buffer_response) / 2;
2294 len =
2295 UniStrnlen((wchar_t *) bcc_ptr,
2296 remaining_words - 1);
2297 /* We look for obvious messed up bcc or strings in response so we do not go off
2298 the end since (at least) WIN2K and Windows XP have a major bug in not null
2299 terminating last Unicode string in response */
2300 if(ses->serverOS)
2301 kfree(ses->serverOS);
2302 ses->serverOS = kzalloc(2 * (len + 1), GFP_KERNEL);
2303 if(ses->serverOS == NULL)
2304 goto sesssetup_nomem;
2305 cifs_strfromUCS_le(ses->serverOS,
2306 (__le16 *)bcc_ptr, len,nls_codepage);
2307 bcc_ptr += 2 * (len + 1);
2308 remaining_words -= len + 1;
2309 ses->serverOS[2 * len] = 0;
2310 ses->serverOS[1 + (2 * len)] = 0;
2311 if (remaining_words > 0) {
2312 len = UniStrnlen((wchar_t *)bcc_ptr,
2313 remaining_words-1);
2314 kfree(ses->serverNOS);
2315 ses->serverNOS = kzalloc(2 * (len + 1),GFP_KERNEL);
2316 if(ses->serverNOS == NULL)
2317 goto sesssetup_nomem;
2318 cifs_strfromUCS_le(ses->serverNOS,
2319 (__le16 *)bcc_ptr,len,nls_codepage);
2320 bcc_ptr += 2 * (len + 1);
2321 ses->serverNOS[2 * len] = 0;
2322 ses->serverNOS[1 + (2 * len)] = 0;
2323 if(strncmp(ses->serverNOS,
2324 "NT LAN Manager 4",16) == 0) {
2325 cFYI(1,("NT4 server"));
2326 ses->flags |= CIFS_SES_NT4;
2328 remaining_words -= len + 1;
2329 if (remaining_words > 0) {
2330 len = UniStrnlen((wchar_t *) bcc_ptr, remaining_words);
2331 /* last string is not always null terminated (for e.g. for Windows XP & 2000) */
2332 if(ses->serverDomain)
2333 kfree(ses->serverDomain);
2334 ses->serverDomain =
2335 kzalloc(2*(len+1),GFP_KERNEL);
2336 if(ses->serverDomain == NULL)
2337 goto sesssetup_nomem;
2338 cifs_strfromUCS_le(ses->serverDomain,
2339 (__le16 *)bcc_ptr,len,nls_codepage);
2340 bcc_ptr += 2 * (len + 1);
2341 ses->serverDomain[2*len] = 0;
2342 ses->serverDomain[1+(2*len)] = 0;
2343 } /* else no more room so create dummy domain string */
2344 else {
2345 if(ses->serverDomain)
2346 kfree(ses->serverDomain);
2347 ses->serverDomain =
2348 kzalloc(2, GFP_KERNEL);
2350 } else { /* no room so create dummy domain and NOS string */
2351 /* if these kcallocs fail not much we
2352 can do, but better to not fail the
2353 sesssetup itself */
2354 kfree(ses->serverDomain);
2355 ses->serverDomain =
2356 kzalloc(2, GFP_KERNEL);
2357 kfree(ses->serverNOS);
2358 ses->serverNOS =
2359 kzalloc(2, GFP_KERNEL);
2361 } else { /* ASCII */
2362 len = strnlen(bcc_ptr, 1024);
2363 if (((long) bcc_ptr + len) - (long)
2364 pByteArea(smb_buffer_response)
2365 <= BCC(smb_buffer_response)) {
2366 kfree(ses->serverOS);
2367 ses->serverOS = kzalloc(len + 1,GFP_KERNEL);
2368 if(ses->serverOS == NULL)
2369 goto sesssetup_nomem;
2370 strncpy(ses->serverOS,bcc_ptr, len);
2372 bcc_ptr += len;
2373 bcc_ptr[0] = 0; /* null terminate the string */
2374 bcc_ptr++;
2376 len = strnlen(bcc_ptr, 1024);
2377 kfree(ses->serverNOS);
2378 ses->serverNOS = kzalloc(len + 1,GFP_KERNEL);
2379 if(ses->serverNOS == NULL)
2380 goto sesssetup_nomem;
2381 strncpy(ses->serverNOS, bcc_ptr, len);
2382 bcc_ptr += len;
2383 bcc_ptr[0] = 0;
2384 bcc_ptr++;
2386 len = strnlen(bcc_ptr, 1024);
2387 if(ses->serverDomain)
2388 kfree(ses->serverDomain);
2389 ses->serverDomain = kzalloc(len + 1,GFP_KERNEL);
2390 if(ses->serverDomain == NULL)
2391 goto sesssetup_nomem;
2392 strncpy(ses->serverDomain, bcc_ptr, len);
2393 bcc_ptr += len;
2394 bcc_ptr[0] = 0;
2395 bcc_ptr++;
2396 } else
2397 cFYI(1,
2398 ("Variable field of length %d extends beyond end of smb ",
2399 len));
2401 } else {
2402 cERROR(1,
2403 (" Security Blob Length extends beyond end of SMB"));
2405 } else {
2406 cERROR(1,
2407 (" Invalid Word count %d: ",
2408 smb_buffer_response->WordCount));
2409 rc = -EIO;
2411 sesssetup_nomem: /* do not return an error on nomem for the info strings,
2412 since that could make reconnection harder, and
2413 reconnection might be needed to free memory */
2414 if (smb_buffer)
2415 cifs_buf_release(smb_buffer);
2417 return rc;
2420 static int
2421 CIFSNTLMSSPNegotiateSessSetup(unsigned int xid,
2422 struct cifsSesInfo *ses, int * pNTLMv2_flag,
2423 const struct nls_table *nls_codepage)
2425 struct smb_hdr *smb_buffer;
2426 struct smb_hdr *smb_buffer_response;
2427 SESSION_SETUP_ANDX *pSMB;
2428 SESSION_SETUP_ANDX *pSMBr;
2429 char *bcc_ptr;
2430 char *domain;
2431 int rc = 0;
2432 int remaining_words = 0;
2433 int bytes_returned = 0;
2434 int len;
2435 int SecurityBlobLength = sizeof (NEGOTIATE_MESSAGE);
2436 PNEGOTIATE_MESSAGE SecurityBlob;
2437 PCHALLENGE_MESSAGE SecurityBlob2;
2438 __u32 negotiate_flags, capabilities;
2439 __u16 count;
2441 cFYI(1, ("In NTLMSSP sesssetup (negotiate)"));
2442 if(ses == NULL)
2443 return -EINVAL;
2444 domain = ses->domainName;
2445 *pNTLMv2_flag = FALSE;
2446 smb_buffer = cifs_buf_get();
2447 if (smb_buffer == NULL) {
2448 return -ENOMEM;
2450 smb_buffer_response = smb_buffer;
2451 pSMB = (SESSION_SETUP_ANDX *) smb_buffer;
2452 pSMBr = (SESSION_SETUP_ANDX *) smb_buffer_response;
2454 /* send SMBsessionSetup here */
2455 header_assemble(smb_buffer, SMB_COM_SESSION_SETUP_ANDX,
2456 NULL /* no tCon exists yet */ , 12 /* wct */ );
2458 smb_buffer->Mid = GetNextMid(ses->server);
2459 pSMB->req.hdr.Flags2 |= SMBFLG2_EXT_SEC;
2460 pSMB->req.hdr.Flags |= (SMBFLG_CASELESS | SMBFLG_CANONICAL_PATH_FORMAT);
2462 pSMB->req.AndXCommand = 0xFF;
2463 pSMB->req.MaxBufferSize = cpu_to_le16(ses->server->maxBuf);
2464 pSMB->req.MaxMpxCount = cpu_to_le16(ses->server->maxReq);
2466 if(ses->server->secMode & (SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED))
2467 smb_buffer->Flags2 |= SMBFLG2_SECURITY_SIGNATURE;
2469 capabilities = CAP_LARGE_FILES | CAP_NT_SMBS | CAP_LEVEL_II_OPLOCKS |
2470 CAP_EXTENDED_SECURITY;
2471 if (ses->capabilities & CAP_UNICODE) {
2472 smb_buffer->Flags2 |= SMBFLG2_UNICODE;
2473 capabilities |= CAP_UNICODE;
2475 if (ses->capabilities & CAP_STATUS32) {
2476 smb_buffer->Flags2 |= SMBFLG2_ERR_STATUS;
2477 capabilities |= CAP_STATUS32;
2479 if (ses->capabilities & CAP_DFS) {
2480 smb_buffer->Flags2 |= SMBFLG2_DFS;
2481 capabilities |= CAP_DFS;
2483 pSMB->req.Capabilities = cpu_to_le32(capabilities);
2485 bcc_ptr = (char *) &pSMB->req.SecurityBlob;
2486 SecurityBlob = (PNEGOTIATE_MESSAGE) bcc_ptr;
2487 strncpy(SecurityBlob->Signature, NTLMSSP_SIGNATURE, 8);
2488 SecurityBlob->MessageType = NtLmNegotiate;
2489 negotiate_flags =
2490 NTLMSSP_NEGOTIATE_UNICODE | NTLMSSP_NEGOTIATE_OEM |
2491 NTLMSSP_REQUEST_TARGET | NTLMSSP_NEGOTIATE_NTLM |
2492 NTLMSSP_NEGOTIATE_56 |
2493 /* NTLMSSP_NEGOTIATE_ALWAYS_SIGN | */ NTLMSSP_NEGOTIATE_128;
2494 if(sign_CIFS_PDUs)
2495 negotiate_flags |= NTLMSSP_NEGOTIATE_SIGN;
2496 /* if(ntlmv2_support)
2497 negotiate_flags |= NTLMSSP_NEGOTIATE_NTLMV2;*/
2498 /* setup pointers to domain name and workstation name */
2499 bcc_ptr += SecurityBlobLength;
2501 SecurityBlob->WorkstationName.Buffer = 0;
2502 SecurityBlob->WorkstationName.Length = 0;
2503 SecurityBlob->WorkstationName.MaximumLength = 0;
2505 /* Domain not sent on first Sesssetup in NTLMSSP, instead it is sent
2506 along with username on auth request (ie the response to challenge) */
2507 SecurityBlob->DomainName.Buffer = 0;
2508 SecurityBlob->DomainName.Length = 0;
2509 SecurityBlob->DomainName.MaximumLength = 0;
2510 if (ses->capabilities & CAP_UNICODE) {
2511 if ((long) bcc_ptr % 2) {
2512 *bcc_ptr = 0;
2513 bcc_ptr++;
2516 bytes_returned =
2517 cifs_strtoUCS((__le16 *) bcc_ptr, "Linux version ",
2518 32, nls_codepage);
2519 bcc_ptr += 2 * bytes_returned;
2520 bytes_returned =
2521 cifs_strtoUCS((__le16 *) bcc_ptr, utsname()->release, 32,
2522 nls_codepage);
2523 bcc_ptr += 2 * bytes_returned;
2524 bcc_ptr += 2; /* null terminate Linux version */
2525 bytes_returned =
2526 cifs_strtoUCS((__le16 *) bcc_ptr, CIFS_NETWORK_OPSYS,
2527 64, nls_codepage);
2528 bcc_ptr += 2 * bytes_returned;
2529 *(bcc_ptr + 1) = 0;
2530 *(bcc_ptr + 2) = 0;
2531 bcc_ptr += 2; /* null terminate network opsys string */
2532 *(bcc_ptr + 1) = 0;
2533 *(bcc_ptr + 2) = 0;
2534 bcc_ptr += 2; /* null domain */
2535 } else { /* ASCII */
2536 strcpy(bcc_ptr, "Linux version ");
2537 bcc_ptr += strlen("Linux version ");
2538 strcpy(bcc_ptr, utsname()->release);
2539 bcc_ptr += strlen(utsname()->release) + 1;
2540 strcpy(bcc_ptr, CIFS_NETWORK_OPSYS);
2541 bcc_ptr += strlen(CIFS_NETWORK_OPSYS) + 1;
2542 bcc_ptr++; /* empty domain field */
2543 *bcc_ptr = 0;
2545 SecurityBlob->NegotiateFlags = cpu_to_le32(negotiate_flags);
2546 pSMB->req.SecurityBlobLength = cpu_to_le16(SecurityBlobLength);
2547 count = (long) bcc_ptr - (long) pByteArea(smb_buffer);
2548 smb_buffer->smb_buf_length += count;
2549 pSMB->req.ByteCount = cpu_to_le16(count);
2551 rc = SendReceive(xid, ses, smb_buffer, smb_buffer_response,
2552 &bytes_returned, 1);
2554 if (smb_buffer_response->Status.CifsError ==
2555 cpu_to_le32(NT_STATUS_MORE_PROCESSING_REQUIRED))
2556 rc = 0;
2558 if (rc) {
2559 /* rc = map_smb_to_linux_error(smb_buffer_response); *//* done in SendReceive now */
2560 } else if ((smb_buffer_response->WordCount == 3)
2561 || (smb_buffer_response->WordCount == 4)) {
2562 __u16 action = le16_to_cpu(pSMBr->resp.Action);
2563 __u16 blob_len = le16_to_cpu(pSMBr->resp.SecurityBlobLength);
2565 if (action & GUEST_LOGIN)
2566 cFYI(1, (" Guest login"));
2567 /* Do we want to set anything in SesInfo struct when guest login? */
2569 bcc_ptr = pByteArea(smb_buffer_response);
2570 /* response can have either 3 or 4 word count - Samba sends 3 */
2572 SecurityBlob2 = (PCHALLENGE_MESSAGE) bcc_ptr;
2573 if (SecurityBlob2->MessageType != NtLmChallenge) {
2574 cFYI(1,
2575 ("Unexpected NTLMSSP message type received %d",
2576 SecurityBlob2->MessageType));
2577 } else if (ses) {
2578 ses->Suid = smb_buffer_response->Uid; /* UID left in le format */
2579 cFYI(1, ("UID = %d", ses->Suid));
2580 if ((pSMBr->resp.hdr.WordCount == 3)
2581 || ((pSMBr->resp.hdr.WordCount == 4)
2582 && (blob_len <
2583 pSMBr->resp.ByteCount))) {
2585 if (pSMBr->resp.hdr.WordCount == 4) {
2586 bcc_ptr += blob_len;
2587 cFYI(1, ("Security Blob Length %d",
2588 blob_len));
2591 cFYI(1, ("NTLMSSP Challenge rcvd"));
2593 memcpy(ses->server->cryptKey,
2594 SecurityBlob2->Challenge,
2595 CIFS_CRYPTO_KEY_SIZE);
2596 if(SecurityBlob2->NegotiateFlags &
2597 cpu_to_le32(NTLMSSP_NEGOTIATE_NTLMV2))
2598 *pNTLMv2_flag = TRUE;
2600 if((SecurityBlob2->NegotiateFlags &
2601 cpu_to_le32(NTLMSSP_NEGOTIATE_ALWAYS_SIGN))
2602 || (sign_CIFS_PDUs > 1))
2603 ses->server->secMode |=
2604 SECMODE_SIGN_REQUIRED;
2605 if ((SecurityBlob2->NegotiateFlags &
2606 cpu_to_le32(NTLMSSP_NEGOTIATE_SIGN)) && (sign_CIFS_PDUs))
2607 ses->server->secMode |=
2608 SECMODE_SIGN_ENABLED;
2610 if (smb_buffer->Flags2 & SMBFLG2_UNICODE) {
2611 if ((long) (bcc_ptr) % 2) {
2612 remaining_words =
2613 (BCC(smb_buffer_response)
2614 - 1) / 2;
2615 bcc_ptr++; /* Unicode strings must be word aligned */
2616 } else {
2617 remaining_words =
2619 (smb_buffer_response) / 2;
2621 len =
2622 UniStrnlen((wchar_t *) bcc_ptr,
2623 remaining_words - 1);
2624 /* We look for obvious messed up bcc or strings in response so we do not go off
2625 the end since (at least) WIN2K and Windows XP have a major bug in not null
2626 terminating last Unicode string in response */
2627 if(ses->serverOS)
2628 kfree(ses->serverOS);
2629 ses->serverOS =
2630 kzalloc(2 * (len + 1), GFP_KERNEL);
2631 cifs_strfromUCS_le(ses->serverOS,
2632 (__le16 *)
2633 bcc_ptr, len,
2634 nls_codepage);
2635 bcc_ptr += 2 * (len + 1);
2636 remaining_words -= len + 1;
2637 ses->serverOS[2 * len] = 0;
2638 ses->serverOS[1 + (2 * len)] = 0;
2639 if (remaining_words > 0) {
2640 len = UniStrnlen((wchar_t *)
2641 bcc_ptr,
2642 remaining_words
2643 - 1);
2644 kfree(ses->serverNOS);
2645 ses->serverNOS =
2646 kzalloc(2 * (len + 1),
2647 GFP_KERNEL);
2648 cifs_strfromUCS_le(ses->
2649 serverNOS,
2650 (__le16 *)
2651 bcc_ptr,
2652 len,
2653 nls_codepage);
2654 bcc_ptr += 2 * (len + 1);
2655 ses->serverNOS[2 * len] = 0;
2656 ses->serverNOS[1 +
2657 (2 * len)] = 0;
2658 remaining_words -= len + 1;
2659 if (remaining_words > 0) {
2660 len = UniStrnlen((wchar_t *) bcc_ptr, remaining_words);
2661 /* last string is not always null terminated (for e.g. for Windows XP & 2000) */
2662 kfree(ses->serverDomain);
2663 ses->serverDomain =
2664 kzalloc(2 *
2665 (len +
2667 GFP_KERNEL);
2668 cifs_strfromUCS_le
2669 (ses->serverDomain,
2670 (__le16 *)bcc_ptr,
2671 len, nls_codepage);
2672 bcc_ptr +=
2673 2 * (len + 1);
2674 ses->serverDomain[2*len]
2675 = 0;
2676 ses->serverDomain
2677 [1 + (2 * len)]
2678 = 0;
2679 } /* else no more room so create dummy domain string */
2680 else {
2681 kfree(ses->serverDomain);
2682 ses->serverDomain =
2683 kzalloc(2,
2684 GFP_KERNEL);
2686 } else { /* no room so create dummy domain and NOS string */
2687 kfree(ses->serverDomain);
2688 ses->serverDomain =
2689 kzalloc(2, GFP_KERNEL);
2690 kfree(ses->serverNOS);
2691 ses->serverNOS =
2692 kzalloc(2, GFP_KERNEL);
2694 } else { /* ASCII */
2695 len = strnlen(bcc_ptr, 1024);
2696 if (((long) bcc_ptr + len) - (long)
2697 pByteArea(smb_buffer_response)
2698 <= BCC(smb_buffer_response)) {
2699 if(ses->serverOS)
2700 kfree(ses->serverOS);
2701 ses->serverOS =
2702 kzalloc(len + 1,
2703 GFP_KERNEL);
2704 strncpy(ses->serverOS,
2705 bcc_ptr, len);
2707 bcc_ptr += len;
2708 bcc_ptr[0] = 0; /* null terminate string */
2709 bcc_ptr++;
2711 len = strnlen(bcc_ptr, 1024);
2712 kfree(ses->serverNOS);
2713 ses->serverNOS =
2714 kzalloc(len + 1,
2715 GFP_KERNEL);
2716 strncpy(ses->serverNOS, bcc_ptr, len);
2717 bcc_ptr += len;
2718 bcc_ptr[0] = 0;
2719 bcc_ptr++;
2721 len = strnlen(bcc_ptr, 1024);
2722 kfree(ses->serverDomain);
2723 ses->serverDomain =
2724 kzalloc(len + 1,
2725 GFP_KERNEL);
2726 strncpy(ses->serverDomain, bcc_ptr, len);
2727 bcc_ptr += len;
2728 bcc_ptr[0] = 0;
2729 bcc_ptr++;
2730 } else
2731 cFYI(1,
2732 ("Variable field of length %d extends beyond end of smb",
2733 len));
2735 } else {
2736 cERROR(1,
2737 (" Security Blob Length extends beyond end of SMB"));
2739 } else {
2740 cERROR(1, ("No session structure passed in."));
2742 } else {
2743 cERROR(1,
2744 (" Invalid Word count %d:",
2745 smb_buffer_response->WordCount));
2746 rc = -EIO;
2749 if (smb_buffer)
2750 cifs_buf_release(smb_buffer);
2752 return rc;
2754 static int
2755 CIFSNTLMSSPAuthSessSetup(unsigned int xid, struct cifsSesInfo *ses,
2756 char *ntlm_session_key, int ntlmv2_flag,
2757 const struct nls_table *nls_codepage)
2759 struct smb_hdr *smb_buffer;
2760 struct smb_hdr *smb_buffer_response;
2761 SESSION_SETUP_ANDX *pSMB;
2762 SESSION_SETUP_ANDX *pSMBr;
2763 char *bcc_ptr;
2764 char *user;
2765 char *domain;
2766 int rc = 0;
2767 int remaining_words = 0;
2768 int bytes_returned = 0;
2769 int len;
2770 int SecurityBlobLength = sizeof (AUTHENTICATE_MESSAGE);
2771 PAUTHENTICATE_MESSAGE SecurityBlob;
2772 __u32 negotiate_flags, capabilities;
2773 __u16 count;
2775 cFYI(1, ("In NTLMSSPSessSetup (Authenticate)"));
2776 if(ses == NULL)
2777 return -EINVAL;
2778 user = ses->userName;
2779 domain = ses->domainName;
2780 smb_buffer = cifs_buf_get();
2781 if (smb_buffer == NULL) {
2782 return -ENOMEM;
2784 smb_buffer_response = smb_buffer;
2785 pSMB = (SESSION_SETUP_ANDX *) smb_buffer;
2786 pSMBr = (SESSION_SETUP_ANDX *) smb_buffer_response;
2788 /* send SMBsessionSetup here */
2789 header_assemble(smb_buffer, SMB_COM_SESSION_SETUP_ANDX,
2790 NULL /* no tCon exists yet */ , 12 /* wct */ );
2792 smb_buffer->Mid = GetNextMid(ses->server);
2793 pSMB->req.hdr.Flags |= (SMBFLG_CASELESS | SMBFLG_CANONICAL_PATH_FORMAT);
2794 pSMB->req.hdr.Flags2 |= SMBFLG2_EXT_SEC;
2795 pSMB->req.AndXCommand = 0xFF;
2796 pSMB->req.MaxBufferSize = cpu_to_le16(ses->server->maxBuf);
2797 pSMB->req.MaxMpxCount = cpu_to_le16(ses->server->maxReq);
2799 pSMB->req.hdr.Uid = ses->Suid;
2801 if(ses->server->secMode & (SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED))
2802 smb_buffer->Flags2 |= SMBFLG2_SECURITY_SIGNATURE;
2804 capabilities = CAP_LARGE_FILES | CAP_NT_SMBS | CAP_LEVEL_II_OPLOCKS |
2805 CAP_EXTENDED_SECURITY;
2806 if (ses->capabilities & CAP_UNICODE) {
2807 smb_buffer->Flags2 |= SMBFLG2_UNICODE;
2808 capabilities |= CAP_UNICODE;
2810 if (ses->capabilities & CAP_STATUS32) {
2811 smb_buffer->Flags2 |= SMBFLG2_ERR_STATUS;
2812 capabilities |= CAP_STATUS32;
2814 if (ses->capabilities & CAP_DFS) {
2815 smb_buffer->Flags2 |= SMBFLG2_DFS;
2816 capabilities |= CAP_DFS;
2818 pSMB->req.Capabilities = cpu_to_le32(capabilities);
2820 bcc_ptr = (char *) &pSMB->req.SecurityBlob;
2821 SecurityBlob = (PAUTHENTICATE_MESSAGE) bcc_ptr;
2822 strncpy(SecurityBlob->Signature, NTLMSSP_SIGNATURE, 8);
2823 SecurityBlob->MessageType = NtLmAuthenticate;
2824 bcc_ptr += SecurityBlobLength;
2825 negotiate_flags =
2826 NTLMSSP_NEGOTIATE_UNICODE | NTLMSSP_REQUEST_TARGET |
2827 NTLMSSP_NEGOTIATE_NTLM | NTLMSSP_NEGOTIATE_TARGET_INFO |
2828 0x80000000 | NTLMSSP_NEGOTIATE_128;
2829 if(sign_CIFS_PDUs)
2830 negotiate_flags |= /* NTLMSSP_NEGOTIATE_ALWAYS_SIGN |*/ NTLMSSP_NEGOTIATE_SIGN;
2831 if(ntlmv2_flag)
2832 negotiate_flags |= NTLMSSP_NEGOTIATE_NTLMV2;
2834 /* setup pointers to domain name and workstation name */
2836 SecurityBlob->WorkstationName.Buffer = 0;
2837 SecurityBlob->WorkstationName.Length = 0;
2838 SecurityBlob->WorkstationName.MaximumLength = 0;
2839 SecurityBlob->SessionKey.Length = 0;
2840 SecurityBlob->SessionKey.MaximumLength = 0;
2841 SecurityBlob->SessionKey.Buffer = 0;
2843 SecurityBlob->LmChallengeResponse.Length = 0;
2844 SecurityBlob->LmChallengeResponse.MaximumLength = 0;
2845 SecurityBlob->LmChallengeResponse.Buffer = 0;
2847 SecurityBlob->NtChallengeResponse.Length =
2848 cpu_to_le16(CIFS_SESS_KEY_SIZE);
2849 SecurityBlob->NtChallengeResponse.MaximumLength =
2850 cpu_to_le16(CIFS_SESS_KEY_SIZE);
2851 memcpy(bcc_ptr, ntlm_session_key, CIFS_SESS_KEY_SIZE);
2852 SecurityBlob->NtChallengeResponse.Buffer =
2853 cpu_to_le32(SecurityBlobLength);
2854 SecurityBlobLength += CIFS_SESS_KEY_SIZE;
2855 bcc_ptr += CIFS_SESS_KEY_SIZE;
2857 if (ses->capabilities & CAP_UNICODE) {
2858 if (domain == NULL) {
2859 SecurityBlob->DomainName.Buffer = 0;
2860 SecurityBlob->DomainName.Length = 0;
2861 SecurityBlob->DomainName.MaximumLength = 0;
2862 } else {
2863 __u16 len =
2864 cifs_strtoUCS((__le16 *) bcc_ptr, domain, 64,
2865 nls_codepage);
2866 len *= 2;
2867 SecurityBlob->DomainName.MaximumLength =
2868 cpu_to_le16(len);
2869 SecurityBlob->DomainName.Buffer =
2870 cpu_to_le32(SecurityBlobLength);
2871 bcc_ptr += len;
2872 SecurityBlobLength += len;
2873 SecurityBlob->DomainName.Length =
2874 cpu_to_le16(len);
2876 if (user == NULL) {
2877 SecurityBlob->UserName.Buffer = 0;
2878 SecurityBlob->UserName.Length = 0;
2879 SecurityBlob->UserName.MaximumLength = 0;
2880 } else {
2881 __u16 len =
2882 cifs_strtoUCS((__le16 *) bcc_ptr, user, 64,
2883 nls_codepage);
2884 len *= 2;
2885 SecurityBlob->UserName.MaximumLength =
2886 cpu_to_le16(len);
2887 SecurityBlob->UserName.Buffer =
2888 cpu_to_le32(SecurityBlobLength);
2889 bcc_ptr += len;
2890 SecurityBlobLength += len;
2891 SecurityBlob->UserName.Length =
2892 cpu_to_le16(len);
2895 /* SecurityBlob->WorkstationName.Length = cifs_strtoUCS((__le16 *) bcc_ptr, "AMACHINE",64, nls_codepage);
2896 SecurityBlob->WorkstationName.Length *= 2;
2897 SecurityBlob->WorkstationName.MaximumLength = cpu_to_le16(SecurityBlob->WorkstationName.Length);
2898 SecurityBlob->WorkstationName.Buffer = cpu_to_le32(SecurityBlobLength);
2899 bcc_ptr += SecurityBlob->WorkstationName.Length;
2900 SecurityBlobLength += SecurityBlob->WorkstationName.Length;
2901 SecurityBlob->WorkstationName.Length = cpu_to_le16(SecurityBlob->WorkstationName.Length); */
2903 if ((long) bcc_ptr % 2) {
2904 *bcc_ptr = 0;
2905 bcc_ptr++;
2907 bytes_returned =
2908 cifs_strtoUCS((__le16 *) bcc_ptr, "Linux version ",
2909 32, nls_codepage);
2910 bcc_ptr += 2 * bytes_returned;
2911 bytes_returned =
2912 cifs_strtoUCS((__le16 *) bcc_ptr, utsname()->release, 32,
2913 nls_codepage);
2914 bcc_ptr += 2 * bytes_returned;
2915 bcc_ptr += 2; /* null term version string */
2916 bytes_returned =
2917 cifs_strtoUCS((__le16 *) bcc_ptr, CIFS_NETWORK_OPSYS,
2918 64, nls_codepage);
2919 bcc_ptr += 2 * bytes_returned;
2920 *(bcc_ptr + 1) = 0;
2921 *(bcc_ptr + 2) = 0;
2922 bcc_ptr += 2; /* null terminate network opsys string */
2923 *(bcc_ptr + 1) = 0;
2924 *(bcc_ptr + 2) = 0;
2925 bcc_ptr += 2; /* null domain */
2926 } else { /* ASCII */
2927 if (domain == NULL) {
2928 SecurityBlob->DomainName.Buffer = 0;
2929 SecurityBlob->DomainName.Length = 0;
2930 SecurityBlob->DomainName.MaximumLength = 0;
2931 } else {
2932 __u16 len;
2933 negotiate_flags |= NTLMSSP_NEGOTIATE_DOMAIN_SUPPLIED;
2934 strncpy(bcc_ptr, domain, 63);
2935 len = strnlen(domain, 64);
2936 SecurityBlob->DomainName.MaximumLength =
2937 cpu_to_le16(len);
2938 SecurityBlob->DomainName.Buffer =
2939 cpu_to_le32(SecurityBlobLength);
2940 bcc_ptr += len;
2941 SecurityBlobLength += len;
2942 SecurityBlob->DomainName.Length = cpu_to_le16(len);
2944 if (user == NULL) {
2945 SecurityBlob->UserName.Buffer = 0;
2946 SecurityBlob->UserName.Length = 0;
2947 SecurityBlob->UserName.MaximumLength = 0;
2948 } else {
2949 __u16 len;
2950 strncpy(bcc_ptr, user, 63);
2951 len = strnlen(user, 64);
2952 SecurityBlob->UserName.MaximumLength =
2953 cpu_to_le16(len);
2954 SecurityBlob->UserName.Buffer =
2955 cpu_to_le32(SecurityBlobLength);
2956 bcc_ptr += len;
2957 SecurityBlobLength += len;
2958 SecurityBlob->UserName.Length = cpu_to_le16(len);
2960 /* BB fill in our workstation name if known BB */
2962 strcpy(bcc_ptr, "Linux version ");
2963 bcc_ptr += strlen("Linux version ");
2964 strcpy(bcc_ptr, utsname()->release);
2965 bcc_ptr += strlen(utsname()->release) + 1;
2966 strcpy(bcc_ptr, CIFS_NETWORK_OPSYS);
2967 bcc_ptr += strlen(CIFS_NETWORK_OPSYS) + 1;
2968 bcc_ptr++; /* null domain */
2969 *bcc_ptr = 0;
2971 SecurityBlob->NegotiateFlags = cpu_to_le32(negotiate_flags);
2972 pSMB->req.SecurityBlobLength = cpu_to_le16(SecurityBlobLength);
2973 count = (long) bcc_ptr - (long) pByteArea(smb_buffer);
2974 smb_buffer->smb_buf_length += count;
2975 pSMB->req.ByteCount = cpu_to_le16(count);
2977 rc = SendReceive(xid, ses, smb_buffer, smb_buffer_response,
2978 &bytes_returned, 1);
2979 if (rc) {
2980 /* rc = map_smb_to_linux_error(smb_buffer_response); *//* done in SendReceive now */
2981 } else if ((smb_buffer_response->WordCount == 3)
2982 || (smb_buffer_response->WordCount == 4)) {
2983 __u16 action = le16_to_cpu(pSMBr->resp.Action);
2984 __u16 blob_len =
2985 le16_to_cpu(pSMBr->resp.SecurityBlobLength);
2986 if (action & GUEST_LOGIN)
2987 cFYI(1, (" Guest login")); /* BB do we want to set anything in SesInfo struct ? */
2988 /* if(SecurityBlob2->MessageType != NtLm??){
2989 cFYI("Unexpected message type on auth response is %d "));
2990 } */
2991 if (ses) {
2992 cFYI(1,
2993 ("Does UID on challenge %d match auth response UID %d ",
2994 ses->Suid, smb_buffer_response->Uid));
2995 ses->Suid = smb_buffer_response->Uid; /* UID left in wire format */
2996 bcc_ptr = pByteArea(smb_buffer_response);
2997 /* response can have either 3 or 4 word count - Samba sends 3 */
2998 if ((pSMBr->resp.hdr.WordCount == 3)
2999 || ((pSMBr->resp.hdr.WordCount == 4)
3000 && (blob_len <
3001 pSMBr->resp.ByteCount))) {
3002 if (pSMBr->resp.hdr.WordCount == 4) {
3003 bcc_ptr +=
3004 blob_len;
3005 cFYI(1,
3006 ("Security Blob Length %d ",
3007 blob_len));
3010 cFYI(1,
3011 ("NTLMSSP response to Authenticate "));
3013 if (smb_buffer->Flags2 & SMBFLG2_UNICODE) {
3014 if ((long) (bcc_ptr) % 2) {
3015 remaining_words =
3016 (BCC(smb_buffer_response)
3017 - 1) / 2;
3018 bcc_ptr++; /* Unicode strings must be word aligned */
3019 } else {
3020 remaining_words = BCC(smb_buffer_response) / 2;
3022 len =
3023 UniStrnlen((wchar_t *) bcc_ptr,remaining_words - 1);
3024 /* We look for obvious messed up bcc or strings in response so we do not go off
3025 the end since (at least) WIN2K and Windows XP have a major bug in not null
3026 terminating last Unicode string in response */
3027 if(ses->serverOS)
3028 kfree(ses->serverOS);
3029 ses->serverOS =
3030 kzalloc(2 * (len + 1), GFP_KERNEL);
3031 cifs_strfromUCS_le(ses->serverOS,
3032 (__le16 *)
3033 bcc_ptr, len,
3034 nls_codepage);
3035 bcc_ptr += 2 * (len + 1);
3036 remaining_words -= len + 1;
3037 ses->serverOS[2 * len] = 0;
3038 ses->serverOS[1 + (2 * len)] = 0;
3039 if (remaining_words > 0) {
3040 len = UniStrnlen((wchar_t *)
3041 bcc_ptr,
3042 remaining_words
3043 - 1);
3044 kfree(ses->serverNOS);
3045 ses->serverNOS =
3046 kzalloc(2 * (len + 1),
3047 GFP_KERNEL);
3048 cifs_strfromUCS_le(ses->
3049 serverNOS,
3050 (__le16 *)
3051 bcc_ptr,
3052 len,
3053 nls_codepage);
3054 bcc_ptr += 2 * (len + 1);
3055 ses->serverNOS[2 * len] = 0;
3056 ses->serverNOS[1+(2*len)] = 0;
3057 remaining_words -= len + 1;
3058 if (remaining_words > 0) {
3059 len = UniStrnlen((wchar_t *) bcc_ptr, remaining_words);
3060 /* last string not always null terminated (e.g. for Windows XP & 2000) */
3061 if(ses->serverDomain)
3062 kfree(ses->serverDomain);
3063 ses->serverDomain =
3064 kzalloc(2 *
3065 (len +
3067 GFP_KERNEL);
3068 cifs_strfromUCS_le
3069 (ses->
3070 serverDomain,
3071 (__le16 *)
3072 bcc_ptr, len,
3073 nls_codepage);
3074 bcc_ptr +=
3075 2 * (len + 1);
3076 ses->
3077 serverDomain[2
3078 * len]
3079 = 0;
3080 ses->
3081 serverDomain[1
3085 len)]
3086 = 0;
3087 } /* else no more room so create dummy domain string */
3088 else {
3089 if(ses->serverDomain)
3090 kfree(ses->serverDomain);
3091 ses->serverDomain = kzalloc(2,GFP_KERNEL);
3093 } else { /* no room so create dummy domain and NOS string */
3094 if(ses->serverDomain)
3095 kfree(ses->serverDomain);
3096 ses->serverDomain = kzalloc(2, GFP_KERNEL);
3097 kfree(ses->serverNOS);
3098 ses->serverNOS = kzalloc(2, GFP_KERNEL);
3100 } else { /* ASCII */
3101 len = strnlen(bcc_ptr, 1024);
3102 if (((long) bcc_ptr + len) -
3103 (long) pByteArea(smb_buffer_response)
3104 <= BCC(smb_buffer_response)) {
3105 if(ses->serverOS)
3106 kfree(ses->serverOS);
3107 ses->serverOS = kzalloc(len + 1,GFP_KERNEL);
3108 strncpy(ses->serverOS,bcc_ptr, len);
3110 bcc_ptr += len;
3111 bcc_ptr[0] = 0; /* null terminate the string */
3112 bcc_ptr++;
3114 len = strnlen(bcc_ptr, 1024);
3115 kfree(ses->serverNOS);
3116 ses->serverNOS = kzalloc(len+1,GFP_KERNEL);
3117 strncpy(ses->serverNOS, bcc_ptr, len);
3118 bcc_ptr += len;
3119 bcc_ptr[0] = 0;
3120 bcc_ptr++;
3122 len = strnlen(bcc_ptr, 1024);
3123 if(ses->serverDomain)
3124 kfree(ses->serverDomain);
3125 ses->serverDomain = kzalloc(len+1,GFP_KERNEL);
3126 strncpy(ses->serverDomain, bcc_ptr, len);
3127 bcc_ptr += len;
3128 bcc_ptr[0] = 0;
3129 bcc_ptr++;
3130 } else
3131 cFYI(1,
3132 ("Variable field of length %d extends beyond end of smb ",
3133 len));
3135 } else {
3136 cERROR(1,
3137 (" Security Blob Length extends beyond end of SMB"));
3139 } else {
3140 cERROR(1, ("No session structure passed in."));
3142 } else {
3143 cERROR(1,
3144 (" Invalid Word count %d: ",
3145 smb_buffer_response->WordCount));
3146 rc = -EIO;
3149 if (smb_buffer)
3150 cifs_buf_release(smb_buffer);
3152 return rc;
3156 CIFSTCon(unsigned int xid, struct cifsSesInfo *ses,
3157 const char *tree, struct cifsTconInfo *tcon,
3158 const struct nls_table *nls_codepage)
3160 struct smb_hdr *smb_buffer;
3161 struct smb_hdr *smb_buffer_response;
3162 TCONX_REQ *pSMB;
3163 TCONX_RSP *pSMBr;
3164 unsigned char *bcc_ptr;
3165 int rc = 0;
3166 int length;
3167 __u16 count;
3169 if (ses == NULL)
3170 return -EIO;
3172 smb_buffer = cifs_buf_get();
3173 if (smb_buffer == NULL) {
3174 return -ENOMEM;
3176 smb_buffer_response = smb_buffer;
3178 header_assemble(smb_buffer, SMB_COM_TREE_CONNECT_ANDX,
3179 NULL /*no tid */ , 4 /*wct */ );
3181 smb_buffer->Mid = GetNextMid(ses->server);
3182 smb_buffer->Uid = ses->Suid;
3183 pSMB = (TCONX_REQ *) smb_buffer;
3184 pSMBr = (TCONX_RSP *) smb_buffer_response;
3186 pSMB->AndXCommand = 0xFF;
3187 pSMB->Flags = cpu_to_le16(TCON_EXTENDED_SECINFO);
3188 bcc_ptr = &pSMB->Password[0];
3189 if((ses->server->secMode) & SECMODE_USER) {
3190 pSMB->PasswordLength = cpu_to_le16(1); /* minimum */
3191 *bcc_ptr = 0; /* password is null byte */
3192 bcc_ptr++; /* skip password */
3193 /* already aligned so no need to do it below */
3194 } else {
3195 pSMB->PasswordLength = cpu_to_le16(CIFS_SESS_KEY_SIZE);
3196 /* BB FIXME add code to fail this if NTLMv2 or Kerberos
3197 specified as required (when that support is added to
3198 the vfs in the future) as only NTLM or the much
3199 weaker LANMAN (which we do not send by default) is accepted
3200 by Samba (not sure whether other servers allow
3201 NTLMv2 password here) */
3202 #ifdef CONFIG_CIFS_WEAK_PW_HASH
3203 if((extended_security & CIFSSEC_MAY_LANMAN) &&
3204 (ses->server->secType == LANMAN))
3205 calc_lanman_hash(ses, bcc_ptr);
3206 else
3207 #endif /* CIFS_WEAK_PW_HASH */
3208 SMBNTencrypt(ses->password,
3209 ses->server->cryptKey,
3210 bcc_ptr);
3212 bcc_ptr += CIFS_SESS_KEY_SIZE;
3213 if(ses->capabilities & CAP_UNICODE) {
3214 /* must align unicode strings */
3215 *bcc_ptr = 0; /* null byte password */
3216 bcc_ptr++;
3220 if(ses->server->secMode &
3221 (SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED))
3222 smb_buffer->Flags2 |= SMBFLG2_SECURITY_SIGNATURE;
3224 if (ses->capabilities & CAP_STATUS32) {
3225 smb_buffer->Flags2 |= SMBFLG2_ERR_STATUS;
3227 if (ses->capabilities & CAP_DFS) {
3228 smb_buffer->Flags2 |= SMBFLG2_DFS;
3230 if (ses->capabilities & CAP_UNICODE) {
3231 smb_buffer->Flags2 |= SMBFLG2_UNICODE;
3232 length =
3233 cifs_strtoUCS((__le16 *) bcc_ptr, tree,
3234 6 /* max utf8 char length in bytes */ *
3235 (/* server len*/ + 256 /* share len */), nls_codepage);
3236 bcc_ptr += 2 * length; /* convert num 16 bit words to bytes */
3237 bcc_ptr += 2; /* skip trailing null */
3238 } else { /* ASCII */
3239 strcpy(bcc_ptr, tree);
3240 bcc_ptr += strlen(tree) + 1;
3242 strcpy(bcc_ptr, "?????");
3243 bcc_ptr += strlen("?????");
3244 bcc_ptr += 1;
3245 count = bcc_ptr - &pSMB->Password[0];
3246 pSMB->hdr.smb_buf_length += count;
3247 pSMB->ByteCount = cpu_to_le16(count);
3249 rc = SendReceive(xid, ses, smb_buffer, smb_buffer_response, &length, 0);
3251 /* if (rc) rc = map_smb_to_linux_error(smb_buffer_response); */
3252 /* above now done in SendReceive */
3253 if ((rc == 0) && (tcon != NULL)) {
3254 tcon->tidStatus = CifsGood;
3255 tcon->tid = smb_buffer_response->Tid;
3256 bcc_ptr = pByteArea(smb_buffer_response);
3257 length = strnlen(bcc_ptr, BCC(smb_buffer_response) - 2);
3258 /* skip service field (NB: this field is always ASCII) */
3259 bcc_ptr += length + 1;
3260 strncpy(tcon->treeName, tree, MAX_TREE_SIZE);
3261 if (smb_buffer->Flags2 & SMBFLG2_UNICODE) {
3262 length = UniStrnlen((wchar_t *) bcc_ptr, 512);
3263 if ((bcc_ptr + (2 * length)) -
3264 pByteArea(smb_buffer_response) <=
3265 BCC(smb_buffer_response)) {
3266 kfree(tcon->nativeFileSystem);
3267 tcon->nativeFileSystem =
3268 kzalloc(length + 2, GFP_KERNEL);
3269 cifs_strfromUCS_le(tcon->nativeFileSystem,
3270 (__le16 *) bcc_ptr,
3271 length, nls_codepage);
3272 bcc_ptr += 2 * length;
3273 bcc_ptr[0] = 0; /* null terminate the string */
3274 bcc_ptr[1] = 0;
3275 bcc_ptr += 2;
3277 /* else do not bother copying these informational fields */
3278 } else {
3279 length = strnlen(bcc_ptr, 1024);
3280 if ((bcc_ptr + length) -
3281 pByteArea(smb_buffer_response) <=
3282 BCC(smb_buffer_response)) {
3283 kfree(tcon->nativeFileSystem);
3284 tcon->nativeFileSystem =
3285 kzalloc(length + 1, GFP_KERNEL);
3286 strncpy(tcon->nativeFileSystem, bcc_ptr,
3287 length);
3289 /* else do not bother copying these informational fields */
3291 if((smb_buffer_response->WordCount == 3) ||
3292 (smb_buffer_response->WordCount == 7))
3293 /* field is in same location */
3294 tcon->Flags = le16_to_cpu(pSMBr->OptionalSupport);
3295 else
3296 tcon->Flags = 0;
3297 cFYI(1, ("Tcon flags: 0x%x ", tcon->Flags));
3298 } else if ((rc == 0) && tcon == NULL) {
3299 /* all we need to save for IPC$ connection */
3300 ses->ipc_tid = smb_buffer_response->Tid;
3303 if (smb_buffer)
3304 cifs_buf_release(smb_buffer);
3305 return rc;
3309 cifs_umount(struct super_block *sb, struct cifs_sb_info *cifs_sb)
3311 int rc = 0;
3312 int xid;
3313 struct cifsSesInfo *ses = NULL;
3314 struct task_struct *cifsd_task;
3315 char * tmp;
3317 xid = GetXid();
3319 if (cifs_sb->tcon) {
3320 ses = cifs_sb->tcon->ses; /* save ptr to ses before delete tcon!*/
3321 rc = CIFSSMBTDis(xid, cifs_sb->tcon);
3322 if (rc == -EBUSY) {
3323 FreeXid(xid);
3324 return 0;
3326 tconInfoFree(cifs_sb->tcon);
3327 if ((ses) && (ses->server)) {
3328 /* save off task so we do not refer to ses later */
3329 cifsd_task = ses->server->tsk;
3330 cFYI(1, ("About to do SMBLogoff "));
3331 rc = CIFSSMBLogoff(xid, ses);
3332 if (rc == -EBUSY) {
3333 FreeXid(xid);
3334 return 0;
3335 } else if (rc == -ESHUTDOWN) {
3336 cFYI(1,("Waking up socket by sending it signal"));
3337 if(cifsd_task) {
3338 send_sig(SIGKILL,cifsd_task,1);
3339 kthread_stop(cifsd_task);
3341 rc = 0;
3342 } /* else - we have an smb session
3343 left on this socket do not kill cifsd */
3344 } else
3345 cFYI(1, ("No session or bad tcon"));
3348 cifs_sb->tcon = NULL;
3349 tmp = cifs_sb->prepath;
3350 cifs_sb->prepathlen = 0;
3351 cifs_sb->prepath = NULL;
3352 kfree(tmp);
3353 if (ses)
3354 schedule_timeout_interruptible(msecs_to_jiffies(500));
3355 if (ses)
3356 sesInfoFree(ses);
3358 FreeXid(xid);
3359 return rc; /* BB check if we should always return zero here */
3362 int cifs_setup_session(unsigned int xid, struct cifsSesInfo *pSesInfo,
3363 struct nls_table * nls_info)
3365 int rc = 0;
3366 char ntlm_session_key[CIFS_SESS_KEY_SIZE];
3367 int ntlmv2_flag = FALSE;
3368 int first_time = 0;
3370 /* what if server changes its buffer size after dropping the session? */
3371 if(pSesInfo->server->maxBuf == 0) /* no need to send on reconnect */ {
3372 rc = CIFSSMBNegotiate(xid, pSesInfo);
3373 if(rc == -EAGAIN) /* retry only once on 1st time connection */ {
3374 rc = CIFSSMBNegotiate(xid, pSesInfo);
3375 if(rc == -EAGAIN)
3376 rc = -EHOSTDOWN;
3378 if(rc == 0) {
3379 spin_lock(&GlobalMid_Lock);
3380 if(pSesInfo->server->tcpStatus != CifsExiting)
3381 pSesInfo->server->tcpStatus = CifsGood;
3382 else
3383 rc = -EHOSTDOWN;
3384 spin_unlock(&GlobalMid_Lock);
3387 first_time = 1;
3389 if (!rc) {
3390 pSesInfo->flags = 0;
3391 pSesInfo->capabilities = pSesInfo->server->capabilities;
3392 if(linuxExtEnabled == 0)
3393 pSesInfo->capabilities &= (~CAP_UNIX);
3394 /* pSesInfo->sequence_number = 0;*/
3395 cFYI(1,("Security Mode: 0x%x Capabilities: 0x%x TimeAdjust: %d",
3396 pSesInfo->server->secMode,
3397 pSesInfo->server->capabilities,
3398 pSesInfo->server->timeAdj));
3399 if(experimEnabled < 2)
3400 rc = CIFS_SessSetup(xid, pSesInfo,
3401 first_time, nls_info);
3402 else if (extended_security
3403 && (pSesInfo->capabilities
3404 & CAP_EXTENDED_SECURITY)
3405 && (pSesInfo->server->secType == NTLMSSP)) {
3406 rc = -EOPNOTSUPP;
3407 } else if (extended_security
3408 && (pSesInfo->capabilities & CAP_EXTENDED_SECURITY)
3409 && (pSesInfo->server->secType == RawNTLMSSP)) {
3410 cFYI(1, ("NTLMSSP sesssetup"));
3411 rc = CIFSNTLMSSPNegotiateSessSetup(xid,
3412 pSesInfo,
3413 &ntlmv2_flag,
3414 nls_info);
3415 if (!rc) {
3416 if(ntlmv2_flag) {
3417 char * v2_response;
3418 cFYI(1,("more secure NTLM ver2 hash"));
3419 if(CalcNTLMv2_partial_mac_key(pSesInfo,
3420 nls_info)) {
3421 rc = -ENOMEM;
3422 goto ss_err_exit;
3423 } else
3424 v2_response = kmalloc(16 + 64 /* blob */, GFP_KERNEL);
3425 if(v2_response) {
3426 CalcNTLMv2_response(pSesInfo,v2_response);
3427 /* if(first_time)
3428 cifs_calculate_ntlmv2_mac_key(
3429 pSesInfo->server->mac_signing_key,
3430 response, ntlm_session_key, */
3431 kfree(v2_response);
3432 /* BB Put dummy sig in SessSetup PDU? */
3433 } else {
3434 rc = -ENOMEM;
3435 goto ss_err_exit;
3438 } else {
3439 SMBNTencrypt(pSesInfo->password,
3440 pSesInfo->server->cryptKey,
3441 ntlm_session_key);
3443 if(first_time)
3444 cifs_calculate_mac_key(
3445 pSesInfo->server->mac_signing_key,
3446 ntlm_session_key,
3447 pSesInfo->password);
3449 /* for better security the weaker lanman hash not sent
3450 in AuthSessSetup so we no longer calculate it */
3452 rc = CIFSNTLMSSPAuthSessSetup(xid,
3453 pSesInfo,
3454 ntlm_session_key,
3455 ntlmv2_flag,
3456 nls_info);
3458 } else { /* old style NTLM 0.12 session setup */
3459 SMBNTencrypt(pSesInfo->password,
3460 pSesInfo->server->cryptKey,
3461 ntlm_session_key);
3463 if(first_time)
3464 cifs_calculate_mac_key(
3465 pSesInfo->server->mac_signing_key,
3466 ntlm_session_key, pSesInfo->password);
3468 rc = CIFSSessSetup(xid, pSesInfo,
3469 ntlm_session_key, nls_info);
3471 if (rc) {
3472 cERROR(1,("Send error in SessSetup = %d",rc));
3473 } else {
3474 cFYI(1,("CIFS Session Established successfully"));
3475 pSesInfo->status = CifsGood;
3478 ss_err_exit:
3479 return rc;