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