find_forced_group can directly change the token in server_info
[samba.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                                            vuid_serverinfo->ptok, snum)) {
650                                 DEBUG(2, ("user '%s' (from session setup) not "
651                                           "permitted to access this share "
652                                           "(%s)\n",
653                                           vuid_serverinfo->unix_name,
654                                           lp_servicename(snum)));
655                                 return NT_STATUS_ACCESS_DENIED;
656                         }
657                 }
658
659                 result = copy_serverinfo(mem_ctx, vuid_serverinfo);
660                 if (result == NULL) {
661                         return NT_STATUS_NO_MEMORY;
662                 }
663
664                 *presult = result;
665                 return NT_STATUS_OK;
666         }
667
668         if (lp_security() == SEC_SHARE) {
669
670                 fstring user;
671                 bool guest;
672
673                 /* add the sharename as a possible user name if we
674                    are in share mode security */
675
676                 add_session_user(lp_servicename(snum));
677
678                 /* shall we let them in? */
679
680                 if (!authorise_login(snum,user,password,&guest)) {
681                         DEBUG( 2, ( "Invalid username/password for [%s]\n",
682                                     lp_servicename(snum)) );
683                         return NT_STATUS_WRONG_PASSWORD;
684                 }
685
686                 return make_serverinfo_from_username(mem_ctx, user, guest,
687                                                      presult);
688         }
689
690         DEBUG(0, ("invalid VUID (vuser) but not in security=share\n"));
691         return NT_STATUS_ACCESS_DENIED;
692 }
693
694
695 /****************************************************************************
696   Make a connection, given the snum to connect to, and the vuser of the
697   connecting user if appropriate.
698 ****************************************************************************/
699
700 static connection_struct *make_connection_snum(int snum, user_struct *vuser,
701                                                DATA_BLOB password, 
702                                                const char *pdev,
703                                                NTSTATUS *pstatus)
704 {
705         connection_struct *conn;
706         SMB_STRUCT_STAT st;
707         fstring dev;
708         int ret;
709         char addr[INET6_ADDRSTRLEN];
710         bool on_err_call_dis_hook = false;
711         NTSTATUS status;
712
713         fstrcpy(dev, pdev);
714         SET_STAT_INVALID(st);
715
716         if (NT_STATUS_IS_ERR(*pstatus = share_sanity_checks(snum, dev))) {
717                 return NULL;
718         }       
719
720         conn = conn_new();
721         if (!conn) {
722                 DEBUG(0,("Couldn't find free connection.\n"));
723                 *pstatus = NT_STATUS_INSUFFICIENT_RESOURCES;
724                 return NULL;
725         }
726
727         conn->params->service = snum;
728         conn->nt_user_token = NULL;
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->user,
825                         &conn->server_info->ptok->user_sids[1],
826                         &conn->server_info->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         conn->uid = conn->server_info->uid;
838         conn->gid = conn->server_info->gid;
839         string_set(&conn->user, conn->server_info->unix_name);
840
841         {
842                 char *s = talloc_sub_advanced(talloc_tos(),
843                                         lp_servicename(SNUM(conn)), conn->user,
844                                         conn->connectpath, conn->gid,
845                                         get_current_username(),
846                                         current_user_info.domain,
847                                         lp_pathname(snum));
848                 if (!s) {
849                         conn_free(conn);
850                         *pstatus = NT_STATUS_NO_MEMORY;
851                         return NULL;
852                 }
853
854                 if (!set_conn_connectpath(conn,s)) {
855                         TALLOC_FREE(s);
856                         conn_free(conn);
857                         *pstatus = NT_STATUS_NO_MEMORY;
858                         return NULL;
859                 }
860                 DEBUG(3,("Connect path is '%s' for service [%s]\n",s,
861                          lp_servicename(snum)));
862                 TALLOC_FREE(s);
863         }
864
865         /*
866          * New code to check if there's a share security descripter
867          * added from NT server manager. This is done after the
868          * smb.conf checks are done as we need a uid and token. JRA.
869          *
870          */
871
872         {
873                 bool can_write = False;
874                 NT_USER_TOKEN *token = conn->nt_user_token ?
875                         conn->nt_user_token :
876                         (vuser ? vuser->server_info->ptok : NULL);
877
878                 /*
879                  * I don't believe this can happen. But the
880                  * logic above is convoluted enough to confuse
881                  * automated checkers, so be sure. JRA.
882                  */
883
884                 if (token == NULL) {
885                         DEBUG(0,("make_connection: connection to %s "
886                                  "denied due to missing "
887                                  "NT token.\n",
888                                   lp_servicename(snum)));
889                         conn_free(conn);
890                         *pstatus = NT_STATUS_ACCESS_DENIED;
891                         return NULL;
892                 }
893
894                 can_write = share_access_check(token,
895                                                     lp_servicename(snum),
896                                                     FILE_WRITE_DATA);
897
898                 if (!can_write) {
899                         if (!share_access_check(token,
900                                                 lp_servicename(snum),
901                                                 FILE_READ_DATA)) {
902                                 /* No access, read or write. */
903                                 DEBUG(0,("make_connection: connection to %s "
904                                          "denied due to security "
905                                          "descriptor.\n",
906                                           lp_servicename(snum)));
907                                 conn_free(conn);
908                                 *pstatus = NT_STATUS_ACCESS_DENIED;
909                                 return NULL;
910                         } else {
911                                 conn->read_only = True;
912                         }
913                 }
914         }
915         /* Initialise VFS function pointers */
916
917         if (!smbd_vfs_init(conn)) {
918                 DEBUG(0, ("vfs_init failed for service %s\n",
919                           lp_servicename(snum)));
920                 conn_free(conn);
921                 *pstatus = NT_STATUS_BAD_NETWORK_NAME;
922                 return NULL;
923         }
924
925         /*
926          * If widelinks are disallowed we need to canonicalise the connect
927          * path here to ensure we don't have any symlinks in the
928          * connectpath. We will be checking all paths on this connection are
929          * below this directory. We must do this after the VFS init as we
930          * depend on the realpath() pointer in the vfs table. JRA.
931          */
932         if (!lp_widelinks(snum)) {
933                 if (!canonicalize_connect_path(conn)) {
934                         DEBUG(0, ("canonicalize_connect_path failed "
935                         "for service %s, path %s\n",
936                                 lp_servicename(snum),
937                                 conn->connectpath));
938                         conn_free(conn);
939                         *pstatus = NT_STATUS_BAD_NETWORK_NAME;
940                         return NULL;
941                 }
942         }
943
944         if ((!conn->printer) && (!conn->ipc)) {
945                 conn->notify_ctx = notify_init(conn, server_id_self(),
946                                                smbd_messaging_context(),
947                                                smbd_event_context(),
948                                                conn);
949         }
950
951 /* ROOT Activities: */  
952         /*
953          * Enforce the max connections parameter.
954          */
955
956         if ((lp_max_connections(snum) > 0)
957             && (count_current_connections(lp_servicename(SNUM(conn)), True) >=
958                 lp_max_connections(snum))) {
959
960                 DEBUG(1, ("Max connections (%d) exceeded for %s\n",
961                           lp_max_connections(snum), lp_servicename(snum)));
962                 conn_free(conn);
963                 *pstatus = NT_STATUS_INSUFFICIENT_RESOURCES;
964                 return NULL;
965         }  
966
967         /*
968          * Get us an entry in the connections db
969          */
970         if (!claim_connection(conn, lp_servicename(snum), 0)) {
971                 DEBUG(1, ("Could not store connections entry\n"));
972                 conn_free(conn);
973                 *pstatus = NT_STATUS_INTERNAL_DB_ERROR;
974                 return NULL;
975         }  
976
977         /* Preexecs are done here as they might make the dir we are to ChDir
978          * to below */
979         /* execute any "root preexec = " line */
980         if (*lp_rootpreexec(snum)) {
981                 char *cmd = talloc_sub_advanced(talloc_tos(),
982                                         lp_servicename(SNUM(conn)), conn->user,
983                                         conn->connectpath, conn->gid,
984                                         get_current_username(),
985                                         current_user_info.domain,
986                                         lp_rootpreexec(snum));
987                 DEBUG(5,("cmd=%s\n",cmd));
988                 ret = smbrun(cmd,NULL);
989                 TALLOC_FREE(cmd);
990                 if (ret != 0 && lp_rootpreexec_close(snum)) {
991                         DEBUG(1,("root preexec gave %d - failing "
992                                  "connection\n", ret));
993                         yield_connection(conn, lp_servicename(snum));
994                         conn_free(conn);
995                         *pstatus = NT_STATUS_ACCESS_DENIED;
996                         return NULL;
997                 }
998         }
999
1000 /* USER Activites: */
1001         if (!change_to_user(conn, conn->vuid)) {
1002                 /* No point continuing if they fail the basic checks */
1003                 DEBUG(0,("Can't become connected user!\n"));
1004                 yield_connection(conn, lp_servicename(snum));
1005                 conn_free(conn);
1006                 *pstatus = NT_STATUS_LOGON_FAILURE;
1007                 return NULL;
1008         }
1009
1010         /* Remember that a different vuid can connect later without these
1011          * checks... */
1012         
1013         /* Preexecs are done here as they might make the dir we are to ChDir
1014          * to below */
1015
1016         /* execute any "preexec = " line */
1017         if (*lp_preexec(snum)) {
1018                 char *cmd = talloc_sub_advanced(talloc_tos(),
1019                                         lp_servicename(SNUM(conn)), conn->user,
1020                                         conn->connectpath, conn->gid,
1021                                         get_current_username(),
1022                                         current_user_info.domain,
1023                                         lp_preexec(snum));
1024                 ret = smbrun(cmd,NULL);
1025                 TALLOC_FREE(cmd);
1026                 if (ret != 0 && lp_preexec_close(snum)) {
1027                         DEBUG(1,("preexec gave %d - failing connection\n",
1028                                  ret));
1029                         *pstatus = NT_STATUS_ACCESS_DENIED;
1030                         goto err_root_exit;
1031                 }
1032         }
1033
1034 #ifdef WITH_FAKE_KASERVER
1035         if (lp_afs_share(snum)) {
1036                 afs_login(conn);
1037         }
1038 #endif
1039         
1040         /* Add veto/hide lists */
1041         if (!IS_IPC(conn) && !IS_PRINT(conn)) {
1042                 set_namearray( &conn->veto_list, lp_veto_files(snum));
1043                 set_namearray( &conn->hide_list, lp_hide_files(snum));
1044                 set_namearray( &conn->veto_oplock_list, lp_veto_oplocks(snum));
1045         }
1046         
1047         /* Invoke VFS make connection hook - do this before the VFS_STAT call
1048            to allow any filesystems needing user credentials to initialize
1049            themselves. */
1050
1051         if (SMB_VFS_CONNECT(conn, lp_servicename(snum), conn->user) < 0) {
1052                 DEBUG(0,("make_connection: VFS make connection failed!\n"));
1053                 *pstatus = NT_STATUS_UNSUCCESSFUL;
1054                 goto err_root_exit;
1055         }
1056
1057         /* Any error exit after here needs to call the disconnect hook. */
1058         on_err_call_dis_hook = true;
1059
1060         /* win2000 does not check the permissions on the directory
1061            during the tree connect, instead relying on permission
1062            check during individual operations. To match this behaviour
1063            I have disabled this chdir check (tridge) */
1064         /* the alternative is just to check the directory exists */
1065         if ((ret = SMB_VFS_STAT(conn, conn->connectpath, &st)) != 0 ||
1066             !S_ISDIR(st.st_mode)) {
1067                 if (ret == 0 && !S_ISDIR(st.st_mode)) {
1068                         DEBUG(0,("'%s' is not a directory, when connecting to "
1069                                  "[%s]\n", conn->connectpath,
1070                                  lp_servicename(snum)));
1071                 } else {
1072                         DEBUG(0,("'%s' does not exist or permission denied "
1073                                  "when connecting to [%s] Error was %s\n",
1074                                  conn->connectpath, lp_servicename(snum),
1075                                  strerror(errno) ));
1076                 }
1077                 *pstatus = NT_STATUS_BAD_NETWORK_NAME;
1078                 goto err_root_exit;
1079         }
1080
1081         string_set(&conn->origpath,conn->connectpath);
1082
1083 #if SOFTLINK_OPTIMISATION
1084         /* resolve any soft links early if possible */
1085         if (vfs_ChDir(conn,conn->connectpath) == 0) {
1086                 TALLOC_CTX *ctx = talloc_tos();
1087                 char *s = vfs_GetWd(ctx,s);
1088                 if (!s) {
1089                         *status = map_nt_error_from_unix(errno);
1090                         goto err_root_exit;
1091                 }
1092                 if (!set_conn_connectpath(conn,s)) {
1093                         *status = NT_STATUS_NO_MEMORY;
1094                         goto err_root_exit;
1095                 }
1096                 vfs_ChDir(conn,conn->connectpath);
1097         }
1098 #endif
1099
1100         /* Figure out the characteristics of the underlying filesystem. This
1101          * assumes that all the filesystem mounted withing a share path have
1102          * the same characteristics, which is likely but not guaranteed.
1103          */
1104
1105         conn->fs_capabilities = SMB_VFS_FS_CAPABILITIES(conn);
1106
1107         /*
1108          * Print out the 'connected as' stuff here as we need
1109          * to know the effective uid and gid we will be using
1110          * (at least initially).
1111          */
1112
1113         if( DEBUGLVL( IS_IPC(conn) ? 3 : 1 ) ) {
1114                 dbgtext( "%s (%s) ", get_remote_machine_name(),
1115                          conn->client_address );
1116                 dbgtext( "%s", srv_is_signing_active() ? "signed " : "");
1117                 dbgtext( "connect to service %s ", lp_servicename(snum) );
1118                 dbgtext( "initially as user %s ", conn->user );
1119                 dbgtext( "(uid=%d, gid=%d) ", (int)geteuid(), (int)getegid() );
1120                 dbgtext( "(pid %d)\n", (int)sys_getpid() );
1121         }
1122
1123         /* we've finished with the user stuff - go back to root */
1124         change_to_root_user();
1125         return(conn);
1126
1127   err_root_exit:
1128
1129         change_to_root_user();
1130         if (on_err_call_dis_hook) {
1131                 /* Call VFS disconnect hook */
1132                 SMB_VFS_DISCONNECT(conn);
1133         }
1134         yield_connection(conn, lp_servicename(snum));
1135         conn_free(conn);
1136         return NULL;
1137 }
1138
1139 /***************************************************************************************
1140  Simple wrapper function for make_connection() to include a call to 
1141  vfs_chdir()
1142  **************************************************************************************/
1143  
1144 connection_struct *make_connection_with_chdir(const char *service_in,
1145                                               DATA_BLOB password, 
1146                                               const char *dev, uint16 vuid,
1147                                               NTSTATUS *status)
1148 {
1149         connection_struct *conn = NULL;
1150         
1151         conn = make_connection(service_in, password, dev, vuid, status);
1152         
1153         /*
1154          * make_connection() does not change the directory for us any more
1155          * so we have to do it as a separate step  --jerry
1156          */
1157          
1158         if ( conn && vfs_ChDir(conn,conn->connectpath) != 0 ) {
1159                 DEBUG(0,("move_driver_to_download_area: Can't change "
1160                          "directory to %s for [print$] (%s)\n",
1161                          conn->connectpath,strerror(errno)));
1162                 yield_connection(conn, lp_servicename(SNUM(conn)));
1163                 conn_free(conn);
1164                 *status = NT_STATUS_UNSUCCESSFUL;
1165                 return NULL;
1166         }
1167         
1168         return conn;
1169 }
1170
1171 /****************************************************************************
1172  Make a connection to a service.
1173  *
1174  * @param service 
1175 ****************************************************************************/
1176
1177 connection_struct *make_connection(const char *service_in, DATA_BLOB password, 
1178                                    const char *pdev, uint16 vuid,
1179                                    NTSTATUS *status)
1180 {
1181         uid_t euid;
1182         user_struct *vuser = NULL;
1183         fstring service;
1184         fstring dev;
1185         int snum = -1;
1186         char addr[INET6_ADDRSTRLEN];
1187
1188         fstrcpy(dev, pdev);
1189
1190         /* This must ONLY BE CALLED AS ROOT. As it exits this function as
1191          * root. */
1192         if (!non_root_mode() && (euid = geteuid()) != 0) {
1193                 DEBUG(0,("make_connection: PANIC ERROR. Called as nonroot "
1194                          "(%u)\n", (unsigned int)euid ));
1195                 smb_panic("make_connection: PANIC ERROR. Called as nonroot\n");
1196         }
1197
1198         if (conn_num_open() > 2047) {
1199                 *status = NT_STATUS_INSUFF_SERVER_RESOURCES;
1200                 return NULL;
1201         }
1202
1203         if(lp_security() != SEC_SHARE) {
1204                 vuser = get_valid_user_struct(vuid);
1205                 if (!vuser) {
1206                         DEBUG(1,("make_connection: refusing to connect with "
1207                                  "no session setup\n"));
1208                         *status = NT_STATUS_ACCESS_DENIED;
1209                         return NULL;
1210                 }
1211         }
1212
1213         /* Logic to try and connect to the correct [homes] share, preferably
1214            without too many getpwnam() lookups.  This is particulary nasty for
1215            winbind usernames, where the share name isn't the same as unix
1216            username.
1217
1218            The snum of the homes share is stored on the vuser at session setup
1219            time.
1220         */
1221
1222         if (strequal(service_in,HOMES_NAME)) {
1223                 if(lp_security() != SEC_SHARE) {
1224                         DATA_BLOB no_pw = data_blob_null;
1225                         if (vuser->homes_snum == -1) {
1226                                 DEBUG(2, ("[homes] share not available for "
1227                                           "this user because it was not found "
1228                                           "or created at session setup "
1229                                           "time\n"));
1230                                 *status = NT_STATUS_BAD_NETWORK_NAME;
1231                                 return NULL;
1232                         }
1233                         DEBUG(5, ("making a connection to [homes] service "
1234                                   "created at session setup time\n"));
1235                         return make_connection_snum(vuser->homes_snum,
1236                                                     vuser, no_pw, 
1237                                                     dev, status);
1238                 } else {
1239                         /* Security = share. Try with
1240                          * current_user_info.smb_name as the username.  */
1241                         if (*current_user_info.smb_name) {
1242                                 fstring unix_username;
1243                                 fstrcpy(unix_username,
1244                                         current_user_info.smb_name);
1245                                 map_username(unix_username);
1246                                 snum = find_service(unix_username);
1247                         } 
1248                         if (snum != -1) {
1249                                 DEBUG(5, ("making a connection to 'homes' "
1250                                           "service %s based on "
1251                                           "security=share\n", service_in));
1252                                 return make_connection_snum(snum, NULL,
1253                                                             password,
1254                                                             dev, status);
1255                         }
1256                 }
1257         } else if ((lp_security() != SEC_SHARE) && (vuser->homes_snum != -1)
1258                    && strequal(service_in,
1259                                lp_servicename(vuser->homes_snum))) {
1260                 DATA_BLOB no_pw = data_blob_null;
1261                 DEBUG(5, ("making a connection to 'homes' service [%s] "
1262                           "created at session setup time\n", service_in));
1263                 return make_connection_snum(vuser->homes_snum,
1264                                             vuser, no_pw, 
1265                                             dev, status);
1266         }
1267         
1268         fstrcpy(service, service_in);
1269
1270         strlower_m(service);
1271
1272         snum = find_service(service);
1273
1274         if (snum < 0) {
1275                 if (strequal(service,"IPC$") ||
1276                     (lp_enable_asu_support() && strequal(service,"ADMIN$"))) {
1277                         DEBUG(3,("refusing IPC connection to %s\n", service));
1278                         *status = NT_STATUS_ACCESS_DENIED;
1279                         return NULL;
1280                 }
1281
1282                 DEBUG(0,("%s (%s) couldn't find service %s\n",
1283                         get_remote_machine_name(),
1284                         client_addr(get_client_fd(),addr,sizeof(addr)),
1285                         service));
1286                 *status = NT_STATUS_BAD_NETWORK_NAME;
1287                 return NULL;
1288         }
1289
1290         /* Handle non-Dfs clients attempting connections to msdfs proxy */
1291         if (lp_host_msdfs() && (*lp_msdfs_proxy(snum) != '\0'))  {
1292                 DEBUG(3, ("refusing connection to dfs proxy share '%s' "
1293                           "(pointing to %s)\n", 
1294                         service, lp_msdfs_proxy(snum)));
1295                 *status = NT_STATUS_BAD_NETWORK_NAME;
1296                 return NULL;
1297         }
1298
1299         DEBUG(5, ("making a connection to 'normal' service %s\n", service));
1300
1301         return make_connection_snum(snum, vuser,
1302                                     password,
1303                                     dev, status);
1304 }
1305
1306 /****************************************************************************
1307  Close a cnum.
1308 ****************************************************************************/
1309
1310 void close_cnum(connection_struct *conn, uint16 vuid)
1311 {
1312         if (IS_IPC(conn)) {
1313                 pipe_close_conn(conn);
1314         } else {
1315                 file_close_conn(conn);
1316                 dptr_closecnum(conn);
1317         }
1318
1319         change_to_root_user();
1320
1321         DEBUG(IS_IPC(conn)?3:1, ("%s (%s) closed connection to service %s\n",
1322                                  get_remote_machine_name(),
1323                                  conn->client_address,
1324                                  lp_servicename(SNUM(conn))));
1325
1326         /* Call VFS disconnect hook */    
1327         SMB_VFS_DISCONNECT(conn);
1328
1329         yield_connection(conn, lp_servicename(SNUM(conn)));
1330
1331         /* make sure we leave the directory available for unmount */
1332         vfs_ChDir(conn, "/");
1333
1334         /* execute any "postexec = " line */
1335         if (*lp_postexec(SNUM(conn)) && 
1336             change_to_user(conn, vuid))  {
1337                 char *cmd = talloc_sub_advanced(talloc_tos(),
1338                                         lp_servicename(SNUM(conn)), conn->user,
1339                                         conn->connectpath, conn->gid,
1340                                         get_current_username(),
1341                                         current_user_info.domain,
1342                                         lp_postexec(SNUM(conn)));
1343                 smbrun(cmd,NULL);
1344                 TALLOC_FREE(cmd);
1345                 change_to_root_user();
1346         }
1347
1348         change_to_root_user();
1349         /* execute any "root postexec = " line */
1350         if (*lp_rootpostexec(SNUM(conn)))  {
1351                 char *cmd = talloc_sub_advanced(talloc_tos(),
1352                                         lp_servicename(SNUM(conn)), conn->user,
1353                                         conn->connectpath, conn->gid,
1354                                         get_current_username(),
1355                                         current_user_info.domain,
1356                                         lp_rootpostexec(SNUM(conn)));
1357                 smbrun(cmd,NULL);
1358                 TALLOC_FREE(cmd);
1359         }
1360
1361         conn_free(conn);
1362 }