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
 729         status = create_connection_server_info(
 730                 conn, snum, vuser ? vuser->server_info : NULL, password,
 731                 &conn->server_info);
 732
 733         if (!NT_STATUS_IS_OK(status)) {
 734                 DEBUG(0, ("create_connection_server_info failed: %s\n",
 735                           nt_errstr(status)));
 736                 *pstatus = status;
 737                 conn_free(conn);
 738                 return NULL;
 739         }
 740
 741         if ((lp_guest_only(snum)) || (lp_security() == SEC_SHARE)) {
 742                 conn->force_user = true;
 743         }
 744
 745         add_session_user(conn->server_info->unix_name);
 746
 747         safe_strcpy(conn->client_address,
 748                         client_addr(get_client_fd(),addr,sizeof(addr)),
 749                         sizeof(conn->client_address)-1);
 750         conn->num_files_open = 0;
 751         conn->lastused = conn->lastused_count = time(NULL);
 752         conn->used = True;
 753         conn->printer = (strncmp(dev,"LPT",3) == 0);
 754         conn->ipc = ( (strncmp(dev,"IPC",3) == 0) ||
 755                       ( lp_enable_asu_support() && strequal(dev,"ADMIN$")) );
 756         conn->dirptr = NULL;
 757
 758         /* Case options for the share. */
 759         if (lp_casesensitive(snum) == Auto) {
 760                 /* We will be setting this per packet. Set to be case
 761                  * insensitive for now. */
 762                 conn->case_sensitive = False;
 763         } else {
 764                 conn->case_sensitive = (bool)lp_casesensitive(snum);
 765         }
 766
 767         conn->case_preserve = lp_preservecase(snum);
 768         conn->short_case_preserve = lp_shortpreservecase(snum);
 769
 770         conn->encrypt_level = lp_smb_encrypt(snum);
 771
 772         conn->veto_list = NULL;
 773         conn->hide_list = NULL;
 774         conn->veto_oplock_list = NULL;
 775         conn->aio_write_behind_list = NULL;
 776         string_set(&conn->dirpath,"");
 777
 778         conn->read_only = lp_readonly(SNUM(conn));
 779         conn->admin_user = False;
 780
 781         if (*lp_force_user(snum)) {
 782
 783                 /*
 784                  * Replace conn->server_info with a completely faked up one
 785                  * from the username we are forced into :-)
 786                  */
 787
 788                 char *fuser;
 789                 struct auth_serversupplied_info *forced_serverinfo;
 790
 791                 fuser = talloc_string_sub(conn, lp_force_user(snum), "%S",
 792                                           lp_servicename(snum));
 793                 if (fuser == NULL) {
 794                         conn_free(conn);
 795                         *pstatus = NT_STATUS_NO_MEMORY;
 796                         return NULL;
 797                 }
 798
 799                 status = make_serverinfo_from_username(
 800                         conn, fuser, conn->server_info->guest,
 801                         &forced_serverinfo);
 802                 if (!NT_STATUS_IS_OK(status)) {
 803                         conn_free(conn);
 804                         *pstatus = status;
 805                         return NULL;
 806                 }
 807
 808                 TALLOC_FREE(conn->server_info);
 809                 conn->server_info = forced_serverinfo;
 810
 811                 conn->force_user = True;
 812                 DEBUG(3,("Forced user %s\n", fuser));
 813         }
 814
 815         /*
 816          * If force group is true, then override
 817          * any groupid stored for the connecting user.
 818          */
 819
 820         if (*lp_force_group(snum)) {
 821
 822                 status = find_forced_group(
 823                         conn->force_user, snum, conn->user,
 824                         &conn->server_info->ptok->user_sids[1],
 825                         &conn->server_info->gid);
 826
 827                 if (!NT_STATUS_IS_OK(status)) {
 828                         conn_free(conn);
 829                         *pstatus = status;
 830                         return NULL;
 831                 }
 832         }
 833
 834         conn->vuid = (vuser != NULL) ? vuser->vuid : UID_FIELD_INVALID;
 835
 836         conn->uid = conn->server_info->uid;
 837         conn->gid = conn->server_info->gid;
 838         string_set(&conn->user, conn->server_info->unix_name);
 839
 840         {
 841                 char *s = talloc_sub_advanced(talloc_tos(),
 842                                         lp_servicename(SNUM(conn)), conn->user,
 843                                         conn->connectpath, conn->gid,
 844                                         get_current_username(),
 845                                         current_user_info.domain,
 846                                         lp_pathname(snum));
 847                 if (!s) {
 848                         conn_free(conn);
 849                         *pstatus = NT_STATUS_NO_MEMORY;
 850                         return NULL;
 851                 }
 852
 853                 if (!set_conn_connectpath(conn,s)) {
 854                         TALLOC_FREE(s);
 855                         conn_free(conn);
 856                         *pstatus = NT_STATUS_NO_MEMORY;
 857                         return NULL;
 858                 }
 859                 DEBUG(3,("Connect path is '%s' for service [%s]\n",s,
 860                          lp_servicename(snum)));
 861                 TALLOC_FREE(s);
 862         }
 863
 864         /*
 865          * New code to check if there's a share security descripter
 866          * added from NT server manager. This is done after the
 867          * smb.conf checks are done as we need a uid and token. JRA.
 868          *
 869          */
 870
 871         {
 872                 bool can_write = False;
 873
 874                 can_write = share_access_check(conn->server_info->ptok,
 875                                                lp_servicename(snum),
 876                                                FILE_WRITE_DATA);
 877
 878                 if (!can_write) {
 879                         if (!share_access_check(conn->server_info->ptok,
 880                                                 lp_servicename(snum),
 881                                                 FILE_READ_DATA)) {
 882                                 /* No access, read or write. */
 883                                 DEBUG(0,("make_connection: connection to %s "
 884                                          "denied due to security "
 885                                          "descriptor.\n",
 886                                           lp_servicename(snum)));
 887                                 conn_free(conn);
 888                                 *pstatus = NT_STATUS_ACCESS_DENIED;
 889                                 return NULL;
 890                         } else {
 891                                 conn->read_only = True;
 892                         }
 893                 }
 894         }
 895         /* Initialise VFS function pointers */
 896
 897         if (!smbd_vfs_init(conn)) {
 898                 DEBUG(0, ("vfs_init failed for service %s\n",
 899                           lp_servicename(snum)));
 900                 conn_free(conn);
 901                 *pstatus = NT_STATUS_BAD_NETWORK_NAME;
 902                 return NULL;
 903         }
 904
 905         /*
 906          * If widelinks are disallowed we need to canonicalise the connect
 907          * path here to ensure we don't have any symlinks in the
 908          * connectpath. We will be checking all paths on this connection are
 909          * below this directory. We must do this after the VFS init as we
 910          * depend on the realpath() pointer in the vfs table. JRA.
 911          */
 912         if (!lp_widelinks(snum)) {
 913                 if (!canonicalize_connect_path(conn)) {
 914                         DEBUG(0, ("canonicalize_connect_path failed "
 915                         "for service %s, path %s\n",
 916                                 lp_servicename(snum),
 917                                 conn->connectpath));
 918                         conn_free(conn);
 919                         *pstatus = NT_STATUS_BAD_NETWORK_NAME;
 920                         return NULL;
 921                 }
 922         }
 923
 924         if ((!conn->printer) && (!conn->ipc)) {
 925                 conn->notify_ctx = notify_init(conn, server_id_self(),
 926                                                smbd_messaging_context(),
 927                                                smbd_event_context(),
 928                                                conn);
 929         }
 930
 931 /* ROOT Activities: */
 932         /*
 933          * Enforce the max connections parameter.
 934          */
 935
 936         if ((lp_max_connections(snum) > 0)
 937             && (count_current_connections(lp_servicename(SNUM(conn)), True) >=
 938                 lp_max_connections(snum))) {
 939
 940                 DEBUG(1, ("Max connections (%d) exceeded for %s\n",
 941                           lp_max_connections(snum), lp_servicename(snum)));
 942                 conn_free(conn);
 943                 *pstatus = NT_STATUS_INSUFFICIENT_RESOURCES;
 944                 return NULL;
 945         }
 946
 947         /*
 948          * Get us an entry in the connections db
 949          */
 950         if (!claim_connection(conn, lp_servicename(snum), 0)) {
 951                 DEBUG(1, ("Could not store connections entry\n"));
 952                 conn_free(conn);
 953                 *pstatus = NT_STATUS_INTERNAL_DB_ERROR;
 954                 return NULL;
 955         }
 956
 957         /* Preexecs are done here as they might make the dir we are to ChDir
 958          * to below */
 959         /* execute any "root preexec = " line */
 960         if (*lp_rootpreexec(snum)) {
 961                 char *cmd = talloc_sub_advanced(talloc_tos(),
 962                                         lp_servicename(SNUM(conn)), conn->user,
 963                                         conn->connectpath, conn->gid,
 964                                         get_current_username(),
 965                                         current_user_info.domain,
 966                                         lp_rootpreexec(snum));
 967                 DEBUG(5,("cmd=%s\n",cmd));
 968                 ret = smbrun(cmd,NULL);
 969                 TALLOC_FREE(cmd);
 970                 if (ret != 0 && lp_rootpreexec_close(snum)) {
 971                         DEBUG(1,("root preexec gave %d - failing "
 972                                  "connection\n", ret));
 973                         yield_connection(conn, lp_servicename(snum));
 974                         conn_free(conn);
 975                         *pstatus = NT_STATUS_ACCESS_DENIED;
 976                         return NULL;
 977                 }
 978         }
 979
 980 /* USER Activites: */
 981         if (!change_to_user(conn, conn->vuid)) {
 982                 /* No point continuing if they fail the basic checks */
 983                 DEBUG(0,("Can't become connected user!\n"));
 984                 yield_connection(conn, lp_servicename(snum));
 985                 conn_free(conn);
 986                 *pstatus = NT_STATUS_LOGON_FAILURE;
 987                 return NULL;
 988         }
 989
 990         /* Remember that a different vuid can connect later without these
 991          * checks... */
 992
 993         /* Preexecs are done here as they might make the dir we are to ChDir
 994          * to below */
 995
 996         /* execute any "preexec = " line */
 997         if (*lp_preexec(snum)) {
 998                 char *cmd = talloc_sub_advanced(talloc_tos(),
 999                                         lp_servicename(SNUM(conn)), conn->user,
1000                                         conn->connectpath, conn->gid,
1001                                         get_current_username(),
1002                                         current_user_info.domain,
1003                                         lp_preexec(snum));
1004                 ret = smbrun(cmd,NULL);
1005                 TALLOC_FREE(cmd);
1006                 if (ret != 0 && lp_preexec_close(snum)) {
1007                         DEBUG(1,("preexec gave %d - failing connection\n",
1008                                  ret));
1009                         *pstatus = NT_STATUS_ACCESS_DENIED;
1010                         goto err_root_exit;
1011                 }
1012         }
1013
1014 #ifdef WITH_FAKE_KASERVER
1015         if (lp_afs_share(snum)) {
1016                 afs_login(conn);
1017         }
1018 #endif
1019
1020         /* Add veto/hide lists */
1021         if (!IS_IPC(conn) && !IS_PRINT(conn)) {
1022                 set_namearray( &conn->veto_list, lp_veto_files(snum));
1023                 set_namearray( &conn->hide_list, lp_hide_files(snum));
1024                 set_namearray( &conn->veto_oplock_list, lp_veto_oplocks(snum));
1025         }
1026
1027         /* Invoke VFS make connection hook - do this before the VFS_STAT call
1028            to allow any filesystems needing user credentials to initialize
1029            themselves. */
1030
1031         if (SMB_VFS_CONNECT(conn, lp_servicename(snum), conn->user) < 0) {
1032                 DEBUG(0,("make_connection: VFS make connection failed!\n"));
1033                 *pstatus = NT_STATUS_UNSUCCESSFUL;
1034                 goto err_root_exit;
1035         }
1036
1037         /* Any error exit after here needs to call the disconnect hook. */
1038         on_err_call_dis_hook = true;
1039
1040         /* win2000 does not check the permissions on the directory
1041            during the tree connect, instead relying on permission
1042            check during individual operations. To match this behaviour
1043            I have disabled this chdir check (tridge) */
1044         /* the alternative is just to check the directory exists */
1045         if ((ret = SMB_VFS_STAT(conn, conn->connectpath, &st)) != 0 ||
1046             !S_ISDIR(st.st_mode)) {
1047                 if (ret == 0 && !S_ISDIR(st.st_mode)) {
1048                         DEBUG(0,("'%s' is not a directory, when connecting to "
1049                                  "[%s]\n", conn->connectpath,
1050                                  lp_servicename(snum)));
1051                 } else {
1052                         DEBUG(0,("'%s' does not exist or permission denied "
1053                                  "when connecting to [%s] Error was %s\n",
1054                                  conn->connectpath, lp_servicename(snum),
1055                                  strerror(errno) ));
1056                 }
1057                 *pstatus = NT_STATUS_BAD_NETWORK_NAME;
1058                 goto err_root_exit;
1059         }
1060
1061         string_set(&conn->origpath,conn->connectpath);
1062
1063 #if SOFTLINK_OPTIMISATION
1064         /* resolve any soft links early if possible */
1065         if (vfs_ChDir(conn,conn->connectpath) == 0) {
1066                 TALLOC_CTX *ctx = talloc_tos();
1067                 char *s = vfs_GetWd(ctx,s);
1068                 if (!s) {
1069                         *status = map_nt_error_from_unix(errno);
1070                         goto err_root_exit;
1071                 }
1072                 if (!set_conn_connectpath(conn,s)) {
1073                         *status = NT_STATUS_NO_MEMORY;
1074                         goto err_root_exit;
1075                 }
1076                 vfs_ChDir(conn,conn->connectpath);
1077         }
1078 #endif
1079
1080         /* Figure out the characteristics of the underlying filesystem. This
1081          * assumes that all the filesystem mounted withing a share path have
1082          * the same characteristics, which is likely but not guaranteed.
1083          */
1084
1085         conn->fs_capabilities = SMB_VFS_FS_CAPABILITIES(conn);
1086
1087         /*
1088          * Print out the 'connected as' stuff here as we need
1089          * to know the effective uid and gid we will be using
1090          * (at least initially).
1091          */
1092
1093         if( DEBUGLVL( IS_IPC(conn) ? 3 : 1 ) ) {
1094                 dbgtext( "%s (%s) ", get_remote_machine_name(),
1095                          conn->client_address );
1096                 dbgtext( "%s", srv_is_signing_active() ? "signed " : "");
1097                 dbgtext( "connect to service %s ", lp_servicename(snum) );
1098                 dbgtext( "initially as user %s ", conn->user );
1099                 dbgtext( "(uid=%d, gid=%d) ", (int)geteuid(), (int)getegid() );
1100                 dbgtext( "(pid %d)\n", (int)sys_getpid() );
1101         }
1102
1103         /* we've finished with the user stuff - go back to root */
1104         change_to_root_user();
1105         return(conn);
1106
1107   err_root_exit:
1108
1109         change_to_root_user();
1110         if (on_err_call_dis_hook) {
1111                 /* Call VFS disconnect hook */
1112                 SMB_VFS_DISCONNECT(conn);
1113         }
1114         yield_connection(conn, lp_servicename(snum));
1115         conn_free(conn);
1116         return NULL;
1117 }
1118
1119 /***************************************************************************************
1120  Simple wrapper function for make_connection() to include a call to
1121  vfs_chdir()
1122  **************************************************************************************/
1123
1124 connection_struct *make_connection_with_chdir(const char *service_in,
1125                                               DATA_BLOB password,
1126                                               const char *dev, uint16 vuid,
1127                                               NTSTATUS *status)
1128 {
1129         connection_struct *conn = NULL;
1130
1131         conn = make_connection(service_in, password, dev, vuid, status);
1132
1133         /*
1134          * make_connection() does not change the directory for us any more
1135          * so we have to do it as a separate step  --jerry
1136          */
1137
1138         if ( conn && vfs_ChDir(conn,conn->connectpath) != 0 ) {
1139                 DEBUG(0,("move_driver_to_download_area: Can't change "
1140                          "directory to %s for [print$] (%s)\n",
1141                          conn->connectpath,strerror(errno)));
1142                 yield_connection(conn, lp_servicename(SNUM(conn)));
1143                 conn_free(conn);
1144                 *status = NT_STATUS_UNSUCCESSFUL;
1145                 return NULL;
1146         }
1147
1148         return conn;
1149 }
1150
1151 /****************************************************************************
1152  Make a connection to a service.
1153  *
1154  * @param service
1155 ****************************************************************************/
1156
1157 connection_struct *make_connection(const char *service_in, DATA_BLOB password,
1158                                    const char *pdev, uint16 vuid,
1159                                    NTSTATUS *status)
1160 {
1161         uid_t euid;
1162         user_struct *vuser = NULL;
1163         fstring service;
1164         fstring dev;
1165         int snum = -1;
1166         char addr[INET6_ADDRSTRLEN];
1167
1168         fstrcpy(dev, pdev);
1169
1170         /* This must ONLY BE CALLED AS ROOT. As it exits this function as
1171          * root. */
1172         if (!non_root_mode() && (euid = geteuid()) != 0) {
1173                 DEBUG(0,("make_connection: PANIC ERROR. Called as nonroot "
1174                          "(%u)\n", (unsigned int)euid ));
1175                 smb_panic("make_connection: PANIC ERROR. Called as nonroot\n");
1176         }
1177
1178         if (conn_num_open() > 2047) {
1179                 *status = NT_STATUS_INSUFF_SERVER_RESOURCES;
1180                 return NULL;
1181         }
1182
1183         if(lp_security() != SEC_SHARE) {
1184                 vuser = get_valid_user_struct(vuid);
1185                 if (!vuser) {
1186                         DEBUG(1,("make_connection: refusing to connect with "
1187                                  "no session setup\n"));
1188                         *status = NT_STATUS_ACCESS_DENIED;
1189                         return NULL;
1190                 }
1191         }
1192
1193         /* Logic to try and connect to the correct [homes] share, preferably
1194            without too many getpwnam() lookups.  This is particulary nasty for
1195            winbind usernames, where the share name isn't the same as unix
1196            username.
1197
1198            The snum of the homes share is stored on the vuser at session setup
1199            time.
1200         */
1201
1202         if (strequal(service_in,HOMES_NAME)) {
1203                 if(lp_security() != SEC_SHARE) {
1204                         DATA_BLOB no_pw = data_blob_null;
1205                         if (vuser->homes_snum == -1) {
1206                                 DEBUG(2, ("[homes] share not available for "
1207                                           "this user because it was not found "
1208                                           "or created at session setup "
1209                                           "time\n"));
1210                                 *status = NT_STATUS_BAD_NETWORK_NAME;
1211                                 return NULL;
1212                         }
1213                         DEBUG(5, ("making a connection to [homes] service "
1214                                   "created at session setup time\n"));
1215                         return make_connection_snum(vuser->homes_snum,
1216                                                     vuser, no_pw,
1217                                                     dev, status);
1218                 } else {
1219                         /* Security = share. Try with
1220                          * current_user_info.smb_name as the username.  */
1221                         if (*current_user_info.smb_name) {
1222                                 fstring unix_username;
1223                                 fstrcpy(unix_username,
1224                                         current_user_info.smb_name);
1225                                 map_username(unix_username);
1226                                 snum = find_service(unix_username);
1227                         }
1228                         if (snum != -1) {
1229                                 DEBUG(5, ("making a connection to 'homes' "
1230                                           "service %s based on "
1231                                           "security=share\n", service_in));
1232                                 return make_connection_snum(snum, NULL,
1233                                                             password,
1234                                                             dev, status);
1235                         }
1236                 }
1237         } else if ((lp_security() != SEC_SHARE) && (vuser->homes_snum != -1)
1238                    && strequal(service_in,
1239                                lp_servicename(vuser->homes_snum))) {
1240                 DATA_BLOB no_pw = data_blob_null;
1241                 DEBUG(5, ("making a connection to 'homes' service [%s] "
1242                           "created at session setup time\n", service_in));
1243                 return make_connection_snum(vuser->homes_snum,
1244                                             vuser, no_pw,
1245                                             dev, status);
1246         }
1247
1248         fstrcpy(service, service_in);
1249
1250         strlower_m(service);
1251
1252         snum = find_service(service);
1253
1254         if (snum < 0) {
1255                 if (strequal(service,"IPC$") ||
1256                     (lp_enable_asu_support() && strequal(service,"ADMIN$"))) {
1257                         DEBUG(3,("refusing IPC connection to %s\n", service));
1258                         *status = NT_STATUS_ACCESS_DENIED;
1259                         return NULL;
1260                 }
1261
1262                 DEBUG(0,("%s (%s) couldn't find service %s\n",
1263                         get_remote_machine_name(),
1264                         client_addr(get_client_fd(),addr,sizeof(addr)),
1265                         service));
1266                 *status = NT_STATUS_BAD_NETWORK_NAME;
1267                 return NULL;
1268         }
1269
1270         /* Handle non-Dfs clients attempting connections to msdfs proxy */
1271         if (lp_host_msdfs() && (*lp_msdfs_proxy(snum) != '\0'))  {
1272                 DEBUG(3, ("refusing connection to dfs proxy share '%s' "
1273                           "(pointing to %s)\n",
1274                         service, lp_msdfs_proxy(snum)));
1275                 *status = NT_STATUS_BAD_NETWORK_NAME;
1276                 return NULL;
1277         }
1278
1279         DEBUG(5, ("making a connection to 'normal' service %s\n", service));
1280
1281         return make_connection_snum(snum, vuser,
1282                                     password,
1283                                     dev, status);
1284 }
1285
1286 /****************************************************************************
1287  Close a cnum.
1288 ****************************************************************************/
1289
1290 void close_cnum(connection_struct *conn, uint16 vuid)
1291 {
1292         if (IS_IPC(conn)) {
1293                 pipe_close_conn(conn);
1294         } else {
1295                 file_close_conn(conn);
1296                 dptr_closecnum(conn);
1297         }
1298
1299         change_to_root_user();
1300
1301         DEBUG(IS_IPC(conn)?3:1, ("%s (%s) closed connection to service %s\n",
1302                                  get_remote_machine_name(),
1303                                  conn->client_address,
1304                                  lp_servicename(SNUM(conn))));
1305
1306         /* Call VFS disconnect hook */
1307         SMB_VFS_DISCONNECT(conn);
1308
1309         yield_connection(conn, lp_servicename(SNUM(conn)));
1310
1311         /* make sure we leave the directory available for unmount */
1312         vfs_ChDir(conn, "/");
1313
1314         /* execute any "postexec = " line */
1315         if (*lp_postexec(SNUM(conn)) &&
1316             change_to_user(conn, vuid))  {
1317                 char *cmd = talloc_sub_advanced(talloc_tos(),
1318                                         lp_servicename(SNUM(conn)), conn->user,
1319                                         conn->connectpath, conn->gid,
1320                                         get_current_username(),
1321                                         current_user_info.domain,
1322                                         lp_postexec(SNUM(conn)));
1323                 smbrun(cmd,NULL);
1324                 TALLOC_FREE(cmd);
1325                 change_to_root_user();
1326         }
1327
1328         change_to_root_user();
1329         /* execute any "root postexec = " line */
1330         if (*lp_rootpostexec(SNUM(conn)))  {
1331                 char *cmd = talloc_sub_advanced(talloc_tos(),
1332                                         lp_servicename(SNUM(conn)), conn->user,
1333                                         conn->connectpath, conn->gid,
1334                                         get_current_username(),
1335                                         current_user_info.domain,
1336                                         lp_rootpostexec(SNUM(conn)));
1337                 smbrun(cmd,NULL);
1338                 TALLOC_FREE(cmd);
1339         }
1340
1341         conn_free(conn);
1342 }