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,
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" },
169 { Opt_backupuid, "backupuid=%s" },
170 { Opt_backupgid, "backupgid=%s" },
171 { Opt_uid, "uid=%s" },
172 { Opt_cruid, "cruid=%s" },
173 { Opt_gid, "gid=%s" },
174 { Opt_file_mode, "file_mode=%s" },
175 { Opt_dirmode, "dirmode=%s" },
176 { Opt_dirmode, "dir_mode=%s" },
177 { Opt_port, "port=%s" },
178 { Opt_rsize, "rsize=%s" },
179 { Opt_wsize, "wsize=%s" },
180 { Opt_actimeo, "actimeo=%s" },
182 { Opt_blank_user, "user=" },
183 { Opt_blank_user, "username=" },
184 { Opt_user, "user=%s" },
185 { Opt_user, "username=%s" },
186 { Opt_blank_pass, "pass=" },
187 { Opt_blank_pass, "password=" },
188 { Opt_pass, "pass=%s" },
189 { Opt_pass, "password=%s" },
190 { Opt_blank_ip, "ip=" },
191 { Opt_blank_ip, "addr=" },
193 { Opt_ip, "addr=%s" },
194 { Opt_ignore, "unc=%s" },
195 { Opt_ignore, "target=%s" },
196 { Opt_ignore, "path=%s" },
197 { Opt_domain, "dom=%s" },
198 { Opt_domain, "domain=%s" },
199 { Opt_domain, "workgroup=%s" },
200 { Opt_srcaddr, "srcaddr=%s" },
201 { Opt_ignore, "prefixpath=%s" },
202 { Opt_iocharset, "iocharset=%s" },
203 { Opt_netbiosname, "netbiosname=%s" },
204 { Opt_servern, "servern=%s" },
205 { Opt_ver, "ver=%s" },
206 { Opt_vers, "vers=%s" },
207 { Opt_sec, "sec=%s" },
208 { Opt_cache, "cache=%s" },
210 { Opt_ignore, "cred" },
211 { Opt_ignore, "credentials" },
212 { Opt_ignore, "cred=%s" },
213 { Opt_ignore, "credentials=%s" },
214 { Opt_ignore, "guest" },
215 { Opt_ignore, "rw" },
216 { Opt_ignore, "ro" },
217 { Opt_ignore, "suid" },
218 { Opt_ignore, "nosuid" },
219 { Opt_ignore, "exec" },
220 { Opt_ignore, "noexec" },
221 { Opt_ignore, "nodev" },
222 { Opt_ignore, "noauto" },
223 { Opt_ignore, "dev" },
224 { Opt_ignore, "mand" },
225 { Opt_ignore, "nomand" },
226 { Opt_ignore, "_netdev" },
232 Opt_sec_krb5, Opt_sec_krb5i, Opt_sec_krb5p,
233 Opt_sec_ntlmsspi, Opt_sec_ntlmssp,
234 Opt_ntlm, Opt_sec_ntlmi, Opt_sec_ntlmv2,
235 Opt_sec_ntlmv2i, Opt_sec_lanman,
241 static const match_table_t cifs_secflavor_tokens = {
242 { Opt_sec_krb5, "krb5" },
243 { Opt_sec_krb5i, "krb5i" },
244 { Opt_sec_krb5p, "krb5p" },
245 { Opt_sec_ntlmsspi, "ntlmsspi" },
246 { Opt_sec_ntlmssp, "ntlmssp" },
247 { Opt_ntlm, "ntlm" },
248 { Opt_sec_ntlmi, "ntlmi" },
249 { Opt_sec_ntlmv2, "nontlm" },
250 { Opt_sec_ntlmv2, "ntlmv2" },
251 { Opt_sec_ntlmv2i, "ntlmv2i" },
252 { Opt_sec_lanman, "lanman" },
253 { Opt_sec_none, "none" },
255 { Opt_sec_err, NULL }
266 static const match_table_t cifs_cacheflavor_tokens = {
267 { Opt_cache_loose, "loose" },
268 { Opt_cache_strict, "strict" },
269 { Opt_cache_none, "none" },
270 { Opt_cache_err, NULL }
273 static const match_table_t cifs_smb_version_tokens = {
274 { Smb_1, SMB1_VERSION_STRING },
275 { Smb_20, SMB20_VERSION_STRING},
276 { Smb_21, SMB21_VERSION_STRING },
277 { Smb_30, SMB30_VERSION_STRING },
280 static int ip_connect(struct TCP_Server_Info *server);
281 static int generic_ip_connect(struct TCP_Server_Info *server);
282 static void tlink_rb_insert(struct rb_root *root, struct tcon_link *new_tlink);
283 static void cifs_prune_tlinks(struct work_struct *work);
284 static int cifs_setup_volume_info(struct smb_vol *volume_info, char *mount_data,
285 const char *devname);
288 * cifs tcp session reconnection
290 * mark tcp session as reconnecting so temporarily locked
291 * mark all smb sessions as reconnecting for tcp session
292 * reconnect tcp session
293 * wake up waiters on reconnection? - (not needed currently)
296 cifs_reconnect(struct TCP_Server_Info *server)
299 struct list_head *tmp, *tmp2;
300 struct cifs_ses *ses;
301 struct cifs_tcon *tcon;
302 struct mid_q_entry *mid_entry;
303 struct list_head retry_list;
305 spin_lock(&GlobalMid_Lock);
306 if (server->tcpStatus == CifsExiting) {
307 /* the demux thread will exit normally
308 next time through the loop */
309 spin_unlock(&GlobalMid_Lock);
312 server->tcpStatus = CifsNeedReconnect;
313 spin_unlock(&GlobalMid_Lock);
315 #ifdef CONFIG_CIFS_SMB2
316 server->max_read = 0;
319 cifs_dbg(FYI, "Reconnecting tcp session\n");
321 /* before reconnecting the tcp session, mark the smb session (uid)
322 and the tid bad so they are not used until reconnected */
323 cifs_dbg(FYI, "%s: marking sessions and tcons for reconnect\n",
325 spin_lock(&cifs_tcp_ses_lock);
326 list_for_each(tmp, &server->smb_ses_list) {
327 ses = list_entry(tmp, struct cifs_ses, smb_ses_list);
328 ses->need_reconnect = true;
330 list_for_each(tmp2, &ses->tcon_list) {
331 tcon = list_entry(tmp2, struct cifs_tcon, tcon_list);
332 tcon->need_reconnect = true;
335 spin_unlock(&cifs_tcp_ses_lock);
337 /* do not want to be sending data on a socket we are freeing */
338 cifs_dbg(FYI, "%s: tearing down socket\n", __func__);
339 mutex_lock(&server->srv_mutex);
340 if (server->ssocket) {
341 cifs_dbg(FYI, "State: 0x%x Flags: 0x%lx\n",
342 server->ssocket->state, server->ssocket->flags);
343 kernel_sock_shutdown(server->ssocket, SHUT_WR);
344 cifs_dbg(FYI, "Post shutdown state: 0x%x Flags: 0x%lx\n",
345 server->ssocket->state, server->ssocket->flags);
346 sock_release(server->ssocket);
347 server->ssocket = NULL;
349 server->sequence_number = 0;
350 server->session_estab = false;
351 kfree(server->session_key.response);
352 server->session_key.response = NULL;
353 server->session_key.len = 0;
354 server->lstrp = jiffies;
355 mutex_unlock(&server->srv_mutex);
357 /* mark submitted MIDs for retry and issue callback */
358 INIT_LIST_HEAD(&retry_list);
359 cifs_dbg(FYI, "%s: moving mids to private list\n", __func__);
360 spin_lock(&GlobalMid_Lock);
361 list_for_each_safe(tmp, tmp2, &server->pending_mid_q) {
362 mid_entry = list_entry(tmp, struct mid_q_entry, qhead);
363 if (mid_entry->mid_state == MID_REQUEST_SUBMITTED)
364 mid_entry->mid_state = MID_RETRY_NEEDED;
365 list_move(&mid_entry->qhead, &retry_list);
367 spin_unlock(&GlobalMid_Lock);
369 cifs_dbg(FYI, "%s: issuing mid callbacks\n", __func__);
370 list_for_each_safe(tmp, tmp2, &retry_list) {
371 mid_entry = list_entry(tmp, struct mid_q_entry, qhead);
372 list_del_init(&mid_entry->qhead);
373 mid_entry->callback(mid_entry);
379 /* we should try only the port we connected to before */
380 rc = generic_ip_connect(server);
382 cifs_dbg(FYI, "reconnect error %d\n", rc);
385 atomic_inc(&tcpSesReconnectCount);
386 spin_lock(&GlobalMid_Lock);
387 if (server->tcpStatus != CifsExiting)
388 server->tcpStatus = CifsNeedNegotiate;
389 spin_unlock(&GlobalMid_Lock);
391 } while (server->tcpStatus == CifsNeedReconnect);
397 cifs_echo_request(struct work_struct *work)
400 struct TCP_Server_Info *server = container_of(work,
401 struct TCP_Server_Info, echo.work);
404 * We cannot send an echo if it is disabled or until the
405 * NEGOTIATE_PROTOCOL request is done, which is indicated by
406 * server->ops->need_neg() == true. Also, no need to ping if
407 * we got a response recently.
409 if (!server->ops->need_neg || server->ops->need_neg(server) ||
410 (server->ops->can_echo && !server->ops->can_echo(server)) ||
411 time_before(jiffies, server->lstrp + SMB_ECHO_INTERVAL - HZ))
414 rc = server->ops->echo ? server->ops->echo(server) : -ENOSYS;
416 cifs_dbg(FYI, "Unable to send echo request to server: %s\n",
420 queue_delayed_work(cifsiod_wq, &server->echo, SMB_ECHO_INTERVAL);
424 allocate_buffers(struct TCP_Server_Info *server)
426 if (!server->bigbuf) {
427 server->bigbuf = (char *)cifs_buf_get();
428 if (!server->bigbuf) {
429 cifs_dbg(VFS, "No memory for large SMB response\n");
431 /* retry will check if exiting */
434 } else if (server->large_buf) {
435 /* we are reusing a dirty large buf, clear its start */
436 memset(server->bigbuf, 0, HEADER_SIZE(server));
439 if (!server->smallbuf) {
440 server->smallbuf = (char *)cifs_small_buf_get();
441 if (!server->smallbuf) {
442 cifs_dbg(VFS, "No memory for SMB response\n");
444 /* retry will check if exiting */
447 /* beginning of smb buffer is cleared in our buf_get */
449 /* if existing small buf clear beginning */
450 memset(server->smallbuf, 0, HEADER_SIZE(server));
457 server_unresponsive(struct TCP_Server_Info *server)
460 * We need to wait 2 echo intervals to make sure we handle such
462 * 1s client sends a normal SMB request
463 * 2s client gets a response
464 * 30s echo workqueue job pops, and decides we got a response recently
465 * and don't need to send another
467 * 65s kernel_recvmsg times out, and we see that we haven't gotten
468 * a response in >60s.
470 if (server->tcpStatus == CifsGood &&
471 time_after(jiffies, server->lstrp + 2 * SMB_ECHO_INTERVAL)) {
472 cifs_dbg(VFS, "Server %s has not responded in %d seconds. Reconnecting...\n",
473 server->hostname, (2 * SMB_ECHO_INTERVAL) / HZ);
474 cifs_reconnect(server);
475 wake_up(&server->response_q);
483 * kvec_array_init - clone a kvec array, and advance into it
484 * @new: pointer to memory for cloned array
485 * @iov: pointer to original array
486 * @nr_segs: number of members in original array
487 * @bytes: number of bytes to advance into the cloned array
489 * This function will copy the array provided in iov to a section of memory
490 * and advance the specified number of bytes into the new array. It returns
491 * the number of segments in the new array. "new" must be at least as big as
492 * the original iov array.
495 kvec_array_init(struct kvec *new, struct kvec *iov, unsigned int nr_segs,
500 while (bytes || !iov->iov_len) {
501 int copy = min(bytes, iov->iov_len);
505 if (iov->iov_len == base) {
511 memcpy(new, iov, sizeof(*iov) * nr_segs);
512 new->iov_base += base;
513 new->iov_len -= base;
518 get_server_iovec(struct TCP_Server_Info *server, unsigned int nr_segs)
520 struct kvec *new_iov;
522 if (server->iov && nr_segs <= server->nr_iov)
525 /* not big enough -- allocate a new one and release the old */
526 new_iov = kmalloc(sizeof(*new_iov) * nr_segs, GFP_NOFS);
529 server->iov = new_iov;
530 server->nr_iov = nr_segs;
536 cifs_readv_from_socket(struct TCP_Server_Info *server, struct kvec *iov_orig,
537 unsigned int nr_segs, unsigned int to_read)
542 struct msghdr smb_msg;
545 iov = get_server_iovec(server, nr_segs);
549 smb_msg.msg_control = NULL;
550 smb_msg.msg_controllen = 0;
552 for (total_read = 0; to_read; total_read += length, to_read -= length) {
555 if (server_unresponsive(server)) {
556 total_read = -EAGAIN;
560 segs = kvec_array_init(iov, iov_orig, nr_segs, total_read);
562 length = kernel_recvmsg(server->ssocket, &smb_msg,
563 iov, segs, to_read, 0);
565 if (server->tcpStatus == CifsExiting) {
566 total_read = -ESHUTDOWN;
568 } else if (server->tcpStatus == CifsNeedReconnect) {
569 cifs_reconnect(server);
570 total_read = -EAGAIN;
572 } else if (length == -ERESTARTSYS ||
576 * Minimum sleep to prevent looping, allowing socket
577 * to clear and app threads to set tcpStatus
578 * CifsNeedReconnect if server hung.
580 usleep_range(1000, 2000);
583 } else if (length <= 0) {
584 cifs_dbg(FYI, "Received no data or error: expecting %d\n"
585 "got %d", to_read, length);
586 cifs_reconnect(server);
587 total_read = -EAGAIN;
595 cifs_read_from_socket(struct TCP_Server_Info *server, char *buf,
596 unsigned int to_read)
601 iov.iov_len = to_read;
603 return cifs_readv_from_socket(server, &iov, 1, to_read);
607 is_smb_response(struct TCP_Server_Info *server, unsigned char type)
610 * The first byte big endian of the length field,
611 * is actually not part of the length but the type
612 * with the most common, zero, as regular data.
615 case RFC1002_SESSION_MESSAGE:
616 /* Regular SMB response */
618 case RFC1002_SESSION_KEEP_ALIVE:
619 cifs_dbg(FYI, "RFC 1002 session keep alive\n");
621 case RFC1002_POSITIVE_SESSION_RESPONSE:
622 cifs_dbg(FYI, "RFC 1002 positive session response\n");
624 case RFC1002_NEGATIVE_SESSION_RESPONSE:
626 * We get this from Windows 98 instead of an error on
627 * SMB negprot response.
629 cifs_dbg(FYI, "RFC 1002 negative session response\n");
630 /* give server a second to clean up */
633 * Always try 445 first on reconnect since we get NACK
634 * on some if we ever connected to port 139 (the NACK
635 * is since we do not begin with RFC1001 session
638 cifs_set_port((struct sockaddr *)&server->dstaddr, CIFS_PORT);
639 cifs_reconnect(server);
640 wake_up(&server->response_q);
643 cifs_dbg(VFS, "RFC 1002 unknown response type 0x%x\n", type);
644 cifs_reconnect(server);
651 dequeue_mid(struct mid_q_entry *mid, bool malformed)
653 #ifdef CONFIG_CIFS_STATS2
654 mid->when_received = jiffies;
656 spin_lock(&GlobalMid_Lock);
658 mid->mid_state = MID_RESPONSE_RECEIVED;
660 mid->mid_state = MID_RESPONSE_MALFORMED;
661 list_del_init(&mid->qhead);
662 spin_unlock(&GlobalMid_Lock);
666 handle_mid(struct mid_q_entry *mid, struct TCP_Server_Info *server,
667 char *buf, int malformed)
669 if (server->ops->check_trans2 &&
670 server->ops->check_trans2(mid, server, buf, malformed))
673 mid->large_buf = server->large_buf;
674 /* Was previous buf put in mpx struct for multi-rsp? */
675 if (!mid->multiRsp) {
676 /* smb buffer will be freed by user thread */
677 if (server->large_buf)
678 server->bigbuf = NULL;
680 server->smallbuf = NULL;
682 dequeue_mid(mid, malformed);
685 static void clean_demultiplex_info(struct TCP_Server_Info *server)
689 /* take it off the list, if it's not already */
690 spin_lock(&cifs_tcp_ses_lock);
691 list_del_init(&server->tcp_ses_list);
692 spin_unlock(&cifs_tcp_ses_lock);
694 spin_lock(&GlobalMid_Lock);
695 server->tcpStatus = CifsExiting;
696 spin_unlock(&GlobalMid_Lock);
697 wake_up_all(&server->response_q);
699 /* check if we have blocked requests that need to free */
700 spin_lock(&server->req_lock);
701 if (server->credits <= 0)
703 spin_unlock(&server->req_lock);
705 * Although there should not be any requests blocked on this queue it
706 * can not hurt to be paranoid and try to wake up requests that may
707 * haven been blocked when more than 50 at time were on the wire to the
708 * same server - they now will see the session is in exit state and get
709 * out of SendReceive.
711 wake_up_all(&server->request_q);
712 /* give those requests time to exit */
715 if (server->ssocket) {
716 sock_release(server->ssocket);
717 server->ssocket = NULL;
720 if (!list_empty(&server->pending_mid_q)) {
721 struct list_head dispose_list;
722 struct mid_q_entry *mid_entry;
723 struct list_head *tmp, *tmp2;
725 INIT_LIST_HEAD(&dispose_list);
726 spin_lock(&GlobalMid_Lock);
727 list_for_each_safe(tmp, tmp2, &server->pending_mid_q) {
728 mid_entry = list_entry(tmp, struct mid_q_entry, qhead);
729 cifs_dbg(FYI, "Clearing mid 0x%llx\n", mid_entry->mid);
730 mid_entry->mid_state = MID_SHUTDOWN;
731 list_move(&mid_entry->qhead, &dispose_list);
733 spin_unlock(&GlobalMid_Lock);
735 /* now walk dispose list and issue callbacks */
736 list_for_each_safe(tmp, tmp2, &dispose_list) {
737 mid_entry = list_entry(tmp, struct mid_q_entry, qhead);
738 cifs_dbg(FYI, "Callback mid 0x%llx\n", mid_entry->mid);
739 list_del_init(&mid_entry->qhead);
740 mid_entry->callback(mid_entry);
742 /* 1/8th of sec is more than enough time for them to exit */
746 if (!list_empty(&server->pending_mid_q)) {
748 * mpx threads have not exited yet give them at least the smb
749 * send timeout time for long ops.
751 * Due to delays on oplock break requests, we need to wait at
752 * least 45 seconds before giving up on a request getting a
753 * response and going ahead and killing cifsd.
755 cifs_dbg(FYI, "Wait for exit from demultiplex thread\n");
758 * If threads still have not exited they are probably never
759 * coming home not much else we can do but free the memory.
763 kfree(server->hostname);
767 length = atomic_dec_return(&tcpSesAllocCount);
769 mempool_resize(cifs_req_poolp, length + cifs_min_rcv,
774 standard_receive3(struct TCP_Server_Info *server, struct mid_q_entry *mid)
777 char *buf = server->smallbuf;
778 unsigned int pdu_length = get_rfc1002_length(buf);
780 /* make sure this will fit in a large buffer */
781 if (pdu_length > CIFSMaxBufSize + MAX_HEADER_SIZE(server) - 4) {
782 cifs_dbg(VFS, "SMB response too long (%u bytes)\n", pdu_length);
783 cifs_reconnect(server);
784 wake_up(&server->response_q);
788 /* switch to large buffer if too big for a small one */
789 if (pdu_length > MAX_CIFS_SMALL_BUFFER_SIZE - 4) {
790 server->large_buf = true;
791 memcpy(server->bigbuf, buf, server->total_read);
792 buf = server->bigbuf;
795 /* now read the rest */
796 length = cifs_read_from_socket(server, buf + HEADER_SIZE(server) - 1,
797 pdu_length - HEADER_SIZE(server) + 1 + 4);
800 server->total_read += length;
802 dump_smb(buf, server->total_read);
805 * We know that we received enough to get to the MID as we
806 * checked the pdu_length earlier. Now check to see
807 * if the rest of the header is OK. We borrow the length
808 * var for the rest of the loop to avoid a new stack var.
810 * 48 bytes is enough to display the header and a little bit
811 * into the payload for debugging purposes.
813 length = server->ops->check_message(buf, server->total_read);
815 cifs_dump_mem("Bad SMB: ", buf,
816 min_t(unsigned int, server->total_read, 48));
818 if (server->ops->is_status_pending &&
819 server->ops->is_status_pending(buf, server, length))
825 handle_mid(mid, server, buf, length);
830 cifs_demultiplex_thread(void *p)
833 struct TCP_Server_Info *server = p;
834 unsigned int pdu_length;
836 struct task_struct *task_to_wake = NULL;
837 struct mid_q_entry *mid_entry;
839 current->flags |= PF_MEMALLOC;
840 cifs_dbg(FYI, "Demultiplex PID: %d\n", task_pid_nr(current));
842 length = atomic_inc_return(&tcpSesAllocCount);
844 mempool_resize(cifs_req_poolp, length + cifs_min_rcv,
848 while (server->tcpStatus != CifsExiting) {
852 if (!allocate_buffers(server))
855 server->large_buf = false;
856 buf = server->smallbuf;
857 pdu_length = 4; /* enough to get RFC1001 header */
859 length = cifs_read_from_socket(server, buf, pdu_length);
862 server->total_read = length;
865 * The right amount was read from socket - 4 bytes,
866 * so we can now interpret the length field.
868 pdu_length = get_rfc1002_length(buf);
870 cifs_dbg(FYI, "RFC1002 header 0x%x\n", pdu_length);
871 if (!is_smb_response(server, buf[0]))
874 /* make sure we have enough to get to the MID */
875 if (pdu_length < HEADER_SIZE(server) - 1 - 4) {
876 cifs_dbg(VFS, "SMB response too short (%u bytes)\n",
878 cifs_reconnect(server);
879 wake_up(&server->response_q);
883 /* read down to the MID */
884 length = cifs_read_from_socket(server, buf + 4,
885 HEADER_SIZE(server) - 1 - 4);
888 server->total_read += length;
890 mid_entry = server->ops->find_mid(server, buf);
892 if (!mid_entry || !mid_entry->receive)
893 length = standard_receive3(server, mid_entry);
895 length = mid_entry->receive(server, mid_entry);
900 if (server->large_buf)
901 buf = server->bigbuf;
903 server->lstrp = jiffies;
904 if (mid_entry != NULL) {
905 if (!mid_entry->multiRsp || mid_entry->multiEnd)
906 mid_entry->callback(mid_entry);
907 } else if (!server->ops->is_oplock_break ||
908 !server->ops->is_oplock_break(buf, server)) {
909 cifs_dbg(VFS, "No task to wake, unknown frame received! NumMids %d\n",
910 atomic_read(&midCount));
911 cifs_dump_mem("Received Data is: ", buf,
912 HEADER_SIZE(server));
913 #ifdef CONFIG_CIFS_DEBUG2
914 if (server->ops->dump_detail)
915 server->ops->dump_detail(buf);
916 cifs_dump_mids(server);
917 #endif /* CIFS_DEBUG2 */
920 } /* end while !EXITING */
922 /* buffer usually freed in free_mid - need to free it here on exit */
923 cifs_buf_release(server->bigbuf);
924 if (server->smallbuf) /* no sense logging a debug message if NULL */
925 cifs_small_buf_release(server->smallbuf);
927 task_to_wake = xchg(&server->tsk, NULL);
928 clean_demultiplex_info(server);
930 /* if server->tsk was NULL then wait for a signal before exiting */
932 set_current_state(TASK_INTERRUPTIBLE);
933 while (!signal_pending(current)) {
935 set_current_state(TASK_INTERRUPTIBLE);
937 set_current_state(TASK_RUNNING);
940 module_put_and_exit(0);
943 /* extract the host portion of the UNC string */
945 extract_hostname(const char *unc)
951 /* skip double chars at beginning of string */
952 /* BB: check validity of these bytes? */
955 /* delimiter between hostname and sharename is always '\\' now */
956 delim = strchr(src, '\\');
958 return ERR_PTR(-EINVAL);
961 dst = kmalloc((len + 1), GFP_KERNEL);
963 return ERR_PTR(-ENOMEM);
965 memcpy(dst, src, len);
971 static int get_option_ul(substring_t args[], unsigned long *option)
976 string = match_strdup(args);
979 rc = kstrtoul(string, 0, option);
985 static int get_option_uid(substring_t args[], kuid_t *result)
991 rc = get_option_ul(args, &value);
995 uid = make_kuid(current_user_ns(), value);
1003 static int get_option_gid(substring_t args[], kgid_t *result)
1005 unsigned long value;
1009 rc = get_option_ul(args, &value);
1013 gid = make_kgid(current_user_ns(), value);
1014 if (!gid_valid(gid))
1021 static int cifs_parse_security_flavors(char *value,
1022 struct smb_vol *vol)
1025 substring_t args[MAX_OPT_ARGS];
1027 switch (match_token(value, cifs_secflavor_tokens, args)) {
1029 vol->secFlg |= CIFSSEC_MAY_KRB5 | CIFSSEC_MAY_SIGN;
1032 vol->secFlg |= CIFSSEC_MAY_KRB5 | CIFSSEC_MUST_SIGN;
1035 /* vol->secFlg |= CIFSSEC_MUST_SEAL | CIFSSEC_MAY_KRB5; */
1036 cifs_dbg(VFS, "Krb5 cifs privacy not supported\n");
1038 case Opt_sec_ntlmssp:
1039 vol->secFlg |= CIFSSEC_MAY_NTLMSSP;
1041 case Opt_sec_ntlmsspi:
1042 vol->secFlg |= CIFSSEC_MAY_NTLMSSP | CIFSSEC_MUST_SIGN;
1045 /* ntlm is default so can be turned off too */
1046 vol->secFlg |= CIFSSEC_MAY_NTLM;
1049 vol->secFlg |= CIFSSEC_MAY_NTLM | CIFSSEC_MUST_SIGN;
1051 case Opt_sec_ntlmv2:
1052 vol->secFlg |= CIFSSEC_MAY_NTLMV2;
1054 case Opt_sec_ntlmv2i:
1055 vol->secFlg |= CIFSSEC_MAY_NTLMV2 | CIFSSEC_MUST_SIGN;
1057 #ifdef CONFIG_CIFS_WEAK_PW_HASH
1058 case Opt_sec_lanman:
1059 vol->secFlg |= CIFSSEC_MAY_LANMAN;
1066 cifs_dbg(VFS, "bad security option: %s\n", value);
1074 cifs_parse_cache_flavor(char *value, struct smb_vol *vol)
1076 substring_t args[MAX_OPT_ARGS];
1078 switch (match_token(value, cifs_cacheflavor_tokens, args)) {
1079 case Opt_cache_loose:
1080 vol->direct_io = false;
1081 vol->strict_io = false;
1083 case Opt_cache_strict:
1084 vol->direct_io = false;
1085 vol->strict_io = true;
1087 case Opt_cache_none:
1088 vol->direct_io = true;
1089 vol->strict_io = false;
1092 cifs_dbg(VFS, "bad cache= option: %s\n", value);
1099 cifs_parse_smb_version(char *value, struct smb_vol *vol)
1101 substring_t args[MAX_OPT_ARGS];
1103 switch (match_token(value, cifs_smb_version_tokens, args)) {
1105 vol->ops = &smb1_operations;
1106 vol->vals = &smb1_values;
1108 #ifdef CONFIG_CIFS_SMB2
1110 vol->ops = &smb21_operations; /* currently identical with 2.1 */
1111 vol->vals = &smb20_values;
1114 vol->ops = &smb21_operations;
1115 vol->vals = &smb21_values;
1118 vol->ops = &smb30_operations;
1119 vol->vals = &smb30_values;
1123 cifs_dbg(VFS, "Unknown vers= option specified: %s\n", value);
1130 * Parse a devname into substrings and populate the vol->UNC and vol->prepath
1131 * fields with the result. Returns 0 on success and an error otherwise.
1134 cifs_parse_devname(const char *devname, struct smb_vol *vol)
1137 const char *delims = "/\\";
1140 /* make sure we have a valid UNC double delimiter prefix */
1141 len = strspn(devname, delims);
1145 /* find delimiter between host and sharename */
1146 pos = strpbrk(devname + 2, delims);
1150 /* skip past delimiter */
1153 /* now go until next delimiter or end of string */
1154 len = strcspn(pos, delims);
1156 /* move "pos" up to delimiter or NULL */
1158 vol->UNC = kstrndup(devname, pos - devname, GFP_KERNEL);
1162 convert_delimiter(vol->UNC, '\\');
1164 /* If pos is NULL, or is a bogus trailing delimiter then no prepath */
1165 if (!*pos++ || !*pos)
1168 vol->prepath = kstrdup(pos, GFP_KERNEL);
1176 cifs_parse_mount_options(const char *mountdata, const char *devname,
1177 struct smb_vol *vol)
1180 char *mountdata_copy = NULL, *options;
1181 unsigned int temp_len, i, j;
1183 short int override_uid = -1;
1184 short int override_gid = -1;
1185 bool uid_specified = false;
1186 bool gid_specified = false;
1187 bool sloppy = false;
1188 char *invalid = NULL;
1189 char *nodename = utsname()->nodename;
1190 char *string = NULL;
1191 char *tmp_end, *value;
1193 bool got_ip = false;
1194 unsigned short port = 0;
1195 struct sockaddr *dstaddr = (struct sockaddr *)&vol->dstaddr;
1199 delim = separator[0];
1201 /* ensure we always start with zeroed-out smb_vol */
1202 memset(vol, 0, sizeof(*vol));
1205 * does not have to be perfect mapping since field is
1206 * informational, only used for servers that do not support
1207 * port 445 and it can be overridden at mount time
1209 memset(vol->source_rfc1001_name, 0x20, RFC1001_NAME_LEN);
1210 for (i = 0; i < strnlen(nodename, RFC1001_NAME_LEN); i++)
1211 vol->source_rfc1001_name[i] = toupper(nodename[i]);
1213 vol->source_rfc1001_name[RFC1001_NAME_LEN] = 0;
1214 /* null target name indicates to use *SMBSERVR default called name
1215 if we end up sending RFC1001 session initialize */
1216 vol->target_rfc1001_name[0] = 0;
1217 vol->cred_uid = current_uid();
1218 vol->linux_uid = current_uid();
1219 vol->linux_gid = current_gid();
1221 /* default to only allowing write access to owner of the mount */
1222 vol->dir_mode = vol->file_mode = S_IRUGO | S_IXUGO | S_IWUSR;
1224 /* vol->retry default is 0 (i.e. "soft" limited retry not hard retry) */
1225 /* default is always to request posix paths. */
1226 vol->posix_paths = 1;
1227 /* default to using server inode numbers where available */
1228 vol->server_ino = 1;
1230 /* default is to use strict cifs caching semantics */
1231 vol->strict_io = true;
1233 vol->actimeo = CIFS_DEF_ACTIMEO;
1235 /* FIXME: add autonegotiation -- for now, SMB1 is default */
1236 vol->ops = &smb1_operations;
1237 vol->vals = &smb1_values;
1240 goto cifs_parse_mount_err;
1242 mountdata_copy = kstrndup(mountdata, PAGE_SIZE, GFP_KERNEL);
1243 if (!mountdata_copy)
1244 goto cifs_parse_mount_err;
1246 options = mountdata_copy;
1247 end = options + strlen(options);
1249 if (strncmp(options, "sep=", 4) == 0) {
1250 if (options[4] != 0) {
1251 separator[0] = options[4];
1254 cifs_dbg(FYI, "Null separator not allowed\n");
1257 vol->backupuid_specified = false; /* no backup intent for a user */
1258 vol->backupgid_specified = false; /* no backup intent for a group */
1261 * For now, we ignore -EINVAL errors under the assumption that the
1262 * unc= and prefixpath= options will be usable.
1264 if (cifs_parse_devname(devname, vol) == -ENOMEM) {
1265 printk(KERN_ERR "CIFS: Unable to allocate memory to parse "
1266 "device string.\n");
1270 while ((data = strsep(&options, separator)) != NULL) {
1271 substring_t args[MAX_OPT_ARGS];
1272 unsigned long option;
1278 token = match_token(data, cifs_mount_option_tokens, args);
1282 /* Ingnore the following */
1286 /* Boolean values */
1287 case Opt_user_xattr:
1290 case Opt_nouser_xattr:
1296 case Opt_noforceuid:
1302 case Opt_noforcegid:
1305 case Opt_noblocksend:
1306 vol->noblocksnd = 1;
1308 case Opt_noautotune:
1309 vol->noautotune = 1;
1326 case Opt_nomapchars:
1338 case Opt_posixpaths:
1339 vol->posix_paths = 1;
1341 case Opt_noposixpaths:
1342 vol->posix_paths = 0;
1345 vol->no_linux_ext = 1;
1356 * turn off mandatory locking in mode
1357 * if remote locking is turned off since the
1358 * local vfs will do advisory
1360 if (vol->file_mode ==
1361 (S_IALLUGO & ~(S_ISUID | S_IXGRP)))
1362 vol->file_mode = S_IALLUGO;
1364 case Opt_forcemandatorylock:
1374 vol->dynperm = true;
1377 vol->dynperm = false;
1391 case Opt_nostrictsync:
1392 vol->nostrictsync = 1;
1394 case Opt_strictsync:
1395 vol->nostrictsync = 0;
1398 vol->server_ino = 1;
1400 case Opt_noserverino:
1401 vol->server_ino = 0;
1403 case Opt_rwpidforward:
1404 vol->rwpidforward = 1;
1413 vol->no_psx_acl = 0;
1416 vol->no_psx_acl = 1;
1418 case Opt_locallease:
1419 vol->local_lease = 1;
1422 vol->secFlg |= CIFSSEC_MUST_SIGN;
1425 /* we do not do the following in secFlags because seal
1426 * is a per tree connection (mount) not a per socket
1427 * or per-smb connection option in the protocol
1428 * vol->secFlg |= CIFSSEC_MUST_SEAL;
1433 printk(KERN_WARNING "CIFS: Mount option noac not "
1434 "supported. Instead set "
1435 "/proc/fs/cifs/LookupCacheEnabled to 0\n");
1438 #ifndef CONFIG_CIFS_FSCACHE
1439 cifs_dbg(VFS, "FS-Cache support needs CONFIG_CIFS_FSCACHE kernel config option set\n");
1440 goto cifs_parse_mount_err;
1444 case Opt_mfsymlinks:
1445 vol->mfsymlinks = true;
1448 vol->multiuser = true;
1454 /* Numeric Values */
1456 if (get_option_uid(args, &vol->backupuid)) {
1457 cifs_dbg(VFS, "%s: Invalid backupuid value\n",
1459 goto cifs_parse_mount_err;
1461 vol->backupuid_specified = true;
1464 if (get_option_gid(args, &vol->backupgid)) {
1465 cifs_dbg(VFS, "%s: Invalid backupgid value\n",
1467 goto cifs_parse_mount_err;
1469 vol->backupgid_specified = true;
1472 if (get_option_uid(args, &vol->linux_uid)) {
1473 cifs_dbg(VFS, "%s: Invalid uid value\n",
1475 goto cifs_parse_mount_err;
1477 uid_specified = true;
1480 if (get_option_uid(args, &vol->cred_uid)) {
1481 cifs_dbg(VFS, "%s: Invalid cruid value\n",
1483 goto cifs_parse_mount_err;
1487 if (get_option_gid(args, &vol->linux_gid)) {
1488 cifs_dbg(VFS, "%s: Invalid gid value\n",
1490 goto cifs_parse_mount_err;
1492 gid_specified = true;
1495 if (get_option_ul(args, &option)) {
1496 cifs_dbg(VFS, "%s: Invalid file_mode value\n",
1498 goto cifs_parse_mount_err;
1500 vol->file_mode = option;
1503 if (get_option_ul(args, &option)) {
1504 cifs_dbg(VFS, "%s: Invalid dir_mode value\n",
1506 goto cifs_parse_mount_err;
1508 vol->dir_mode = option;
1511 if (get_option_ul(args, &option) ||
1512 option > USHRT_MAX) {
1513 cifs_dbg(VFS, "%s: Invalid port value\n",
1515 goto cifs_parse_mount_err;
1517 port = (unsigned short)option;
1520 if (get_option_ul(args, &option)) {
1521 cifs_dbg(VFS, "%s: Invalid rsize value\n",
1523 goto cifs_parse_mount_err;
1525 vol->rsize = option;
1528 if (get_option_ul(args, &option)) {
1529 cifs_dbg(VFS, "%s: Invalid wsize value\n",
1531 goto cifs_parse_mount_err;
1533 vol->wsize = option;
1536 if (get_option_ul(args, &option)) {
1537 cifs_dbg(VFS, "%s: Invalid actimeo value\n",
1539 goto cifs_parse_mount_err;
1541 vol->actimeo = HZ * option;
1542 if (vol->actimeo > CIFS_MAX_ACTIMEO) {
1543 cifs_dbg(VFS, "attribute cache timeout too large\n");
1544 goto cifs_parse_mount_err;
1548 /* String Arguments */
1550 case Opt_blank_user:
1551 /* null user, ie. anonymous authentication */
1553 vol->username = NULL;
1556 string = match_strdup(args);
1560 if (strnlen(string, MAX_USERNAME_SIZE) >
1561 MAX_USERNAME_SIZE) {
1562 printk(KERN_WARNING "CIFS: username too long\n");
1563 goto cifs_parse_mount_err;
1565 vol->username = kstrdup(string, GFP_KERNEL);
1567 goto cifs_parse_mount_err;
1569 case Opt_blank_pass:
1570 vol->password = NULL;
1573 /* passwords have to be handled differently
1574 * to allow the character used for deliminator
1575 * to be passed within them
1578 /* Obtain the value string */
1579 value = strchr(data, '=');
1582 /* Set tmp_end to end of the string */
1583 tmp_end = (char *) value + strlen(value);
1585 /* Check if following character is the deliminator
1586 * If yes, we have encountered a double deliminator
1587 * reset the NULL character to the deliminator
1589 if (tmp_end < end && tmp_end[1] == delim) {
1592 /* Keep iterating until we get to a single
1593 * deliminator OR the end
1595 while ((tmp_end = strchr(tmp_end, delim))
1596 != NULL && (tmp_end[1] == delim)) {
1597 tmp_end = (char *) &tmp_end[2];
1600 /* Reset var options to point to next element */
1603 options = (char *) &tmp_end[1];
1605 /* Reached the end of the mount option
1610 /* Now build new password string */
1611 temp_len = strlen(value);
1612 vol->password = kzalloc(temp_len+1, GFP_KERNEL);
1613 if (vol->password == NULL) {
1614 printk(KERN_WARNING "CIFS: no memory "
1616 goto cifs_parse_mount_err;
1619 for (i = 0, j = 0; i < temp_len; i++, j++) {
1620 vol->password[j] = value[i];
1621 if ((value[i] == delim) &&
1622 value[i+1] == delim)
1623 /* skip the second deliminator */
1626 vol->password[j] = '\0';
1629 /* FIXME: should this be an error instead? */
1633 string = match_strdup(args);
1637 if (!cifs_convert_address(dstaddr, string,
1639 printk(KERN_ERR "CIFS: bad ip= option (%s).\n",
1641 goto cifs_parse_mount_err;
1646 string = match_strdup(args);
1650 if (strnlen(string, 256) == 256) {
1651 printk(KERN_WARNING "CIFS: domain name too"
1653 goto cifs_parse_mount_err;
1656 vol->domainname = kstrdup(string, GFP_KERNEL);
1657 if (!vol->domainname) {
1658 printk(KERN_WARNING "CIFS: no memory "
1659 "for domainname\n");
1660 goto cifs_parse_mount_err;
1662 cifs_dbg(FYI, "Domain name set\n");
1665 string = match_strdup(args);
1669 if (!cifs_convert_address(
1670 (struct sockaddr *)&vol->srcaddr,
1671 string, strlen(string))) {
1672 printk(KERN_WARNING "CIFS: Could not parse"
1673 " srcaddr: %s\n", string);
1674 goto cifs_parse_mount_err;
1678 string = match_strdup(args);
1682 if (strnlen(string, 1024) >= 65) {
1683 printk(KERN_WARNING "CIFS: iocharset name "
1685 goto cifs_parse_mount_err;
1688 if (strnicmp(string, "default", 7) != 0) {
1689 vol->iocharset = kstrdup(string,
1691 if (!vol->iocharset) {
1692 printk(KERN_WARNING "CIFS: no memory"
1694 goto cifs_parse_mount_err;
1697 /* if iocharset not set then load_nls_default
1700 cifs_dbg(FYI, "iocharset set to %s\n", string);
1702 case Opt_netbiosname:
1703 string = match_strdup(args);
1707 memset(vol->source_rfc1001_name, 0x20,
1710 * FIXME: are there cases in which a comma can
1711 * be valid in workstation netbios name (and
1712 * need special handling)?
1714 for (i = 0; i < RFC1001_NAME_LEN; i++) {
1715 /* don't ucase netbiosname for user */
1718 vol->source_rfc1001_name[i] = string[i];
1720 /* The string has 16th byte zero still from
1721 * set at top of the function
1723 if (i == RFC1001_NAME_LEN && string[i] != 0)
1724 printk(KERN_WARNING "CIFS: netbiosname"
1725 " longer than 15 truncated.\n");
1729 /* servernetbiosname specified override *SMBSERVER */
1730 string = match_strdup(args);
1734 /* last byte, type, is 0x20 for servr type */
1735 memset(vol->target_rfc1001_name, 0x20,
1736 RFC1001_NAME_LEN_WITH_NULL);
1738 /* BB are there cases in which a comma can be
1739 valid in this workstation netbios name
1740 (and need special handling)? */
1742 /* user or mount helper must uppercase the
1744 for (i = 0; i < 15; i++) {
1747 vol->target_rfc1001_name[i] = string[i];
1749 /* The string has 16th byte zero still from
1750 set at top of the function */
1751 if (i == RFC1001_NAME_LEN && string[i] != 0)
1752 printk(KERN_WARNING "CIFS: server net"
1753 "biosname longer than 15 truncated.\n");
1756 string = match_strdup(args);
1760 if (strnicmp(string, "1", 1) == 0) {
1761 /* This is the default */
1764 /* For all other value, error */
1765 printk(KERN_WARNING "CIFS: Invalid version"
1767 goto cifs_parse_mount_err;
1769 string = match_strdup(args);
1773 if (cifs_parse_smb_version(string, vol) != 0)
1774 goto cifs_parse_mount_err;
1777 string = match_strdup(args);
1781 if (cifs_parse_security_flavors(string, vol) != 0)
1782 goto cifs_parse_mount_err;
1785 string = match_strdup(args);
1789 if (cifs_parse_cache_flavor(string, vol) != 0)
1790 goto cifs_parse_mount_err;
1794 * An option we don't recognize. Save it off for later
1795 * if we haven't already found one
1801 /* Free up any allocated string */
1806 if (!sloppy && invalid) {
1807 printk(KERN_ERR "CIFS: Unknown mount option \"%s\"\n", invalid);
1808 goto cifs_parse_mount_err;
1812 /* Muliuser mounts require CONFIG_KEYS support */
1813 if (vol->multiuser) {
1814 cifs_dbg(VFS, "Multiuser mounts require kernels with CONFIG_KEYS enabled\n");
1815 goto cifs_parse_mount_err;
1819 cifs_dbg(VFS, "CIFS mount error: No usable UNC path provided in device string or in unc= option!\n");
1820 goto cifs_parse_mount_err;
1823 /* make sure UNC has a share name */
1824 if (!strchr(vol->UNC + 3, '\\')) {
1825 cifs_dbg(VFS, "Malformed UNC. Unable to find share name.\n");
1826 goto cifs_parse_mount_err;
1830 /* No ip= option specified? Try to get it from UNC */
1831 if (!cifs_convert_address(dstaddr, &vol->UNC[2],
1832 strlen(&vol->UNC[2]))) {
1833 printk(KERN_ERR "Unable to determine destination "
1835 goto cifs_parse_mount_err;
1839 /* set the port that we got earlier */
1840 cifs_set_port(dstaddr, port);
1843 vol->override_uid = override_uid;
1844 else if (override_uid == 1)
1845 printk(KERN_NOTICE "CIFS: ignoring forceuid mount option "
1846 "specified with no uid= option.\n");
1849 vol->override_gid = override_gid;
1850 else if (override_gid == 1)
1851 printk(KERN_NOTICE "CIFS: ignoring forcegid mount option "
1852 "specified with no gid= option.\n");
1854 kfree(mountdata_copy);
1858 printk(KERN_WARNING "Could not allocate temporary buffer\n");
1859 cifs_parse_mount_err:
1861 kfree(mountdata_copy);
1865 /** Returns true if srcaddr isn't specified and rhs isn't
1866 * specified, or if srcaddr is specified and
1867 * matches the IP address of the rhs argument.
1870 srcip_matches(struct sockaddr *srcaddr, struct sockaddr *rhs)
1872 switch (srcaddr->sa_family) {
1874 return (rhs->sa_family == AF_UNSPEC);
1876 struct sockaddr_in *saddr4 = (struct sockaddr_in *)srcaddr;
1877 struct sockaddr_in *vaddr4 = (struct sockaddr_in *)rhs;
1878 return (saddr4->sin_addr.s_addr == vaddr4->sin_addr.s_addr);
1881 struct sockaddr_in6 *saddr6 = (struct sockaddr_in6 *)srcaddr;
1882 struct sockaddr_in6 *vaddr6 = (struct sockaddr_in6 *)rhs;
1883 return ipv6_addr_equal(&saddr6->sin6_addr, &vaddr6->sin6_addr);
1887 return false; /* don't expect to be here */
1892 * If no port is specified in addr structure, we try to match with 445 port
1893 * and if it fails - with 139 ports. It should be called only if address
1894 * families of server and addr are equal.
1897 match_port(struct TCP_Server_Info *server, struct sockaddr *addr)
1899 __be16 port, *sport;
1901 switch (addr->sa_family) {
1903 sport = &((struct sockaddr_in *) &server->dstaddr)->sin_port;
1904 port = ((struct sockaddr_in *) addr)->sin_port;
1907 sport = &((struct sockaddr_in6 *) &server->dstaddr)->sin6_port;
1908 port = ((struct sockaddr_in6 *) addr)->sin6_port;
1916 port = htons(CIFS_PORT);
1920 port = htons(RFC1001_PORT);
1923 return port == *sport;
1927 match_address(struct TCP_Server_Info *server, struct sockaddr *addr,
1928 struct sockaddr *srcaddr)
1930 switch (addr->sa_family) {
1932 struct sockaddr_in *addr4 = (struct sockaddr_in *)addr;
1933 struct sockaddr_in *srv_addr4 =
1934 (struct sockaddr_in *)&server->dstaddr;
1936 if (addr4->sin_addr.s_addr != srv_addr4->sin_addr.s_addr)
1941 struct sockaddr_in6 *addr6 = (struct sockaddr_in6 *)addr;
1942 struct sockaddr_in6 *srv_addr6 =
1943 (struct sockaddr_in6 *)&server->dstaddr;
1945 if (!ipv6_addr_equal(&addr6->sin6_addr,
1946 &srv_addr6->sin6_addr))
1948 if (addr6->sin6_scope_id != srv_addr6->sin6_scope_id)
1954 return false; /* don't expect to be here */
1957 if (!srcip_matches(srcaddr, (struct sockaddr *)&server->srcaddr))
1964 match_security(struct TCP_Server_Info *server, struct smb_vol *vol)
1966 unsigned int secFlags;
1968 if (vol->secFlg & (~(CIFSSEC_MUST_SIGN | CIFSSEC_MUST_SEAL)))
1969 secFlags = vol->secFlg;
1971 secFlags = global_secflags | vol->secFlg;
1973 switch (server->secType) {
1975 if (!(secFlags & (CIFSSEC_MAY_LANMAN|CIFSSEC_MAY_PLNTXT)))
1979 if (!(secFlags & CIFSSEC_MAY_NTLMV2))
1983 if (!(secFlags & CIFSSEC_MAY_NTLM))
1987 if (!(secFlags & CIFSSEC_MAY_KRB5))
1991 if (!(secFlags & CIFSSEC_MAY_NTLMSSP))
1995 /* shouldn't happen */
1999 /* now check if signing mode is acceptable */
2000 if ((secFlags & CIFSSEC_MAY_SIGN) == 0 &&
2001 (server->sec_mode & SECMODE_SIGN_REQUIRED))
2003 else if (((secFlags & CIFSSEC_MUST_SIGN) == CIFSSEC_MUST_SIGN) &&
2005 (SECMODE_SIGN_ENABLED|SECMODE_SIGN_REQUIRED)) == 0)
2011 static int match_server(struct TCP_Server_Info *server, struct smb_vol *vol)
2013 struct sockaddr *addr = (struct sockaddr *)&vol->dstaddr;
2015 if ((server->vals != vol->vals) || (server->ops != vol->ops))
2018 if (!net_eq(cifs_net_ns(server), current->nsproxy->net_ns))
2021 if (!match_address(server, addr,
2022 (struct sockaddr *)&vol->srcaddr))
2025 if (!match_port(server, addr))
2028 if (!match_security(server, vol))
2034 static struct TCP_Server_Info *
2035 cifs_find_tcp_session(struct smb_vol *vol)
2037 struct TCP_Server_Info *server;
2039 spin_lock(&cifs_tcp_ses_lock);
2040 list_for_each_entry(server, &cifs_tcp_ses_list, tcp_ses_list) {
2041 if (!match_server(server, vol))
2044 ++server->srv_count;
2045 spin_unlock(&cifs_tcp_ses_lock);
2046 cifs_dbg(FYI, "Existing tcp session with server found\n");
2049 spin_unlock(&cifs_tcp_ses_lock);
2054 cifs_put_tcp_session(struct TCP_Server_Info *server)
2056 struct task_struct *task;
2058 spin_lock(&cifs_tcp_ses_lock);
2059 if (--server->srv_count > 0) {
2060 spin_unlock(&cifs_tcp_ses_lock);
2064 put_net(cifs_net_ns(server));
2066 list_del_init(&server->tcp_ses_list);
2067 spin_unlock(&cifs_tcp_ses_lock);
2069 cancel_delayed_work_sync(&server->echo);
2071 spin_lock(&GlobalMid_Lock);
2072 server->tcpStatus = CifsExiting;
2073 spin_unlock(&GlobalMid_Lock);
2075 cifs_crypto_shash_release(server);
2076 cifs_fscache_release_client_cookie(server);
2078 kfree(server->session_key.response);
2079 server->session_key.response = NULL;
2080 server->session_key.len = 0;
2082 task = xchg(&server->tsk, NULL);
2084 force_sig(SIGKILL, task);
2087 static struct TCP_Server_Info *
2088 cifs_get_tcp_session(struct smb_vol *volume_info)
2090 struct TCP_Server_Info *tcp_ses = NULL;
2093 cifs_dbg(FYI, "UNC: %s\n", volume_info->UNC);
2095 /* see if we already have a matching tcp_ses */
2096 tcp_ses = cifs_find_tcp_session(volume_info);
2100 tcp_ses = kzalloc(sizeof(struct TCP_Server_Info), GFP_KERNEL);
2106 rc = cifs_crypto_shash_allocate(tcp_ses);
2108 cifs_dbg(VFS, "could not setup hash structures rc %d\n", rc);
2112 tcp_ses->ops = volume_info->ops;
2113 tcp_ses->vals = volume_info->vals;
2114 cifs_set_net_ns(tcp_ses, get_net(current->nsproxy->net_ns));
2115 tcp_ses->hostname = extract_hostname(volume_info->UNC);
2116 if (IS_ERR(tcp_ses->hostname)) {
2117 rc = PTR_ERR(tcp_ses->hostname);
2118 goto out_err_crypto_release;
2121 tcp_ses->noblocksnd = volume_info->noblocksnd;
2122 tcp_ses->noautotune = volume_info->noautotune;
2123 tcp_ses->tcp_nodelay = volume_info->sockopt_tcp_nodelay;
2124 tcp_ses->in_flight = 0;
2125 tcp_ses->credits = 1;
2126 init_waitqueue_head(&tcp_ses->response_q);
2127 init_waitqueue_head(&tcp_ses->request_q);
2128 INIT_LIST_HEAD(&tcp_ses->pending_mid_q);
2129 mutex_init(&tcp_ses->srv_mutex);
2130 memcpy(tcp_ses->workstation_RFC1001_name,
2131 volume_info->source_rfc1001_name, RFC1001_NAME_LEN_WITH_NULL);
2132 memcpy(tcp_ses->server_RFC1001_name,
2133 volume_info->target_rfc1001_name, RFC1001_NAME_LEN_WITH_NULL);
2134 tcp_ses->session_estab = false;
2135 tcp_ses->sequence_number = 0;
2136 tcp_ses->lstrp = jiffies;
2137 spin_lock_init(&tcp_ses->req_lock);
2138 INIT_LIST_HEAD(&tcp_ses->tcp_ses_list);
2139 INIT_LIST_HEAD(&tcp_ses->smb_ses_list);
2140 INIT_DELAYED_WORK(&tcp_ses->echo, cifs_echo_request);
2141 memcpy(&tcp_ses->srcaddr, &volume_info->srcaddr,
2142 sizeof(tcp_ses->srcaddr));
2143 memcpy(&tcp_ses->dstaddr, &volume_info->dstaddr,
2144 sizeof(tcp_ses->dstaddr));
2146 * at this point we are the only ones with the pointer
2147 * to the struct since the kernel thread not created yet
2148 * no need to spinlock this init of tcpStatus or srv_count
2150 tcp_ses->tcpStatus = CifsNew;
2151 ++tcp_ses->srv_count;
2153 rc = ip_connect(tcp_ses);
2155 cifs_dbg(VFS, "Error connecting to socket. Aborting operation.\n");
2156 goto out_err_crypto_release;
2160 * since we're in a cifs function already, we know that
2161 * this will succeed. No need for try_module_get().
2163 __module_get(THIS_MODULE);
2164 tcp_ses->tsk = kthread_run(cifs_demultiplex_thread,
2166 if (IS_ERR(tcp_ses->tsk)) {
2167 rc = PTR_ERR(tcp_ses->tsk);
2168 cifs_dbg(VFS, "error %d create cifsd thread\n", rc);
2169 module_put(THIS_MODULE);
2170 goto out_err_crypto_release;
2172 tcp_ses->tcpStatus = CifsNeedNegotiate;
2174 /* thread spawned, put it on the list */
2175 spin_lock(&cifs_tcp_ses_lock);
2176 list_add(&tcp_ses->tcp_ses_list, &cifs_tcp_ses_list);
2177 spin_unlock(&cifs_tcp_ses_lock);
2179 cifs_fscache_get_client_cookie(tcp_ses);
2181 /* queue echo request delayed work */
2182 queue_delayed_work(cifsiod_wq, &tcp_ses->echo, SMB_ECHO_INTERVAL);
2186 out_err_crypto_release:
2187 cifs_crypto_shash_release(tcp_ses);
2189 put_net(cifs_net_ns(tcp_ses));
2193 if (!IS_ERR(tcp_ses->hostname))
2194 kfree(tcp_ses->hostname);
2195 if (tcp_ses->ssocket)
2196 sock_release(tcp_ses->ssocket);
2202 static int match_session(struct cifs_ses *ses, struct smb_vol *vol)
2204 switch (ses->server->secType) {
2206 if (!uid_eq(vol->cred_uid, ses->cred_uid))
2210 /* NULL username means anonymous session */
2211 if (ses->user_name == NULL) {
2217 /* anything else takes username/password */
2218 if (strncmp(ses->user_name,
2219 vol->username ? vol->username : "",
2222 if (strlen(vol->username) != 0 &&
2223 ses->password != NULL &&
2224 strncmp(ses->password,
2225 vol->password ? vol->password : "",
2232 static struct cifs_ses *
2233 cifs_find_smb_ses(struct TCP_Server_Info *server, struct smb_vol *vol)
2235 struct cifs_ses *ses;
2237 spin_lock(&cifs_tcp_ses_lock);
2238 list_for_each_entry(ses, &server->smb_ses_list, smb_ses_list) {
2239 if (!match_session(ses, vol))
2242 spin_unlock(&cifs_tcp_ses_lock);
2245 spin_unlock(&cifs_tcp_ses_lock);
2250 cifs_put_smb_ses(struct cifs_ses *ses)
2253 struct TCP_Server_Info *server = ses->server;
2255 cifs_dbg(FYI, "%s: ses_count=%d\n", __func__, ses->ses_count);
2256 spin_lock(&cifs_tcp_ses_lock);
2257 if (--ses->ses_count > 0) {
2258 spin_unlock(&cifs_tcp_ses_lock);
2262 list_del_init(&ses->smb_ses_list);
2263 spin_unlock(&cifs_tcp_ses_lock);
2265 if (ses->status == CifsGood && server->ops->logoff) {
2267 server->ops->logoff(xid, ses);
2271 cifs_put_tcp_session(server);
2276 /* strlen("cifs:a:") + INET6_ADDRSTRLEN + 1 */
2277 #define CIFSCREDS_DESC_SIZE (7 + INET6_ADDRSTRLEN + 1)
2279 /* Populate username and pw fields from keyring if possible */
2281 cifs_set_cifscreds(struct smb_vol *vol, struct cifs_ses *ses)
2284 char *desc, *delim, *payload;
2287 struct TCP_Server_Info *server = ses->server;
2288 struct sockaddr_in *sa;
2289 struct sockaddr_in6 *sa6;
2290 struct user_key_payload *upayload;
2292 desc = kmalloc(CIFSCREDS_DESC_SIZE, GFP_KERNEL);
2296 /* try to find an address key first */
2297 switch (server->dstaddr.ss_family) {
2299 sa = (struct sockaddr_in *)&server->dstaddr;
2300 sprintf(desc, "cifs:a:%pI4", &sa->sin_addr.s_addr);
2303 sa6 = (struct sockaddr_in6 *)&server->dstaddr;
2304 sprintf(desc, "cifs:a:%pI6c", &sa6->sin6_addr.s6_addr);
2307 cifs_dbg(FYI, "Bad ss_family (%hu)\n",
2308 server->dstaddr.ss_family);
2313 cifs_dbg(FYI, "%s: desc=%s\n", __func__, desc);
2314 key = request_key(&key_type_logon, desc, "");
2316 if (!ses->domainName) {
2317 cifs_dbg(FYI, "domainName is NULL\n");
2322 /* didn't work, try to find a domain key */
2323 sprintf(desc, "cifs:d:%s", ses->domainName);
2324 cifs_dbg(FYI, "%s: desc=%s\n", __func__, desc);
2325 key = request_key(&key_type_logon, desc, "");
2332 down_read(&key->sem);
2333 upayload = key->payload.data;
2334 if (IS_ERR_OR_NULL(upayload)) {
2335 rc = upayload ? PTR_ERR(upayload) : -EINVAL;
2339 /* find first : in payload */
2340 payload = (char *)upayload->data;
2341 delim = strnchr(payload, upayload->datalen, ':');
2342 cifs_dbg(FYI, "payload=%s\n", payload);
2344 cifs_dbg(FYI, "Unable to find ':' in payload (datalen=%d)\n",
2350 len = delim - payload;
2351 if (len > MAX_USERNAME_SIZE || len <= 0) {
2352 cifs_dbg(FYI, "Bad value from username search (len=%zd)\n",
2358 vol->username = kstrndup(payload, len, GFP_KERNEL);
2359 if (!vol->username) {
2360 cifs_dbg(FYI, "Unable to allocate %zd bytes for username\n",
2365 cifs_dbg(FYI, "%s: username=%s\n", __func__, vol->username);
2367 len = key->datalen - (len + 1);
2368 if (len > MAX_PASSWORD_SIZE || len <= 0) {
2369 cifs_dbg(FYI, "Bad len for password search (len=%zd)\n", len);
2371 kfree(vol->username);
2372 vol->username = NULL;
2377 vol->password = kstrndup(delim, len, GFP_KERNEL);
2378 if (!vol->password) {
2379 cifs_dbg(FYI, "Unable to allocate %zd bytes for password\n",
2382 kfree(vol->username);
2383 vol->username = NULL;
2392 cifs_dbg(FYI, "%s: returning %d\n", __func__, rc);
2395 #else /* ! CONFIG_KEYS */
2397 cifs_set_cifscreds(struct smb_vol *vol __attribute__((unused)),
2398 struct cifs_ses *ses __attribute__((unused)))
2402 #endif /* CONFIG_KEYS */
2404 static struct cifs_ses *
2405 cifs_get_smb_ses(struct TCP_Server_Info *server, struct smb_vol *volume_info)
2409 struct cifs_ses *ses;
2410 struct sockaddr_in *addr = (struct sockaddr_in *)&server->dstaddr;
2411 struct sockaddr_in6 *addr6 = (struct sockaddr_in6 *)&server->dstaddr;
2415 ses = cifs_find_smb_ses(server, volume_info);
2417 cifs_dbg(FYI, "Existing smb sess found (status=%d)\n",
2420 mutex_lock(&ses->session_mutex);
2421 rc = cifs_negotiate_protocol(xid, ses);
2423 mutex_unlock(&ses->session_mutex);
2424 /* problem -- put our ses reference */
2425 cifs_put_smb_ses(ses);
2429 if (ses->need_reconnect) {
2430 cifs_dbg(FYI, "Session needs reconnect\n");
2431 rc = cifs_setup_session(xid, ses,
2432 volume_info->local_nls);
2434 mutex_unlock(&ses->session_mutex);
2435 /* problem -- put our reference */
2436 cifs_put_smb_ses(ses);
2441 mutex_unlock(&ses->session_mutex);
2443 /* existing SMB ses has a server reference already */
2444 cifs_put_tcp_session(server);
2449 cifs_dbg(FYI, "Existing smb sess not found\n");
2450 ses = sesInfoAlloc();
2454 /* new SMB session uses our server ref */
2455 ses->server = server;
2456 if (server->dstaddr.ss_family == AF_INET6)
2457 sprintf(ses->serverName, "%pI6", &addr6->sin6_addr);
2459 sprintf(ses->serverName, "%pI4", &addr->sin_addr);
2461 if (volume_info->username) {
2462 ses->user_name = kstrdup(volume_info->username, GFP_KERNEL);
2463 if (!ses->user_name)
2467 /* volume_info->password freed at unmount */
2468 if (volume_info->password) {
2469 ses->password = kstrdup(volume_info->password, GFP_KERNEL);
2473 if (volume_info->domainname) {
2474 ses->domainName = kstrdup(volume_info->domainname, GFP_KERNEL);
2475 if (!ses->domainName)
2478 ses->cred_uid = volume_info->cred_uid;
2479 ses->linux_uid = volume_info->linux_uid;
2481 ses->overrideSecFlg = volume_info->secFlg;
2483 mutex_lock(&ses->session_mutex);
2484 rc = cifs_negotiate_protocol(xid, ses);
2486 rc = cifs_setup_session(xid, ses, volume_info->local_nls);
2487 mutex_unlock(&ses->session_mutex);
2491 /* success, put it on the list */
2492 spin_lock(&cifs_tcp_ses_lock);
2493 list_add(&ses->smb_ses_list, &server->smb_ses_list);
2494 spin_unlock(&cifs_tcp_ses_lock);
2505 static int match_tcon(struct cifs_tcon *tcon, const char *unc)
2507 if (tcon->tidStatus == CifsExiting)
2509 if (strncmp(tcon->treeName, unc, MAX_TREE_SIZE))
2514 static struct cifs_tcon *
2515 cifs_find_tcon(struct cifs_ses *ses, const char *unc)
2517 struct list_head *tmp;
2518 struct cifs_tcon *tcon;
2520 spin_lock(&cifs_tcp_ses_lock);
2521 list_for_each(tmp, &ses->tcon_list) {
2522 tcon = list_entry(tmp, struct cifs_tcon, tcon_list);
2523 if (!match_tcon(tcon, unc))
2526 spin_unlock(&cifs_tcp_ses_lock);
2529 spin_unlock(&cifs_tcp_ses_lock);
2534 cifs_put_tcon(struct cifs_tcon *tcon)
2537 struct cifs_ses *ses = tcon->ses;
2539 cifs_dbg(FYI, "%s: tc_count=%d\n", __func__, tcon->tc_count);
2540 spin_lock(&cifs_tcp_ses_lock);
2541 if (--tcon->tc_count > 0) {
2542 spin_unlock(&cifs_tcp_ses_lock);
2546 list_del_init(&tcon->tcon_list);
2547 spin_unlock(&cifs_tcp_ses_lock);
2550 if (ses->server->ops->tree_disconnect)
2551 ses->server->ops->tree_disconnect(xid, tcon);
2554 cifs_fscache_release_super_cookie(tcon);
2556 cifs_put_smb_ses(ses);
2559 static struct cifs_tcon *
2560 cifs_get_tcon(struct cifs_ses *ses, struct smb_vol *volume_info)
2563 struct cifs_tcon *tcon;
2565 tcon = cifs_find_tcon(ses, volume_info->UNC);
2567 cifs_dbg(FYI, "Found match on UNC path\n");
2568 /* existing tcon already has a reference */
2569 cifs_put_smb_ses(ses);
2570 if (tcon->seal != volume_info->seal)
2571 cifs_dbg(VFS, "transport encryption setting conflicts with existing tid\n");
2575 if (!ses->server->ops->tree_connect) {
2580 tcon = tconInfoAlloc();
2587 if (volume_info->password) {
2588 tcon->password = kstrdup(volume_info->password, GFP_KERNEL);
2589 if (!tcon->password) {
2596 * BB Do we need to wrap session_mutex around this TCon call and Unix
2597 * SetFS as we do on SessSetup and reconnect?
2600 rc = ses->server->ops->tree_connect(xid, ses, volume_info->UNC, tcon,
2601 volume_info->local_nls);
2603 cifs_dbg(FYI, "Tcon rc = %d\n", rc);
2607 if (volume_info->nodfs) {
2608 tcon->Flags &= ~SMB_SHARE_IS_IN_DFS;
2609 cifs_dbg(FYI, "DFS disabled (%d)\n", tcon->Flags);
2611 tcon->seal = volume_info->seal;
2613 * We can have only one retry value for a connection to a share so for
2614 * resources mounted more than once to the same server share the last
2615 * value passed in for the retry flag is used.
2617 tcon->retry = volume_info->retry;
2618 tcon->nocase = volume_info->nocase;
2619 tcon->local_lease = volume_info->local_lease;
2620 INIT_LIST_HEAD(&tcon->pending_opens);
2622 spin_lock(&cifs_tcp_ses_lock);
2623 list_add(&tcon->tcon_list, &ses->tcon_list);
2624 spin_unlock(&cifs_tcp_ses_lock);
2626 cifs_fscache_get_super_cookie(tcon);
2636 cifs_put_tlink(struct tcon_link *tlink)
2638 if (!tlink || IS_ERR(tlink))
2641 if (!atomic_dec_and_test(&tlink->tl_count) ||
2642 test_bit(TCON_LINK_IN_TREE, &tlink->tl_flags)) {
2643 tlink->tl_time = jiffies;
2647 if (!IS_ERR(tlink_tcon(tlink)))
2648 cifs_put_tcon(tlink_tcon(tlink));
2653 static inline struct tcon_link *
2654 cifs_sb_master_tlink(struct cifs_sb_info *cifs_sb)
2656 return cifs_sb->master_tlink;
2660 compare_mount_options(struct super_block *sb, struct cifs_mnt_data *mnt_data)
2662 struct cifs_sb_info *old = CIFS_SB(sb);
2663 struct cifs_sb_info *new = mnt_data->cifs_sb;
2665 if ((sb->s_flags & CIFS_MS_MASK) != (mnt_data->flags & CIFS_MS_MASK))
2668 if ((old->mnt_cifs_flags & CIFS_MOUNT_MASK) !=
2669 (new->mnt_cifs_flags & CIFS_MOUNT_MASK))
2673 * We want to share sb only if we don't specify an r/wsize or
2674 * specified r/wsize is greater than or equal to existing one.
2676 if (new->wsize && new->wsize < old->wsize)
2679 if (new->rsize && new->rsize < old->rsize)
2682 if (!uid_eq(old->mnt_uid, new->mnt_uid) || !gid_eq(old->mnt_gid, new->mnt_gid))
2685 if (old->mnt_file_mode != new->mnt_file_mode ||
2686 old->mnt_dir_mode != new->mnt_dir_mode)
2689 if (strcmp(old->local_nls->charset, new->local_nls->charset))
2692 if (old->actimeo != new->actimeo)
2699 cifs_match_super(struct super_block *sb, void *data)
2701 struct cifs_mnt_data *mnt_data = (struct cifs_mnt_data *)data;
2702 struct smb_vol *volume_info;
2703 struct cifs_sb_info *cifs_sb;
2704 struct TCP_Server_Info *tcp_srv;
2705 struct cifs_ses *ses;
2706 struct cifs_tcon *tcon;
2707 struct tcon_link *tlink;
2710 spin_lock(&cifs_tcp_ses_lock);
2711 cifs_sb = CIFS_SB(sb);
2712 tlink = cifs_get_tlink(cifs_sb_master_tlink(cifs_sb));
2713 if (IS_ERR(tlink)) {
2714 spin_unlock(&cifs_tcp_ses_lock);
2717 tcon = tlink_tcon(tlink);
2719 tcp_srv = ses->server;
2721 volume_info = mnt_data->vol;
2723 if (!match_server(tcp_srv, volume_info) ||
2724 !match_session(ses, volume_info) ||
2725 !match_tcon(tcon, volume_info->UNC)) {
2730 rc = compare_mount_options(sb, mnt_data);
2732 spin_unlock(&cifs_tcp_ses_lock);
2733 cifs_put_tlink(tlink);
2738 get_dfs_path(const unsigned int xid, struct cifs_ses *ses, const char *old_path,
2739 const struct nls_table *nls_codepage, unsigned int *num_referrals,
2740 struct dfs_info3_param **referrals, int remap)
2745 if (!ses->server->ops->tree_connect || !ses->server->ops->get_dfs_refer)
2751 if (ses->ipc_tid == 0) {
2752 temp_unc = kmalloc(2 /* for slashes */ +
2753 strnlen(ses->serverName, SERVER_NAME_LEN_WITH_NULL * 2)
2754 + 1 + 4 /* slash IPC$ */ + 2, GFP_KERNEL);
2755 if (temp_unc == NULL)
2759 strcpy(temp_unc + 2, ses->serverName);
2760 strcpy(temp_unc + 2 + strlen(ses->serverName), "\\IPC$");
2761 rc = ses->server->ops->tree_connect(xid, ses, temp_unc, NULL,
2763 cifs_dbg(FYI, "Tcon rc = %d ipc_tid = %d\n", rc, ses->ipc_tid);
2767 rc = ses->server->ops->get_dfs_refer(xid, ses, old_path,
2768 referrals, num_referrals,
2769 nls_codepage, remap);
2771 * BB - map targetUNCs to dfs_info3 structures, here or in
2772 * ses->server->ops->get_dfs_refer.
2778 #ifdef CONFIG_DEBUG_LOCK_ALLOC
2779 static struct lock_class_key cifs_key[2];
2780 static struct lock_class_key cifs_slock_key[2];
2783 cifs_reclassify_socket4(struct socket *sock)
2785 struct sock *sk = sock->sk;
2786 BUG_ON(sock_owned_by_user(sk));
2787 sock_lock_init_class_and_name(sk, "slock-AF_INET-CIFS",
2788 &cifs_slock_key[0], "sk_lock-AF_INET-CIFS", &cifs_key[0]);
2792 cifs_reclassify_socket6(struct socket *sock)
2794 struct sock *sk = sock->sk;
2795 BUG_ON(sock_owned_by_user(sk));
2796 sock_lock_init_class_and_name(sk, "slock-AF_INET6-CIFS",
2797 &cifs_slock_key[1], "sk_lock-AF_INET6-CIFS", &cifs_key[1]);
2801 cifs_reclassify_socket4(struct socket *sock)
2806 cifs_reclassify_socket6(struct socket *sock)
2811 /* See RFC1001 section 14 on representation of Netbios names */
2812 static void rfc1002mangle(char *target, char *source, unsigned int length)
2816 for (i = 0, j = 0; i < (length); i++) {
2817 /* mask a nibble at a time and encode */
2818 target[j] = 'A' + (0x0F & (source[i] >> 4));
2819 target[j+1] = 'A' + (0x0F & source[i]);
2826 bind_socket(struct TCP_Server_Info *server)
2829 if (server->srcaddr.ss_family != AF_UNSPEC) {
2830 /* Bind to the specified local IP address */
2831 struct socket *socket = server->ssocket;
2832 rc = socket->ops->bind(socket,
2833 (struct sockaddr *) &server->srcaddr,
2834 sizeof(server->srcaddr));
2836 struct sockaddr_in *saddr4;
2837 struct sockaddr_in6 *saddr6;
2838 saddr4 = (struct sockaddr_in *)&server->srcaddr;
2839 saddr6 = (struct sockaddr_in6 *)&server->srcaddr;
2840 if (saddr6->sin6_family == AF_INET6)
2841 cifs_dbg(VFS, "Failed to bind to: %pI6c, error: %d\n",
2842 &saddr6->sin6_addr, rc);
2844 cifs_dbg(VFS, "Failed to bind to: %pI4, error: %d\n",
2845 &saddr4->sin_addr.s_addr, rc);
2852 ip_rfc1001_connect(struct TCP_Server_Info *server)
2856 * some servers require RFC1001 sessinit before sending
2857 * negprot - BB check reconnection in case where second
2858 * sessinit is sent but no second negprot
2860 struct rfc1002_session_packet *ses_init_buf;
2861 struct smb_hdr *smb_buf;
2862 ses_init_buf = kzalloc(sizeof(struct rfc1002_session_packet),
2865 ses_init_buf->trailer.session_req.called_len = 32;
2867 if (server->server_RFC1001_name &&
2868 server->server_RFC1001_name[0] != 0)
2869 rfc1002mangle(ses_init_buf->trailer.
2870 session_req.called_name,
2871 server->server_RFC1001_name,
2872 RFC1001_NAME_LEN_WITH_NULL);
2874 rfc1002mangle(ses_init_buf->trailer.
2875 session_req.called_name,
2876 DEFAULT_CIFS_CALLED_NAME,
2877 RFC1001_NAME_LEN_WITH_NULL);
2879 ses_init_buf->trailer.session_req.calling_len = 32;
2882 * calling name ends in null (byte 16) from old smb
2885 if (server->workstation_RFC1001_name &&
2886 server->workstation_RFC1001_name[0] != 0)
2887 rfc1002mangle(ses_init_buf->trailer.
2888 session_req.calling_name,
2889 server->workstation_RFC1001_name,
2890 RFC1001_NAME_LEN_WITH_NULL);
2892 rfc1002mangle(ses_init_buf->trailer.
2893 session_req.calling_name,
2895 RFC1001_NAME_LEN_WITH_NULL);
2897 ses_init_buf->trailer.session_req.scope1 = 0;
2898 ses_init_buf->trailer.session_req.scope2 = 0;
2899 smb_buf = (struct smb_hdr *)ses_init_buf;
2901 /* sizeof RFC1002_SESSION_REQUEST with no scope */
2902 smb_buf->smb_buf_length = cpu_to_be32(0x81000044);
2903 rc = smb_send(server, smb_buf, 0x44);
2904 kfree(ses_init_buf);
2906 * RFC1001 layer in at least one server
2907 * requires very short break before negprot
2908 * presumably because not expecting negprot
2909 * to follow so fast. This is a simple
2910 * solution that works without
2911 * complicating the code and causes no
2912 * significant slowing down on mount
2915 usleep_range(1000, 2000);
2918 * else the negprot may still work without this
2919 * even though malloc failed
2926 generic_ip_connect(struct TCP_Server_Info *server)
2931 struct socket *socket = server->ssocket;
2932 struct sockaddr *saddr;
2934 saddr = (struct sockaddr *) &server->dstaddr;
2936 if (server->dstaddr.ss_family == AF_INET6) {
2937 sport = ((struct sockaddr_in6 *) saddr)->sin6_port;
2938 slen = sizeof(struct sockaddr_in6);
2941 sport = ((struct sockaddr_in *) saddr)->sin_port;
2942 slen = sizeof(struct sockaddr_in);
2946 if (socket == NULL) {
2947 rc = __sock_create(cifs_net_ns(server), sfamily, SOCK_STREAM,
2948 IPPROTO_TCP, &socket, 1);
2950 cifs_dbg(VFS, "Error %d creating socket\n", rc);
2951 server->ssocket = NULL;
2955 /* BB other socket options to set KEEPALIVE, NODELAY? */
2956 cifs_dbg(FYI, "Socket created\n");
2957 server->ssocket = socket;
2958 socket->sk->sk_allocation = GFP_NOFS;
2959 if (sfamily == AF_INET6)
2960 cifs_reclassify_socket6(socket);
2962 cifs_reclassify_socket4(socket);
2965 rc = bind_socket(server);
2970 * Eventually check for other socket options to change from
2971 * the default. sock_setsockopt not used because it expects
2974 socket->sk->sk_rcvtimeo = 7 * HZ;
2975 socket->sk->sk_sndtimeo = 5 * HZ;
2977 /* make the bufsizes depend on wsize/rsize and max requests */
2978 if (server->noautotune) {
2979 if (socket->sk->sk_sndbuf < (200 * 1024))
2980 socket->sk->sk_sndbuf = 200 * 1024;
2981 if (socket->sk->sk_rcvbuf < (140 * 1024))
2982 socket->sk->sk_rcvbuf = 140 * 1024;
2985 if (server->tcp_nodelay) {
2987 rc = kernel_setsockopt(socket, SOL_TCP, TCP_NODELAY,
2988 (char *)&val, sizeof(val));
2990 cifs_dbg(FYI, "set TCP_NODELAY socket option error %d\n",
2994 cifs_dbg(FYI, "sndbuf %d rcvbuf %d rcvtimeo 0x%lx\n",
2995 socket->sk->sk_sndbuf,
2996 socket->sk->sk_rcvbuf, socket->sk->sk_rcvtimeo);
2998 rc = socket->ops->connect(socket, saddr, slen, 0);
3000 cifs_dbg(FYI, "Error %d connecting to server\n", rc);
3001 sock_release(socket);
3002 server->ssocket = NULL;
3006 if (sport == htons(RFC1001_PORT))
3007 rc = ip_rfc1001_connect(server);
3013 ip_connect(struct TCP_Server_Info *server)
3016 struct sockaddr_in6 *addr6 = (struct sockaddr_in6 *)&server->dstaddr;
3017 struct sockaddr_in *addr = (struct sockaddr_in *)&server->dstaddr;
3019 if (server->dstaddr.ss_family == AF_INET6)
3020 sport = &addr6->sin6_port;
3022 sport = &addr->sin_port;
3027 /* try with 445 port at first */
3028 *sport = htons(CIFS_PORT);
3030 rc = generic_ip_connect(server);
3034 /* if it failed, try with 139 port */
3035 *sport = htons(RFC1001_PORT);
3038 return generic_ip_connect(server);
3041 void reset_cifs_unix_caps(unsigned int xid, struct cifs_tcon *tcon,
3042 struct cifs_sb_info *cifs_sb, struct smb_vol *vol_info)
3044 /* if we are reconnecting then should we check to see if
3045 * any requested capabilities changed locally e.g. via
3046 * remount but we can not do much about it here
3047 * if they have (even if we could detect it by the following)
3048 * Perhaps we could add a backpointer to array of sb from tcon
3049 * or if we change to make all sb to same share the same
3050 * sb as NFS - then we only have one backpointer to sb.
3051 * What if we wanted to mount the server share twice once with
3052 * and once without posixacls or posix paths? */
3053 __u64 saved_cap = le64_to_cpu(tcon->fsUnixInfo.Capability);
3055 if (vol_info && vol_info->no_linux_ext) {
3056 tcon->fsUnixInfo.Capability = 0;
3057 tcon->unix_ext = 0; /* Unix Extensions disabled */
3058 cifs_dbg(FYI, "Linux protocol extensions disabled\n");
3060 } else if (vol_info)
3061 tcon->unix_ext = 1; /* Unix Extensions supported */
3063 if (tcon->unix_ext == 0) {
3064 cifs_dbg(FYI, "Unix extensions disabled so not set on reconnect\n");
3068 if (!CIFSSMBQFSUnixInfo(xid, tcon)) {
3069 __u64 cap = le64_to_cpu(tcon->fsUnixInfo.Capability);
3070 cifs_dbg(FYI, "unix caps which server supports %lld\n", cap);
3071 /* check for reconnect case in which we do not
3072 want to change the mount behavior if we can avoid it */
3073 if (vol_info == NULL) {
3074 /* turn off POSIX ACL and PATHNAMES if not set
3075 originally at mount time */
3076 if ((saved_cap & CIFS_UNIX_POSIX_ACL_CAP) == 0)
3077 cap &= ~CIFS_UNIX_POSIX_ACL_CAP;
3078 if ((saved_cap & CIFS_UNIX_POSIX_PATHNAMES_CAP) == 0) {
3079 if (cap & CIFS_UNIX_POSIX_PATHNAMES_CAP)
3080 cifs_dbg(VFS, "POSIXPATH support change\n");
3081 cap &= ~CIFS_UNIX_POSIX_PATHNAMES_CAP;
3082 } else if ((cap & CIFS_UNIX_POSIX_PATHNAMES_CAP) == 0) {
3083 cifs_dbg(VFS, "possible reconnect error\n");
3084 cifs_dbg(VFS, "server disabled POSIX path support\n");
3088 if (cap & CIFS_UNIX_TRANSPORT_ENCRYPTION_MANDATORY_CAP)
3089 cifs_dbg(VFS, "per-share encryption not supported yet\n");
3091 cap &= CIFS_UNIX_CAP_MASK;
3092 if (vol_info && vol_info->no_psx_acl)
3093 cap &= ~CIFS_UNIX_POSIX_ACL_CAP;
3094 else if (CIFS_UNIX_POSIX_ACL_CAP & cap) {
3095 cifs_dbg(FYI, "negotiated posix acl support\n");
3097 cifs_sb->mnt_cifs_flags |=
3098 CIFS_MOUNT_POSIXACL;
3101 if (vol_info && vol_info->posix_paths == 0)
3102 cap &= ~CIFS_UNIX_POSIX_PATHNAMES_CAP;
3103 else if (cap & CIFS_UNIX_POSIX_PATHNAMES_CAP) {
3104 cifs_dbg(FYI, "negotiate posix pathnames\n");
3106 cifs_sb->mnt_cifs_flags |=
3107 CIFS_MOUNT_POSIX_PATHS;
3110 cifs_dbg(FYI, "Negotiate caps 0x%x\n", (int)cap);
3111 #ifdef CONFIG_CIFS_DEBUG2
3112 if (cap & CIFS_UNIX_FCNTL_CAP)
3113 cifs_dbg(FYI, "FCNTL cap\n");
3114 if (cap & CIFS_UNIX_EXTATTR_CAP)
3115 cifs_dbg(FYI, "EXTATTR cap\n");
3116 if (cap & CIFS_UNIX_POSIX_PATHNAMES_CAP)
3117 cifs_dbg(FYI, "POSIX path cap\n");
3118 if (cap & CIFS_UNIX_XATTR_CAP)
3119 cifs_dbg(FYI, "XATTR cap\n");
3120 if (cap & CIFS_UNIX_POSIX_ACL_CAP)
3121 cifs_dbg(FYI, "POSIX ACL cap\n");
3122 if (cap & CIFS_UNIX_LARGE_READ_CAP)
3123 cifs_dbg(FYI, "very large read cap\n");
3124 if (cap & CIFS_UNIX_LARGE_WRITE_CAP)
3125 cifs_dbg(FYI, "very large write cap\n");
3126 if (cap & CIFS_UNIX_TRANSPORT_ENCRYPTION_CAP)
3127 cifs_dbg(FYI, "transport encryption cap\n");
3128 if (cap & CIFS_UNIX_TRANSPORT_ENCRYPTION_MANDATORY_CAP)
3129 cifs_dbg(FYI, "mandatory transport encryption cap\n");
3130 #endif /* CIFS_DEBUG2 */
3131 if (CIFSSMBSetFSUnixInfo(xid, tcon, cap)) {
3132 if (vol_info == NULL) {
3133 cifs_dbg(FYI, "resetting capabilities failed\n");
3135 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");
3141 void cifs_setup_cifs_sb(struct smb_vol *pvolume_info,
3142 struct cifs_sb_info *cifs_sb)
3144 INIT_DELAYED_WORK(&cifs_sb->prune_tlinks, cifs_prune_tlinks);
3146 spin_lock_init(&cifs_sb->tlink_tree_lock);
3147 cifs_sb->tlink_tree = RB_ROOT;
3150 * Temporarily set r/wsize for matching superblock. If we end up using
3151 * new sb then client will later negotiate it downward if needed.
3153 cifs_sb->rsize = pvolume_info->rsize;
3154 cifs_sb->wsize = pvolume_info->wsize;
3156 cifs_sb->mnt_uid = pvolume_info->linux_uid;
3157 cifs_sb->mnt_gid = pvolume_info->linux_gid;
3158 cifs_sb->mnt_file_mode = pvolume_info->file_mode;
3159 cifs_sb->mnt_dir_mode = pvolume_info->dir_mode;
3160 cifs_dbg(FYI, "file mode: 0x%hx dir mode: 0x%hx\n",
3161 cifs_sb->mnt_file_mode, cifs_sb->mnt_dir_mode);
3163 cifs_sb->actimeo = pvolume_info->actimeo;
3164 cifs_sb->local_nls = pvolume_info->local_nls;
3166 if (pvolume_info->noperm)
3167 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NO_PERM;
3168 if (pvolume_info->setuids)
3169 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_SET_UID;
3170 if (pvolume_info->server_ino)
3171 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_SERVER_INUM;
3172 if (pvolume_info->remap)
3173 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_MAP_SPECIAL_CHR;
3174 if (pvolume_info->no_xattr)
3175 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NO_XATTR;
3176 if (pvolume_info->sfu_emul)
3177 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_UNX_EMUL;
3178 if (pvolume_info->nobrl)
3179 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NO_BRL;
3180 if (pvolume_info->nostrictsync)
3181 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NOSSYNC;
3182 if (pvolume_info->mand_lock)
3183 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_NOPOSIXBRL;
3184 if (pvolume_info->rwpidforward)
3185 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_RWPIDFORWARD;
3186 if (pvolume_info->cifs_acl)
3187 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_CIFS_ACL;
3188 if (pvolume_info->backupuid_specified) {
3189 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_CIFS_BACKUPUID;
3190 cifs_sb->mnt_backupuid = pvolume_info->backupuid;
3192 if (pvolume_info->backupgid_specified) {
3193 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_CIFS_BACKUPGID;
3194 cifs_sb->mnt_backupgid = pvolume_info->backupgid;
3196 if (pvolume_info->override_uid)
3197 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_OVERR_UID;
3198 if (pvolume_info->override_gid)
3199 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_OVERR_GID;
3200 if (pvolume_info->dynperm)
3201 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_DYNPERM;
3202 if (pvolume_info->fsc)
3203 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_FSCACHE;
3204 if (pvolume_info->multiuser)
3205 cifs_sb->mnt_cifs_flags |= (CIFS_MOUNT_MULTIUSER |
3206 CIFS_MOUNT_NO_PERM);
3207 if (pvolume_info->strict_io)
3208 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_STRICT_IO;
3209 if (pvolume_info->direct_io) {
3210 cifs_dbg(FYI, "mounting share using direct i/o\n");
3211 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_DIRECT_IO;
3213 if (pvolume_info->mfsymlinks) {
3214 if (pvolume_info->sfu_emul) {
3215 cifs_dbg(VFS, "mount option mfsymlinks ignored if sfu mount option is used\n");
3217 cifs_sb->mnt_cifs_flags |= CIFS_MOUNT_MF_SYMLINKS;
3221 if ((pvolume_info->cifs_acl) && (pvolume_info->dynperm))
3222 cifs_dbg(VFS, "mount option dynperm ignored if cifsacl mount option supported\n");
3226 cleanup_volume_info_contents(struct smb_vol *volume_info)
3228 kfree(volume_info->username);
3229 kzfree(volume_info->password);
3230 kfree(volume_info->UNC);
3231 kfree(volume_info->domainname);
3232 kfree(volume_info->iocharset);
3233 kfree(volume_info->prepath);
3237 cifs_cleanup_volume_info(struct smb_vol *volume_info)
3241 cleanup_volume_info_contents(volume_info);
3246 #ifdef CONFIG_CIFS_DFS_UPCALL
3248 * cifs_build_path_to_root returns full path to root when we do not have an
3249 * exiting connection (tcon)
3252 build_unc_path_to_root(const struct smb_vol *vol,
3253 const struct cifs_sb_info *cifs_sb)
3255 char *full_path, *pos;
3256 unsigned int pplen = vol->prepath ? strlen(vol->prepath) + 1 : 0;
3257 unsigned int unc_len = strnlen(vol->UNC, MAX_TREE_SIZE + 1);
3259 full_path = kmalloc(unc_len + pplen + 1, GFP_KERNEL);
3260 if (full_path == NULL)
3261 return ERR_PTR(-ENOMEM);
3263 strncpy(full_path, vol->UNC, unc_len);
3264 pos = full_path + unc_len;
3267 *pos++ = CIFS_DIR_SEP(cifs_sb);
3268 strncpy(pos, vol->prepath, pplen);
3272 *pos = '\0'; /* add trailing null */
3273 convert_delimiter(full_path, CIFS_DIR_SEP(cifs_sb));
3274 cifs_dbg(FYI, "%s: full_path=%s\n", __func__, full_path);
3279 * Perform a dfs referral query for a share and (optionally) prefix
3281 * If a referral is found, cifs_sb->mountdata will be (re-)allocated
3282 * to a string containing updated options for the submount. Otherwise it
3283 * will be left untouched.
3285 * Returns the rc from get_dfs_path to the caller, which can be used to
3286 * determine whether there were referrals.
3289 expand_dfs_referral(const unsigned int xid, struct cifs_ses *ses,
3290 struct smb_vol *volume_info, struct cifs_sb_info *cifs_sb,
3294 unsigned int num_referrals = 0;
3295 struct dfs_info3_param *referrals = NULL;
3296 char *full_path = NULL, *ref_path = NULL, *mdata = NULL;
3298 full_path = build_unc_path_to_root(volume_info, cifs_sb);
3299 if (IS_ERR(full_path))
3300 return PTR_ERR(full_path);
3302 /* For DFS paths, skip the first '\' of the UNC */
3303 ref_path = check_prefix ? full_path + 1 : volume_info->UNC + 1;
3305 rc = get_dfs_path(xid, ses, ref_path, cifs_sb->local_nls,
3306 &num_referrals, &referrals,
3307 cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MAP_SPECIAL_CHR);
3309 if (!rc && num_referrals > 0) {
3310 char *fake_devname = NULL;
3312 mdata = cifs_compose_mount_options(cifs_sb->mountdata,
3313 full_path + 1, referrals,
3316 free_dfs_info_array(referrals, num_referrals);
3318 if (IS_ERR(mdata)) {
3319 rc = PTR_ERR(mdata);
3322 cleanup_volume_info_contents(volume_info);
3323 rc = cifs_setup_volume_info(volume_info, mdata,
3326 kfree(fake_devname);
3327 kfree(cifs_sb->mountdata);
3328 cifs_sb->mountdata = mdata;
3336 cifs_setup_volume_info(struct smb_vol *volume_info, char *mount_data,
3337 const char *devname)
3341 if (cifs_parse_mount_options(mount_data, devname, volume_info))
3344 if (volume_info->nullauth) {
3345 cifs_dbg(FYI, "Anonymous login\n");
3346 kfree(volume_info->username);
3347 volume_info->username = NULL;
3348 } else if (volume_info->username) {
3349 /* BB fixme parse for domain name here */
3350 cifs_dbg(FYI, "Username: %s\n", volume_info->username);
3352 cifs_dbg(VFS, "No username specified\n");
3353 /* In userspace mount helper we can get user name from alternate
3354 locations such as env variables and files on disk */
3358 /* this is needed for ASCII cp to Unicode converts */
3359 if (volume_info->iocharset == NULL) {
3360 /* load_nls_default cannot return null */
3361 volume_info->local_nls = load_nls_default();
3363 volume_info->local_nls = load_nls(volume_info->iocharset);
3364 if (volume_info->local_nls == NULL) {
3365 cifs_dbg(VFS, "CIFS mount error: iocharset %s not found\n",
3366 volume_info->iocharset);
3375 cifs_get_volume_info(char *mount_data, const char *devname)
3378 struct smb_vol *volume_info;
3380 volume_info = kmalloc(sizeof(struct smb_vol), GFP_KERNEL);
3382 return ERR_PTR(-ENOMEM);
3384 rc = cifs_setup_volume_info(volume_info, mount_data, devname);
3386 cifs_cleanup_volume_info(volume_info);
3387 volume_info = ERR_PTR(rc);
3394 cifs_mount(struct cifs_sb_info *cifs_sb, struct smb_vol *volume_info)
3398 struct cifs_ses *ses;
3399 struct cifs_tcon *tcon;
3400 struct TCP_Server_Info *server;
3402 struct tcon_link *tlink;
3403 #ifdef CONFIG_CIFS_DFS_UPCALL
3404 int referral_walks_count = 0;
3407 rc = bdi_setup_and_register(&cifs_sb->bdi, "cifs", BDI_CAP_MAP_COPY);
3411 #ifdef CONFIG_CIFS_DFS_UPCALL
3413 /* cleanup activities if we're chasing a referral */
3414 if (referral_walks_count) {
3416 cifs_put_tcon(tcon);
3418 cifs_put_smb_ses(ses);
3432 /* get a reference to a tcp session */
3433 server = cifs_get_tcp_session(volume_info);
3434 if (IS_ERR(server)) {
3435 rc = PTR_ERR(server);
3436 bdi_destroy(&cifs_sb->bdi);
3440 /* get a reference to a SMB session */
3441 ses = cifs_get_smb_ses(server, volume_info);
3445 goto mount_fail_check;
3448 /* search for existing tcon to this server share */
3449 tcon = cifs_get_tcon(ses, volume_info);
3453 goto remote_path_check;
3456 /* tell server which Unix caps we support */
3457 if (cap_unix(tcon->ses)) {
3458 /* reset of caps checks mount to see if unix extensions
3459 disabled for just this mount */
3460 reset_cifs_unix_caps(xid, tcon, cifs_sb, volume_info);
3461 if ((tcon->ses->server->tcpStatus == CifsNeedReconnect) &&
3462 (le64_to_cpu(tcon->fsUnixInfo.Capability) &
3463 CIFS_UNIX_TRANSPORT_ENCRYPTION_MANDATORY_CAP)) {
3465 goto mount_fail_check;
3468 tcon->unix_ext = 0; /* server does not support them */
3470 /* do not care if a following call succeed - informational */
3471 if (!tcon->ipc && server->ops->qfs_tcon)
3472 server->ops->qfs_tcon(xid, tcon);
3474 cifs_sb->wsize = server->ops->negotiate_wsize(tcon, volume_info);
3475 cifs_sb->rsize = server->ops->negotiate_rsize(tcon, volume_info);
3477 /* tune readahead according to rsize */
3478 cifs_sb->bdi.ra_pages = cifs_sb->rsize / PAGE_CACHE_SIZE;
3481 #ifdef CONFIG_CIFS_DFS_UPCALL
3483 * Perform an unconditional check for whether there are DFS
3484 * referrals for this path without prefix, to provide support
3485 * for DFS referrals from w2k8 servers which don't seem to respond
3486 * with PATH_NOT_COVERED to requests that include the prefix.
3487 * Chase the referral if found, otherwise continue normally.
3489 if (referral_walks_count == 0) {
3490 int refrc = expand_dfs_referral(xid, ses, volume_info, cifs_sb,
3493 referral_walks_count++;
3494 goto try_mount_again;
3499 /* check if a whole path is not remote */
3501 if (!server->ops->is_path_accessible) {
3503 goto mount_fail_check;
3506 * cifs_build_path_to_root works only when we have a valid tcon
3508 full_path = cifs_build_path_to_root(volume_info, cifs_sb, tcon);
3509 if (full_path == NULL) {
3511 goto mount_fail_check;
3513 rc = server->ops->is_path_accessible(xid, tcon, cifs_sb,
3515 if (rc != 0 && rc != -EREMOTE) {
3517 goto mount_fail_check;
3522 /* get referral if needed */
3523 if (rc == -EREMOTE) {
3524 #ifdef CONFIG_CIFS_DFS_UPCALL
3525 if (referral_walks_count > MAX_NESTED_LINKS) {
3527 * BB: when we implement proper loop detection,
3528 * we will remove this check. But now we need it
3529 * to prevent an indefinite loop if 'DFS tree' is
3530 * misconfigured (i.e. has loops).
3533 goto mount_fail_check;
3536 rc = expand_dfs_referral(xid, ses, volume_info, cifs_sb, true);
3539 referral_walks_count++;
3540 goto try_mount_again;
3542 goto mount_fail_check;
3543 #else /* No DFS support, return error on mount */
3549 goto mount_fail_check;
3551 /* now, hang the tcon off of the superblock */
3552 tlink = kzalloc(sizeof *tlink, GFP_KERNEL);
3553 if (tlink == NULL) {
3555 goto mount_fail_check;
3558 tlink->tl_uid = ses->linux_uid;
3559 tlink->tl_tcon = tcon;
3560 tlink->tl_time = jiffies;
3561 set_bit(TCON_LINK_MASTER, &tlink->tl_flags);
3562 set_bit(TCON_LINK_IN_TREE, &tlink->tl_flags);
3564 cifs_sb->master_tlink = tlink;
3565 spin_lock(&cifs_sb->tlink_tree_lock);
3566 tlink_rb_insert(&cifs_sb->tlink_tree, tlink);
3567 spin_unlock(&cifs_sb->tlink_tree_lock);
3569 queue_delayed_work(cifsiod_wq, &cifs_sb->prune_tlinks,
3573 /* on error free sesinfo and tcon struct if needed */
3575 /* If find_unc succeeded then rc == 0 so we can not end */
3576 /* up accidentally freeing someone elses tcon struct */
3578 cifs_put_tcon(tcon);
3580 cifs_put_smb_ses(ses);
3582 cifs_put_tcp_session(server);
3583 bdi_destroy(&cifs_sb->bdi);
3592 * Issue a TREE_CONNECT request. Note that for IPC$ shares, that the tcon
3593 * pointer may be NULL.
3596 CIFSTCon(const unsigned int xid, struct cifs_ses *ses,
3597 const char *tree, struct cifs_tcon *tcon,
3598 const struct nls_table *nls_codepage)
3600 struct smb_hdr *smb_buffer;
3601 struct smb_hdr *smb_buffer_response;
3604 unsigned char *bcc_ptr;
3607 __u16 bytes_left, count;
3612 smb_buffer = cifs_buf_get();
3613 if (smb_buffer == NULL)
3616 smb_buffer_response = smb_buffer;
3618 header_assemble(smb_buffer, SMB_COM_TREE_CONNECT_ANDX,
3619 NULL /*no tid */ , 4 /*wct */ );
3621 smb_buffer->Mid = get_next_mid(ses->server);
3622 smb_buffer->Uid = ses->Suid;
3623 pSMB = (TCONX_REQ *) smb_buffer;
3624 pSMBr = (TCONX_RSP *) smb_buffer_response;
3626 pSMB->AndXCommand = 0xFF;
3627 pSMB->Flags = cpu_to_le16(TCON_EXTENDED_SECINFO);
3628 bcc_ptr = &pSMB->Password[0];
3629 if (!tcon || (ses->server->sec_mode & SECMODE_USER)) {
3630 pSMB->PasswordLength = cpu_to_le16(1); /* minimum */
3631 *bcc_ptr = 0; /* password is null byte */
3632 bcc_ptr++; /* skip password */
3633 /* already aligned so no need to do it below */
3635 pSMB->PasswordLength = cpu_to_le16(CIFS_AUTH_RESP_SIZE);
3636 /* BB FIXME add code to fail this if NTLMv2 or Kerberos
3637 specified as required (when that support is added to
3638 the vfs in the future) as only NTLM or the much
3639 weaker LANMAN (which we do not send by default) is accepted
3640 by Samba (not sure whether other servers allow
3641 NTLMv2 password here) */
3642 #ifdef CONFIG_CIFS_WEAK_PW_HASH
3643 if ((global_secflags & CIFSSEC_MAY_LANMAN) &&
3644 (ses->server->secType == LANMAN))
3645 calc_lanman_hash(tcon->password, ses->server->cryptkey,
3646 ses->server->sec_mode &
3647 SECMODE_PW_ENCRYPT ? true : false,
3650 #endif /* CIFS_WEAK_PW_HASH */
3651 rc = SMBNTencrypt(tcon->password, ses->server->cryptkey,
3652 bcc_ptr, nls_codepage);
3654 bcc_ptr += CIFS_AUTH_RESP_SIZE;
3655 if (ses->capabilities & CAP_UNICODE) {
3656 /* must align unicode strings */
3657 *bcc_ptr = 0; /* null byte password */
3662 if (ses->server->sec_mode &
3663 (SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED))
3664 smb_buffer->Flags2 |= SMBFLG2_SECURITY_SIGNATURE;
3666 if (ses->capabilities & CAP_STATUS32) {
3667 smb_buffer->Flags2 |= SMBFLG2_ERR_STATUS;
3669 if (ses->capabilities & CAP_DFS) {
3670 smb_buffer->Flags2 |= SMBFLG2_DFS;
3672 if (ses->capabilities & CAP_UNICODE) {
3673 smb_buffer->Flags2 |= SMBFLG2_UNICODE;
3675 cifs_strtoUTF16((__le16 *) bcc_ptr, tree,
3676 6 /* max utf8 char length in bytes */ *
3677 (/* server len*/ + 256 /* share len */), nls_codepage);
3678 bcc_ptr += 2 * length; /* convert num 16 bit words to bytes */
3679 bcc_ptr += 2; /* skip trailing null */
3680 } else { /* ASCII */
3681 strcpy(bcc_ptr, tree);
3682 bcc_ptr += strlen(tree) + 1;
3684 strcpy(bcc_ptr, "?????");
3685 bcc_ptr += strlen("?????");
3687 count = bcc_ptr - &pSMB->Password[0];
3688 pSMB->hdr.smb_buf_length = cpu_to_be32(be32_to_cpu(
3689 pSMB->hdr.smb_buf_length) + count);
3690 pSMB->ByteCount = cpu_to_le16(count);
3692 rc = SendReceive(xid, ses, smb_buffer, smb_buffer_response, &length,
3695 /* above now done in SendReceive */
3696 if ((rc == 0) && (tcon != NULL)) {
3699 tcon->tidStatus = CifsGood;
3700 tcon->need_reconnect = false;
3701 tcon->tid = smb_buffer_response->Tid;
3702 bcc_ptr = pByteArea(smb_buffer_response);
3703 bytes_left = get_bcc(smb_buffer_response);
3704 length = strnlen(bcc_ptr, bytes_left - 2);
3705 if (smb_buffer->Flags2 & SMBFLG2_UNICODE)
3711 /* skip service field (NB: this field is always ASCII) */
3713 if ((bcc_ptr[0] == 'I') && (bcc_ptr[1] == 'P') &&
3714 (bcc_ptr[2] == 'C')) {
3715 cifs_dbg(FYI, "IPC connection\n");
3718 } else if (length == 2) {
3719 if ((bcc_ptr[0] == 'A') && (bcc_ptr[1] == ':')) {
3720 /* the most common case */
3721 cifs_dbg(FYI, "disk share connection\n");
3724 bcc_ptr += length + 1;
3725 bytes_left -= (length + 1);
3726 strncpy(tcon->treeName, tree, MAX_TREE_SIZE);
3728 /* mostly informational -- no need to fail on error here */
3729 kfree(tcon->nativeFileSystem);
3730 tcon->nativeFileSystem = cifs_strndup_from_utf16(bcc_ptr,
3731 bytes_left, is_unicode,
3734 cifs_dbg(FYI, "nativeFileSystem=%s\n", tcon->nativeFileSystem);
3736 if ((smb_buffer_response->WordCount == 3) ||
3737 (smb_buffer_response->WordCount == 7))
3738 /* field is in same location */
3739 tcon->Flags = le16_to_cpu(pSMBr->OptionalSupport);
3742 cifs_dbg(FYI, "Tcon flags: 0x%x\n", tcon->Flags);
3743 } else if ((rc == 0) && tcon == NULL) {
3744 /* all we need to save for IPC$ connection */
3745 ses->ipc_tid = smb_buffer_response->Tid;
3748 cifs_buf_release(smb_buffer);
3753 cifs_umount(struct cifs_sb_info *cifs_sb)
3755 struct rb_root *root = &cifs_sb->tlink_tree;
3756 struct rb_node *node;
3757 struct tcon_link *tlink;
3759 cancel_delayed_work_sync(&cifs_sb->prune_tlinks);
3761 spin_lock(&cifs_sb->tlink_tree_lock);
3762 while ((node = rb_first(root))) {
3763 tlink = rb_entry(node, struct tcon_link, tl_rbnode);
3764 cifs_get_tlink(tlink);
3765 clear_bit(TCON_LINK_IN_TREE, &tlink->tl_flags);
3766 rb_erase(node, root);
3768 spin_unlock(&cifs_sb->tlink_tree_lock);
3769 cifs_put_tlink(tlink);
3770 spin_lock(&cifs_sb->tlink_tree_lock);
3772 spin_unlock(&cifs_sb->tlink_tree_lock);
3774 bdi_destroy(&cifs_sb->bdi);
3775 kfree(cifs_sb->mountdata);
3776 unload_nls(cifs_sb->local_nls);
3781 cifs_negotiate_protocol(const unsigned int xid, struct cifs_ses *ses)
3784 struct TCP_Server_Info *server = ses->server;
3786 if (!server->ops->need_neg || !server->ops->negotiate)
3789 /* only send once per connect */
3790 if (!server->ops->need_neg(server))
3793 set_credits(server, 1);
3795 rc = server->ops->negotiate(xid, ses);
3797 spin_lock(&GlobalMid_Lock);
3798 if (server->tcpStatus == CifsNeedNegotiate)
3799 server->tcpStatus = CifsGood;
3802 spin_unlock(&GlobalMid_Lock);
3809 cifs_setup_session(const unsigned int xid, struct cifs_ses *ses,
3810 struct nls_table *nls_info)
3813 struct TCP_Server_Info *server = ses->server;
3816 ses->capabilities = server->capabilities;
3817 if (linuxExtEnabled == 0)
3818 ses->capabilities &= (~server->vals->cap_unix);
3820 cifs_dbg(FYI, "Security Mode: 0x%x Capabilities: 0x%x TimeAdjust: %d\n",
3821 server->sec_mode, server->capabilities, server->timeAdj);
3823 if (server->ops->sess_setup)
3824 rc = server->ops->sess_setup(xid, ses, nls_info);
3827 cifs_dbg(VFS, "Send error in SessSetup = %d\n", rc);
3829 mutex_lock(&ses->server->srv_mutex);
3830 if (!server->session_estab) {
3831 server->session_key.response = ses->auth_key.response;
3832 server->session_key.len = ses->auth_key.len;
3833 server->sequence_number = 0x2;
3834 server->session_estab = true;
3835 ses->auth_key.response = NULL;
3837 mutex_unlock(&server->srv_mutex);
3839 cifs_dbg(FYI, "CIFS Session Established successfully\n");
3840 spin_lock(&GlobalMid_Lock);
3841 ses->status = CifsGood;
3842 ses->need_reconnect = false;
3843 spin_unlock(&GlobalMid_Lock);
3846 kfree(ses->auth_key.response);
3847 ses->auth_key.response = NULL;
3848 ses->auth_key.len = 0;
3849 kfree(ses->ntlmssp);
3850 ses->ntlmssp = NULL;
3856 cifs_set_vol_auth(struct smb_vol *vol, struct cifs_ses *ses)
3858 switch (ses->server->secType) {
3860 vol->secFlg = CIFSSEC_MUST_KRB5;
3863 vol->secFlg = CIFSSEC_MUST_NTLMV2;
3866 vol->secFlg = CIFSSEC_MUST_NTLM;
3869 vol->secFlg = CIFSSEC_MUST_NTLMSSP;
3872 vol->secFlg = CIFSSEC_MUST_LANMAN;
3876 return cifs_set_cifscreds(vol, ses);
3879 static struct cifs_tcon *
3880 cifs_construct_tcon(struct cifs_sb_info *cifs_sb, kuid_t fsuid)
3883 struct cifs_tcon *master_tcon = cifs_sb_master_tcon(cifs_sb);
3884 struct cifs_ses *ses;
3885 struct cifs_tcon *tcon = NULL;
3886 struct smb_vol *vol_info;
3888 vol_info = kzalloc(sizeof(*vol_info), GFP_KERNEL);
3889 if (vol_info == NULL)
3890 return ERR_PTR(-ENOMEM);
3892 vol_info->local_nls = cifs_sb->local_nls;
3893 vol_info->linux_uid = fsuid;
3894 vol_info->cred_uid = fsuid;
3895 vol_info->UNC = master_tcon->treeName;
3896 vol_info->retry = master_tcon->retry;
3897 vol_info->nocase = master_tcon->nocase;
3898 vol_info->local_lease = master_tcon->local_lease;
3899 vol_info->no_linux_ext = !master_tcon->unix_ext;
3901 rc = cifs_set_vol_auth(vol_info, master_tcon->ses);
3907 /* get a reference for the same TCP session */
3908 spin_lock(&cifs_tcp_ses_lock);
3909 ++master_tcon->ses->server->srv_count;
3910 spin_unlock(&cifs_tcp_ses_lock);
3912 ses = cifs_get_smb_ses(master_tcon->ses->server, vol_info);
3914 tcon = (struct cifs_tcon *)ses;
3915 cifs_put_tcp_session(master_tcon->ses->server);
3919 tcon = cifs_get_tcon(ses, vol_info);
3921 cifs_put_smb_ses(ses);
3926 reset_cifs_unix_caps(0, tcon, NULL, vol_info);
3928 kfree(vol_info->username);
3929 kfree(vol_info->password);
3936 cifs_sb_master_tcon(struct cifs_sb_info *cifs_sb)
3938 return tlink_tcon(cifs_sb_master_tlink(cifs_sb));
3942 cifs_sb_tcon_pending_wait(void *unused)
3945 return signal_pending(current) ? -ERESTARTSYS : 0;
3948 /* find and return a tlink with given uid */
3949 static struct tcon_link *
3950 tlink_rb_search(struct rb_root *root, kuid_t uid)
3952 struct rb_node *node = root->rb_node;
3953 struct tcon_link *tlink;
3956 tlink = rb_entry(node, struct tcon_link, tl_rbnode);
3958 if (uid_gt(tlink->tl_uid, uid))
3959 node = node->rb_left;
3960 else if (uid_lt(tlink->tl_uid, uid))
3961 node = node->rb_right;
3968 /* insert a tcon_link into the tree */
3970 tlink_rb_insert(struct rb_root *root, struct tcon_link *new_tlink)
3972 struct rb_node **new = &(root->rb_node), *parent = NULL;
3973 struct tcon_link *tlink;
3976 tlink = rb_entry(*new, struct tcon_link, tl_rbnode);
3979 if (uid_gt(tlink->tl_uid, new_tlink->tl_uid))
3980 new = &((*new)->rb_left);
3982 new = &((*new)->rb_right);
3985 rb_link_node(&new_tlink->tl_rbnode, parent, new);
3986 rb_insert_color(&new_tlink->tl_rbnode, root);
3990 * Find or construct an appropriate tcon given a cifs_sb and the fsuid of the
3993 * If the superblock doesn't refer to a multiuser mount, then just return
3994 * the master tcon for the mount.
3996 * First, search the rbtree for an existing tcon for this fsuid. If one
3997 * exists, then check to see if it's pending construction. If it is then wait
3998 * for construction to complete. Once it's no longer pending, check to see if
3999 * it failed and either return an error or retry construction, depending on
4002 * If one doesn't exist then insert a new tcon_link struct into the tree and
4003 * try to construct a new one.
4006 cifs_sb_tlink(struct cifs_sb_info *cifs_sb)
4009 kuid_t fsuid = current_fsuid();
4010 struct tcon_link *tlink, *newtlink;
4012 if (!(cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MULTIUSER))
4013 return cifs_get_tlink(cifs_sb_master_tlink(cifs_sb));
4015 spin_lock(&cifs_sb->tlink_tree_lock);
4016 tlink = tlink_rb_search(&cifs_sb->tlink_tree, fsuid);
4018 cifs_get_tlink(tlink);
4019 spin_unlock(&cifs_sb->tlink_tree_lock);
4021 if (tlink == NULL) {
4022 newtlink = kzalloc(sizeof(*tlink), GFP_KERNEL);
4023 if (newtlink == NULL)
4024 return ERR_PTR(-ENOMEM);
4025 newtlink->tl_uid = fsuid;
4026 newtlink->tl_tcon = ERR_PTR(-EACCES);
4027 set_bit(TCON_LINK_PENDING, &newtlink->tl_flags);
4028 set_bit(TCON_LINK_IN_TREE, &newtlink->tl_flags);
4029 cifs_get_tlink(newtlink);
4031 spin_lock(&cifs_sb->tlink_tree_lock);
4032 /* was one inserted after previous search? */
4033 tlink = tlink_rb_search(&cifs_sb->tlink_tree, fsuid);
4035 cifs_get_tlink(tlink);
4036 spin_unlock(&cifs_sb->tlink_tree_lock);
4038 goto wait_for_construction;
4041 tlink_rb_insert(&cifs_sb->tlink_tree, tlink);
4042 spin_unlock(&cifs_sb->tlink_tree_lock);
4044 wait_for_construction:
4045 ret = wait_on_bit(&tlink->tl_flags, TCON_LINK_PENDING,
4046 cifs_sb_tcon_pending_wait,
4047 TASK_INTERRUPTIBLE);
4049 cifs_put_tlink(tlink);
4050 return ERR_PTR(ret);
4053 /* if it's good, return it */
4054 if (!IS_ERR(tlink->tl_tcon))
4057 /* return error if we tried this already recently */
4058 if (time_before(jiffies, tlink->tl_time + TLINK_ERROR_EXPIRE)) {
4059 cifs_put_tlink(tlink);
4060 return ERR_PTR(-EACCES);
4063 if (test_and_set_bit(TCON_LINK_PENDING, &tlink->tl_flags))
4064 goto wait_for_construction;
4067 tlink->tl_tcon = cifs_construct_tcon(cifs_sb, fsuid);
4068 clear_bit(TCON_LINK_PENDING, &tlink->tl_flags);
4069 wake_up_bit(&tlink->tl_flags, TCON_LINK_PENDING);
4071 if (IS_ERR(tlink->tl_tcon)) {
4072 cifs_put_tlink(tlink);
4073 return ERR_PTR(-EACCES);
4080 * periodic workqueue job that scans tcon_tree for a superblock and closes
4084 cifs_prune_tlinks(struct work_struct *work)
4086 struct cifs_sb_info *cifs_sb = container_of(work, struct cifs_sb_info,
4088 struct rb_root *root = &cifs_sb->tlink_tree;
4089 struct rb_node *node = rb_first(root);
4090 struct rb_node *tmp;
4091 struct tcon_link *tlink;
4094 * Because we drop the spinlock in the loop in order to put the tlink
4095 * it's not guarded against removal of links from the tree. The only
4096 * places that remove entries from the tree are this function and
4097 * umounts. Because this function is non-reentrant and is canceled
4098 * before umount can proceed, this is safe.
4100 spin_lock(&cifs_sb->tlink_tree_lock);
4101 node = rb_first(root);
4102 while (node != NULL) {
4104 node = rb_next(tmp);
4105 tlink = rb_entry(tmp, struct tcon_link, tl_rbnode);
4107 if (test_bit(TCON_LINK_MASTER, &tlink->tl_flags) ||
4108 atomic_read(&tlink->tl_count) != 0 ||
4109 time_after(tlink->tl_time + TLINK_IDLE_EXPIRE, jiffies))
4112 cifs_get_tlink(tlink);
4113 clear_bit(TCON_LINK_IN_TREE, &tlink->tl_flags);
4114 rb_erase(tmp, root);
4116 spin_unlock(&cifs_sb->tlink_tree_lock);
4117 cifs_put_tlink(tlink);
4118 spin_lock(&cifs_sb->tlink_tree_lock);
4120 spin_unlock(&cifs_sb->tlink_tree_lock);
4122 queue_delayed_work(cifsiod_wq, &cifs_sb->prune_tlinks,