4 * Copyright (C) International Business Machines Corp., 2002,2011
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
22 #include <linux/net.h>
23 #include <linux/string.h>
24 #include <linux/list.h>
25 #include <linux/wait.h>
26 #include <linux/slab.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 <linux/namei.h>
37 #include <asm/uaccess.h>
38 #include <asm/processor.h>
39 #include <linux/inet.h>
40 #include <linux/module.h>
41 #include <keys/user-type.h>
43 #include <linux/parser.h>
47 #include "cifsproto.h"
48 #include "cifs_unicode.h"
49 #include "cifs_debug.h"
50 #include "cifs_fs_sb.h"
53 #include "rfc1002pdu.h"
57 #define RFC1001_PORT 139
59 extern mempool_t
*cifs_req_poolp
;
61 /* FIXME: should these be tunable? */
62 #define TLINK_ERROR_EXPIRE (1 * HZ)
63 #define TLINK_IDLE_EXPIRE (600 * HZ)
67 /* Mount options that take no arguments */
68 Opt_user_xattr
, Opt_nouser_xattr
,
69 Opt_forceuid
, Opt_noforceuid
,
70 Opt_forcegid
, Opt_noforcegid
,
71 Opt_noblocksend
, Opt_noautotune
,
72 Opt_hard
, Opt_soft
, Opt_perm
, Opt_noperm
,
73 Opt_mapchars
, Opt_nomapchars
, Opt_sfu
,
74 Opt_nosfu
, Opt_nodfs
, Opt_posixpaths
,
75 Opt_noposixpaths
, Opt_nounix
,
78 Opt_forcemandatorylock
, Opt_setuids
,
79 Opt_nosetuids
, Opt_dynperm
, Opt_nodynperm
,
80 Opt_nohard
, Opt_nosoft
,
82 Opt_nostrictsync
, Opt_strictsync
,
83 Opt_serverino
, Opt_noserverino
,
84 Opt_rwpidforward
, Opt_cifsacl
, Opt_nocifsacl
,
85 Opt_acl
, Opt_noacl
, Opt_locallease
,
86 Opt_sign
, Opt_seal
, Opt_noac
,
87 Opt_fsc
, Opt_mfsymlinks
,
88 Opt_multiuser
, Opt_sloppy
, Opt_nosharesock
,
90 /* Mount options which take numeric value */
91 Opt_backupuid
, Opt_backupgid
, Opt_uid
,
92 Opt_cruid
, Opt_gid
, Opt_file_mode
,
93 Opt_dirmode
, Opt_port
,
94 Opt_rsize
, Opt_wsize
, Opt_actimeo
,
96 /* Mount options which take string value */
97 Opt_user
, Opt_pass
, Opt_ip
,
98 Opt_domain
, Opt_srcaddr
, Opt_iocharset
,
99 Opt_netbiosname
, Opt_servern
,
100 Opt_ver
, Opt_vers
, Opt_sec
, Opt_cache
,
102 /* Mount options to be ignored */
105 /* Options which could be blank */
113 static const match_table_t cifs_mount_option_tokens
= {
115 { Opt_user_xattr
, "user_xattr" },
116 { Opt_nouser_xattr
, "nouser_xattr" },
117 { Opt_forceuid
, "forceuid" },
118 { Opt_noforceuid
, "noforceuid" },
119 { Opt_forcegid
, "forcegid" },
120 { Opt_noforcegid
, "noforcegid" },
121 { Opt_noblocksend
, "noblocksend" },
122 { Opt_noautotune
, "noautotune" },
123 { Opt_hard
, "hard" },
124 { Opt_soft
, "soft" },
125 { Opt_perm
, "perm" },
126 { Opt_noperm
, "noperm" },
127 { Opt_mapchars
, "mapchars" },
128 { Opt_nomapchars
, "nomapchars" },
130 { Opt_nosfu
, "nosfu" },
131 { Opt_nodfs
, "nodfs" },
132 { Opt_posixpaths
, "posixpaths" },
133 { Opt_noposixpaths
, "noposixpaths" },
134 { Opt_nounix
, "nounix" },
135 { Opt_nounix
, "nolinux" },
136 { Opt_nocase
, "nocase" },
137 { Opt_nocase
, "ignorecase" },
139 { Opt_nobrl
, "nobrl" },
140 { Opt_nobrl
, "nolock" },
141 { Opt_forcemandatorylock
, "forcemandatorylock" },
142 { Opt_forcemandatorylock
, "forcemand" },
143 { Opt_setuids
, "setuids" },
144 { Opt_nosetuids
, "nosetuids" },
145 { Opt_dynperm
, "dynperm" },
146 { Opt_nodynperm
, "nodynperm" },
147 { Opt_nohard
, "nohard" },
148 { Opt_nosoft
, "nosoft" },
149 { Opt_nointr
, "nointr" },
150 { Opt_intr
, "intr" },
151 { Opt_nostrictsync
, "nostrictsync" },
152 { Opt_strictsync
, "strictsync" },
153 { Opt_serverino
, "serverino" },
154 { Opt_noserverino
, "noserverino" },
155 { Opt_rwpidforward
, "rwpidforward" },
156 { Opt_cifsacl
, "cifsacl" },
157 { Opt_nocifsacl
, "nocifsacl" },
159 { Opt_noacl
, "noacl" },
160 { Opt_locallease
, "locallease" },
161 { Opt_sign
, "sign" },
162 { Opt_seal
, "seal" },
163 { Opt_noac
, "noac" },
165 { Opt_mfsymlinks
, "mfsymlinks" },
166 { Opt_multiuser
, "multiuser" },
167 { Opt_sloppy
, "sloppy" },
168 { Opt_nosharesock
, "nosharesock" },
170 { Opt_backupuid
, "backupuid=%s" },
171 { Opt_backupgid
, "backupgid=%s" },
172 { Opt_uid
, "uid=%s" },
173 { Opt_cruid
, "cruid=%s" },
174 { Opt_gid
, "gid=%s" },
175 { Opt_file_mode
, "file_mode=%s" },
176 { Opt_dirmode
, "dirmode=%s" },
177 { Opt_dirmode
, "dir_mode=%s" },
178 { Opt_port
, "port=%s" },
179 { Opt_rsize
, "rsize=%s" },
180 { Opt_wsize
, "wsize=%s" },
181 { Opt_actimeo
, "actimeo=%s" },
183 { Opt_blank_user
, "user=" },
184 { Opt_blank_user
, "username=" },
185 { Opt_user
, "user=%s" },
186 { Opt_user
, "username=%s" },
187 { Opt_blank_pass
, "pass=" },
188 { Opt_blank_pass
, "password=" },
189 { Opt_pass
, "pass=%s" },
190 { Opt_pass
, "password=%s" },
191 { Opt_blank_ip
, "ip=" },
192 { Opt_blank_ip
, "addr=" },
194 { Opt_ip
, "addr=%s" },
195 { Opt_ignore
, "unc=%s" },
196 { Opt_ignore
, "target=%s" },
197 { Opt_ignore
, "path=%s" },
198 { Opt_domain
, "dom=%s" },
199 { Opt_domain
, "domain=%s" },
200 { Opt_domain
, "workgroup=%s" },
201 { Opt_srcaddr
, "srcaddr=%s" },
202 { Opt_ignore
, "prefixpath=%s" },
203 { Opt_iocharset
, "iocharset=%s" },
204 { Opt_netbiosname
, "netbiosname=%s" },
205 { Opt_servern
, "servern=%s" },
206 { Opt_ver
, "ver=%s" },
207 { Opt_vers
, "vers=%s" },
208 { Opt_sec
, "sec=%s" },
209 { Opt_cache
, "cache=%s" },
211 { Opt_ignore
, "cred" },
212 { Opt_ignore
, "credentials" },
213 { Opt_ignore
, "cred=%s" },
214 { Opt_ignore
, "credentials=%s" },
215 { Opt_ignore
, "guest" },
216 { Opt_ignore
, "rw" },
217 { Opt_ignore
, "ro" },
218 { Opt_ignore
, "suid" },
219 { Opt_ignore
, "nosuid" },
220 { Opt_ignore
, "exec" },
221 { Opt_ignore
, "noexec" },
222 { Opt_ignore
, "nodev" },
223 { Opt_ignore
, "noauto" },
224 { Opt_ignore
, "dev" },
225 { Opt_ignore
, "mand" },
226 { Opt_ignore
, "nomand" },
227 { Opt_ignore
, "_netdev" },
233 Opt_sec_krb5
, Opt_sec_krb5i
, Opt_sec_krb5p
,
234 Opt_sec_ntlmsspi
, Opt_sec_ntlmssp
,
235 Opt_ntlm
, Opt_sec_ntlmi
, Opt_sec_ntlmv2
,
236 Opt_sec_ntlmv2i
, Opt_sec_lanman
,
242 static const match_table_t cifs_secflavor_tokens
= {
243 { Opt_sec_krb5
, "krb5" },
244 { Opt_sec_krb5i
, "krb5i" },
245 { Opt_sec_krb5p
, "krb5p" },
246 { Opt_sec_ntlmsspi
, "ntlmsspi" },
247 { Opt_sec_ntlmssp
, "ntlmssp" },
248 { Opt_ntlm
, "ntlm" },
249 { Opt_sec_ntlmi
, "ntlmi" },
250 { Opt_sec_ntlmv2
, "nontlm" },
251 { Opt_sec_ntlmv2
, "ntlmv2" },
252 { Opt_sec_ntlmv2i
, "ntlmv2i" },
253 { Opt_sec_lanman
, "lanman" },
254 { Opt_sec_none
, "none" },
256 { Opt_sec_err
, NULL
}
267 static const match_table_t cifs_cacheflavor_tokens
= {
268 { Opt_cache_loose
, "loose" },
269 { Opt_cache_strict
, "strict" },
270 { Opt_cache_none
, "none" },
271 { Opt_cache_err
, NULL
}
274 static const match_table_t cifs_smb_version_tokens
= {
275 { Smb_1
, SMB1_VERSION_STRING
},
276 { Smb_20
, SMB20_VERSION_STRING
},
277 { Smb_21
, SMB21_VERSION_STRING
},
278 { Smb_30
, SMB30_VERSION_STRING
},
279 { Smb_302
, SMB302_VERSION_STRING
},
282 static int ip_connect(struct TCP_Server_Info
*server
);
283 static int generic_ip_connect(struct TCP_Server_Info
*server
);
284 static void tlink_rb_insert(struct rb_root
*root
, struct tcon_link
*new_tlink
);
285 static void cifs_prune_tlinks(struct work_struct
*work
);
286 static int cifs_setup_volume_info(struct smb_vol
*volume_info
, char *mount_data
,
287 const char *devname
);
290 * cifs tcp session reconnection
292 * mark tcp session as reconnecting so temporarily locked
293 * mark all smb sessions as reconnecting for tcp session
294 * reconnect tcp session
295 * wake up waiters on reconnection? - (not needed currently)
298 cifs_reconnect(struct TCP_Server_Info
*server
)
301 struct list_head
*tmp
, *tmp2
;
302 struct cifs_ses
*ses
;
303 struct cifs_tcon
*tcon
;
304 struct mid_q_entry
*mid_entry
;
305 struct list_head retry_list
;
307 spin_lock(&GlobalMid_Lock
);
308 if (server
->tcpStatus
== CifsExiting
) {
309 /* the demux thread will exit normally
310 next time through the loop */
311 spin_unlock(&GlobalMid_Lock
);
314 server
->tcpStatus
= CifsNeedReconnect
;
315 spin_unlock(&GlobalMid_Lock
);
317 #ifdef CONFIG_CIFS_SMB2
318 server
->max_read
= 0;
321 cifs_dbg(FYI
, "Reconnecting tcp session\n");
323 /* before reconnecting the tcp session, mark the smb session (uid)
324 and the tid bad so they are not used until reconnected */
325 cifs_dbg(FYI
, "%s: marking sessions and tcons for reconnect\n",
327 spin_lock(&cifs_tcp_ses_lock
);
328 list_for_each(tmp
, &server
->smb_ses_list
) {
329 ses
= list_entry(tmp
, struct cifs_ses
, smb_ses_list
);
330 ses
->need_reconnect
= true;
332 list_for_each(tmp2
, &ses
->tcon_list
) {
333 tcon
= list_entry(tmp2
, struct cifs_tcon
, tcon_list
);
334 tcon
->need_reconnect
= true;
337 spin_unlock(&cifs_tcp_ses_lock
);
339 /* do not want to be sending data on a socket we are freeing */
340 cifs_dbg(FYI
, "%s: tearing down socket\n", __func__
);
341 mutex_lock(&server
->srv_mutex
);
342 if (server
->ssocket
) {
343 cifs_dbg(FYI
, "State: 0x%x Flags: 0x%lx\n",
344 server
->ssocket
->state
, server
->ssocket
->flags
);
345 kernel_sock_shutdown(server
->ssocket
, SHUT_WR
);
346 cifs_dbg(FYI
, "Post shutdown state: 0x%x Flags: 0x%lx\n",
347 server
->ssocket
->state
, server
->ssocket
->flags
);
348 sock_release(server
->ssocket
);
349 server
->ssocket
= NULL
;
351 server
->sequence_number
= 0;
352 server
->session_estab
= false;
353 kfree(server
->session_key
.response
);
354 server
->session_key
.response
= NULL
;
355 server
->session_key
.len
= 0;
356 server
->lstrp
= jiffies
;
357 mutex_unlock(&server
->srv_mutex
);
359 /* mark submitted MIDs for retry and issue callback */
360 INIT_LIST_HEAD(&retry_list
);
361 cifs_dbg(FYI
, "%s: moving mids to private list\n", __func__
);
362 spin_lock(&GlobalMid_Lock
);
363 list_for_each_safe(tmp
, tmp2
, &server
->pending_mid_q
) {
364 mid_entry
= list_entry(tmp
, struct mid_q_entry
, qhead
);
365 if (mid_entry
->mid_state
== MID_REQUEST_SUBMITTED
)
366 mid_entry
->mid_state
= MID_RETRY_NEEDED
;
367 list_move(&mid_entry
->qhead
, &retry_list
);
369 spin_unlock(&GlobalMid_Lock
);
371 cifs_dbg(FYI
, "%s: issuing mid callbacks\n", __func__
);
372 list_for_each_safe(tmp
, tmp2
, &retry_list
) {
373 mid_entry
= list_entry(tmp
, struct mid_q_entry
, qhead
);
374 list_del_init(&mid_entry
->qhead
);
375 mid_entry
->callback(mid_entry
);
381 /* we should try only the port we connected to before */
382 mutex_lock(&server
->srv_mutex
);
383 rc
= generic_ip_connect(server
);
385 cifs_dbg(FYI
, "reconnect error %d\n", rc
);
388 atomic_inc(&tcpSesReconnectCount
);
389 spin_lock(&GlobalMid_Lock
);
390 if (server
->tcpStatus
!= CifsExiting
)
391 server
->tcpStatus
= CifsNeedNegotiate
;
392 spin_unlock(&GlobalMid_Lock
);
394 mutex_unlock(&server
->srv_mutex
);
395 } while (server
->tcpStatus
== CifsNeedReconnect
);
401 cifs_echo_request(struct work_struct
*work
)
404 struct TCP_Server_Info
*server
= container_of(work
,
405 struct TCP_Server_Info
, echo
.work
);
408 * We cannot send an echo if it is disabled or until the
409 * NEGOTIATE_PROTOCOL request is done, which is indicated by
410 * server->ops->need_neg() == true. Also, no need to ping if
411 * we got a response recently.
413 if (!server
->ops
->need_neg
|| server
->ops
->need_neg(server
) ||
414 (server
->ops
->can_echo
&& !server
->ops
->can_echo(server
)) ||
415 time_before(jiffies
, server
->lstrp
+ SMB_ECHO_INTERVAL
- HZ
))
418 rc
= server
->ops
->echo
? server
->ops
->echo(server
) : -ENOSYS
;
420 cifs_dbg(FYI
, "Unable to send echo request to server: %s\n",
424 queue_delayed_work(cifsiod_wq
, &server
->echo
, SMB_ECHO_INTERVAL
);
428 allocate_buffers(struct TCP_Server_Info
*server
)
430 if (!server
->bigbuf
) {
431 server
->bigbuf
= (char *)cifs_buf_get();
432 if (!server
->bigbuf
) {
433 cifs_dbg(VFS
, "No memory for large SMB response\n");
435 /* retry will check if exiting */
438 } else if (server
->large_buf
) {
439 /* we are reusing a dirty large buf, clear its start */
440 memset(server
->bigbuf
, 0, HEADER_SIZE(server
));
443 if (!server
->smallbuf
) {
444 server
->smallbuf
= (char *)cifs_small_buf_get();
445 if (!server
->smallbuf
) {
446 cifs_dbg(VFS
, "No memory for SMB response\n");
448 /* retry will check if exiting */
451 /* beginning of smb buffer is cleared in our buf_get */
453 /* if existing small buf clear beginning */
454 memset(server
->smallbuf
, 0, HEADER_SIZE(server
));
461 server_unresponsive(struct TCP_Server_Info
*server
)
464 * We need to wait 2 echo intervals to make sure we handle such
466 * 1s client sends a normal SMB request
467 * 2s client gets a response
468 * 30s echo workqueue job pops, and decides we got a response recently
469 * and don't need to send another
471 * 65s kernel_recvmsg times out, and we see that we haven't gotten
472 * a response in >60s.
474 if (server
->tcpStatus
== CifsGood
&&
475 time_after(jiffies
, server
->lstrp
+ 2 * SMB_ECHO_INTERVAL
)) {
476 cifs_dbg(VFS
, "Server %s has not responded in %d seconds. Reconnecting...\n",
477 server
->hostname
, (2 * SMB_ECHO_INTERVAL
) / HZ
);
478 cifs_reconnect(server
);
479 wake_up(&server
->response_q
);
487 * kvec_array_init - clone a kvec array, and advance into it
488 * @new: pointer to memory for cloned array
489 * @iov: pointer to original array
490 * @nr_segs: number of members in original array
491 * @bytes: number of bytes to advance into the cloned array
493 * This function will copy the array provided in iov to a section of memory
494 * and advance the specified number of bytes into the new array. It returns
495 * the number of segments in the new array. "new" must be at least as big as
496 * the original iov array.
499 kvec_array_init(struct kvec
*new, struct kvec
*iov
, unsigned int nr_segs
,
504 while (bytes
|| !iov
->iov_len
) {
505 int copy
= min(bytes
, iov
->iov_len
);
509 if (iov
->iov_len
== base
) {
515 memcpy(new, iov
, sizeof(*iov
) * nr_segs
);
516 new->iov_base
+= base
;
517 new->iov_len
-= base
;
522 get_server_iovec(struct TCP_Server_Info
*server
, unsigned int nr_segs
)
524 struct kvec
*new_iov
;
526 if (server
->iov
&& nr_segs
<= server
->nr_iov
)
529 /* not big enough -- allocate a new one and release the old */
530 new_iov
= kmalloc(sizeof(*new_iov
) * nr_segs
, GFP_NOFS
);
533 server
->iov
= new_iov
;
534 server
->nr_iov
= nr_segs
;
540 cifs_readv_from_socket(struct TCP_Server_Info
*server
, struct kvec
*iov_orig
,
541 unsigned int nr_segs
, unsigned int to_read
)
546 struct msghdr smb_msg
;
549 iov
= get_server_iovec(server
, nr_segs
);
553 smb_msg
.msg_control
= NULL
;
554 smb_msg
.msg_controllen
= 0;
556 for (total_read
= 0; to_read
; total_read
+= length
, to_read
-= length
) {
559 if (server_unresponsive(server
)) {
560 total_read
= -EAGAIN
;
564 segs
= kvec_array_init(iov
, iov_orig
, nr_segs
, total_read
);
566 length
= kernel_recvmsg(server
->ssocket
, &smb_msg
,
567 iov
, segs
, to_read
, 0);
569 if (server
->tcpStatus
== CifsExiting
) {
570 total_read
= -ESHUTDOWN
;
572 } else if (server
->tcpStatus
== CifsNeedReconnect
) {
573 cifs_reconnect(server
);
574 total_read
= -EAGAIN
;
576 } else if (length
== -ERESTARTSYS
||
580 * Minimum sleep to prevent looping, allowing socket
581 * to clear and app threads to set tcpStatus
582 * CifsNeedReconnect if server hung.
584 usleep_range(1000, 2000);
587 } else if (length
<= 0) {
588 cifs_dbg(FYI
, "Received no data or error: expecting %d\n"
589 "got %d", to_read
, length
);
590 cifs_reconnect(server
);
591 total_read
= -EAGAIN
;
599 cifs_read_from_socket(struct TCP_Server_Info
*server
, char *buf
,
600 unsigned int to_read
)
605 iov
.iov_len
= to_read
;
607 return cifs_readv_from_socket(server
, &iov
, 1, to_read
);
611 is_smb_response(struct TCP_Server_Info
*server
, unsigned char type
)
614 * The first byte big endian of the length field,
615 * is actually not part of the length but the type
616 * with the most common, zero, as regular data.
619 case RFC1002_SESSION_MESSAGE
:
620 /* Regular SMB response */
622 case RFC1002_SESSION_KEEP_ALIVE
:
623 cifs_dbg(FYI
, "RFC 1002 session keep alive\n");
625 case RFC1002_POSITIVE_SESSION_RESPONSE
:
626 cifs_dbg(FYI
, "RFC 1002 positive session response\n");
628 case RFC1002_NEGATIVE_SESSION_RESPONSE
:
630 * We get this from Windows 98 instead of an error on
631 * SMB negprot response.
633 cifs_dbg(FYI
, "RFC 1002 negative session response\n");
634 /* give server a second to clean up */
637 * Always try 445 first on reconnect since we get NACK
638 * on some if we ever connected to port 139 (the NACK
639 * is since we do not begin with RFC1001 session
642 cifs_set_port((struct sockaddr
*)&server
->dstaddr
, CIFS_PORT
);
643 cifs_reconnect(server
);
644 wake_up(&server
->response_q
);
647 cifs_dbg(VFS
, "RFC 1002 unknown response type 0x%x\n", type
);
648 cifs_reconnect(server
);
655 dequeue_mid(struct mid_q_entry
*mid
, bool malformed
)
657 #ifdef CONFIG_CIFS_STATS2
658 mid
->when_received
= jiffies
;
660 spin_lock(&GlobalMid_Lock
);
662 mid
->mid_state
= MID_RESPONSE_RECEIVED
;
664 mid
->mid_state
= MID_RESPONSE_MALFORMED
;
665 list_del_init(&mid
->qhead
);
666 spin_unlock(&GlobalMid_Lock
);
670 handle_mid(struct mid_q_entry
*mid
, struct TCP_Server_Info
*server
,
671 char *buf
, int malformed
)
673 if (server
->ops
->check_trans2
&&
674 server
->ops
->check_trans2(mid
, server
, buf
, malformed
))
677 mid
->large_buf
= server
->large_buf
;
678 /* Was previous buf put in mpx struct for multi-rsp? */
679 if (!mid
->multiRsp
) {
680 /* smb buffer will be freed by user thread */
681 if (server
->large_buf
)
682 server
->bigbuf
= NULL
;
684 server
->smallbuf
= NULL
;
686 dequeue_mid(mid
, malformed
);
689 static void clean_demultiplex_info(struct TCP_Server_Info
*server
)
693 /* take it off the list, if it's not already */
694 spin_lock(&cifs_tcp_ses_lock
);
695 list_del_init(&server
->tcp_ses_list
);
696 spin_unlock(&cifs_tcp_ses_lock
);
698 spin_lock(&GlobalMid_Lock
);
699 server
->tcpStatus
= CifsExiting
;
700 spin_unlock(&GlobalMid_Lock
);
701 wake_up_all(&server
->response_q
);
703 /* check if we have blocked requests that need to free */
704 spin_lock(&server
->req_lock
);
705 if (server
->credits
<= 0)
707 spin_unlock(&server
->req_lock
);
709 * Although there should not be any requests blocked on this queue it
710 * can not hurt to be paranoid and try to wake up requests that may
711 * haven been blocked when more than 50 at time were on the wire to the
712 * same server - they now will see the session is in exit state and get
713 * out of SendReceive.
715 wake_up_all(&server
->request_q
);
716 /* give those requests time to exit */
719 if (server
->ssocket
) {
720 sock_release(server
->ssocket
);
721 server
->ssocket
= NULL
;
724 if (!list_empty(&server
->pending_mid_q
)) {
725 struct list_head dispose_list
;
726 struct mid_q_entry
*mid_entry
;
727 struct list_head
*tmp
, *tmp2
;
729 INIT_LIST_HEAD(&dispose_list
);
730 spin_lock(&GlobalMid_Lock
);
731 list_for_each_safe(tmp
, tmp2
, &server
->pending_mid_q
) {
732 mid_entry
= list_entry(tmp
, struct mid_q_entry
, qhead
);
733 cifs_dbg(FYI
, "Clearing mid 0x%llx\n", mid_entry
->mid
);
734 mid_entry
->mid_state
= MID_SHUTDOWN
;
735 list_move(&mid_entry
->qhead
, &dispose_list
);
737 spin_unlock(&GlobalMid_Lock
);
739 /* now walk dispose list and issue callbacks */
740 list_for_each_safe(tmp
, tmp2
, &dispose_list
) {
741 mid_entry
= list_entry(tmp
, struct mid_q_entry
, qhead
);
742 cifs_dbg(FYI
, "Callback mid 0x%llx\n", mid_entry
->mid
);
743 list_del_init(&mid_entry
->qhead
);
744 mid_entry
->callback(mid_entry
);
746 /* 1/8th of sec is more than enough time for them to exit */
750 if (!list_empty(&server
->pending_mid_q
)) {
752 * mpx threads have not exited yet give them at least the smb
753 * send timeout time for long ops.
755 * Due to delays on oplock break requests, we need to wait at
756 * least 45 seconds before giving up on a request getting a
757 * response and going ahead and killing cifsd.
759 cifs_dbg(FYI
, "Wait for exit from demultiplex thread\n");
762 * If threads still have not exited they are probably never
763 * coming home not much else we can do but free the memory.
767 kfree(server
->hostname
);
771 length
= atomic_dec_return(&tcpSesAllocCount
);
773 mempool_resize(cifs_req_poolp
, length
+ cifs_min_rcv
,
778 standard_receive3(struct TCP_Server_Info
*server
, struct mid_q_entry
*mid
)
781 char *buf
= server
->smallbuf
;
782 unsigned int pdu_length
= get_rfc1002_length(buf
);
784 /* make sure this will fit in a large buffer */
785 if (pdu_length
> CIFSMaxBufSize
+ MAX_HEADER_SIZE(server
) - 4) {
786 cifs_dbg(VFS
, "SMB response too long (%u bytes)\n", pdu_length
);
787 cifs_reconnect(server
);
788 wake_up(&server
->response_q
);
792 /* switch to large buffer if too big for a small one */
793 if (pdu_length
> MAX_CIFS_SMALL_BUFFER_SIZE
- 4) {
794 server
->large_buf
= true;
795 memcpy(server
->bigbuf
, buf
, server
->total_read
);
796 buf
= server
->bigbuf
;
799 /* now read the rest */
800 length
= cifs_read_from_socket(server
, buf
+ HEADER_SIZE(server
) - 1,
801 pdu_length
- HEADER_SIZE(server
) + 1 + 4);
804 server
->total_read
+= length
;
806 dump_smb(buf
, server
->total_read
);
809 * We know that we received enough to get to the MID as we
810 * checked the pdu_length earlier. Now check to see
811 * if the rest of the header is OK. We borrow the length
812 * var for the rest of the loop to avoid a new stack var.
814 * 48 bytes is enough to display the header and a little bit
815 * into the payload for debugging purposes.
817 length
= server
->ops
->check_message(buf
, server
->total_read
);
819 cifs_dump_mem("Bad SMB: ", buf
,
820 min_t(unsigned int, server
->total_read
, 48));
822 if (server
->ops
->is_status_pending
&&
823 server
->ops
->is_status_pending(buf
, server
, length
))
829 handle_mid(mid
, server
, buf
, length
);
834 cifs_demultiplex_thread(void *p
)
837 struct TCP_Server_Info
*server
= p
;
838 unsigned int pdu_length
;
840 struct task_struct
*task_to_wake
= NULL
;
841 struct mid_q_entry
*mid_entry
;
843 current
->flags
|= PF_MEMALLOC
;
844 cifs_dbg(FYI
, "Demultiplex PID: %d\n", task_pid_nr(current
));
846 length
= atomic_inc_return(&tcpSesAllocCount
);
848 mempool_resize(cifs_req_poolp
, length
+ cifs_min_rcv
,
852 while (server
->tcpStatus
!= CifsExiting
) {
856 if (!allocate_buffers(server
))
859 server
->large_buf
= false;
860 buf
= server
->smallbuf
;
861 pdu_length
= 4; /* enough to get RFC1001 header */
863 length
= cifs_read_from_socket(server
, buf
, pdu_length
);
866 server
->total_read
= length
;
869 * The right amount was read from socket - 4 bytes,
870 * so we can now interpret the length field.
872 pdu_length
= get_rfc1002_length(buf
);
874 cifs_dbg(FYI
, "RFC1002 header 0x%x\n", pdu_length
);
875 if (!is_smb_response(server
, buf
[0]))
878 /* make sure we have enough to get to the MID */
879 if (pdu_length
< HEADER_SIZE(server
) - 1 - 4) {
880 cifs_dbg(VFS
, "SMB response too short (%u bytes)\n",
882 cifs_reconnect(server
);
883 wake_up(&server
->response_q
);
887 /* read down to the MID */
888 length
= cifs_read_from_socket(server
, buf
+ 4,
889 HEADER_SIZE(server
) - 1 - 4);
892 server
->total_read
+= length
;
894 mid_entry
= server
->ops
->find_mid(server
, buf
);
896 if (!mid_entry
|| !mid_entry
->receive
)
897 length
= standard_receive3(server
, mid_entry
);
899 length
= mid_entry
->receive(server
, mid_entry
);
904 if (server
->large_buf
)
905 buf
= server
->bigbuf
;
907 server
->lstrp
= jiffies
;
908 if (mid_entry
!= NULL
) {
909 if (!mid_entry
->multiRsp
|| mid_entry
->multiEnd
)
910 mid_entry
->callback(mid_entry
);
911 } else if (!server
->ops
->is_oplock_break
||
912 !server
->ops
->is_oplock_break(buf
, server
)) {
913 cifs_dbg(VFS
, "No task to wake, unknown frame received! NumMids %d\n",
914 atomic_read(&midCount
));
915 cifs_dump_mem("Received Data is: ", buf
,
916 HEADER_SIZE(server
));
917 #ifdef CONFIG_CIFS_DEBUG2
918 if (server
->ops
->dump_detail
)
919 server
->ops
->dump_detail(buf
);
920 cifs_dump_mids(server
);
921 #endif /* CIFS_DEBUG2 */
924 } /* end while !EXITING */
926 /* buffer usually freed in free_mid - need to free it here on exit */
927 cifs_buf_release(server
->bigbuf
);
928 if (server
->smallbuf
) /* no sense logging a debug message if NULL */
929 cifs_small_buf_release(server
->smallbuf
);
931 task_to_wake
= xchg(&server
->tsk
, NULL
);
932 clean_demultiplex_info(server
);
934 /* if server->tsk was NULL then wait for a signal before exiting */
936 set_current_state(TASK_INTERRUPTIBLE
);
937 while (!signal_pending(current
)) {
939 set_current_state(TASK_INTERRUPTIBLE
);
941 set_current_state(TASK_RUNNING
);
944 module_put_and_exit(0);
947 /* extract the host portion of the UNC string */
949 extract_hostname(const char *unc
)
955 /* skip double chars at beginning of string */
956 /* BB: check validity of these bytes? */
959 /* delimiter between hostname and sharename is always '\\' now */
960 delim
= strchr(src
, '\\');
962 return ERR_PTR(-EINVAL
);
965 dst
= kmalloc((len
+ 1), GFP_KERNEL
);
967 return ERR_PTR(-ENOMEM
);
969 memcpy(dst
, src
, len
);
975 static int get_option_ul(substring_t args
[], unsigned long *option
)
980 string
= match_strdup(args
);
983 rc
= kstrtoul(string
, 0, option
);
989 static int get_option_uid(substring_t args
[], kuid_t
*result
)
995 rc
= get_option_ul(args
, &value
);
999 uid
= make_kuid(current_user_ns(), value
);
1000 if (!uid_valid(uid
))
1007 static int get_option_gid(substring_t args
[], kgid_t
*result
)
1009 unsigned long value
;
1013 rc
= get_option_ul(args
, &value
);
1017 gid
= make_kgid(current_user_ns(), value
);
1018 if (!gid_valid(gid
))
1025 static int cifs_parse_security_flavors(char *value
,
1026 struct smb_vol
*vol
)
1029 substring_t args
[MAX_OPT_ARGS
];
1032 * With mount options, the last one should win. Reset any existing
1033 * settings back to default.
1035 vol
->sectype
= Unspecified
;
1038 switch (match_token(value
, cifs_secflavor_tokens
, args
)) {
1040 cifs_dbg(VFS
, "sec=krb5p is not supported!\n");
1046 vol
->sectype
= Kerberos
;
1048 case Opt_sec_ntlmsspi
:
1051 case Opt_sec_ntlmssp
:
1052 vol
->sectype
= RawNTLMSSP
;
1058 vol
->sectype
= NTLM
;
1060 case Opt_sec_ntlmv2i
:
1063 case Opt_sec_ntlmv2
:
1064 vol
->sectype
= NTLMv2
;
1066 #ifdef CONFIG_CIFS_WEAK_PW_HASH
1067 case Opt_sec_lanman
:
1068 vol
->sectype
= LANMAN
;
1075 cifs_dbg(VFS
, "bad security option: %s\n", value
);
1083 cifs_parse_cache_flavor(char *value
, struct smb_vol
*vol
)
1085 substring_t args
[MAX_OPT_ARGS
];
1087 switch (match_token(value
, cifs_cacheflavor_tokens
, args
)) {
1088 case Opt_cache_loose
:
1089 vol
->direct_io
= false;
1090 vol
->strict_io
= false;
1092 case Opt_cache_strict
:
1093 vol
->direct_io
= false;
1094 vol
->strict_io
= true;
1096 case Opt_cache_none
:
1097 vol
->direct_io
= true;
1098 vol
->strict_io
= false;
1101 cifs_dbg(VFS
, "bad cache= option: %s\n", value
);
1108 cifs_parse_smb_version(char *value
, struct smb_vol
*vol
)
1110 substring_t args
[MAX_OPT_ARGS
];
1112 switch (match_token(value
, cifs_smb_version_tokens
, args
)) {
1114 vol
->ops
= &smb1_operations
;
1115 vol
->vals
= &smb1_values
;
1117 #ifdef CONFIG_CIFS_SMB2
1119 vol
->ops
= &smb20_operations
;
1120 vol
->vals
= &smb20_values
;
1123 vol
->ops
= &smb21_operations
;
1124 vol
->vals
= &smb21_values
;
1127 vol
->ops
= &smb30_operations
;
1128 vol
->vals
= &smb30_values
;
1131 vol
->ops
= &smb30_operations
; /* currently identical with 3.0 */
1132 vol
->vals
= &smb302_values
;
1136 cifs_dbg(VFS
, "Unknown vers= option specified: %s\n", value
);
1143 * Parse a devname into substrings and populate the vol->UNC and vol->prepath
1144 * fields with the result. Returns 0 on success and an error otherwise.
1147 cifs_parse_devname(const char *devname
, struct smb_vol
*vol
)
1150 const char *delims
= "/\\";
1153 /* make sure we have a valid UNC double delimiter prefix */
1154 len
= strspn(devname
, delims
);
1158 /* find delimiter between host and sharename */
1159 pos
= strpbrk(devname
+ 2, delims
);
1163 /* skip past delimiter */
1166 /* now go until next delimiter or end of string */
1167 len
= strcspn(pos
, delims
);
1169 /* move "pos" up to delimiter or NULL */
1171 vol
->UNC
= kstrndup(devname
, pos
- devname
, GFP_KERNEL
);
1175 convert_delimiter(vol
->UNC
, '\\');
1177 /* If pos is NULL, or is a bogus trailing delimiter then no prepath */
1178 if (!*pos
++ || !*pos
)
1181 vol
->prepath
= kstrdup(pos
, GFP_KERNEL
);
1189 cifs_parse_mount_options(const char *mountdata
, const char *devname
,
1190 struct smb_vol
*vol
)
1193 char *mountdata_copy
= NULL
, *options
;
1194 unsigned int temp_len
, i
, j
;
1196 short int override_uid
= -1;
1197 short int override_gid
= -1;
1198 bool uid_specified
= false;
1199 bool gid_specified
= false;
1200 bool sloppy
= false;
1201 char *invalid
= NULL
;
1202 char *nodename
= utsname()->nodename
;
1203 char *string
= NULL
;
1204 char *tmp_end
, *value
;
1206 bool got_ip
= false;
1207 unsigned short port
= 0;
1208 struct sockaddr
*dstaddr
= (struct sockaddr
*)&vol
->dstaddr
;
1212 delim
= separator
[0];
1214 /* ensure we always start with zeroed-out smb_vol */
1215 memset(vol
, 0, sizeof(*vol
));
1218 * does not have to be perfect mapping since field is
1219 * informational, only used for servers that do not support
1220 * port 445 and it can be overridden at mount time
1222 memset(vol
->source_rfc1001_name
, 0x20, RFC1001_NAME_LEN
);
1223 for (i
= 0; i
< strnlen(nodename
, RFC1001_NAME_LEN
); i
++)
1224 vol
->source_rfc1001_name
[i
] = toupper(nodename
[i
]);
1226 vol
->source_rfc1001_name
[RFC1001_NAME_LEN
] = 0;
1227 /* null target name indicates to use *SMBSERVR default called name
1228 if we end up sending RFC1001 session initialize */
1229 vol
->target_rfc1001_name
[0] = 0;
1230 vol
->cred_uid
= current_uid();
1231 vol
->linux_uid
= current_uid();
1232 vol
->linux_gid
= current_gid();
1234 /* default to only allowing write access to owner of the mount */
1235 vol
->dir_mode
= vol
->file_mode
= S_IRUGO
| S_IXUGO
| S_IWUSR
;
1237 /* vol->retry default is 0 (i.e. "soft" limited retry not hard retry) */
1238 /* default is always to request posix paths. */
1239 vol
->posix_paths
= 1;
1240 /* default to using server inode numbers where available */
1241 vol
->server_ino
= 1;
1243 /* default is to use strict cifs caching semantics */
1244 vol
->strict_io
= true;
1246 vol
->actimeo
= CIFS_DEF_ACTIMEO
;
1248 /* FIXME: add autonegotiation -- for now, SMB1 is default */
1249 vol
->ops
= &smb1_operations
;
1250 vol
->vals
= &smb1_values
;
1253 goto cifs_parse_mount_err
;
1255 mountdata_copy
= kstrndup(mountdata
, PAGE_SIZE
, GFP_KERNEL
);
1256 if (!mountdata_copy
)
1257 goto cifs_parse_mount_err
;
1259 options
= mountdata_copy
;
1260 end
= options
+ strlen(options
);
1262 if (strncmp(options
, "sep=", 4) == 0) {
1263 if (options
[4] != 0) {
1264 separator
[0] = options
[4];
1267 cifs_dbg(FYI
, "Null separator not allowed\n");
1270 vol
->backupuid_specified
= false; /* no backup intent for a user */
1271 vol
->backupgid_specified
= false; /* no backup intent for a group */
1273 switch (cifs_parse_devname(devname
, vol
)) {
1277 cifs_dbg(VFS
, "Unable to allocate memory for devname.\n");
1278 goto cifs_parse_mount_err
;
1280 cifs_dbg(VFS
, "Malformed UNC in devname.\n");
1281 goto cifs_parse_mount_err
;
1283 cifs_dbg(VFS
, "Unknown error parsing devname.\n");
1284 goto cifs_parse_mount_err
;
1287 while ((data
= strsep(&options
, separator
)) != NULL
) {
1288 substring_t args
[MAX_OPT_ARGS
];
1289 unsigned long option
;
1295 token
= match_token(data
, cifs_mount_option_tokens
, args
);
1299 /* Ingnore the following */
1303 /* Boolean values */
1304 case Opt_user_xattr
:
1307 case Opt_nouser_xattr
:
1313 case Opt_noforceuid
:
1319 case Opt_noforcegid
:
1322 case Opt_noblocksend
:
1323 vol
->noblocksnd
= 1;
1325 case Opt_noautotune
:
1326 vol
->noautotune
= 1;
1343 case Opt_nomapchars
:
1355 case Opt_posixpaths
:
1356 vol
->posix_paths
= 1;
1358 case Opt_noposixpaths
:
1359 vol
->posix_paths
= 0;
1362 vol
->no_linux_ext
= 1;
1373 * turn off mandatory locking in mode
1374 * if remote locking is turned off since the
1375 * local vfs will do advisory
1377 if (vol
->file_mode
==
1378 (S_IALLUGO
& ~(S_ISUID
| S_IXGRP
)))
1379 vol
->file_mode
= S_IALLUGO
;
1381 case Opt_forcemandatorylock
:
1391 vol
->dynperm
= true;
1394 vol
->dynperm
= false;
1408 case Opt_nostrictsync
:
1409 vol
->nostrictsync
= 1;
1411 case Opt_strictsync
:
1412 vol
->nostrictsync
= 0;
1415 vol
->server_ino
= 1;
1417 case Opt_noserverino
:
1418 vol
->server_ino
= 0;
1420 case Opt_rwpidforward
:
1421 vol
->rwpidforward
= 1;
1430 vol
->no_psx_acl
= 0;
1433 vol
->no_psx_acl
= 1;
1435 case Opt_locallease
:
1436 vol
->local_lease
= 1;
1442 /* we do not do the following in secFlags because seal
1443 * is a per tree connection (mount) not a per socket
1444 * or per-smb connection option in the protocol
1445 * vol->secFlg |= CIFSSEC_MUST_SEAL;
1450 printk(KERN_WARNING
"CIFS: Mount option noac not "
1451 "supported. Instead set "
1452 "/proc/fs/cifs/LookupCacheEnabled to 0\n");
1455 #ifndef CONFIG_CIFS_FSCACHE
1456 cifs_dbg(VFS
, "FS-Cache support needs CONFIG_CIFS_FSCACHE kernel config option set\n");
1457 goto cifs_parse_mount_err
;
1461 case Opt_mfsymlinks
:
1462 vol
->mfsymlinks
= true;
1465 vol
->multiuser
= true;
1470 case Opt_nosharesock
:
1471 vol
->nosharesock
= true;
1474 /* Numeric Values */
1476 if (get_option_uid(args
, &vol
->backupuid
)) {
1477 cifs_dbg(VFS
, "%s: Invalid backupuid value\n",
1479 goto cifs_parse_mount_err
;
1481 vol
->backupuid_specified
= true;
1484 if (get_option_gid(args
, &vol
->backupgid
)) {
1485 cifs_dbg(VFS
, "%s: Invalid backupgid value\n",
1487 goto cifs_parse_mount_err
;
1489 vol
->backupgid_specified
= true;
1492 if (get_option_uid(args
, &vol
->linux_uid
)) {
1493 cifs_dbg(VFS
, "%s: Invalid uid value\n",
1495 goto cifs_parse_mount_err
;
1497 uid_specified
= true;
1500 if (get_option_uid(args
, &vol
->cred_uid
)) {
1501 cifs_dbg(VFS
, "%s: Invalid cruid value\n",
1503 goto cifs_parse_mount_err
;
1507 if (get_option_gid(args
, &vol
->linux_gid
)) {
1508 cifs_dbg(VFS
, "%s: Invalid gid value\n",
1510 goto cifs_parse_mount_err
;
1512 gid_specified
= true;
1515 if (get_option_ul(args
, &option
)) {
1516 cifs_dbg(VFS
, "%s: Invalid file_mode value\n",
1518 goto cifs_parse_mount_err
;
1520 vol
->file_mode
= option
;
1523 if (get_option_ul(args
, &option
)) {
1524 cifs_dbg(VFS
, "%s: Invalid dir_mode value\n",
1526 goto cifs_parse_mount_err
;
1528 vol
->dir_mode
= option
;
1531 if (get_option_ul(args
, &option
) ||
1532 option
> USHRT_MAX
) {
1533 cifs_dbg(VFS
, "%s: Invalid port value\n",
1535 goto cifs_parse_mount_err
;
1537 port
= (unsigned short)option
;
1540 if (get_option_ul(args
, &option
)) {
1541 cifs_dbg(VFS
, "%s: Invalid rsize value\n",
1543 goto cifs_parse_mount_err
;
1545 vol
->rsize
= option
;
1548 if (get_option_ul(args
, &option
)) {
1549 cifs_dbg(VFS
, "%s: Invalid wsize value\n",
1551 goto cifs_parse_mount_err
;
1553 vol
->wsize
= option
;
1556 if (get_option_ul(args
, &option
)) {
1557 cifs_dbg(VFS
, "%s: Invalid actimeo value\n",
1559 goto cifs_parse_mount_err
;
1561 vol
->actimeo
= HZ
* option
;
1562 if (vol
->actimeo
> CIFS_MAX_ACTIMEO
) {
1563 cifs_dbg(VFS
, "attribute cache timeout too large\n");
1564 goto cifs_parse_mount_err
;
1568 /* String Arguments */
1570 case Opt_blank_user
:
1571 /* null user, ie. anonymous authentication */
1573 vol
->username
= NULL
;
1576 string
= match_strdup(args
);
1580 if (strnlen(string
, CIFS_MAX_USERNAME_LEN
) >
1581 CIFS_MAX_USERNAME_LEN
) {
1582 printk(KERN_WARNING
"CIFS: username too long\n");
1583 goto cifs_parse_mount_err
;
1585 vol
->username
= kstrdup(string
, GFP_KERNEL
);
1587 goto cifs_parse_mount_err
;
1589 case Opt_blank_pass
:
1590 /* passwords have to be handled differently
1591 * to allow the character used for deliminator
1592 * to be passed within them
1596 * Check if this is a case where the password
1597 * starts with a delimiter
1599 tmp_end
= strchr(data
, '=');
1601 if (!(tmp_end
< end
&& tmp_end
[1] == delim
)) {
1602 /* No it is not. Set the password to NULL */
1603 vol
->password
= NULL
;
1606 /* Yes it is. Drop down to Opt_pass below.*/
1608 /* Obtain the value string */
1609 value
= strchr(data
, '=');
1612 /* Set tmp_end to end of the string */
1613 tmp_end
= (char *) value
+ strlen(value
);
1615 /* Check if following character is the deliminator
1616 * If yes, we have encountered a double deliminator
1617 * reset the NULL character to the deliminator
1619 if (tmp_end
< end
&& tmp_end
[1] == delim
) {
1622 /* Keep iterating until we get to a single
1623 * deliminator OR the end
1625 while ((tmp_end
= strchr(tmp_end
, delim
))
1626 != NULL
&& (tmp_end
[1] == delim
)) {
1627 tmp_end
= (char *) &tmp_end
[2];
1630 /* Reset var options to point to next element */
1633 options
= (char *) &tmp_end
[1];
1635 /* Reached the end of the mount option
1640 /* Now build new password string */
1641 temp_len
= strlen(value
);
1642 vol
->password
= kzalloc(temp_len
+1, GFP_KERNEL
);
1643 if (vol
->password
== NULL
) {
1644 printk(KERN_WARNING
"CIFS: no memory "
1646 goto cifs_parse_mount_err
;
1649 for (i
= 0, j
= 0; i
< temp_len
; i
++, j
++) {
1650 vol
->password
[j
] = value
[i
];
1651 if ((value
[i
] == delim
) &&
1652 value
[i
+1] == delim
)
1653 /* skip the second deliminator */
1656 vol
->password
[j
] = '\0';
1659 /* FIXME: should this be an error instead? */
1663 string
= match_strdup(args
);
1667 if (!cifs_convert_address(dstaddr
, string
,
1669 printk(KERN_ERR
"CIFS: bad ip= option (%s).\n",
1671 goto cifs_parse_mount_err
;
1676 string
= match_strdup(args
);
1680 if (strnlen(string
, CIFS_MAX_DOMAINNAME_LEN
)
1681 == CIFS_MAX_DOMAINNAME_LEN
) {
1682 printk(KERN_WARNING
"CIFS: domain name too"
1684 goto cifs_parse_mount_err
;
1687 vol
->domainname
= kstrdup(string
, GFP_KERNEL
);
1688 if (!vol
->domainname
) {
1689 printk(KERN_WARNING
"CIFS: no memory "
1690 "for domainname\n");
1691 goto cifs_parse_mount_err
;
1693 cifs_dbg(FYI
, "Domain name set\n");
1696 string
= match_strdup(args
);
1700 if (!cifs_convert_address(
1701 (struct sockaddr
*)&vol
->srcaddr
,
1702 string
, strlen(string
))) {
1703 printk(KERN_WARNING
"CIFS: Could not parse"
1704 " srcaddr: %s\n", string
);
1705 goto cifs_parse_mount_err
;
1709 string
= match_strdup(args
);
1713 if (strnlen(string
, 1024) >= 65) {
1714 printk(KERN_WARNING
"CIFS: iocharset name "
1716 goto cifs_parse_mount_err
;
1719 if (strnicmp(string
, "default", 7) != 0) {
1720 vol
->iocharset
= kstrdup(string
,
1722 if (!vol
->iocharset
) {
1723 printk(KERN_WARNING
"CIFS: no memory"
1725 goto cifs_parse_mount_err
;
1728 /* if iocharset not set then load_nls_default
1731 cifs_dbg(FYI
, "iocharset set to %s\n", string
);
1733 case Opt_netbiosname
:
1734 string
= match_strdup(args
);
1738 memset(vol
->source_rfc1001_name
, 0x20,
1741 * FIXME: are there cases in which a comma can
1742 * be valid in workstation netbios name (and
1743 * need special handling)?
1745 for (i
= 0; i
< RFC1001_NAME_LEN
; i
++) {
1746 /* don't ucase netbiosname for user */
1749 vol
->source_rfc1001_name
[i
] = string
[i
];
1751 /* The string has 16th byte zero still from
1752 * set at top of the function
1754 if (i
== RFC1001_NAME_LEN
&& string
[i
] != 0)
1755 printk(KERN_WARNING
"CIFS: netbiosname"
1756 " longer than 15 truncated.\n");
1760 /* servernetbiosname specified override *SMBSERVER */
1761 string
= match_strdup(args
);
1765 /* last byte, type, is 0x20 for servr type */
1766 memset(vol
->target_rfc1001_name
, 0x20,
1767 RFC1001_NAME_LEN_WITH_NULL
);
1769 /* BB are there cases in which a comma can be
1770 valid in this workstation netbios name
1771 (and need special handling)? */
1773 /* user or mount helper must uppercase the
1775 for (i
= 0; i
< 15; i
++) {
1778 vol
->target_rfc1001_name
[i
] = string
[i
];
1780 /* The string has 16th byte zero still from
1781 set at top of the function */
1782 if (i
== RFC1001_NAME_LEN
&& string
[i
] != 0)
1783 printk(KERN_WARNING
"CIFS: server net"
1784 "biosname longer than 15 truncated.\n");
1787 string
= match_strdup(args
);
1791 if (strnicmp(string
, "1", 1) == 0) {
1792 /* This is the default */
1795 /* For all other value, error */
1796 printk(KERN_WARNING
"CIFS: Invalid version"
1798 goto cifs_parse_mount_err
;
1800 string
= match_strdup(args
);
1804 if (cifs_parse_smb_version(string
, vol
) != 0)
1805 goto cifs_parse_mount_err
;
1808 string
= match_strdup(args
);
1812 if (cifs_parse_security_flavors(string
, vol
) != 0)
1813 goto cifs_parse_mount_err
;
1816 string
= match_strdup(args
);
1820 if (cifs_parse_cache_flavor(string
, vol
) != 0)
1821 goto cifs_parse_mount_err
;
1825 * An option we don't recognize. Save it off for later
1826 * if we haven't already found one
1832 /* Free up any allocated string */
1837 if (!sloppy
&& invalid
) {
1838 printk(KERN_ERR
"CIFS: Unknown mount option \"%s\"\n", invalid
);
1839 goto cifs_parse_mount_err
;
1843 /* Muliuser mounts require CONFIG_KEYS support */
1844 if (vol
->multiuser
) {
1845 cifs_dbg(VFS
, "Multiuser mounts require kernels with CONFIG_KEYS enabled\n");
1846 goto cifs_parse_mount_err
;
1850 cifs_dbg(VFS
, "CIFS mount error: No usable UNC path provided in device string!\n");
1851 goto cifs_parse_mount_err
;
1854 /* make sure UNC has a share name */
1855 if (!strchr(vol
->UNC
+ 3, '\\')) {
1856 cifs_dbg(VFS
, "Malformed UNC. Unable to find share name.\n");
1857 goto cifs_parse_mount_err
;
1861 /* No ip= option specified? Try to get it from UNC */
1862 if (!cifs_convert_address(dstaddr
, &vol
->UNC
[2],
1863 strlen(&vol
->UNC
[2]))) {
1864 printk(KERN_ERR
"Unable to determine destination "
1866 goto cifs_parse_mount_err
;
1870 /* set the port that we got earlier */
1871 cifs_set_port(dstaddr
, port
);
1874 vol
->override_uid
= override_uid
;
1875 else if (override_uid
== 1)
1876 printk(KERN_NOTICE
"CIFS: ignoring forceuid mount option "
1877 "specified with no uid= option.\n");
1880 vol
->override_gid
= override_gid
;
1881 else if (override_gid
== 1)
1882 printk(KERN_NOTICE
"CIFS: ignoring forcegid mount option "
1883 "specified with no gid= option.\n");
1885 kfree(mountdata_copy
);
1889 printk(KERN_WARNING
"Could not allocate temporary buffer\n");
1890 cifs_parse_mount_err
:
1892 kfree(mountdata_copy
);
1896 /** Returns true if srcaddr isn't specified and rhs isn't
1897 * specified, or if srcaddr is specified and
1898 * matches the IP address of the rhs argument.
1901 srcip_matches(struct sockaddr
*srcaddr
, struct sockaddr
*rhs
)
1903 switch (srcaddr
->sa_family
) {
1905 return (rhs
->sa_family
== AF_UNSPEC
);
1907 struct sockaddr_in
*saddr4
= (struct sockaddr_in
*)srcaddr
;
1908 struct sockaddr_in
*vaddr4
= (struct sockaddr_in
*)rhs
;
1909 return (saddr4
->sin_addr
.s_addr
== vaddr4
->sin_addr
.s_addr
);
1912 struct sockaddr_in6
*saddr6
= (struct sockaddr_in6
*)srcaddr
;
1913 struct sockaddr_in6
*vaddr6
= (struct sockaddr_in6
*)rhs
;
1914 return ipv6_addr_equal(&saddr6
->sin6_addr
, &vaddr6
->sin6_addr
);
1918 return false; /* don't expect to be here */
1923 * If no port is specified in addr structure, we try to match with 445 port
1924 * and if it fails - with 139 ports. It should be called only if address
1925 * families of server and addr are equal.
1928 match_port(struct TCP_Server_Info
*server
, struct sockaddr
*addr
)
1930 __be16 port
, *sport
;
1932 switch (addr
->sa_family
) {
1934 sport
= &((struct sockaddr_in
*) &server
->dstaddr
)->sin_port
;
1935 port
= ((struct sockaddr_in
*) addr
)->sin_port
;
1938 sport
= &((struct sockaddr_in6
*) &server
->dstaddr
)->sin6_port
;
1939 port
= ((struct sockaddr_in6
*) addr
)->sin6_port
;
1947 port
= htons(CIFS_PORT
);
1951 port
= htons(RFC1001_PORT
);
1954 return port
== *sport
;
1958 match_address(struct TCP_Server_Info
*server
, struct sockaddr
*addr
,
1959 struct sockaddr
*srcaddr
)
1961 switch (addr
->sa_family
) {
1963 struct sockaddr_in
*addr4
= (struct sockaddr_in
*)addr
;
1964 struct sockaddr_in
*srv_addr4
=
1965 (struct sockaddr_in
*)&server
->dstaddr
;
1967 if (addr4
->sin_addr
.s_addr
!= srv_addr4
->sin_addr
.s_addr
)
1972 struct sockaddr_in6
*addr6
= (struct sockaddr_in6
*)addr
;
1973 struct sockaddr_in6
*srv_addr6
=
1974 (struct sockaddr_in6
*)&server
->dstaddr
;
1976 if (!ipv6_addr_equal(&addr6
->sin6_addr
,
1977 &srv_addr6
->sin6_addr
))
1979 if (addr6
->sin6_scope_id
!= srv_addr6
->sin6_scope_id
)
1985 return false; /* don't expect to be here */
1988 if (!srcip_matches(srcaddr
, (struct sockaddr
*)&server
->srcaddr
))
1995 match_security(struct TCP_Server_Info
*server
, struct smb_vol
*vol
)
1998 * The select_sectype function should either return the vol->sectype
1999 * that was specified, or "Unspecified" if that sectype was not
2000 * compatible with the given NEGOTIATE request.
2002 if (select_sectype(server
, vol
->sectype
) == Unspecified
)
2006 * Now check if signing mode is acceptable. No need to check
2007 * global_secflags at this point since if MUST_SIGN is set then
2008 * the server->sign had better be too.
2010 if (vol
->sign
&& !server
->sign
)
2016 static int match_server(struct TCP_Server_Info
*server
, struct smb_vol
*vol
)
2018 struct sockaddr
*addr
= (struct sockaddr
*)&vol
->dstaddr
;
2020 if (vol
->nosharesock
)
2023 if ((server
->vals
!= vol
->vals
) || (server
->ops
!= vol
->ops
))
2026 if (!net_eq(cifs_net_ns(server
), current
->nsproxy
->net_ns
))
2029 if (!match_address(server
, addr
,
2030 (struct sockaddr
*)&vol
->srcaddr
))
2033 if (!match_port(server
, addr
))
2036 if (!match_security(server
, vol
))
2042 static struct TCP_Server_Info
*
2043 cifs_find_tcp_session(struct smb_vol
*vol
)
2045 struct TCP_Server_Info
*server
;
2047 spin_lock(&cifs_tcp_ses_lock
);
2048 list_for_each_entry(server
, &cifs_tcp_ses_list
, tcp_ses_list
) {
2049 if (!match_server(server
, vol
))
2052 ++server
->srv_count
;
2053 spin_unlock(&cifs_tcp_ses_lock
);
2054 cifs_dbg(FYI
, "Existing tcp session with server found\n");
2057 spin_unlock(&cifs_tcp_ses_lock
);
2062 cifs_put_tcp_session(struct TCP_Server_Info
*server
)
2064 struct task_struct
*task
;
2066 spin_lock(&cifs_tcp_ses_lock
);
2067 if (--server
->srv_count
> 0) {
2068 spin_unlock(&cifs_tcp_ses_lock
);
2072 put_net(cifs_net_ns(server
));
2074 list_del_init(&server
->tcp_ses_list
);
2075 spin_unlock(&cifs_tcp_ses_lock
);
2077 cancel_delayed_work_sync(&server
->echo
);
2079 spin_lock(&GlobalMid_Lock
);
2080 server
->tcpStatus
= CifsExiting
;
2081 spin_unlock(&GlobalMid_Lock
);
2083 cifs_crypto_shash_release(server
);
2084 cifs_fscache_release_client_cookie(server
);
2086 kfree(server
->session_key
.response
);
2087 server
->session_key
.response
= NULL
;
2088 server
->session_key
.len
= 0;
2090 task
= xchg(&server
->tsk
, NULL
);
2092 force_sig(SIGKILL
, task
);
2095 static struct TCP_Server_Info
*
2096 cifs_get_tcp_session(struct smb_vol
*volume_info
)
2098 struct TCP_Server_Info
*tcp_ses
= NULL
;
2101 cifs_dbg(FYI
, "UNC: %s\n", volume_info
->UNC
);
2103 /* see if we already have a matching tcp_ses */
2104 tcp_ses
= cifs_find_tcp_session(volume_info
);
2108 tcp_ses
= kzalloc(sizeof(struct TCP_Server_Info
), GFP_KERNEL
);
2114 tcp_ses
->ops
= volume_info
->ops
;
2115 tcp_ses
->vals
= volume_info
->vals
;
2116 cifs_set_net_ns(tcp_ses
, get_net(current
->nsproxy
->net_ns
));
2117 tcp_ses
->hostname
= extract_hostname(volume_info
->UNC
);
2118 if (IS_ERR(tcp_ses
->hostname
)) {
2119 rc
= PTR_ERR(tcp_ses
->hostname
);
2120 goto out_err_crypto_release
;
2123 tcp_ses
->noblocksnd
= volume_info
->noblocksnd
;
2124 tcp_ses
->noautotune
= volume_info
->noautotune
;
2125 tcp_ses
->tcp_nodelay
= volume_info
->sockopt_tcp_nodelay
;
2126 tcp_ses
->in_flight
= 0;
2127 tcp_ses
->credits
= 1;
2128 init_waitqueue_head(&tcp_ses
->response_q
);
2129 init_waitqueue_head(&tcp_ses
->request_q
);
2130 INIT_LIST_HEAD(&tcp_ses
->pending_mid_q
);
2131 mutex_init(&tcp_ses
->srv_mutex
);
2132 memcpy(tcp_ses
->workstation_RFC1001_name
,
2133 volume_info
->source_rfc1001_name
, RFC1001_NAME_LEN_WITH_NULL
);
2134 memcpy(tcp_ses
->server_RFC1001_name
,
2135 volume_info
->target_rfc1001_name
, RFC1001_NAME_LEN_WITH_NULL
);
2136 tcp_ses
->session_estab
= false;
2137 tcp_ses
->sequence_number
= 0;
2138 tcp_ses
->lstrp
= jiffies
;
2139 spin_lock_init(&tcp_ses
->req_lock
);
2140 INIT_LIST_HEAD(&tcp_ses
->tcp_ses_list
);
2141 INIT_LIST_HEAD(&tcp_ses
->smb_ses_list
);
2142 INIT_DELAYED_WORK(&tcp_ses
->echo
, cifs_echo_request
);
2143 memcpy(&tcp_ses
->srcaddr
, &volume_info
->srcaddr
,
2144 sizeof(tcp_ses
->srcaddr
));
2145 memcpy(&tcp_ses
->dstaddr
, &volume_info
->dstaddr
,
2146 sizeof(tcp_ses
->dstaddr
));
2147 #ifdef CONFIG_CIFS_SMB2
2148 get_random_bytes(tcp_ses
->client_guid
, SMB2_CLIENT_GUID_SIZE
);
2151 * at this point we are the only ones with the pointer
2152 * to the struct since the kernel thread not created yet
2153 * no need to spinlock this init of tcpStatus or srv_count
2155 tcp_ses
->tcpStatus
= CifsNew
;
2156 ++tcp_ses
->srv_count
;
2158 rc
= ip_connect(tcp_ses
);
2160 cifs_dbg(VFS
, "Error connecting to socket. Aborting operation.\n");
2161 goto out_err_crypto_release
;
2165 * since we're in a cifs function already, we know that
2166 * this will succeed. No need for try_module_get().
2168 __module_get(THIS_MODULE
);
2169 tcp_ses
->tsk
= kthread_run(cifs_demultiplex_thread
,
2171 if (IS_ERR(tcp_ses
->tsk
)) {
2172 rc
= PTR_ERR(tcp_ses
->tsk
);
2173 cifs_dbg(VFS
, "error %d create cifsd thread\n", rc
);
2174 module_put(THIS_MODULE
);
2175 goto out_err_crypto_release
;
2177 tcp_ses
->tcpStatus
= CifsNeedNegotiate
;
2179 /* thread spawned, put it on the list */
2180 spin_lock(&cifs_tcp_ses_lock
);
2181 list_add(&tcp_ses
->tcp_ses_list
, &cifs_tcp_ses_list
);
2182 spin_unlock(&cifs_tcp_ses_lock
);
2184 cifs_fscache_get_client_cookie(tcp_ses
);
2186 /* queue echo request delayed work */
2187 queue_delayed_work(cifsiod_wq
, &tcp_ses
->echo
, SMB_ECHO_INTERVAL
);
2191 out_err_crypto_release
:
2192 cifs_crypto_shash_release(tcp_ses
);
2194 put_net(cifs_net_ns(tcp_ses
));
2198 if (!IS_ERR(tcp_ses
->hostname
))
2199 kfree(tcp_ses
->hostname
);
2200 if (tcp_ses
->ssocket
)
2201 sock_release(tcp_ses
->ssocket
);
2207 static int match_session(struct cifs_ses
*ses
, struct smb_vol
*vol
)
2209 if (vol
->sectype
!= Unspecified
&&
2210 vol
->sectype
!= ses
->sectype
)
2213 switch (ses
->sectype
) {
2215 if (!uid_eq(vol
->cred_uid
, ses
->cred_uid
))
2219 /* NULL username means anonymous session */
2220 if (ses
->user_name
== NULL
) {
2226 /* anything else takes username/password */
2227 if (strncmp(ses
->user_name
,
2228 vol
->username
? vol
->username
: "",
2229 CIFS_MAX_USERNAME_LEN
))
2231 if (strlen(vol
->username
) != 0 &&
2232 ses
->password
!= NULL
&&
2233 strncmp(ses
->password
,
2234 vol
->password
? vol
->password
: "",
2235 CIFS_MAX_PASSWORD_LEN
))
2241 static struct cifs_ses
*
2242 cifs_find_smb_ses(struct TCP_Server_Info
*server
, struct smb_vol
*vol
)
2244 struct cifs_ses
*ses
;
2246 spin_lock(&cifs_tcp_ses_lock
);
2247 list_for_each_entry(ses
, &server
->smb_ses_list
, smb_ses_list
) {
2248 if (!match_session(ses
, vol
))
2251 spin_unlock(&cifs_tcp_ses_lock
);
2254 spin_unlock(&cifs_tcp_ses_lock
);
2259 cifs_put_smb_ses(struct cifs_ses
*ses
)
2262 struct TCP_Server_Info
*server
= ses
->server
;
2264 cifs_dbg(FYI
, "%s: ses_count=%d\n", __func__
, ses
->ses_count
);
2265 spin_lock(&cifs_tcp_ses_lock
);
2266 if (--ses
->ses_count
> 0) {
2267 spin_unlock(&cifs_tcp_ses_lock
);
2271 list_del_init(&ses
->smb_ses_list
);
2272 spin_unlock(&cifs_tcp_ses_lock
);
2274 if (ses
->status
== CifsGood
&& server
->ops
->logoff
) {
2276 server
->ops
->logoff(xid
, ses
);
2280 cifs_put_tcp_session(server
);
2285 /* strlen("cifs:a:") + CIFS_MAX_DOMAINNAME_LEN + 1 */
2286 #define CIFSCREDS_DESC_SIZE (7 + CIFS_MAX_DOMAINNAME_LEN + 1)
2288 /* Populate username and pw fields from keyring if possible */
2290 cifs_set_cifscreds(struct smb_vol
*vol
, struct cifs_ses
*ses
)
2293 char *desc
, *delim
, *payload
;
2296 struct TCP_Server_Info
*server
= ses
->server
;
2297 struct sockaddr_in
*sa
;
2298 struct sockaddr_in6
*sa6
;
2299 struct user_key_payload
*upayload
;
2301 desc
= kmalloc(CIFSCREDS_DESC_SIZE
, GFP_KERNEL
);
2305 /* try to find an address key first */
2306 switch (server
->dstaddr
.ss_family
) {
2308 sa
= (struct sockaddr_in
*)&server
->dstaddr
;
2309 sprintf(desc
, "cifs:a:%pI4", &sa
->sin_addr
.s_addr
);
2312 sa6
= (struct sockaddr_in6
*)&server
->dstaddr
;
2313 sprintf(desc
, "cifs:a:%pI6c", &sa6
->sin6_addr
.s6_addr
);
2316 cifs_dbg(FYI
, "Bad ss_family (%hu)\n",
2317 server
->dstaddr
.ss_family
);
2322 cifs_dbg(FYI
, "%s: desc=%s\n", __func__
, desc
);
2323 key
= request_key(&key_type_logon
, desc
, "");
2325 if (!ses
->domainName
) {
2326 cifs_dbg(FYI
, "domainName is NULL\n");
2331 /* didn't work, try to find a domain key */
2332 sprintf(desc
, "cifs:d:%s", ses
->domainName
);
2333 cifs_dbg(FYI
, "%s: desc=%s\n", __func__
, desc
);
2334 key
= request_key(&key_type_logon
, desc
, "");
2341 down_read(&key
->sem
);
2342 upayload
= key
->payload
.data
;
2343 if (IS_ERR_OR_NULL(upayload
)) {
2344 rc
= upayload
? PTR_ERR(upayload
) : -EINVAL
;
2348 /* find first : in payload */
2349 payload
= (char *)upayload
->data
;
2350 delim
= strnchr(payload
, upayload
->datalen
, ':');
2351 cifs_dbg(FYI
, "payload=%s\n", payload
);
2353 cifs_dbg(FYI
, "Unable to find ':' in payload (datalen=%d)\n",
2359 len
= delim
- payload
;
2360 if (len
> CIFS_MAX_USERNAME_LEN
|| len
<= 0) {
2361 cifs_dbg(FYI
, "Bad value from username search (len=%zd)\n",
2367 vol
->username
= kstrndup(payload
, len
, GFP_KERNEL
);
2368 if (!vol
->username
) {
2369 cifs_dbg(FYI
, "Unable to allocate %zd bytes for username\n",
2374 cifs_dbg(FYI
, "%s: username=%s\n", __func__
, vol
->username
);
2376 len
= key
->datalen
- (len
+ 1);
2377 if (len
> CIFS_MAX_PASSWORD_LEN
|| len
<= 0) {
2378 cifs_dbg(FYI
, "Bad len for password search (len=%zd)\n", len
);
2380 kfree(vol
->username
);
2381 vol
->username
= NULL
;
2386 vol
->password
= kstrndup(delim
, len
, GFP_KERNEL
);
2387 if (!vol
->password
) {
2388 cifs_dbg(FYI
, "Unable to allocate %zd bytes for password\n",
2391 kfree(vol
->username
);
2392 vol
->username
= NULL
;
2401 cifs_dbg(FYI
, "%s: returning %d\n", __func__
, rc
);
2404 #else /* ! CONFIG_KEYS */
2406 cifs_set_cifscreds(struct smb_vol
*vol
__attribute__((unused
)),
2407 struct cifs_ses
*ses
__attribute__((unused
)))
2411 #endif /* CONFIG_KEYS */
2413 static struct cifs_ses
*
2414 cifs_get_smb_ses(struct TCP_Server_Info
*server
, struct smb_vol
*volume_info
)
2418 struct cifs_ses
*ses
;
2419 struct sockaddr_in
*addr
= (struct sockaddr_in
*)&server
->dstaddr
;
2420 struct sockaddr_in6
*addr6
= (struct sockaddr_in6
*)&server
->dstaddr
;
2424 ses
= cifs_find_smb_ses(server
, volume_info
);
2426 cifs_dbg(FYI
, "Existing smb sess found (status=%d)\n",
2429 mutex_lock(&ses
->session_mutex
);
2430 rc
= cifs_negotiate_protocol(xid
, ses
);
2432 mutex_unlock(&ses
->session_mutex
);
2433 /* problem -- put our ses reference */
2434 cifs_put_smb_ses(ses
);
2438 if (ses
->need_reconnect
) {
2439 cifs_dbg(FYI
, "Session needs reconnect\n");
2440 rc
= cifs_setup_session(xid
, ses
,
2441 volume_info
->local_nls
);
2443 mutex_unlock(&ses
->session_mutex
);
2444 /* problem -- put our reference */
2445 cifs_put_smb_ses(ses
);
2450 mutex_unlock(&ses
->session_mutex
);
2452 /* existing SMB ses has a server reference already */
2453 cifs_put_tcp_session(server
);
2458 cifs_dbg(FYI
, "Existing smb sess not found\n");
2459 ses
= sesInfoAlloc();
2463 /* new SMB session uses our server ref */
2464 ses
->server
= server
;
2465 if (server
->dstaddr
.ss_family
== AF_INET6
)
2466 sprintf(ses
->serverName
, "%pI6", &addr6
->sin6_addr
);
2468 sprintf(ses
->serverName
, "%pI4", &addr
->sin_addr
);
2470 if (volume_info
->username
) {
2471 ses
->user_name
= kstrdup(volume_info
->username
, GFP_KERNEL
);
2472 if (!ses
->user_name
)
2476 /* volume_info->password freed at unmount */
2477 if (volume_info
->password
) {
2478 ses
->password
= kstrdup(volume_info
->password
, GFP_KERNEL
);
2482 if (volume_info
->domainname
) {
2483 ses
->domainName
= kstrdup(volume_info
->domainname
, GFP_KERNEL
);
2484 if (!ses
->domainName
)
2487 ses
->cred_uid
= volume_info
->cred_uid
;
2488 ses
->linux_uid
= volume_info
->linux_uid
;
2490 ses
->sectype
= volume_info
->sectype
;
2491 ses
->sign
= volume_info
->sign
;
2493 mutex_lock(&ses
->session_mutex
);
2494 rc
= cifs_negotiate_protocol(xid
, ses
);
2496 rc
= cifs_setup_session(xid
, ses
, volume_info
->local_nls
);
2497 mutex_unlock(&ses
->session_mutex
);
2501 /* success, put it on the list */
2502 spin_lock(&cifs_tcp_ses_lock
);
2503 list_add(&ses
->smb_ses_list
, &server
->smb_ses_list
);
2504 spin_unlock(&cifs_tcp_ses_lock
);
2515 static int match_tcon(struct cifs_tcon
*tcon
, const char *unc
)
2517 if (tcon
->tidStatus
== CifsExiting
)
2519 if (strncmp(tcon
->treeName
, unc
, MAX_TREE_SIZE
))
2524 static struct cifs_tcon
*
2525 cifs_find_tcon(struct cifs_ses
*ses
, const char *unc
)
2527 struct list_head
*tmp
;
2528 struct cifs_tcon
*tcon
;
2530 spin_lock(&cifs_tcp_ses_lock
);
2531 list_for_each(tmp
, &ses
->tcon_list
) {
2532 tcon
= list_entry(tmp
, struct cifs_tcon
, tcon_list
);
2533 if (!match_tcon(tcon
, unc
))
2536 spin_unlock(&cifs_tcp_ses_lock
);
2539 spin_unlock(&cifs_tcp_ses_lock
);
2544 cifs_put_tcon(struct cifs_tcon
*tcon
)
2547 struct cifs_ses
*ses
= tcon
->ses
;
2549 cifs_dbg(FYI
, "%s: tc_count=%d\n", __func__
, tcon
->tc_count
);
2550 spin_lock(&cifs_tcp_ses_lock
);
2551 if (--tcon
->tc_count
> 0) {
2552 spin_unlock(&cifs_tcp_ses_lock
);
2556 list_del_init(&tcon
->tcon_list
);
2557 spin_unlock(&cifs_tcp_ses_lock
);
2560 if (ses
->server
->ops
->tree_disconnect
)
2561 ses
->server
->ops
->tree_disconnect(xid
, tcon
);
2564 cifs_fscache_release_super_cookie(tcon
);
2566 cifs_put_smb_ses(ses
);
2569 static struct cifs_tcon
*
2570 cifs_get_tcon(struct cifs_ses
*ses
, struct smb_vol
*volume_info
)
2573 struct cifs_tcon
*tcon
;
2575 tcon
= cifs_find_tcon(ses
, volume_info
->UNC
);
2577 cifs_dbg(FYI
, "Found match on UNC path\n");
2578 /* existing tcon already has a reference */
2579 cifs_put_smb_ses(ses
);
2580 if (tcon
->seal
!= volume_info
->seal
)
2581 cifs_dbg(VFS
, "transport encryption setting conflicts with existing tid\n");
2585 if (!ses
->server
->ops
->tree_connect
) {
2590 tcon
= tconInfoAlloc();
2597 if (volume_info
->password
) {
2598 tcon
->password
= kstrdup(volume_info
->password
, GFP_KERNEL
);
2599 if (!tcon
->password
) {
2606 * BB Do we need to wrap session_mutex around this TCon call and Unix
2607 * SetFS as we do on SessSetup and reconnect?
2610 rc
= ses
->server
->ops
->tree_connect(xid
, ses
, volume_info
->UNC
, tcon
,
2611 volume_info
->local_nls
);
2613 cifs_dbg(FYI
, "Tcon rc = %d\n", rc
);
2617 if (volume_info
->nodfs
) {
2618 tcon
->Flags
&= ~SMB_SHARE_IS_IN_DFS
;
2619 cifs_dbg(FYI
, "DFS disabled (%d)\n", tcon
->Flags
);
2621 tcon
->seal
= volume_info
->seal
;
2623 * We can have only one retry value for a connection to a share so for
2624 * resources mounted more than once to the same server share the last
2625 * value passed in for the retry flag is used.
2627 tcon
->retry
= volume_info
->retry
;
2628 tcon
->nocase
= volume_info
->nocase
;
2629 tcon
->local_lease
= volume_info
->local_lease
;
2630 INIT_LIST_HEAD(&tcon
->pending_opens
);
2632 spin_lock(&cifs_tcp_ses_lock
);
2633 list_add(&tcon
->tcon_list
, &ses
->tcon_list
);
2634 spin_unlock(&cifs_tcp_ses_lock
);
2636 cifs_fscache_get_super_cookie(tcon
);
2646 cifs_put_tlink(struct tcon_link
*tlink
)
2648 if (!tlink
|| IS_ERR(tlink
))
2651 if (!atomic_dec_and_test(&tlink
->tl_count
) ||
2652 test_bit(TCON_LINK_IN_TREE
, &tlink
->tl_flags
)) {
2653 tlink
->tl_time
= jiffies
;
2657 if (!IS_ERR(tlink_tcon(tlink
)))
2658 cifs_put_tcon(tlink_tcon(tlink
));
2663 static inline struct tcon_link
*
2664 cifs_sb_master_tlink(struct cifs_sb_info
*cifs_sb
)
2666 return cifs_sb
->master_tlink
;
2670 compare_mount_options(struct super_block
*sb
, struct cifs_mnt_data
*mnt_data
)
2672 struct cifs_sb_info
*old
= CIFS_SB(sb
);
2673 struct cifs_sb_info
*new = mnt_data
->cifs_sb
;
2675 if ((sb
->s_flags
& CIFS_MS_MASK
) != (mnt_data
->flags
& CIFS_MS_MASK
))
2678 if ((old
->mnt_cifs_flags
& CIFS_MOUNT_MASK
) !=
2679 (new->mnt_cifs_flags
& CIFS_MOUNT_MASK
))
2683 * We want to share sb only if we don't specify an r/wsize or
2684 * specified r/wsize is greater than or equal to existing one.
2686 if (new->wsize
&& new->wsize
< old
->wsize
)
2689 if (new->rsize
&& new->rsize
< old
->rsize
)
2692 if (!uid_eq(old
->mnt_uid
, new->mnt_uid
) || !gid_eq(old
->mnt_gid
, new->mnt_gid
))
2695 if (old
->mnt_file_mode
!= new->mnt_file_mode
||
2696 old
->mnt_dir_mode
!= new->mnt_dir_mode
)
2699 if (strcmp(old
->local_nls
->charset
, new->local_nls
->charset
))
2702 if (old
->actimeo
!= new->actimeo
)
2709 cifs_match_super(struct super_block
*sb
, void *data
)
2711 struct cifs_mnt_data
*mnt_data
= (struct cifs_mnt_data
*)data
;
2712 struct smb_vol
*volume_info
;
2713 struct cifs_sb_info
*cifs_sb
;
2714 struct TCP_Server_Info
*tcp_srv
;
2715 struct cifs_ses
*ses
;
2716 struct cifs_tcon
*tcon
;
2717 struct tcon_link
*tlink
;
2720 spin_lock(&cifs_tcp_ses_lock
);
2721 cifs_sb
= CIFS_SB(sb
);
2722 tlink
= cifs_get_tlink(cifs_sb_master_tlink(cifs_sb
));
2723 if (IS_ERR(tlink
)) {
2724 spin_unlock(&cifs_tcp_ses_lock
);
2727 tcon
= tlink_tcon(tlink
);
2729 tcp_srv
= ses
->server
;
2731 volume_info
= mnt_data
->vol
;
2733 if (!match_server(tcp_srv
, volume_info
) ||
2734 !match_session(ses
, volume_info
) ||
2735 !match_tcon(tcon
, volume_info
->UNC
)) {
2740 rc
= compare_mount_options(sb
, mnt_data
);
2742 spin_unlock(&cifs_tcp_ses_lock
);
2743 cifs_put_tlink(tlink
);
2748 get_dfs_path(const unsigned int xid
, struct cifs_ses
*ses
, const char *old_path
,
2749 const struct nls_table
*nls_codepage
, unsigned int *num_referrals
,
2750 struct dfs_info3_param
**referrals
, int remap
)
2755 if (!ses
->server
->ops
->tree_connect
|| !ses
->server
->ops
->get_dfs_refer
)
2761 if (ses
->ipc_tid
== 0) {
2762 temp_unc
= kmalloc(2 /* for slashes */ +
2763 strnlen(ses
->serverName
, SERVER_NAME_LEN_WITH_NULL
* 2)
2764 + 1 + 4 /* slash IPC$ */ + 2, GFP_KERNEL
);
2765 if (temp_unc
== NULL
)
2769 strcpy(temp_unc
+ 2, ses
->serverName
);
2770 strcpy(temp_unc
+ 2 + strlen(ses
->serverName
), "\\IPC$");
2771 rc
= ses
->server
->ops
->tree_connect(xid
, ses
, temp_unc
, NULL
,
2773 cifs_dbg(FYI
, "Tcon rc = %d ipc_tid = %d\n", rc
, ses
->ipc_tid
);
2777 rc
= ses
->server
->ops
->get_dfs_refer(xid
, ses
, old_path
,
2778 referrals
, num_referrals
,
2779 nls_codepage
, remap
);
2781 * BB - map targetUNCs to dfs_info3 structures, here or in
2782 * ses->server->ops->get_dfs_refer.
2788 #ifdef CONFIG_DEBUG_LOCK_ALLOC
2789 static struct lock_class_key cifs_key
[2];
2790 static struct lock_class_key cifs_slock_key
[2];
2793 cifs_reclassify_socket4(struct socket
*sock
)
2795 struct sock
*sk
= sock
->sk
;
2796 BUG_ON(sock_owned_by_user(sk
));
2797 sock_lock_init_class_and_name(sk
, "slock-AF_INET-CIFS",
2798 &cifs_slock_key
[0], "sk_lock-AF_INET-CIFS", &cifs_key
[0]);
2802 cifs_reclassify_socket6(struct socket
*sock
)
2804 struct sock
*sk
= sock
->sk
;
2805 BUG_ON(sock_owned_by_user(sk
));
2806 sock_lock_init_class_and_name(sk
, "slock-AF_INET6-CIFS",
2807 &cifs_slock_key
[1], "sk_lock-AF_INET6-CIFS", &cifs_key
[1]);
2811 cifs_reclassify_socket4(struct socket
*sock
)
2816 cifs_reclassify_socket6(struct socket
*sock
)
2821 /* See RFC1001 section 14 on representation of Netbios names */
2822 static void rfc1002mangle(char *target
, char *source
, unsigned int length
)
2826 for (i
= 0, j
= 0; i
< (length
); i
++) {
2827 /* mask a nibble at a time and encode */
2828 target
[j
] = 'A' + (0x0F & (source
[i
] >> 4));
2829 target
[j
+1] = 'A' + (0x0F & source
[i
]);
2836 bind_socket(struct TCP_Server_Info
*server
)
2839 if (server
->srcaddr
.ss_family
!= AF_UNSPEC
) {
2840 /* Bind to the specified local IP address */
2841 struct socket
*socket
= server
->ssocket
;
2842 rc
= socket
->ops
->bind(socket
,
2843 (struct sockaddr
*) &server
->srcaddr
,
2844 sizeof(server
->srcaddr
));
2846 struct sockaddr_in
*saddr4
;
2847 struct sockaddr_in6
*saddr6
;
2848 saddr4
= (struct sockaddr_in
*)&server
->srcaddr
;
2849 saddr6
= (struct sockaddr_in6
*)&server
->srcaddr
;
2850 if (saddr6
->sin6_family
== AF_INET6
)
2851 cifs_dbg(VFS
, "Failed to bind to: %pI6c, error: %d\n",
2852 &saddr6
->sin6_addr
, rc
);
2854 cifs_dbg(VFS
, "Failed to bind to: %pI4, error: %d\n",
2855 &saddr4
->sin_addr
.s_addr
, rc
);
2862 ip_rfc1001_connect(struct TCP_Server_Info
*server
)
2866 * some servers require RFC1001 sessinit before sending
2867 * negprot - BB check reconnection in case where second
2868 * sessinit is sent but no second negprot
2870 struct rfc1002_session_packet
*ses_init_buf
;
2871 struct smb_hdr
*smb_buf
;
2872 ses_init_buf
= kzalloc(sizeof(struct rfc1002_session_packet
),
2875 ses_init_buf
->trailer
.session_req
.called_len
= 32;
2877 if (server
->server_RFC1001_name
&&
2878 server
->server_RFC1001_name
[0] != 0)
2879 rfc1002mangle(ses_init_buf
->trailer
.
2880 session_req
.called_name
,
2881 server
->server_RFC1001_name
,
2882 RFC1001_NAME_LEN_WITH_NULL
);
2884 rfc1002mangle(ses_init_buf
->trailer
.
2885 session_req
.called_name
,
2886 DEFAULT_CIFS_CALLED_NAME
,
2887 RFC1001_NAME_LEN_WITH_NULL
);
2889 ses_init_buf
->trailer
.session_req
.calling_len
= 32;
2892 * calling name ends in null (byte 16) from old smb
2895 if (server
->workstation_RFC1001_name
&&
2896 server
->workstation_RFC1001_name
[0] != 0)
2897 rfc1002mangle(ses_init_buf
->trailer
.
2898 session_req
.calling_name
,
2899 server
->workstation_RFC1001_name
,
2900 RFC1001_NAME_LEN_WITH_NULL
);
2902 rfc1002mangle(ses_init_buf
->trailer
.
2903 session_req
.calling_name
,
2905 RFC1001_NAME_LEN_WITH_NULL
);
2907 ses_init_buf
->trailer
.session_req
.scope1
= 0;
2908 ses_init_buf
->trailer
.session_req
.scope2
= 0;
2909 smb_buf
= (struct smb_hdr
*)ses_init_buf
;
2911 /* sizeof RFC1002_SESSION_REQUEST with no scope */
2912 smb_buf
->smb_buf_length
= cpu_to_be32(0x81000044);
2913 rc
= smb_send(server
, smb_buf
, 0x44);
2914 kfree(ses_init_buf
);
2916 * RFC1001 layer in at least one server
2917 * requires very short break before negprot
2918 * presumably because not expecting negprot
2919 * to follow so fast. This is a simple
2920 * solution that works without
2921 * complicating the code and causes no
2922 * significant slowing down on mount
2925 usleep_range(1000, 2000);
2928 * else the negprot may still work without this
2929 * even though malloc failed
2936 generic_ip_connect(struct TCP_Server_Info
*server
)
2941 struct socket
*socket
= server
->ssocket
;
2942 struct sockaddr
*saddr
;
2944 saddr
= (struct sockaddr
*) &server
->dstaddr
;
2946 if (server
->dstaddr
.ss_family
== AF_INET6
) {
2947 sport
= ((struct sockaddr_in6
*) saddr
)->sin6_port
;
2948 slen
= sizeof(struct sockaddr_in6
);
2951 sport
= ((struct sockaddr_in
*) saddr
)->sin_port
;
2952 slen
= sizeof(struct sockaddr_in
);
2956 if (socket
== NULL
) {
2957 rc
= __sock_create(cifs_net_ns(server
), sfamily
, SOCK_STREAM
,
2958 IPPROTO_TCP
, &socket
, 1);
2960 cifs_dbg(VFS
, "Error %d creating socket\n", rc
);
2961 server
->ssocket
= NULL
;
2965 /* BB other socket options to set KEEPALIVE, NODELAY? */
2966 cifs_dbg(FYI
, "Socket created\n");
2967 server
->ssocket
= socket
;
2968 socket
->sk
->sk_allocation
= GFP_NOFS
;
2969 if (sfamily
== AF_INET6
)
2970 cifs_reclassify_socket6(socket
);
2972 cifs_reclassify_socket4(socket
);
2975 rc
= bind_socket(server
);
2980 * Eventually check for other socket options to change from
2981 * the default. sock_setsockopt not used because it expects
2984 socket
->sk
->sk_rcvtimeo
= 7 * HZ
;
2985 socket
->sk
->sk_sndtimeo
= 5 * HZ
;
2987 /* make the bufsizes depend on wsize/rsize and max requests */
2988 if (server
->noautotune
) {
2989 if (socket
->sk
->sk_sndbuf
< (200 * 1024))
2990 socket
->sk
->sk_sndbuf
= 200 * 1024;
2991 if (socket
->sk
->sk_rcvbuf
< (140 * 1024))
2992 socket
->sk
->sk_rcvbuf
= 140 * 1024;
2995 if (server
->tcp_nodelay
) {
2997 rc
= kernel_setsockopt(socket
, SOL_TCP
, TCP_NODELAY
,
2998 (char *)&val
, sizeof(val
));
3000 cifs_dbg(FYI
, "set TCP_NODELAY socket option error %d\n",
3004 cifs_dbg(FYI
, "sndbuf %d rcvbuf %d rcvtimeo 0x%lx\n",
3005 socket
->sk
->sk_sndbuf
,
3006 socket
->sk
->sk_rcvbuf
, socket
->sk
->sk_rcvtimeo
);
3008 rc
= socket
->ops
->connect(socket
, saddr
, slen
, 0);
3010 cifs_dbg(FYI
, "Error %d connecting to server\n", rc
);
3011 sock_release(socket
);
3012 server
->ssocket
= NULL
;
3016 if (sport
== htons(RFC1001_PORT
))
3017 rc
= ip_rfc1001_connect(server
);
3023 ip_connect(struct TCP_Server_Info
*server
)
3026 struct sockaddr_in6
*addr6
= (struct sockaddr_in6
*)&server
->dstaddr
;
3027 struct sockaddr_in
*addr
= (struct sockaddr_in
*)&server
->dstaddr
;
3029 if (server
->dstaddr
.ss_family
== AF_INET6
)
3030 sport
= &addr6
->sin6_port
;
3032 sport
= &addr
->sin_port
;
3037 /* try with 445 port at first */
3038 *sport
= htons(CIFS_PORT
);
3040 rc
= generic_ip_connect(server
);
3044 /* if it failed, try with 139 port */
3045 *sport
= htons(RFC1001_PORT
);
3048 return generic_ip_connect(server
);
3051 void reset_cifs_unix_caps(unsigned int xid
, struct cifs_tcon
*tcon
,
3052 struct cifs_sb_info
*cifs_sb
, struct smb_vol
*vol_info
)
3054 /* if we are reconnecting then should we check to see if
3055 * any requested capabilities changed locally e.g. via
3056 * remount but we can not do much about it here
3057 * if they have (even if we could detect it by the following)
3058 * Perhaps we could add a backpointer to array of sb from tcon
3059 * or if we change to make all sb to same share the same
3060 * sb as NFS - then we only have one backpointer to sb.
3061 * What if we wanted to mount the server share twice once with
3062 * and once without posixacls or posix paths? */
3063 __u64 saved_cap
= le64_to_cpu(tcon
->fsUnixInfo
.Capability
);
3065 if (vol_info
&& vol_info
->no_linux_ext
) {
3066 tcon
->fsUnixInfo
.Capability
= 0;
3067 tcon
->unix_ext
= 0; /* Unix Extensions disabled */
3068 cifs_dbg(FYI
, "Linux protocol extensions disabled\n");
3070 } else if (vol_info
)
3071 tcon
->unix_ext
= 1; /* Unix Extensions supported */
3073 if (tcon
->unix_ext
== 0) {
3074 cifs_dbg(FYI
, "Unix extensions disabled so not set on reconnect\n");
3078 if (!CIFSSMBQFSUnixInfo(xid
, tcon
)) {
3079 __u64 cap
= le64_to_cpu(tcon
->fsUnixInfo
.Capability
);
3080 cifs_dbg(FYI
, "unix caps which server supports %lld\n", cap
);
3081 /* check for reconnect case in which we do not
3082 want to change the mount behavior if we can avoid it */
3083 if (vol_info
== NULL
) {
3084 /* turn off POSIX ACL and PATHNAMES if not set
3085 originally at mount time */
3086 if ((saved_cap
& CIFS_UNIX_POSIX_ACL_CAP
) == 0)
3087 cap
&= ~CIFS_UNIX_POSIX_ACL_CAP
;
3088 if ((saved_cap
& CIFS_UNIX_POSIX_PATHNAMES_CAP
) == 0) {
3089 if (cap
& CIFS_UNIX_POSIX_PATHNAMES_CAP
)
3090 cifs_dbg(VFS
, "POSIXPATH support change\n");
3091 cap
&= ~CIFS_UNIX_POSIX_PATHNAMES_CAP
;
3092 } else if ((cap
& CIFS_UNIX_POSIX_PATHNAMES_CAP
) == 0) {
3093 cifs_dbg(VFS
, "possible reconnect error\n");
3094 cifs_dbg(VFS
, "server disabled POSIX path support\n");
3098 if (cap
& CIFS_UNIX_TRANSPORT_ENCRYPTION_MANDATORY_CAP
)
3099 cifs_dbg(VFS
, "per-share encryption not supported yet\n");
3101 cap
&= CIFS_UNIX_CAP_MASK
;
3102 if (vol_info
&& vol_info
->no_psx_acl
)
3103 cap
&= ~CIFS_UNIX_POSIX_ACL_CAP
;
3104 else if (CIFS_UNIX_POSIX_ACL_CAP
& cap
) {
3105 cifs_dbg(FYI
, "negotiated posix acl support\n");
3107 cifs_sb
->mnt_cifs_flags
|=
3108 CIFS_MOUNT_POSIXACL
;
3111 if (vol_info
&& vol_info
->posix_paths
== 0)
3112 cap
&= ~CIFS_UNIX_POSIX_PATHNAMES_CAP
;
3113 else if (cap
& CIFS_UNIX_POSIX_PATHNAMES_CAP
) {
3114 cifs_dbg(FYI
, "negotiate posix pathnames\n");
3116 cifs_sb
->mnt_cifs_flags
|=
3117 CIFS_MOUNT_POSIX_PATHS
;
3120 cifs_dbg(FYI
, "Negotiate caps 0x%x\n", (int)cap
);
3121 #ifdef CONFIG_CIFS_DEBUG2
3122 if (cap
& CIFS_UNIX_FCNTL_CAP
)
3123 cifs_dbg(FYI
, "FCNTL cap\n");
3124 if (cap
& CIFS_UNIX_EXTATTR_CAP
)
3125 cifs_dbg(FYI
, "EXTATTR cap\n");
3126 if (cap
& CIFS_UNIX_POSIX_PATHNAMES_CAP
)
3127 cifs_dbg(FYI
, "POSIX path cap\n");
3128 if (cap
& CIFS_UNIX_XATTR_CAP
)
3129 cifs_dbg(FYI
, "XATTR cap\n");
3130 if (cap
& CIFS_UNIX_POSIX_ACL_CAP
)
3131 cifs_dbg(FYI
, "POSIX ACL cap\n");
3132 if (cap
& CIFS_UNIX_LARGE_READ_CAP
)
3133 cifs_dbg(FYI
, "very large read cap\n");
3134 if (cap
& CIFS_UNIX_LARGE_WRITE_CAP
)
3135 cifs_dbg(FYI
, "very large write cap\n");
3136 if (cap
& CIFS_UNIX_TRANSPORT_ENCRYPTION_CAP
)
3137 cifs_dbg(FYI
, "transport encryption cap\n");
3138 if (cap
& CIFS_UNIX_TRANSPORT_ENCRYPTION_MANDATORY_CAP
)
3139 cifs_dbg(FYI
, "mandatory transport encryption cap\n");
3140 #endif /* CIFS_DEBUG2 */
3141 if (CIFSSMBSetFSUnixInfo(xid
, tcon
, cap
)) {
3142 if (vol_info
== NULL
) {
3143 cifs_dbg(FYI
, "resetting capabilities failed\n");
3145 cifs_dbg(VFS
, "Negotiating Unix capabilities with the server failed. Consider mounting with the Unix Extensions disabled if problems are found by specifying the nounix mount option.\n");
3151 void cifs_setup_cifs_sb(struct smb_vol
*pvolume_info
,
3152 struct cifs_sb_info
*cifs_sb
)
3154 INIT_DELAYED_WORK(&cifs_sb
->prune_tlinks
, cifs_prune_tlinks
);
3156 spin_lock_init(&cifs_sb
->tlink_tree_lock
);
3157 cifs_sb
->tlink_tree
= RB_ROOT
;
3160 * Temporarily set r/wsize for matching superblock. If we end up using
3161 * new sb then client will later negotiate it downward if needed.
3163 cifs_sb
->rsize
= pvolume_info
->rsize
;
3164 cifs_sb
->wsize
= pvolume_info
->wsize
;
3166 cifs_sb
->mnt_uid
= pvolume_info
->linux_uid
;
3167 cifs_sb
->mnt_gid
= pvolume_info
->linux_gid
;
3168 cifs_sb
->mnt_file_mode
= pvolume_info
->file_mode
;
3169 cifs_sb
->mnt_dir_mode
= pvolume_info
->dir_mode
;
3170 cifs_dbg(FYI
, "file mode: 0x%hx dir mode: 0x%hx\n",
3171 cifs_sb
->mnt_file_mode
, cifs_sb
->mnt_dir_mode
);
3173 cifs_sb
->actimeo
= pvolume_info
->actimeo
;
3174 cifs_sb
->local_nls
= pvolume_info
->local_nls
;
3176 if (pvolume_info
->noperm
)
3177 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_NO_PERM
;
3178 if (pvolume_info
->setuids
)
3179 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_SET_UID
;
3180 if (pvolume_info
->server_ino
)
3181 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_SERVER_INUM
;
3182 if (pvolume_info
->remap
)
3183 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_MAP_SPECIAL_CHR
;
3184 if (pvolume_info
->no_xattr
)
3185 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_NO_XATTR
;
3186 if (pvolume_info
->sfu_emul
)
3187 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_UNX_EMUL
;
3188 if (pvolume_info
->nobrl
)
3189 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_NO_BRL
;
3190 if (pvolume_info
->nostrictsync
)
3191 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_NOSSYNC
;
3192 if (pvolume_info
->mand_lock
)
3193 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_NOPOSIXBRL
;
3194 if (pvolume_info
->rwpidforward
)
3195 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_RWPIDFORWARD
;
3196 if (pvolume_info
->cifs_acl
)
3197 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_CIFS_ACL
;
3198 if (pvolume_info
->backupuid_specified
) {
3199 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_CIFS_BACKUPUID
;
3200 cifs_sb
->mnt_backupuid
= pvolume_info
->backupuid
;
3202 if (pvolume_info
->backupgid_specified
) {
3203 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_CIFS_BACKUPGID
;
3204 cifs_sb
->mnt_backupgid
= pvolume_info
->backupgid
;
3206 if (pvolume_info
->override_uid
)
3207 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_OVERR_UID
;
3208 if (pvolume_info
->override_gid
)
3209 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_OVERR_GID
;
3210 if (pvolume_info
->dynperm
)
3211 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_DYNPERM
;
3212 if (pvolume_info
->fsc
)
3213 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_FSCACHE
;
3214 if (pvolume_info
->multiuser
)
3215 cifs_sb
->mnt_cifs_flags
|= (CIFS_MOUNT_MULTIUSER
|
3216 CIFS_MOUNT_NO_PERM
);
3217 if (pvolume_info
->strict_io
)
3218 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_STRICT_IO
;
3219 if (pvolume_info
->direct_io
) {
3220 cifs_dbg(FYI
, "mounting share using direct i/o\n");
3221 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_DIRECT_IO
;
3223 if (pvolume_info
->mfsymlinks
) {
3224 if (pvolume_info
->sfu_emul
) {
3225 cifs_dbg(VFS
, "mount option mfsymlinks ignored if sfu mount option is used\n");
3227 cifs_sb
->mnt_cifs_flags
|= CIFS_MOUNT_MF_SYMLINKS
;
3231 if ((pvolume_info
->cifs_acl
) && (pvolume_info
->dynperm
))
3232 cifs_dbg(VFS
, "mount option dynperm ignored if cifsacl mount option supported\n");
3236 cleanup_volume_info_contents(struct smb_vol
*volume_info
)
3238 kfree(volume_info
->username
);
3239 kzfree(volume_info
->password
);
3240 kfree(volume_info
->UNC
);
3241 kfree(volume_info
->domainname
);
3242 kfree(volume_info
->iocharset
);
3243 kfree(volume_info
->prepath
);
3247 cifs_cleanup_volume_info(struct smb_vol
*volume_info
)
3251 cleanup_volume_info_contents(volume_info
);
3256 #ifdef CONFIG_CIFS_DFS_UPCALL
3258 * cifs_build_path_to_root returns full path to root when we do not have an
3259 * exiting connection (tcon)
3262 build_unc_path_to_root(const struct smb_vol
*vol
,
3263 const struct cifs_sb_info
*cifs_sb
)
3265 char *full_path
, *pos
;
3266 unsigned int pplen
= vol
->prepath
? strlen(vol
->prepath
) + 1 : 0;
3267 unsigned int unc_len
= strnlen(vol
->UNC
, MAX_TREE_SIZE
+ 1);
3269 full_path
= kmalloc(unc_len
+ pplen
+ 1, GFP_KERNEL
);
3270 if (full_path
== NULL
)
3271 return ERR_PTR(-ENOMEM
);
3273 strncpy(full_path
, vol
->UNC
, unc_len
);
3274 pos
= full_path
+ unc_len
;
3277 *pos
= CIFS_DIR_SEP(cifs_sb
);
3278 strncpy(pos
+ 1, vol
->prepath
, pplen
);
3282 *pos
= '\0'; /* add trailing null */
3283 convert_delimiter(full_path
, CIFS_DIR_SEP(cifs_sb
));
3284 cifs_dbg(FYI
, "%s: full_path=%s\n", __func__
, full_path
);
3289 * Perform a dfs referral query for a share and (optionally) prefix
3291 * If a referral is found, cifs_sb->mountdata will be (re-)allocated
3292 * to a string containing updated options for the submount. Otherwise it
3293 * will be left untouched.
3295 * Returns the rc from get_dfs_path to the caller, which can be used to
3296 * determine whether there were referrals.
3299 expand_dfs_referral(const unsigned int xid
, struct cifs_ses
*ses
,
3300 struct smb_vol
*volume_info
, struct cifs_sb_info
*cifs_sb
,
3304 unsigned int num_referrals
= 0;
3305 struct dfs_info3_param
*referrals
= NULL
;
3306 char *full_path
= NULL
, *ref_path
= NULL
, *mdata
= NULL
;
3308 full_path
= build_unc_path_to_root(volume_info
, cifs_sb
);
3309 if (IS_ERR(full_path
))
3310 return PTR_ERR(full_path
);
3312 /* For DFS paths, skip the first '\' of the UNC */
3313 ref_path
= check_prefix
? full_path
+ 1 : volume_info
->UNC
+ 1;
3315 rc
= get_dfs_path(xid
, ses
, ref_path
, cifs_sb
->local_nls
,
3316 &num_referrals
, &referrals
,
3317 cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_MAP_SPECIAL_CHR
);
3319 if (!rc
&& num_referrals
> 0) {
3320 char *fake_devname
= NULL
;
3322 mdata
= cifs_compose_mount_options(cifs_sb
->mountdata
,
3323 full_path
+ 1, referrals
,
3326 free_dfs_info_array(referrals
, num_referrals
);
3328 if (IS_ERR(mdata
)) {
3329 rc
= PTR_ERR(mdata
);
3332 cleanup_volume_info_contents(volume_info
);
3333 rc
= cifs_setup_volume_info(volume_info
, mdata
,
3336 kfree(fake_devname
);
3337 kfree(cifs_sb
->mountdata
);
3338 cifs_sb
->mountdata
= mdata
;
3346 cifs_setup_volume_info(struct smb_vol
*volume_info
, char *mount_data
,
3347 const char *devname
)
3351 if (cifs_parse_mount_options(mount_data
, devname
, volume_info
))
3354 if (volume_info
->nullauth
) {
3355 cifs_dbg(FYI
, "Anonymous login\n");
3356 kfree(volume_info
->username
);
3357 volume_info
->username
= NULL
;
3358 } else if (volume_info
->username
) {
3359 /* BB fixme parse for domain name here */
3360 cifs_dbg(FYI
, "Username: %s\n", volume_info
->username
);
3362 cifs_dbg(VFS
, "No username specified\n");
3363 /* In userspace mount helper we can get user name from alternate
3364 locations such as env variables and files on disk */
3368 /* this is needed for ASCII cp to Unicode converts */
3369 if (volume_info
->iocharset
== NULL
) {
3370 /* load_nls_default cannot return null */
3371 volume_info
->local_nls
= load_nls_default();
3373 volume_info
->local_nls
= load_nls(volume_info
->iocharset
);
3374 if (volume_info
->local_nls
== NULL
) {
3375 cifs_dbg(VFS
, "CIFS mount error: iocharset %s not found\n",
3376 volume_info
->iocharset
);
3385 cifs_get_volume_info(char *mount_data
, const char *devname
)
3388 struct smb_vol
*volume_info
;
3390 volume_info
= kmalloc(sizeof(struct smb_vol
), GFP_KERNEL
);
3392 return ERR_PTR(-ENOMEM
);
3394 rc
= cifs_setup_volume_info(volume_info
, mount_data
, devname
);
3396 cifs_cleanup_volume_info(volume_info
);
3397 volume_info
= ERR_PTR(rc
);
3404 cifs_mount(struct cifs_sb_info
*cifs_sb
, struct smb_vol
*volume_info
)
3408 struct cifs_ses
*ses
;
3409 struct cifs_tcon
*tcon
;
3410 struct TCP_Server_Info
*server
;
3412 struct tcon_link
*tlink
;
3413 #ifdef CONFIG_CIFS_DFS_UPCALL
3414 int referral_walks_count
= 0;
3417 rc
= bdi_setup_and_register(&cifs_sb
->bdi
, "cifs", BDI_CAP_MAP_COPY
);
3421 #ifdef CONFIG_CIFS_DFS_UPCALL
3423 /* cleanup activities if we're chasing a referral */
3424 if (referral_walks_count
) {
3426 cifs_put_tcon(tcon
);
3428 cifs_put_smb_ses(ses
);
3442 /* get a reference to a tcp session */
3443 server
= cifs_get_tcp_session(volume_info
);
3444 if (IS_ERR(server
)) {
3445 rc
= PTR_ERR(server
);
3446 bdi_destroy(&cifs_sb
->bdi
);
3450 /* get a reference to a SMB session */
3451 ses
= cifs_get_smb_ses(server
, volume_info
);
3455 goto mount_fail_check
;
3458 /* search for existing tcon to this server share */
3459 tcon
= cifs_get_tcon(ses
, volume_info
);
3463 goto remote_path_check
;
3466 /* tell server which Unix caps we support */
3467 if (cap_unix(tcon
->ses
)) {
3468 /* reset of caps checks mount to see if unix extensions
3469 disabled for just this mount */
3470 reset_cifs_unix_caps(xid
, tcon
, cifs_sb
, volume_info
);
3471 if ((tcon
->ses
->server
->tcpStatus
== CifsNeedReconnect
) &&
3472 (le64_to_cpu(tcon
->fsUnixInfo
.Capability
) &
3473 CIFS_UNIX_TRANSPORT_ENCRYPTION_MANDATORY_CAP
)) {
3475 goto mount_fail_check
;
3478 tcon
->unix_ext
= 0; /* server does not support them */
3480 /* do not care if a following call succeed - informational */
3481 if (!tcon
->ipc
&& server
->ops
->qfs_tcon
)
3482 server
->ops
->qfs_tcon(xid
, tcon
);
3484 cifs_sb
->wsize
= server
->ops
->negotiate_wsize(tcon
, volume_info
);
3485 cifs_sb
->rsize
= server
->ops
->negotiate_rsize(tcon
, volume_info
);
3487 /* tune readahead according to rsize */
3488 cifs_sb
->bdi
.ra_pages
= cifs_sb
->rsize
/ PAGE_CACHE_SIZE
;
3491 #ifdef CONFIG_CIFS_DFS_UPCALL
3493 * Perform an unconditional check for whether there are DFS
3494 * referrals for this path without prefix, to provide support
3495 * for DFS referrals from w2k8 servers which don't seem to respond
3496 * with PATH_NOT_COVERED to requests that include the prefix.
3497 * Chase the referral if found, otherwise continue normally.
3499 if (referral_walks_count
== 0) {
3500 int refrc
= expand_dfs_referral(xid
, ses
, volume_info
, cifs_sb
,
3503 referral_walks_count
++;
3504 goto try_mount_again
;
3509 /* check if a whole path is not remote */
3511 if (!server
->ops
->is_path_accessible
) {
3513 goto mount_fail_check
;
3516 * cifs_build_path_to_root works only when we have a valid tcon
3518 full_path
= cifs_build_path_to_root(volume_info
, cifs_sb
, tcon
);
3519 if (full_path
== NULL
) {
3521 goto mount_fail_check
;
3523 rc
= server
->ops
->is_path_accessible(xid
, tcon
, cifs_sb
,
3525 if (rc
!= 0 && rc
!= -EREMOTE
) {
3527 goto mount_fail_check
;
3532 /* get referral if needed */
3533 if (rc
== -EREMOTE
) {
3534 #ifdef CONFIG_CIFS_DFS_UPCALL
3535 if (referral_walks_count
> MAX_NESTED_LINKS
) {
3537 * BB: when we implement proper loop detection,
3538 * we will remove this check. But now we need it
3539 * to prevent an indefinite loop if 'DFS tree' is
3540 * misconfigured (i.e. has loops).
3543 goto mount_fail_check
;
3546 rc
= expand_dfs_referral(xid
, ses
, volume_info
, cifs_sb
, true);
3549 referral_walks_count
++;
3550 goto try_mount_again
;
3552 goto mount_fail_check
;
3553 #else /* No DFS support, return error on mount */
3559 goto mount_fail_check
;
3561 /* now, hang the tcon off of the superblock */
3562 tlink
= kzalloc(sizeof *tlink
, GFP_KERNEL
);
3563 if (tlink
== NULL
) {
3565 goto mount_fail_check
;
3568 tlink
->tl_uid
= ses
->linux_uid
;
3569 tlink
->tl_tcon
= tcon
;
3570 tlink
->tl_time
= jiffies
;
3571 set_bit(TCON_LINK_MASTER
, &tlink
->tl_flags
);
3572 set_bit(TCON_LINK_IN_TREE
, &tlink
->tl_flags
);
3574 cifs_sb
->master_tlink
= tlink
;
3575 spin_lock(&cifs_sb
->tlink_tree_lock
);
3576 tlink_rb_insert(&cifs_sb
->tlink_tree
, tlink
);
3577 spin_unlock(&cifs_sb
->tlink_tree_lock
);
3579 queue_delayed_work(cifsiod_wq
, &cifs_sb
->prune_tlinks
,
3583 /* on error free sesinfo and tcon struct if needed */
3585 /* If find_unc succeeded then rc == 0 so we can not end */
3586 /* up accidentally freeing someone elses tcon struct */
3588 cifs_put_tcon(tcon
);
3590 cifs_put_smb_ses(ses
);
3592 cifs_put_tcp_session(server
);
3593 bdi_destroy(&cifs_sb
->bdi
);
3602 * Issue a TREE_CONNECT request. Note that for IPC$ shares, that the tcon
3603 * pointer may be NULL.
3606 CIFSTCon(const unsigned int xid
, struct cifs_ses
*ses
,
3607 const char *tree
, struct cifs_tcon
*tcon
,
3608 const struct nls_table
*nls_codepage
)
3610 struct smb_hdr
*smb_buffer
;
3611 struct smb_hdr
*smb_buffer_response
;
3614 unsigned char *bcc_ptr
;
3617 __u16 bytes_left
, count
;
3622 smb_buffer
= cifs_buf_get();
3623 if (smb_buffer
== NULL
)
3626 smb_buffer_response
= smb_buffer
;
3628 header_assemble(smb_buffer
, SMB_COM_TREE_CONNECT_ANDX
,
3629 NULL
/*no tid */ , 4 /*wct */ );
3631 smb_buffer
->Mid
= get_next_mid(ses
->server
);
3632 smb_buffer
->Uid
= ses
->Suid
;
3633 pSMB
= (TCONX_REQ
*) smb_buffer
;
3634 pSMBr
= (TCONX_RSP
*) smb_buffer_response
;
3636 pSMB
->AndXCommand
= 0xFF;
3637 pSMB
->Flags
= cpu_to_le16(TCON_EXTENDED_SECINFO
);
3638 bcc_ptr
= &pSMB
->Password
[0];
3639 if (!tcon
|| (ses
->server
->sec_mode
& SECMODE_USER
)) {
3640 pSMB
->PasswordLength
= cpu_to_le16(1); /* minimum */
3641 *bcc_ptr
= 0; /* password is null byte */
3642 bcc_ptr
++; /* skip password */
3643 /* already aligned so no need to do it below */
3645 pSMB
->PasswordLength
= cpu_to_le16(CIFS_AUTH_RESP_SIZE
);
3646 /* BB FIXME add code to fail this if NTLMv2 or Kerberos
3647 specified as required (when that support is added to
3648 the vfs in the future) as only NTLM or the much
3649 weaker LANMAN (which we do not send by default) is accepted
3650 by Samba (not sure whether other servers allow
3651 NTLMv2 password here) */
3652 #ifdef CONFIG_CIFS_WEAK_PW_HASH
3653 if ((global_secflags
& CIFSSEC_MAY_LANMAN
) &&
3654 (ses
->sectype
== LANMAN
))
3655 calc_lanman_hash(tcon
->password
, ses
->server
->cryptkey
,
3656 ses
->server
->sec_mode
&
3657 SECMODE_PW_ENCRYPT
? true : false,
3660 #endif /* CIFS_WEAK_PW_HASH */
3661 rc
= SMBNTencrypt(tcon
->password
, ses
->server
->cryptkey
,
3662 bcc_ptr
, nls_codepage
);
3664 bcc_ptr
+= CIFS_AUTH_RESP_SIZE
;
3665 if (ses
->capabilities
& CAP_UNICODE
) {
3666 /* must align unicode strings */
3667 *bcc_ptr
= 0; /* null byte password */
3672 if (ses
->server
->sign
)
3673 smb_buffer
->Flags2
|= SMBFLG2_SECURITY_SIGNATURE
;
3675 if (ses
->capabilities
& CAP_STATUS32
) {
3676 smb_buffer
->Flags2
|= SMBFLG2_ERR_STATUS
;
3678 if (ses
->capabilities
& CAP_DFS
) {
3679 smb_buffer
->Flags2
|= SMBFLG2_DFS
;
3681 if (ses
->capabilities
& CAP_UNICODE
) {
3682 smb_buffer
->Flags2
|= SMBFLG2_UNICODE
;
3684 cifs_strtoUTF16((__le16
*) bcc_ptr
, tree
,
3685 6 /* max utf8 char length in bytes */ *
3686 (/* server len*/ + 256 /* share len */), nls_codepage
);
3687 bcc_ptr
+= 2 * length
; /* convert num 16 bit words to bytes */
3688 bcc_ptr
+= 2; /* skip trailing null */
3689 } else { /* ASCII */
3690 strcpy(bcc_ptr
, tree
);
3691 bcc_ptr
+= strlen(tree
) + 1;
3693 strcpy(bcc_ptr
, "?????");
3694 bcc_ptr
+= strlen("?????");
3696 count
= bcc_ptr
- &pSMB
->Password
[0];
3697 pSMB
->hdr
.smb_buf_length
= cpu_to_be32(be32_to_cpu(
3698 pSMB
->hdr
.smb_buf_length
) + count
);
3699 pSMB
->ByteCount
= cpu_to_le16(count
);
3701 rc
= SendReceive(xid
, ses
, smb_buffer
, smb_buffer_response
, &length
,
3704 /* above now done in SendReceive */
3705 if ((rc
== 0) && (tcon
!= NULL
)) {
3708 tcon
->tidStatus
= CifsGood
;
3709 tcon
->need_reconnect
= false;
3710 tcon
->tid
= smb_buffer_response
->Tid
;
3711 bcc_ptr
= pByteArea(smb_buffer_response
);
3712 bytes_left
= get_bcc(smb_buffer_response
);
3713 length
= strnlen(bcc_ptr
, bytes_left
- 2);
3714 if (smb_buffer
->Flags2
& SMBFLG2_UNICODE
)
3720 /* skip service field (NB: this field is always ASCII) */
3722 if ((bcc_ptr
[0] == 'I') && (bcc_ptr
[1] == 'P') &&
3723 (bcc_ptr
[2] == 'C')) {
3724 cifs_dbg(FYI
, "IPC connection\n");
3727 } else if (length
== 2) {
3728 if ((bcc_ptr
[0] == 'A') && (bcc_ptr
[1] == ':')) {
3729 /* the most common case */
3730 cifs_dbg(FYI
, "disk share connection\n");
3733 bcc_ptr
+= length
+ 1;
3734 bytes_left
-= (length
+ 1);
3735 strlcpy(tcon
->treeName
, tree
, sizeof(tcon
->treeName
));
3737 /* mostly informational -- no need to fail on error here */
3738 kfree(tcon
->nativeFileSystem
);
3739 tcon
->nativeFileSystem
= cifs_strndup_from_utf16(bcc_ptr
,
3740 bytes_left
, is_unicode
,
3743 cifs_dbg(FYI
, "nativeFileSystem=%s\n", tcon
->nativeFileSystem
);
3745 if ((smb_buffer_response
->WordCount
== 3) ||
3746 (smb_buffer_response
->WordCount
== 7))
3747 /* field is in same location */
3748 tcon
->Flags
= le16_to_cpu(pSMBr
->OptionalSupport
);
3751 cifs_dbg(FYI
, "Tcon flags: 0x%x\n", tcon
->Flags
);
3752 } else if ((rc
== 0) && tcon
== NULL
) {
3753 /* all we need to save for IPC$ connection */
3754 ses
->ipc_tid
= smb_buffer_response
->Tid
;
3757 cifs_buf_release(smb_buffer
);
3762 cifs_umount(struct cifs_sb_info
*cifs_sb
)
3764 struct rb_root
*root
= &cifs_sb
->tlink_tree
;
3765 struct rb_node
*node
;
3766 struct tcon_link
*tlink
;
3768 cancel_delayed_work_sync(&cifs_sb
->prune_tlinks
);
3770 spin_lock(&cifs_sb
->tlink_tree_lock
);
3771 while ((node
= rb_first(root
))) {
3772 tlink
= rb_entry(node
, struct tcon_link
, tl_rbnode
);
3773 cifs_get_tlink(tlink
);
3774 clear_bit(TCON_LINK_IN_TREE
, &tlink
->tl_flags
);
3775 rb_erase(node
, root
);
3777 spin_unlock(&cifs_sb
->tlink_tree_lock
);
3778 cifs_put_tlink(tlink
);
3779 spin_lock(&cifs_sb
->tlink_tree_lock
);
3781 spin_unlock(&cifs_sb
->tlink_tree_lock
);
3783 bdi_destroy(&cifs_sb
->bdi
);
3784 kfree(cifs_sb
->mountdata
);
3785 unload_nls(cifs_sb
->local_nls
);
3790 cifs_negotiate_protocol(const unsigned int xid
, struct cifs_ses
*ses
)
3793 struct TCP_Server_Info
*server
= ses
->server
;
3795 if (!server
->ops
->need_neg
|| !server
->ops
->negotiate
)
3798 /* only send once per connect */
3799 if (!server
->ops
->need_neg(server
))
3802 set_credits(server
, 1);
3804 rc
= server
->ops
->negotiate(xid
, ses
);
3806 spin_lock(&GlobalMid_Lock
);
3807 if (server
->tcpStatus
== CifsNeedNegotiate
)
3808 server
->tcpStatus
= CifsGood
;
3811 spin_unlock(&GlobalMid_Lock
);
3818 cifs_setup_session(const unsigned int xid
, struct cifs_ses
*ses
,
3819 struct nls_table
*nls_info
)
3822 struct TCP_Server_Info
*server
= ses
->server
;
3824 ses
->capabilities
= server
->capabilities
;
3825 if (linuxExtEnabled
== 0)
3826 ses
->capabilities
&= (~server
->vals
->cap_unix
);
3828 cifs_dbg(FYI
, "Security Mode: 0x%x Capabilities: 0x%x TimeAdjust: %d\n",
3829 server
->sec_mode
, server
->capabilities
, server
->timeAdj
);
3831 if (server
->ops
->sess_setup
)
3832 rc
= server
->ops
->sess_setup(xid
, ses
, nls_info
);
3835 cifs_dbg(VFS
, "Send error in SessSetup = %d\n", rc
);
3841 cifs_set_vol_auth(struct smb_vol
*vol
, struct cifs_ses
*ses
)
3843 vol
->sectype
= ses
->sectype
;
3845 /* krb5 is special, since we don't need username or pw */
3846 if (vol
->sectype
== Kerberos
)
3849 return cifs_set_cifscreds(vol
, ses
);
3852 static struct cifs_tcon
*
3853 cifs_construct_tcon(struct cifs_sb_info
*cifs_sb
, kuid_t fsuid
)
3856 struct cifs_tcon
*master_tcon
= cifs_sb_master_tcon(cifs_sb
);
3857 struct cifs_ses
*ses
;
3858 struct cifs_tcon
*tcon
= NULL
;
3859 struct smb_vol
*vol_info
;
3861 vol_info
= kzalloc(sizeof(*vol_info
), GFP_KERNEL
);
3862 if (vol_info
== NULL
)
3863 return ERR_PTR(-ENOMEM
);
3865 vol_info
->local_nls
= cifs_sb
->local_nls
;
3866 vol_info
->linux_uid
= fsuid
;
3867 vol_info
->cred_uid
= fsuid
;
3868 vol_info
->UNC
= master_tcon
->treeName
;
3869 vol_info
->retry
= master_tcon
->retry
;
3870 vol_info
->nocase
= master_tcon
->nocase
;
3871 vol_info
->local_lease
= master_tcon
->local_lease
;
3872 vol_info
->no_linux_ext
= !master_tcon
->unix_ext
;
3873 vol_info
->sectype
= master_tcon
->ses
->sectype
;
3874 vol_info
->sign
= master_tcon
->ses
->sign
;
3876 rc
= cifs_set_vol_auth(vol_info
, master_tcon
->ses
);
3882 /* get a reference for the same TCP session */
3883 spin_lock(&cifs_tcp_ses_lock
);
3884 ++master_tcon
->ses
->server
->srv_count
;
3885 spin_unlock(&cifs_tcp_ses_lock
);
3887 ses
= cifs_get_smb_ses(master_tcon
->ses
->server
, vol_info
);
3889 tcon
= (struct cifs_tcon
*)ses
;
3890 cifs_put_tcp_session(master_tcon
->ses
->server
);
3894 tcon
= cifs_get_tcon(ses
, vol_info
);
3896 cifs_put_smb_ses(ses
);
3901 reset_cifs_unix_caps(0, tcon
, NULL
, vol_info
);
3903 kfree(vol_info
->username
);
3904 kfree(vol_info
->password
);
3911 cifs_sb_master_tcon(struct cifs_sb_info
*cifs_sb
)
3913 return tlink_tcon(cifs_sb_master_tlink(cifs_sb
));
3917 cifs_sb_tcon_pending_wait(void *unused
)
3920 return signal_pending(current
) ? -ERESTARTSYS
: 0;
3923 /* find and return a tlink with given uid */
3924 static struct tcon_link
*
3925 tlink_rb_search(struct rb_root
*root
, kuid_t uid
)
3927 struct rb_node
*node
= root
->rb_node
;
3928 struct tcon_link
*tlink
;
3931 tlink
= rb_entry(node
, struct tcon_link
, tl_rbnode
);
3933 if (uid_gt(tlink
->tl_uid
, uid
))
3934 node
= node
->rb_left
;
3935 else if (uid_lt(tlink
->tl_uid
, uid
))
3936 node
= node
->rb_right
;
3943 /* insert a tcon_link into the tree */
3945 tlink_rb_insert(struct rb_root
*root
, struct tcon_link
*new_tlink
)
3947 struct rb_node
**new = &(root
->rb_node
), *parent
= NULL
;
3948 struct tcon_link
*tlink
;
3951 tlink
= rb_entry(*new, struct tcon_link
, tl_rbnode
);
3954 if (uid_gt(tlink
->tl_uid
, new_tlink
->tl_uid
))
3955 new = &((*new)->rb_left
);
3957 new = &((*new)->rb_right
);
3960 rb_link_node(&new_tlink
->tl_rbnode
, parent
, new);
3961 rb_insert_color(&new_tlink
->tl_rbnode
, root
);
3965 * Find or construct an appropriate tcon given a cifs_sb and the fsuid of the
3968 * If the superblock doesn't refer to a multiuser mount, then just return
3969 * the master tcon for the mount.
3971 * First, search the rbtree for an existing tcon for this fsuid. If one
3972 * exists, then check to see if it's pending construction. If it is then wait
3973 * for construction to complete. Once it's no longer pending, check to see if
3974 * it failed and either return an error or retry construction, depending on
3977 * If one doesn't exist then insert a new tcon_link struct into the tree and
3978 * try to construct a new one.
3981 cifs_sb_tlink(struct cifs_sb_info
*cifs_sb
)
3984 kuid_t fsuid
= current_fsuid();
3985 struct tcon_link
*tlink
, *newtlink
;
3987 if (!(cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_MULTIUSER
))
3988 return cifs_get_tlink(cifs_sb_master_tlink(cifs_sb
));
3990 spin_lock(&cifs_sb
->tlink_tree_lock
);
3991 tlink
= tlink_rb_search(&cifs_sb
->tlink_tree
, fsuid
);
3993 cifs_get_tlink(tlink
);
3994 spin_unlock(&cifs_sb
->tlink_tree_lock
);
3996 if (tlink
== NULL
) {
3997 newtlink
= kzalloc(sizeof(*tlink
), GFP_KERNEL
);
3998 if (newtlink
== NULL
)
3999 return ERR_PTR(-ENOMEM
);
4000 newtlink
->tl_uid
= fsuid
;
4001 newtlink
->tl_tcon
= ERR_PTR(-EACCES
);
4002 set_bit(TCON_LINK_PENDING
, &newtlink
->tl_flags
);
4003 set_bit(TCON_LINK_IN_TREE
, &newtlink
->tl_flags
);
4004 cifs_get_tlink(newtlink
);
4006 spin_lock(&cifs_sb
->tlink_tree_lock
);
4007 /* was one inserted after previous search? */
4008 tlink
= tlink_rb_search(&cifs_sb
->tlink_tree
, fsuid
);
4010 cifs_get_tlink(tlink
);
4011 spin_unlock(&cifs_sb
->tlink_tree_lock
);
4013 goto wait_for_construction
;
4016 tlink_rb_insert(&cifs_sb
->tlink_tree
, tlink
);
4017 spin_unlock(&cifs_sb
->tlink_tree_lock
);
4019 wait_for_construction
:
4020 ret
= wait_on_bit(&tlink
->tl_flags
, TCON_LINK_PENDING
,
4021 cifs_sb_tcon_pending_wait
,
4022 TASK_INTERRUPTIBLE
);
4024 cifs_put_tlink(tlink
);
4025 return ERR_PTR(ret
);
4028 /* if it's good, return it */
4029 if (!IS_ERR(tlink
->tl_tcon
))
4032 /* return error if we tried this already recently */
4033 if (time_before(jiffies
, tlink
->tl_time
+ TLINK_ERROR_EXPIRE
)) {
4034 cifs_put_tlink(tlink
);
4035 return ERR_PTR(-EACCES
);
4038 if (test_and_set_bit(TCON_LINK_PENDING
, &tlink
->tl_flags
))
4039 goto wait_for_construction
;
4042 tlink
->tl_tcon
= cifs_construct_tcon(cifs_sb
, fsuid
);
4043 clear_bit(TCON_LINK_PENDING
, &tlink
->tl_flags
);
4044 wake_up_bit(&tlink
->tl_flags
, TCON_LINK_PENDING
);
4046 if (IS_ERR(tlink
->tl_tcon
)) {
4047 cifs_put_tlink(tlink
);
4048 return ERR_PTR(-EACCES
);
4055 * periodic workqueue job that scans tcon_tree for a superblock and closes
4059 cifs_prune_tlinks(struct work_struct
*work
)
4061 struct cifs_sb_info
*cifs_sb
= container_of(work
, struct cifs_sb_info
,
4063 struct rb_root
*root
= &cifs_sb
->tlink_tree
;
4064 struct rb_node
*node
= rb_first(root
);
4065 struct rb_node
*tmp
;
4066 struct tcon_link
*tlink
;
4069 * Because we drop the spinlock in the loop in order to put the tlink
4070 * it's not guarded against removal of links from the tree. The only
4071 * places that remove entries from the tree are this function and
4072 * umounts. Because this function is non-reentrant and is canceled
4073 * before umount can proceed, this is safe.
4075 spin_lock(&cifs_sb
->tlink_tree_lock
);
4076 node
= rb_first(root
);
4077 while (node
!= NULL
) {
4079 node
= rb_next(tmp
);
4080 tlink
= rb_entry(tmp
, struct tcon_link
, tl_rbnode
);
4082 if (test_bit(TCON_LINK_MASTER
, &tlink
->tl_flags
) ||
4083 atomic_read(&tlink
->tl_count
) != 0 ||
4084 time_after(tlink
->tl_time
+ TLINK_IDLE_EXPIRE
, jiffies
))
4087 cifs_get_tlink(tlink
);
4088 clear_bit(TCON_LINK_IN_TREE
, &tlink
->tl_flags
);
4089 rb_erase(tmp
, root
);
4091 spin_unlock(&cifs_sb
->tlink_tree_lock
);
4092 cifs_put_tlink(tlink
);
4093 spin_lock(&cifs_sb
->tlink_tree_lock
);
4095 spin_unlock(&cifs_sb
->tlink_tree_lock
);
4097 queue_delayed_work(cifsiod_wq
, &cifs_sb
->prune_tlinks
,