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