Merge branch 'master' of ssh://git.samba.org/data/git/samba into regsrv
[kai/samba-autobuild/.git] / source3 / smbd / service.c
1 /* 
2    Unix SMB/CIFS implementation.
3    service (connection) opening and closing
4    Copyright (C) Andrew Tridgell 1992-1998
5    
6    This program is free software; you can redistribute it and/or modify
7    it under the terms of the GNU General Public License as published by
8    the Free Software Foundation; either version 3 of the License, or
9    (at your option) any later version.
10    
11    This program is distributed in the hope that it will be useful,
12    but WITHOUT ANY WARRANTY; without even the implied warranty of
13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14    GNU General Public License for more details.
15    
16    You should have received a copy of the GNU General Public License
17    along with this program.  If not, see <http://www.gnu.org/licenses/>.
18 */
19
20 #include "includes.h"
21
22 extern userdom_struct current_user_info;
23
24 static bool canonicalize_connect_path(connection_struct *conn)
25 {
26 #ifdef REALPATH_TAKES_NULL
27         bool ret;
28         char *resolved_name = SMB_VFS_REALPATH(conn,conn->connectpath,NULL);
29         if (!resolved_name) {
30                 return false;
31         }
32         ret = set_conn_connectpath(conn,resolved_name);
33         SAFE_FREE(resolved_name);
34         return ret;
35 #else
36         char resolved_name_buf[PATH_MAX+1];
37         char *resolved_name = SMB_VFS_REALPATH(conn,conn->connectpath,resolved_name_buf);
38         if (!resolved_name) {
39                 return false;
40         }
41         return set_conn_connectpath(conn,resolved_name);
42 #endif /* REALPATH_TAKES_NULL */
43 }
44
45 /****************************************************************************
46  Ensure when setting connectpath it is a canonicalized (no ./ // or ../)
47  absolute path stating in / and not ending in /.
48  Observent people will notice a similarity between this and check_path_syntax :-).
49 ****************************************************************************/
50
51 bool set_conn_connectpath(connection_struct *conn, const char *connectpath)
52 {
53         char *destname;
54         char *d;
55         const char *s = connectpath;
56         bool start_of_name_component = true;
57
58         destname = SMB_STRDUP(connectpath);
59         if (!destname) {
60                 return false;
61         }
62         d = destname;
63
64         *d++ = '/'; /* Always start with root. */
65
66         while (*s) {
67                 if (*s == '/') {
68                         /* Eat multiple '/' */
69                         while (*s == '/') {
70                                 s++;
71                         }
72                         if ((d > destname + 1) && (*s != '\0')) {
73                                 *d++ = '/';
74                         }
75                         start_of_name_component = True;
76                         continue;
77                 }
78
79                 if (start_of_name_component) {
80                         if ((s[0] == '.') && (s[1] == '.') && (s[2] == '/' || s[2] == '\0')) {
81                                 /* Uh oh - "/../" or "/..\0" ! */
82
83                                 /* Go past the ../ or .. */
84                                 if (s[2] == '/') {
85                                         s += 3;
86                                 } else {
87                                         s += 2; /* Go past the .. */
88                                 }
89
90                                 /* If  we just added a '/' - delete it */
91                                 if ((d > destname) && (*(d-1) == '/')) {
92                                         *(d-1) = '\0';
93                                         d--;
94                                 }
95
96                                 /* Are we at the start ? Can't go back further if so. */
97                                 if (d <= destname) {
98                                         *d++ = '/'; /* Can't delete root */
99                                         continue;
100                                 }
101                                 /* Go back one level... */
102                                 /* Decrement d first as d points to the *next* char to write into. */
103                                 for (d--; d > destname; d--) {
104                                         if (*d == '/') {
105                                                 break;
106                                         }
107                                 }
108                                 /* We're still at the start of a name component, just the previous one. */
109                                 continue;
110                         } else if ((s[0] == '.') && ((s[1] == '\0') || s[1] == '/')) {
111                                 /* Component of pathname can't be "." only - skip the '.' . */
112                                 if (s[1] == '/') {
113                                         s += 2;
114                                 } else {
115                                         s++;
116                                 }
117                                 continue;
118                         }
119                 }
120
121                 if (!(*s & 0x80)) {
122                         *d++ = *s++;
123                 } else {
124                         size_t siz;
125                         /* Get the size of the next MB character. */
126                         next_codepoint(s,&siz);
127                         switch(siz) {
128                                 case 5:
129                                         *d++ = *s++;
130                                         /*fall through*/
131                                 case 4:
132                                         *d++ = *s++;
133                                         /*fall through*/
134                                 case 3:
135                                         *d++ = *s++;
136                                         /*fall through*/
137                                 case 2:
138                                         *d++ = *s++;
139                                         /*fall through*/
140                                 case 1:
141                                         *d++ = *s++;
142                                         break;
143                                 default:
144                                         break;
145                         }
146                 }
147                 start_of_name_component = false;
148         }
149         *d = '\0';
150
151         /* And must not end in '/' */
152         if (d > destname + 1 && (*(d-1) == '/')) {
153                 *(d-1) = '\0';
154         }
155
156         DEBUG(10,("set_conn_connectpath: service %s, connectpath = %s\n",
157                 lp_servicename(SNUM(conn)), destname ));
158
159         string_set(&conn->connectpath, destname);
160         SAFE_FREE(destname);
161         return true;
162 }
163
164 /****************************************************************************
165  Load parameters specific to a connection/service.
166 ****************************************************************************/
167
168 bool set_current_service(connection_struct *conn, uint16 flags, bool do_chdir)
169 {
170         static connection_struct *last_conn;
171         static uint16 last_flags;
172         int snum;
173
174         if (!conn)  {
175                 last_conn = NULL;
176                 return(False);
177         }
178
179         conn->lastused_count++;
180
181         snum = SNUM(conn);
182   
183         if (do_chdir &&
184             vfs_ChDir(conn,conn->connectpath) != 0 &&
185             vfs_ChDir(conn,conn->origpath) != 0) {
186                 DEBUG(0,("chdir (%s) failed\n",
187                          conn->connectpath));
188                 return(False);
189         }
190
191         if ((conn == last_conn) && (last_flags == flags)) {
192                 return(True);
193         }
194
195         last_conn = conn;
196         last_flags = flags;
197         
198         /* Obey the client case sensitivity requests - only for clients that support it. */
199         switch (lp_casesensitive(snum)) {
200                 case Auto:
201                         {
202                                 /* We need this uglyness due to DOS/Win9x clients that lie about case insensitivity. */
203                                 enum remote_arch_types ra_type = get_remote_arch();
204                                 if ((ra_type != RA_SAMBA) && (ra_type != RA_CIFSFS)) {
205                                         /* Client can't support per-packet case sensitive pathnames. */
206                                         conn->case_sensitive = False;
207                                 } else {
208                                         conn->case_sensitive = !(flags & FLAG_CASELESS_PATHNAMES);
209                                 }
210                         }
211                         break;
212                 case True:
213                         conn->case_sensitive = True;
214                         break;
215                 default:
216                         conn->case_sensitive = False;
217                         break;
218         }
219         return(True);
220 }
221
222 static int load_registry_service(const char *servicename)
223 {
224         struct registry_key *key;
225         char *path;
226         WERROR err;
227
228         uint32 i;
229         char *value_name;
230         struct registry_value *value;
231
232         int res = -1;
233
234         if (!lp_registry_shares()) {
235                 return -1;
236         }
237
238         if (strequal(servicename, GLOBAL_NAME)) {
239                 return -2;
240         }
241
242         if (asprintf(&path, "%s\\%s", KEY_SMBCONF, servicename) == -1) {
243                 return -1;
244         }
245
246         err = reg_open_path(NULL, path, REG_KEY_READ, get_root_nt_token(),
247                             &key);
248         SAFE_FREE(path);
249
250         if (!W_ERROR_IS_OK(err)) {
251                 return -1;
252         }
253
254         res = lp_add_service(servicename, -1);
255         if (res == -1) {
256                 goto error;
257         }
258
259         for (i=0;
260              W_ERROR_IS_OK(reg_enumvalue(key, key, i, &value_name, &value));
261              i++) {
262                 switch (value->type) {
263                 case REG_DWORD: { 
264                         char *tmp;
265                         if (asprintf(&tmp, "%d", value->v.dword) == -1) {
266                                 continue;
267                         }
268                         lp_do_parameter(res, value_name, tmp);
269                         SAFE_FREE(tmp);
270                         break;
271                 }
272                 case REG_SZ: {
273                         lp_do_parameter(res, value_name, value->v.sz.str);
274                         break;
275                 }
276                 default:
277                         /* Ignore all the rest */
278                         break;
279                 }
280
281                 TALLOC_FREE(value_name);
282                 TALLOC_FREE(value);
283         }
284
285  error:
286
287         TALLOC_FREE(key);
288         return res;
289 }
290
291 void load_registry_shares(void)
292 {
293         struct registry_key *key;
294         char *name;
295         WERROR err;
296         int i;
297
298         DEBUG(8, ("load_registry_shares()\n"));
299         if (!lp_registry_shares()) {
300                 return;
301         }
302
303         err = reg_open_path(NULL, KEY_SMBCONF, REG_KEY_READ,
304                             get_root_nt_token(), &key);
305         if (!(W_ERROR_IS_OK(err))) {
306                 return;
307         }
308
309         for (i=0; W_ERROR_IS_OK(reg_enumkey(key, key, i, &name, NULL)); i++) {
310                 load_registry_service(name);
311                 TALLOC_FREE(name);
312         }
313
314         TALLOC_FREE(key);
315         return;
316 }
317
318 /****************************************************************************
319  Add a home service. Returns the new service number or -1 if fail.
320 ****************************************************************************/
321
322 int add_home_service(const char *service, const char *username, const char *homedir)
323 {
324         int iHomeService;
325
326         if (!service || !homedir)
327                 return -1;
328
329         if ((iHomeService = lp_servicenumber(HOMES_NAME)) < 0) {
330                 if ((iHomeService = load_registry_service(HOMES_NAME)) < 0) {
331                         return -1;
332                 }
333         }
334
335         /*
336          * If this is a winbindd provided username, remove
337          * the domain component before adding the service.
338          * Log a warning if the "path=" parameter does not
339          * include any macros.
340          */
341
342         {
343                 const char *p = strchr(service,*lp_winbind_separator());
344
345                 /* We only want the 'user' part of the string */
346                 if (p) {
347                         service = p + 1;
348                 }
349         }
350
351         if (!lp_add_home(service, iHomeService, username, homedir)) {
352                 return -1;
353         }
354         
355         return lp_servicenumber(service);
356
357 }
358
359 /**
360  * Find a service entry.
361  *
362  * @param service is modified (to canonical form??)
363  **/
364
365 int find_service(fstring service)
366 {
367         int iService;
368
369         all_string_sub(service,"\\","/",0);
370
371         iService = lp_servicenumber(service);
372
373         /* now handle the special case of a home directory */
374         if (iService < 0) {
375                 char *phome_dir = get_user_home_dir(talloc_tos(), service);
376
377                 if(!phome_dir) {
378                         /*
379                          * Try mapping the servicename, it may
380                          * be a Windows to unix mapped user name.
381                          */
382                         if(map_username(service))
383                                 phome_dir = get_user_home_dir(
384                                         talloc_tos(), service);
385                 }
386
387                 DEBUG(3,("checking for home directory %s gave %s\n",service,
388                         phome_dir?phome_dir:"(NULL)"));
389
390                 iService = add_home_service(service,service /* 'username' */, phome_dir);
391         }
392
393         /* If we still don't have a service, attempt to add it as a printer. */
394         if (iService < 0) {
395                 int iPrinterService;
396
397                 if ((iPrinterService = lp_servicenumber(PRINTERS_NAME)) < 0) {
398                         iPrinterService = load_registry_service(PRINTERS_NAME);
399                 }
400                 if (iPrinterService) {
401                         DEBUG(3,("checking whether %s is a valid printer name...\n", service));
402                         if (pcap_printername_ok(service)) {
403                                 DEBUG(3,("%s is a valid printer name\n", service));
404                                 DEBUG(3,("adding %s as a printer service\n", service));
405                                 lp_add_printer(service, iPrinterService);
406                                 iService = lp_servicenumber(service);
407                                 if (iService < 0) {
408                                         DEBUG(0,("failed to add %s as a printer service!\n", service));
409                                 }
410                         } else {
411                                 DEBUG(3,("%s is not a valid printer name\n", service));
412                         }
413                 }
414         }
415
416         /* Check for default vfs service?  Unsure whether to implement this */
417         if (iService < 0) {
418         }
419
420         if (iService < 0) {
421                 iService = load_registry_service(service);
422         }
423
424         /* Is it a usershare service ? */
425         if (iService < 0 && *lp_usershare_path()) {
426                 /* Ensure the name is canonicalized. */
427                 strlower_m(service);
428                 iService = load_usershare_service(service);
429         }
430
431         /* just possibly it's a default service? */
432         if (iService < 0) {
433                 char *pdefservice = lp_defaultservice();
434                 if (pdefservice && *pdefservice && !strequal(pdefservice,service) && !strstr_m(service,"..")) {
435                         /*
436                          * We need to do a local copy here as lp_defaultservice() 
437                          * returns one of the rotating lp_string buffers that
438                          * could get overwritten by the recursive find_service() call
439                          * below. Fix from Josef Hinteregger <joehtg@joehtg.co.at>.
440                          */
441                         char *defservice = SMB_STRDUP(pdefservice);
442
443                         if (!defservice) {
444                                 goto fail;
445                         }
446
447                         /* Disallow anything except explicit share names. */
448                         if (strequal(defservice,HOMES_NAME) ||
449                                         strequal(defservice, PRINTERS_NAME) ||
450                                         strequal(defservice, "IPC$")) {
451                                 SAFE_FREE(defservice);
452                                 goto fail;
453                         }
454
455                         iService = find_service(defservice);
456                         if (iService >= 0) {
457                                 all_string_sub(service, "_","/",0);
458                                 iService = lp_add_service(service, iService);
459                         }
460                         SAFE_FREE(defservice);
461                 }
462         }
463
464         if (iService >= 0) {
465                 if (!VALID_SNUM(iService)) {
466                         DEBUG(0,("Invalid snum %d for %s\n",iService, service));
467                         iService = -1;
468                 }
469         }
470
471   fail:
472
473         if (iService < 0)
474                 DEBUG(3,("find_service() failed to find service %s\n", service));
475
476         return (iService);
477 }
478
479
480 /****************************************************************************
481  do some basic sainity checks on the share.  
482  This function modifies dev, ecode.
483 ****************************************************************************/
484
485 static NTSTATUS share_sanity_checks(int snum, fstring dev) 
486 {
487         
488         if (!lp_snum_ok(snum) || 
489             !check_access(smbd_server_fd(), 
490                           lp_hostsallow(snum), lp_hostsdeny(snum))) {    
491                 return NT_STATUS_ACCESS_DENIED;
492         }
493
494         if (dev[0] == '?' || !dev[0]) {
495                 if (lp_print_ok(snum)) {
496                         fstrcpy(dev,"LPT1:");
497                 } else if (strequal(lp_fstype(snum), "IPC")) {
498                         fstrcpy(dev, "IPC");
499                 } else {
500                         fstrcpy(dev,"A:");
501                 }
502         }
503
504         strupper_m(dev);
505
506         if (lp_print_ok(snum)) {
507                 if (!strequal(dev, "LPT1:")) {
508                         return NT_STATUS_BAD_DEVICE_TYPE;
509                 }
510         } else if (strequal(lp_fstype(snum), "IPC")) {
511                 if (!strequal(dev, "IPC")) {
512                         return NT_STATUS_BAD_DEVICE_TYPE;
513                 }
514         } else if (!strequal(dev, "A:")) {
515                 return NT_STATUS_BAD_DEVICE_TYPE;
516         }
517
518         /* Behave as a printer if we are supposed to */
519         if (lp_print_ok(snum) && (strcmp(dev, "A:") == 0)) {
520                 fstrcpy(dev, "LPT1:");
521         }
522
523         return NT_STATUS_OK;
524 }
525
526 /*
527  * Go through lookup_name etc to find the force'd group.  
528  *
529  * Create a new token from src_token, replacing the primary group sid with the
530  * one found.
531  */
532
533 static NTSTATUS find_forced_group(bool force_user,
534                                   int snum, const char *username,
535                                   DOM_SID *pgroup_sid,
536                                   gid_t *pgid)
537 {
538         NTSTATUS result = NT_STATUS_NO_SUCH_GROUP;
539         TALLOC_CTX *frame = talloc_stackframe();
540         DOM_SID group_sid;
541         enum lsa_SidType type;
542         char *groupname;
543         bool user_must_be_member = False;
544         gid_t gid;
545
546         groupname = talloc_strdup(talloc_tos(), lp_force_group(snum));
547         if (groupname == NULL) {
548                 DEBUG(1, ("talloc_strdup failed\n"));
549                 result = NT_STATUS_NO_MEMORY;
550                 goto done;
551         }
552
553         if (groupname[0] == '+') {
554                 user_must_be_member = True;
555                 groupname += 1;
556         }
557
558         groupname = talloc_string_sub(talloc_tos(), groupname,
559                                       "%S", lp_servicename(snum));
560         if (groupname == NULL) {
561                 DEBUG(1, ("talloc_string_sub failed\n"));
562                 result = NT_STATUS_NO_MEMORY;
563                 goto done;
564         }
565
566         if (!lookup_name_smbconf(talloc_tos(), groupname,
567                          LOOKUP_NAME_ALL|LOOKUP_NAME_GROUP,
568                          NULL, NULL, &group_sid, &type)) {
569                 DEBUG(10, ("lookup_name_smbconf(%s) failed\n",
570                            groupname));
571                 goto done;
572         }
573
574         if ((type != SID_NAME_DOM_GRP) && (type != SID_NAME_ALIAS) &&
575             (type != SID_NAME_WKN_GRP)) {
576                 DEBUG(10, ("%s is a %s, not a group\n", groupname,
577                            sid_type_lookup(type)));
578                 goto done;
579         }
580
581         if (!sid_to_gid(&group_sid, &gid)) {
582                 DEBUG(10, ("sid_to_gid(%s) for %s failed\n",
583                            sid_string_dbg(&group_sid), groupname));
584                 goto done;
585         }
586
587         /*
588          * If the user has been forced and the forced group starts with a '+',
589          * then we only set the group to be the forced group if the forced
590          * user is a member of that group.  Otherwise, the meaning of the '+'
591          * would be ignored.
592          */
593
594         if (force_user && user_must_be_member) {
595                 if (user_in_group_sid(username, &group_sid)) {
596                         sid_copy(pgroup_sid, &group_sid);
597                         *pgid = gid;
598                         DEBUG(3,("Forced group %s for member %s\n",
599                                  groupname, username));
600                 } else {
601                         DEBUG(0,("find_forced_group: forced user %s is not a member "
602                                 "of forced group %s. Disallowing access.\n",
603                                 username, groupname ));
604                         result = NT_STATUS_MEMBER_NOT_IN_GROUP;
605                         goto done;
606                 }
607         } else {
608                 sid_copy(pgroup_sid, &group_sid);
609                 *pgid = gid;
610                 DEBUG(3,("Forced group %s\n", groupname));
611         }
612
613         result = NT_STATUS_OK;
614  done:
615         TALLOC_FREE(frame);
616         return result;
617 }
618
619 /****************************************************************************
620   Create an auth_serversupplied_info structure for a connection_struct
621 ****************************************************************************/
622
623 static NTSTATUS create_connection_server_info(TALLOC_CTX *mem_ctx, int snum,
624                                               struct auth_serversupplied_info *vuid_serverinfo,
625                                               DATA_BLOB password,
626                                               struct auth_serversupplied_info **presult)
627 {
628         if (lp_guest_only(snum)) {
629                 return make_server_info_guest(mem_ctx, presult);
630         }
631
632         if (vuid_serverinfo != NULL) {
633
634                 struct auth_serversupplied_info *result;
635
636                 /*
637                  * This is the normal security != share case where we have a
638                  * valid vuid from the session setup.                 */
639
640                 if (vuid_serverinfo->guest) {
641                         if (!lp_guest_ok(snum)) {
642                                 DEBUG(2, ("guest user (from session setup) "
643                                           "not permitted to access this share "
644                                           "(%s)\n", lp_servicename(snum)));
645                                 return NT_STATUS_ACCESS_DENIED;
646                         }
647                 } else {
648                         if (!user_ok_token(vuid_serverinfo->unix_name,
649                                            pdb_get_domain(vuid_serverinfo->sam_account),
650                                            vuid_serverinfo->ptok, snum)) {
651                                 DEBUG(2, ("user '%s' (from session setup) not "
652                                           "permitted to access this share "
653                                           "(%s)\n",
654                                           vuid_serverinfo->unix_name,
655                                           lp_servicename(snum)));
656                                 return NT_STATUS_ACCESS_DENIED;
657                         }
658                 }
659
660                 result = copy_serverinfo(mem_ctx, vuid_serverinfo);
661                 if (result == NULL) {
662                         return NT_STATUS_NO_MEMORY;
663                 }
664
665                 *presult = result;
666                 return NT_STATUS_OK;
667         }
668
669         if (lp_security() == SEC_SHARE) {
670
671                 fstring user;
672                 bool guest;
673
674                 /* add the sharename as a possible user name if we
675                    are in share mode security */
676
677                 add_session_user(lp_servicename(snum));
678
679                 /* shall we let them in? */
680
681                 if (!authorise_login(snum,user,password,&guest)) {
682                         DEBUG( 2, ( "Invalid username/password for [%s]\n",
683                                     lp_servicename(snum)) );
684                         return NT_STATUS_WRONG_PASSWORD;
685                 }
686
687                 return make_serverinfo_from_username(mem_ctx, user, guest,
688                                                      presult);
689         }
690
691         DEBUG(0, ("invalid VUID (vuser) but not in security=share\n"));
692         return NT_STATUS_ACCESS_DENIED;
693 }
694
695
696 /****************************************************************************
697   Make a connection, given the snum to connect to, and the vuser of the
698   connecting user if appropriate.
699 ****************************************************************************/
700
701 static connection_struct *make_connection_snum(int snum, user_struct *vuser,
702                                                DATA_BLOB password, 
703                                                const char *pdev,
704                                                NTSTATUS *pstatus)
705 {
706         connection_struct *conn;
707         SMB_STRUCT_STAT st;
708         fstring dev;
709         int ret;
710         char addr[INET6_ADDRSTRLEN];
711         bool on_err_call_dis_hook = false;
712         NTSTATUS status;
713
714         fstrcpy(dev, pdev);
715         SET_STAT_INVALID(st);
716
717         if (NT_STATUS_IS_ERR(*pstatus = share_sanity_checks(snum, dev))) {
718                 return NULL;
719         }       
720
721         conn = conn_new();
722         if (!conn) {
723                 DEBUG(0,("Couldn't find free connection.\n"));
724                 *pstatus = NT_STATUS_INSUFFICIENT_RESOURCES;
725                 return NULL;
726         }
727
728         conn->params->service = snum;
729
730         status = create_connection_server_info(
731                 conn, snum, vuser ? vuser->server_info : NULL, password,
732                 &conn->server_info);
733
734         if (!NT_STATUS_IS_OK(status)) {
735                 DEBUG(0, ("create_connection_server_info failed: %s\n",
736                           nt_errstr(status)));
737                 *pstatus = status;
738                 conn_free(conn);
739                 return NULL;
740         }
741
742         if ((lp_guest_only(snum)) || (lp_security() == SEC_SHARE)) {
743                 conn->force_user = true;
744         }
745
746         add_session_user(conn->server_info->unix_name);
747
748         safe_strcpy(conn->client_address,
749                         client_addr(get_client_fd(),addr,sizeof(addr)), 
750                         sizeof(conn->client_address)-1);
751         conn->num_files_open = 0;
752         conn->lastused = conn->lastused_count = time(NULL);
753         conn->used = True;
754         conn->printer = (strncmp(dev,"LPT",3) == 0);
755         conn->ipc = ( (strncmp(dev,"IPC",3) == 0) ||
756                       ( lp_enable_asu_support() && strequal(dev,"ADMIN$")) );
757         conn->dirptr = NULL;
758
759         /* Case options for the share. */
760         if (lp_casesensitive(snum) == Auto) {
761                 /* We will be setting this per packet. Set to be case
762                  * insensitive for now. */
763                 conn->case_sensitive = False;
764         } else {
765                 conn->case_sensitive = (bool)lp_casesensitive(snum);
766         }
767
768         conn->case_preserve = lp_preservecase(snum);
769         conn->short_case_preserve = lp_shortpreservecase(snum);
770
771         conn->encrypt_level = lp_smb_encrypt(snum);
772
773         conn->veto_list = NULL;
774         conn->hide_list = NULL;
775         conn->veto_oplock_list = NULL;
776         conn->aio_write_behind_list = NULL;
777         string_set(&conn->dirpath,"");
778
779         conn->read_only = lp_readonly(SNUM(conn));
780         conn->admin_user = False;
781
782         if (*lp_force_user(snum)) {
783
784                 /*
785                  * Replace conn->server_info with a completely faked up one
786                  * from the username we are forced into :-)
787                  */
788
789                 char *fuser;
790                 struct auth_serversupplied_info *forced_serverinfo;
791
792                 fuser = talloc_string_sub(conn, lp_force_user(snum), "%S",
793                                           lp_servicename(snum));
794                 if (fuser == NULL) {
795                         conn_free(conn);
796                         *pstatus = NT_STATUS_NO_MEMORY;
797                         return NULL;
798                 }
799
800                 status = make_serverinfo_from_username(
801                         conn, fuser, conn->server_info->guest,
802                         &forced_serverinfo);
803                 if (!NT_STATUS_IS_OK(status)) {
804                         conn_free(conn);
805                         *pstatus = status;
806                         return NULL;
807                 }
808
809                 TALLOC_FREE(conn->server_info);
810                 conn->server_info = forced_serverinfo;
811
812                 conn->force_user = True;
813                 DEBUG(3,("Forced user %s\n", fuser));
814         }
815
816         /*
817          * If force group is true, then override
818          * any groupid stored for the connecting user.
819          */
820
821         if (*lp_force_group(snum)) {
822
823                 status = find_forced_group(
824                         conn->force_user, snum, conn->server_info->unix_name,
825                         &conn->server_info->ptok->user_sids[1],
826                         &conn->server_info->utok.gid);
827
828                 if (!NT_STATUS_IS_OK(status)) {
829                         conn_free(conn);
830                         *pstatus = status;
831                         return NULL;
832                 }
833         }
834
835         conn->vuid = (vuser != NULL) ? vuser->vuid : UID_FIELD_INVALID;
836
837         {
838                 char *s = talloc_sub_advanced(talloc_tos(),
839                                         lp_servicename(SNUM(conn)),
840                                         conn->server_info->unix_name,
841                                         conn->connectpath,
842                                         conn->server_info->utok.gid,
843                                         conn->server_info->sanitized_username,
844                                         pdb_get_domain(conn->server_info->sam_account),
845                                         lp_pathname(snum));
846                 if (!s) {
847                         conn_free(conn);
848                         *pstatus = NT_STATUS_NO_MEMORY;
849                         return NULL;
850                 }
851
852                 if (!set_conn_connectpath(conn,s)) {
853                         TALLOC_FREE(s);
854                         conn_free(conn);
855                         *pstatus = NT_STATUS_NO_MEMORY;
856                         return NULL;
857                 }
858                 DEBUG(3,("Connect path is '%s' for service [%s]\n",s,
859                          lp_servicename(snum)));
860                 TALLOC_FREE(s);
861         }
862
863         /*
864          * New code to check if there's a share security descripter
865          * added from NT server manager. This is done after the
866          * smb.conf checks are done as we need a uid and token. JRA.
867          *
868          */
869
870         {
871                 bool can_write = False;
872
873                 can_write = share_access_check(conn->server_info->ptok,
874                                                lp_servicename(snum),
875                                                FILE_WRITE_DATA);
876
877                 if (!can_write) {
878                         if (!share_access_check(conn->server_info->ptok,
879                                                 lp_servicename(snum),
880                                                 FILE_READ_DATA)) {
881                                 /* No access, read or write. */
882                                 DEBUG(0,("make_connection: connection to %s "
883                                          "denied due to security "
884                                          "descriptor.\n",
885                                           lp_servicename(snum)));
886                                 conn_free(conn);
887                                 *pstatus = NT_STATUS_ACCESS_DENIED;
888                                 return NULL;
889                         } else {
890                                 conn->read_only = True;
891                         }
892                 }
893         }
894         /* Initialise VFS function pointers */
895
896         if (!smbd_vfs_init(conn)) {
897                 DEBUG(0, ("vfs_init failed for service %s\n",
898                           lp_servicename(snum)));
899                 conn_free(conn);
900                 *pstatus = NT_STATUS_BAD_NETWORK_NAME;
901                 return NULL;
902         }
903
904         /*
905          * If widelinks are disallowed we need to canonicalise the connect
906          * path here to ensure we don't have any symlinks in the
907          * connectpath. We will be checking all paths on this connection are
908          * below this directory. We must do this after the VFS init as we
909          * depend on the realpath() pointer in the vfs table. JRA.
910          */
911         if (!lp_widelinks(snum)) {
912                 if (!canonicalize_connect_path(conn)) {
913                         DEBUG(0, ("canonicalize_connect_path failed "
914                         "for service %s, path %s\n",
915                                 lp_servicename(snum),
916                                 conn->connectpath));
917                         conn_free(conn);
918                         *pstatus = NT_STATUS_BAD_NETWORK_NAME;
919                         return NULL;
920                 }
921         }
922
923         if ((!conn->printer) && (!conn->ipc)) {
924                 conn->notify_ctx = notify_init(conn, server_id_self(),
925                                                smbd_messaging_context(),
926                                                smbd_event_context(),
927                                                conn);
928         }
929
930 /* ROOT Activities: */  
931         /*
932          * Enforce the max connections parameter.
933          */
934
935         if ((lp_max_connections(snum) > 0)
936             && (count_current_connections(lp_servicename(SNUM(conn)), True) >=
937                 lp_max_connections(snum))) {
938
939                 DEBUG(1, ("Max connections (%d) exceeded for %s\n",
940                           lp_max_connections(snum), lp_servicename(snum)));
941                 conn_free(conn);
942                 *pstatus = NT_STATUS_INSUFFICIENT_RESOURCES;
943                 return NULL;
944         }  
945
946         /*
947          * Get us an entry in the connections db
948          */
949         if (!claim_connection(conn, lp_servicename(snum), 0)) {
950                 DEBUG(1, ("Could not store connections entry\n"));
951                 conn_free(conn);
952                 *pstatus = NT_STATUS_INTERNAL_DB_ERROR;
953                 return NULL;
954         }  
955
956         /* Preexecs are done here as they might make the dir we are to ChDir
957          * to below */
958         /* execute any "root preexec = " line */
959         if (*lp_rootpreexec(snum)) {
960                 char *cmd = talloc_sub_advanced(talloc_tos(),
961                                         lp_servicename(SNUM(conn)),
962                                         conn->server_info->unix_name,
963                                         conn->connectpath,
964                                         conn->server_info->utok.gid,
965                                         conn->server_info->sanitized_username,
966                                         pdb_get_domain(conn->server_info->sam_account),
967                                         lp_rootpreexec(snum));
968                 DEBUG(5,("cmd=%s\n",cmd));
969                 ret = smbrun(cmd,NULL);
970                 TALLOC_FREE(cmd);
971                 if (ret != 0 && lp_rootpreexec_close(snum)) {
972                         DEBUG(1,("root preexec gave %d - failing "
973                                  "connection\n", ret));
974                         yield_connection(conn, lp_servicename(snum));
975                         conn_free(conn);
976                         *pstatus = NT_STATUS_ACCESS_DENIED;
977                         return NULL;
978                 }
979         }
980
981 /* USER Activites: */
982         if (!change_to_user(conn, conn->vuid)) {
983                 /* No point continuing if they fail the basic checks */
984                 DEBUG(0,("Can't become connected user!\n"));
985                 yield_connection(conn, lp_servicename(snum));
986                 conn_free(conn);
987                 *pstatus = NT_STATUS_LOGON_FAILURE;
988                 return NULL;
989         }
990
991         /* Remember that a different vuid can connect later without these
992          * checks... */
993         
994         /* Preexecs are done here as they might make the dir we are to ChDir
995          * to below */
996
997         /* execute any "preexec = " line */
998         if (*lp_preexec(snum)) {
999                 char *cmd = talloc_sub_advanced(talloc_tos(),
1000                                         lp_servicename(SNUM(conn)),
1001                                         conn->server_info->unix_name,
1002                                         conn->connectpath,
1003                                         conn->server_info->utok.gid,
1004                                         conn->server_info->sanitized_username,
1005                                         pdb_get_domain(conn->server_info->sam_account),
1006                                         lp_preexec(snum));
1007                 ret = smbrun(cmd,NULL);
1008                 TALLOC_FREE(cmd);
1009                 if (ret != 0 && lp_preexec_close(snum)) {
1010                         DEBUG(1,("preexec gave %d - failing connection\n",
1011                                  ret));
1012                         *pstatus = NT_STATUS_ACCESS_DENIED;
1013                         goto err_root_exit;
1014                 }
1015         }
1016
1017 #ifdef WITH_FAKE_KASERVER
1018         if (lp_afs_share(snum)) {
1019                 afs_login(conn);
1020         }
1021 #endif
1022         
1023         /* Add veto/hide lists */
1024         if (!IS_IPC(conn) && !IS_PRINT(conn)) {
1025                 set_namearray( &conn->veto_list, lp_veto_files(snum));
1026                 set_namearray( &conn->hide_list, lp_hide_files(snum));
1027                 set_namearray( &conn->veto_oplock_list, lp_veto_oplocks(snum));
1028                 set_namearray( &conn->aio_write_behind_list,
1029                                 lp_aio_write_behind(snum));
1030         }
1031         
1032         /* Invoke VFS make connection hook - do this before the VFS_STAT call
1033            to allow any filesystems needing user credentials to initialize
1034            themselves. */
1035
1036         if (SMB_VFS_CONNECT(conn, lp_servicename(snum),
1037                             conn->server_info->unix_name) < 0) {
1038                 DEBUG(0,("make_connection: VFS make connection failed!\n"));
1039                 *pstatus = NT_STATUS_UNSUCCESSFUL;
1040                 goto err_root_exit;
1041         }
1042
1043         /* Any error exit after here needs to call the disconnect hook. */
1044         on_err_call_dis_hook = true;
1045
1046         /* win2000 does not check the permissions on the directory
1047            during the tree connect, instead relying on permission
1048            check during individual operations. To match this behaviour
1049            I have disabled this chdir check (tridge) */
1050         /* the alternative is just to check the directory exists */
1051         if ((ret = SMB_VFS_STAT(conn, conn->connectpath, &st)) != 0 ||
1052             !S_ISDIR(st.st_mode)) {
1053                 if (ret == 0 && !S_ISDIR(st.st_mode)) {
1054                         DEBUG(0,("'%s' is not a directory, when connecting to "
1055                                  "[%s]\n", conn->connectpath,
1056                                  lp_servicename(snum)));
1057                 } else {
1058                         DEBUG(0,("'%s' does not exist or permission denied "
1059                                  "when connecting to [%s] Error was %s\n",
1060                                  conn->connectpath, lp_servicename(snum),
1061                                  strerror(errno) ));
1062                 }
1063                 *pstatus = NT_STATUS_BAD_NETWORK_NAME;
1064                 goto err_root_exit;
1065         }
1066
1067         string_set(&conn->origpath,conn->connectpath);
1068
1069 #if SOFTLINK_OPTIMISATION
1070         /* resolve any soft links early if possible */
1071         if (vfs_ChDir(conn,conn->connectpath) == 0) {
1072                 TALLOC_CTX *ctx = talloc_tos();
1073                 char *s = vfs_GetWd(ctx,s);
1074                 if (!s) {
1075                         *status = map_nt_error_from_unix(errno);
1076                         goto err_root_exit;
1077                 }
1078                 if (!set_conn_connectpath(conn,s)) {
1079                         *status = NT_STATUS_NO_MEMORY;
1080                         goto err_root_exit;
1081                 }
1082                 vfs_ChDir(conn,conn->connectpath);
1083         }
1084 #endif
1085
1086         /* Figure out the characteristics of the underlying filesystem. This
1087          * assumes that all the filesystem mounted withing a share path have
1088          * the same characteristics, which is likely but not guaranteed.
1089          */
1090
1091         conn->fs_capabilities = SMB_VFS_FS_CAPABILITIES(conn);
1092
1093         /*
1094          * Print out the 'connected as' stuff here as we need
1095          * to know the effective uid and gid we will be using
1096          * (at least initially).
1097          */
1098
1099         if( DEBUGLVL( IS_IPC(conn) ? 3 : 1 ) ) {
1100                 dbgtext( "%s (%s) ", get_remote_machine_name(),
1101                          conn->client_address );
1102                 dbgtext( "%s", srv_is_signing_active() ? "signed " : "");
1103                 dbgtext( "connect to service %s ", lp_servicename(snum) );
1104                 dbgtext( "initially as user %s ",
1105                          conn->server_info->unix_name );
1106                 dbgtext( "(uid=%d, gid=%d) ", (int)geteuid(), (int)getegid() );
1107                 dbgtext( "(pid %d)\n", (int)sys_getpid() );
1108         }
1109
1110         /* we've finished with the user stuff - go back to root */
1111         change_to_root_user();
1112         return(conn);
1113
1114   err_root_exit:
1115
1116         change_to_root_user();
1117         if (on_err_call_dis_hook) {
1118                 /* Call VFS disconnect hook */
1119                 SMB_VFS_DISCONNECT(conn);
1120         }
1121         yield_connection(conn, lp_servicename(snum));
1122         conn_free(conn);
1123         return NULL;
1124 }
1125
1126 /***************************************************************************************
1127  Simple wrapper function for make_connection() to include a call to 
1128  vfs_chdir()
1129  **************************************************************************************/
1130  
1131 connection_struct *make_connection_with_chdir(const char *service_in,
1132                                               DATA_BLOB password, 
1133                                               const char *dev, uint16 vuid,
1134                                               NTSTATUS *status)
1135 {
1136         connection_struct *conn = NULL;
1137         
1138         conn = make_connection(service_in, password, dev, vuid, status);
1139         
1140         /*
1141          * make_connection() does not change the directory for us any more
1142          * so we have to do it as a separate step  --jerry
1143          */
1144          
1145         if ( conn && vfs_ChDir(conn,conn->connectpath) != 0 ) {
1146                 DEBUG(0,("make_connection_with_chdir: Can't change "
1147                          "directory to %s for [print$] (%s)\n",
1148                          conn->connectpath,strerror(errno)));
1149                 yield_connection(conn, lp_servicename(SNUM(conn)));
1150                 conn_free(conn);
1151                 *status = NT_STATUS_UNSUCCESSFUL;
1152                 return NULL;
1153         }
1154         
1155         return conn;
1156 }
1157
1158 /****************************************************************************
1159  Make a connection to a service.
1160  *
1161  * @param service 
1162 ****************************************************************************/
1163
1164 connection_struct *make_connection(const char *service_in, DATA_BLOB password, 
1165                                    const char *pdev, uint16 vuid,
1166                                    NTSTATUS *status)
1167 {
1168         uid_t euid;
1169         user_struct *vuser = NULL;
1170         fstring service;
1171         fstring dev;
1172         int snum = -1;
1173         char addr[INET6_ADDRSTRLEN];
1174
1175         fstrcpy(dev, pdev);
1176
1177         /* This must ONLY BE CALLED AS ROOT. As it exits this function as
1178          * root. */
1179         if (!non_root_mode() && (euid = geteuid()) != 0) {
1180                 DEBUG(0,("make_connection: PANIC ERROR. Called as nonroot "
1181                          "(%u)\n", (unsigned int)euid ));
1182                 smb_panic("make_connection: PANIC ERROR. Called as nonroot\n");
1183         }
1184
1185         if (conn_num_open() > 2047) {
1186                 *status = NT_STATUS_INSUFF_SERVER_RESOURCES;
1187                 return NULL;
1188         }
1189
1190         if(lp_security() != SEC_SHARE) {
1191                 vuser = get_valid_user_struct(vuid);
1192                 if (!vuser) {
1193                         DEBUG(1,("make_connection: refusing to connect with "
1194                                  "no session setup\n"));
1195                         *status = NT_STATUS_ACCESS_DENIED;
1196                         return NULL;
1197                 }
1198         }
1199
1200         /* Logic to try and connect to the correct [homes] share, preferably
1201            without too many getpwnam() lookups.  This is particulary nasty for
1202            winbind usernames, where the share name isn't the same as unix
1203            username.
1204
1205            The snum of the homes share is stored on the vuser at session setup
1206            time.
1207         */
1208
1209         if (strequal(service_in,HOMES_NAME)) {
1210                 if(lp_security() != SEC_SHARE) {
1211                         DATA_BLOB no_pw = data_blob_null;
1212                         if (vuser->homes_snum == -1) {
1213                                 DEBUG(2, ("[homes] share not available for "
1214                                           "this user because it was not found "
1215                                           "or created at session setup "
1216                                           "time\n"));
1217                                 *status = NT_STATUS_BAD_NETWORK_NAME;
1218                                 return NULL;
1219                         }
1220                         DEBUG(5, ("making a connection to [homes] service "
1221                                   "created at session setup time\n"));
1222                         return make_connection_snum(vuser->homes_snum,
1223                                                     vuser, no_pw, 
1224                                                     dev, status);
1225                 } else {
1226                         /* Security = share. Try with
1227                          * current_user_info.smb_name as the username.  */
1228                         if (*current_user_info.smb_name) {
1229                                 fstring unix_username;
1230                                 fstrcpy(unix_username,
1231                                         current_user_info.smb_name);
1232                                 map_username(unix_username);
1233                                 snum = find_service(unix_username);
1234                         } 
1235                         if (snum != -1) {
1236                                 DEBUG(5, ("making a connection to 'homes' "
1237                                           "service %s based on "
1238                                           "security=share\n", service_in));
1239                                 return make_connection_snum(snum, NULL,
1240                                                             password,
1241                                                             dev, status);
1242                         }
1243                 }
1244         } else if ((lp_security() != SEC_SHARE) && (vuser->homes_snum != -1)
1245                    && strequal(service_in,
1246                                lp_servicename(vuser->homes_snum))) {
1247                 DATA_BLOB no_pw = data_blob_null;
1248                 DEBUG(5, ("making a connection to 'homes' service [%s] "
1249                           "created at session setup time\n", service_in));
1250                 return make_connection_snum(vuser->homes_snum,
1251                                             vuser, no_pw, 
1252                                             dev, status);
1253         }
1254         
1255         fstrcpy(service, service_in);
1256
1257         strlower_m(service);
1258
1259         snum = find_service(service);
1260
1261         if (snum < 0) {
1262                 if (strequal(service,"IPC$") ||
1263                     (lp_enable_asu_support() && strequal(service,"ADMIN$"))) {
1264                         DEBUG(3,("refusing IPC connection to %s\n", service));
1265                         *status = NT_STATUS_ACCESS_DENIED;
1266                         return NULL;
1267                 }
1268
1269                 DEBUG(0,("%s (%s) couldn't find service %s\n",
1270                         get_remote_machine_name(),
1271                         client_addr(get_client_fd(),addr,sizeof(addr)),
1272                         service));
1273                 *status = NT_STATUS_BAD_NETWORK_NAME;
1274                 return NULL;
1275         }
1276
1277         /* Handle non-Dfs clients attempting connections to msdfs proxy */
1278         if (lp_host_msdfs() && (*lp_msdfs_proxy(snum) != '\0'))  {
1279                 DEBUG(3, ("refusing connection to dfs proxy share '%s' "
1280                           "(pointing to %s)\n", 
1281                         service, lp_msdfs_proxy(snum)));
1282                 *status = NT_STATUS_BAD_NETWORK_NAME;
1283                 return NULL;
1284         }
1285
1286         DEBUG(5, ("making a connection to 'normal' service %s\n", service));
1287
1288         return make_connection_snum(snum, vuser,
1289                                     password,
1290                                     dev, status);
1291 }
1292
1293 /****************************************************************************
1294  Close a cnum.
1295 ****************************************************************************/
1296
1297 void close_cnum(connection_struct *conn, uint16 vuid)
1298 {
1299         file_close_conn(conn);
1300
1301         if (!IS_IPC(conn)) {
1302                 dptr_closecnum(conn);
1303         }
1304
1305         change_to_root_user();
1306
1307         DEBUG(IS_IPC(conn)?3:1, ("%s (%s) closed connection to service %s\n",
1308                                  get_remote_machine_name(),
1309                                  conn->client_address,
1310                                  lp_servicename(SNUM(conn))));
1311
1312         /* Call VFS disconnect hook */    
1313         SMB_VFS_DISCONNECT(conn);
1314
1315         yield_connection(conn, lp_servicename(SNUM(conn)));
1316
1317         /* make sure we leave the directory available for unmount */
1318         vfs_ChDir(conn, "/");
1319
1320         /* execute any "postexec = " line */
1321         if (*lp_postexec(SNUM(conn)) && 
1322             change_to_user(conn, vuid))  {
1323                 char *cmd = talloc_sub_advanced(talloc_tos(),
1324                                         lp_servicename(SNUM(conn)),
1325                                         conn->server_info->unix_name,
1326                                         conn->connectpath,
1327                                         conn->server_info->utok.gid,
1328                                         conn->server_info->sanitized_username,
1329                                         pdb_get_domain(conn->server_info->sam_account),
1330                                         lp_postexec(SNUM(conn)));
1331                 smbrun(cmd,NULL);
1332                 TALLOC_FREE(cmd);
1333                 change_to_root_user();
1334         }
1335
1336         change_to_root_user();
1337         /* execute any "root postexec = " line */
1338         if (*lp_rootpostexec(SNUM(conn)))  {
1339                 char *cmd = talloc_sub_advanced(talloc_tos(),
1340                                         lp_servicename(SNUM(conn)),
1341                                         conn->server_info->unix_name,
1342                                         conn->connectpath,
1343                                         conn->server_info->utok.gid,
1344                                         conn->server_info->sanitized_username,
1345                                         pdb_get_domain(conn->server_info->sam_account),
1346                                         lp_rootpostexec(SNUM(conn)));
1347                 smbrun(cmd,NULL);
1348                 TALLOC_FREE(cmd);
1349         }
1350
1351         conn_free(conn);
1352 }