source/smbd/reply.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3    Main SMB reply routines
   4    Copyright (C) Andrew Tridgell 1992-1998
   5    Copyright (C) Andrew Bartlett      2001
   6    Copyright (C) Jeremy Allison 1992-2007.
   7
   8    This program is free software; you can redistribute it and/or modify
   9    it under the terms of the GNU General Public License as published by
  10    the Free Software Foundation; either version 2 of the License, or
  11    (at your option) any later version.
  12
  13    This program is distributed in the hope that it will be useful,
  14    but WITHOUT ANY WARRANTY; without even the implied warranty of
  15    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16    GNU General Public License for more details.
  17
  18    You should have received a copy of the GNU General Public License
  19    along with this program; if not, write to the Free Software
  20    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  21 */
  22 /*
  23    This file handles most of the reply_ calls that the server
  24    makes to handle specific protocols
  25 */
  26
  27 #include "includes.h"
  28
  29 /* look in server.c for some explanation of these variables */
  30 extern enum protocol_types Protocol;
  31 extern int max_send;
  32 extern int max_recv;
  33 unsigned int smb_echo_count = 0;
  34 extern uint32 global_client_caps;
  35
  36 extern struct current_user current_user;
  37 extern BOOL global_encrypted_passwords_negotiated;
  38
  39 /****************************************************************************
  40  Ensure we check the path in *exactly* the same way as W2K for a findfirst/findnext
  41  path or anything including wildcards.
  42  We're assuming here that '/' is not the second byte in any multibyte char
  43  set (a safe assumption). '\\' *may* be the second byte in a multibyte char
  44  set.
  45 ****************************************************************************/
  46
  47 /* Custom version for processing POSIX paths. */
  48 #define IS_PATH_SEP(c,posix_only) ((c) == '/' || (!(posix_only) && (c) == '\\'))
  49
  50 NTSTATUS check_path_syntax_internal(pstring destname,
  51                                     const pstring srcname,
  52                                     BOOL posix_path,
  53                                     BOOL *p_last_component_contains_wcard)
  54 {
  55         char *d = destname;
  56         const char *s = srcname;
  57         NTSTATUS ret = NT_STATUS_OK;
  58         BOOL start_of_name_component = True;
  59
  60         *p_last_component_contains_wcard = False;
  61
  62         while (*s) {
  63                 if (IS_PATH_SEP(*s,posix_path)) {
  64                         /*
  65                          * Safe to assume is not the second part of a mb char
  66                          * as this is handled below.
  67                          */
  68                         /* Eat multiple '/' or '\\' */
  69                         while (IS_PATH_SEP(*s,posix_path)) {
  70                                 s++;
  71                         }
  72                         if ((d != destname) && (*s != '\0')) {
  73                                 /* We only care about non-leading or trailing '/' or '\\' */
  74                                 *d++ = '/';
  75                         }
  76
  77                         start_of_name_component = True;
  78                         /* New component. */
  79                         *p_last_component_contains_wcard = False;
  80                         continue;
  81                 }
  82
  83                 if (start_of_name_component) {
  84                         if ((s[0] == '.') && (s[1] == '.') && (IS_PATH_SEP(s[2],posix_path) || s[2] == '\0')) {
  85                                 /* Uh oh - "/../" or "\\..\\"  or "/..\0" or "\\..\0" ! */
  86
  87                                 /*
  88                                  * No mb char starts with '.' so we're safe checking the directory separator here.
  89                                  */
  90
  91                                 /* If  we just added a '/' - delete it */
  92                                 if ((d > destname) && (*(d-1) == '/')) {
  93                                         *(d-1) = '\0';
  94                                         d--;
  95                                 }
  96
  97                                 /* Are we at the start ? Can't go back further if so. */
  98                                 if (d <= destname) {
  99                                         ret = NT_STATUS_OBJECT_PATH_SYNTAX_BAD;
 100                                         break;
 101                                 }
 102                                 /* Go back one level... */
 103                                 /* We know this is safe as '/' cannot be part of a mb sequence. */
 104                                 /* NOTE - if this assumption is invalid we are not in good shape... */
 105                                 /* Decrement d first as d points to the *next* char to write into. */
 106                                 for (d--; d > destname; d--) {
 107                                         if (*d == '/')
 108                                                 break;
 109                                 }
 110                                 s += 2; /* Else go past the .. */
 111                                 /* We're still at the start of a name component, just the previous one. */
 112                                 continue;
 113
 114                         } else if ((s[0] == '.') && ((s[1] == '\0') || IS_PATH_SEP(s[1],posix_path))) {
 115                                 if (posix_path) {
 116                                         /* Eat the '.' */
 117                                         s++;
 118                                         continue;
 119                                 }
 120                         }
 121
 122                 }
 123
 124                 if (!(*s & 0x80)) {
 125                         if (!posix_path) {
 126                                 if (*s <= 0x1f) {
 127                                         return NT_STATUS_OBJECT_NAME_INVALID;
 128                                 }
 129                                 switch (*s) {
 130                                         case '*':
 131                                         case '?':
 132                                         case '<':
 133                                         case '>':
 134                                         case '"':
 135                                                 *p_last_component_contains_wcard = True;
 136                                                 break;
 137                                         default:
 138                                                 break;
 139                                 }
 140                         }
 141                         *d++ = *s++;
 142                 } else {
 143                         size_t siz;
 144                         /* Get the size of the next MB character. */
 145                         next_codepoint(s,&siz);
 146                         switch(siz) {
 147                                 case 5:
 148                                         *d++ = *s++;
 149                                         /*fall through*/
 150                                 case 4:
 151                                         *d++ = *s++;
 152                                         /*fall through*/
 153                                 case 3:
 154                                         *d++ = *s++;
 155                                         /*fall through*/
 156                                 case 2:
 157                                         *d++ = *s++;
 158                                         /*fall through*/
 159                                 case 1:
 160                                         *d++ = *s++;
 161                                         break;
 162                                 default:
 163                                         DEBUG(0,("check_path_syntax_internal: character length assumptions invalid !\n"));
 164                                         *d = '\0';
 165                                         return NT_STATUS_INVALID_PARAMETER;
 166                         }
 167                 }
 168                 start_of_name_component = False;
 169         }
 170
 171         *d = '\0';
 172         return ret;
 173 }
 174
 175 /****************************************************************************
 176  Ensure we check the path in *exactly* the same way as W2K for regular pathnames.
 177  No wildcards allowed.
 178 ****************************************************************************/
 179
 180 NTSTATUS check_path_syntax(pstring destname, const pstring srcname)
 181 {
 182         BOOL ignore;
 183         return check_path_syntax_internal(destname, srcname, False, &ignore);
 184 }
 185
 186 /****************************************************************************
 187  Ensure we check the path in *exactly* the same way as W2K for regular pathnames.
 188  Wildcards allowed - p_contains_wcard returns true if the last component contained
 189  a wildcard.
 190 ****************************************************************************/
 191
 192 NTSTATUS check_path_syntax_wcard(pstring destname, const pstring srcname, BOOL *p_contains_wcard)
 193 {
 194         return check_path_syntax_internal(destname, srcname, False, p_contains_wcard);
 195 }
 196
 197 /****************************************************************************
 198  Check the path for a POSIX client.
 199  We're assuming here that '/' is not the second byte in any multibyte char
 200  set (a safe assumption).
 201 ****************************************************************************/
 202
 203 NTSTATUS check_path_syntax_posix(pstring destname, const pstring srcname)
 204 {
 205         BOOL ignore;
 206         return check_path_syntax_internal(destname, srcname, True, &ignore);
 207 }
 208
 209 /****************************************************************************
 210  Pull a string and check the path allowing a wilcard - provide for error return.
 211 ****************************************************************************/
 212
 213 size_t srvstr_get_path_wcard(char *inbuf, char *dest, const char *src, size_t dest_len, size_t src_len, int flags,
 214                                 NTSTATUS *err, BOOL *contains_wcard)
 215 {
 216         pstring tmppath;
 217         char *tmppath_ptr = tmppath;
 218         size_t ret;
 219 #ifdef DEVELOPER
 220         SMB_ASSERT(dest_len == sizeof(pstring));
 221 #endif
 222
 223         if (src_len == 0) {
 224                 ret = srvstr_pull_buf( inbuf, tmppath_ptr, src, dest_len, flags);
 225         } else {
 226                 ret = srvstr_pull( inbuf, tmppath_ptr, src, dest_len, src_len, flags);
 227         }
 228
 229         *contains_wcard = False;
 230
 231         if (SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES) {
 232                 /*
 233                  * For a DFS path the function parse_dfs_path()
 234                  * will do the path processing, just make a copy.
 235                  */
 236                 pstrcpy(dest, tmppath);
 237                 *err = NT_STATUS_OK;
 238                 return ret;
 239         }
 240
 241         if (lp_posix_pathnames()) {
 242                 *err = check_path_syntax_posix(dest, tmppath);
 243         } else {
 244                 *err = check_path_syntax_wcard(dest, tmppath, contains_wcard);
 245         }
 246
 247         return ret;
 248 }
 249
 250 /****************************************************************************
 251  Pull a string and check the path - provide for error return.
 252 ****************************************************************************/
 253
 254 size_t srvstr_get_path(char *inbuf, char *dest, const char *src, size_t dest_len, size_t src_len, int flags, NTSTATUS *err)
 255 {
 256         pstring tmppath;
 257         char *tmppath_ptr = tmppath;
 258         size_t ret;
 259 #ifdef DEVELOPER
 260         SMB_ASSERT(dest_len == sizeof(pstring));
 261 #endif
 262
 263         if (src_len == 0) {
 264                 ret = srvstr_pull_buf( inbuf, tmppath_ptr, src, dest_len, flags);
 265         } else {
 266                 ret = srvstr_pull( inbuf, tmppath_ptr, src, dest_len, src_len, flags);
 267         }
 268
 269         if (SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES) {
 270                 /*
 271                  * For a DFS path the function parse_dfs_path()
 272                  * will do the path processing, just make a copy.
 273                  */
 274                 pstrcpy(dest, tmppath);
 275                 *err = NT_STATUS_OK;
 276                 return ret;
 277         }
 278
 279         if (lp_posix_pathnames()) {
 280                 *err = check_path_syntax_posix(dest, tmppath);
 281         } else {
 282                 *err = check_path_syntax(dest, tmppath);
 283         }
 284
 285         return ret;
 286 }
 287
 288 /****************************************************************************
 289  Reply to a special message.
 290 ****************************************************************************/
 291
 292 int reply_special(char *inbuf,char *outbuf)
 293 {
 294         int outsize = 4;
 295         int msg_type = CVAL(inbuf,0);
 296         int msg_flags = CVAL(inbuf,1);
 297         fstring name1,name2;
 298         char name_type = 0;
 299
 300         static BOOL already_got_session = False;
 301
 302         *name1 = *name2 = 0;
 303
 304         memset(outbuf,'\0',smb_size);
 305
 306         smb_setlen(inbuf,outbuf,0);
 307
 308         switch (msg_type) {
 309         case 0x81: /* session request */
 310
 311                 if (already_got_session) {
 312                         exit_server_cleanly("multiple session request not permitted");
 313                 }
 314
 315                 SCVAL(outbuf,0,0x82);
 316                 SCVAL(outbuf,3,0);
 317                 if (name_len(inbuf+4) > 50 ||
 318                     name_len(inbuf+4 + name_len(inbuf + 4)) > 50) {
 319                         DEBUG(0,("Invalid name length in session request\n"));
 320                         return(0);
 321                 }
 322                 name_extract(inbuf,4,name1);
 323                 name_type = name_extract(inbuf,4 + name_len(inbuf + 4),name2);
 324                 DEBUG(2,("netbios connect: name1=%s name2=%s\n",
 325                          name1,name2));
 326
 327                 set_local_machine_name(name1, True);
 328                 set_remote_machine_name(name2, True);
 329
 330                 DEBUG(2,("netbios connect: local=%s remote=%s, name type = %x\n",
 331                          get_local_machine_name(), get_remote_machine_name(),
 332                          name_type));
 333
 334                 if (name_type == 'R') {
 335                         /* We are being asked for a pathworks session ---
 336                            no thanks! */
 337                         SCVAL(outbuf, 0,0x83);
 338                         break;
 339                 }
 340
 341                 /* only add the client's machine name to the list
 342                    of possibly valid usernames if we are operating
 343                    in share mode security */
 344                 if (lp_security() == SEC_SHARE) {
 345                         add_session_user(get_remote_machine_name());
 346                 }
 347
 348                 reload_services(True);
 349                 reopen_logs();
 350
 351                 already_got_session = True;
 352                 break;
 353
 354         case 0x89: /* session keepalive request
 355                       (some old clients produce this?) */
 356                 SCVAL(outbuf,0,SMBkeepalive);
 357                 SCVAL(outbuf,3,0);
 358                 break;
 359
 360         case 0x82: /* positive session response */
 361         case 0x83: /* negative session response */
 362         case 0x84: /* retarget session response */
 363                 DEBUG(0,("Unexpected session response\n"));
 364                 break;
 365
 366         case SMBkeepalive: /* session keepalive */
 367         default:
 368                 return(0);
 369         }
 370
 371         DEBUG(5,("init msg_type=0x%x msg_flags=0x%x\n",
 372                     msg_type, msg_flags));
 373
 374         return(outsize);
 375 }
 376
 377 /****************************************************************************
 378  Reply to a tcon.
 379  conn POINTER CAN BE NULL HERE !
 380 ****************************************************************************/
 381
 382 int reply_tcon(connection_struct *conn,
 383                char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
 384 {
 385         const char *service;
 386         pstring service_buf;
 387         pstring password;
 388         pstring dev;
 389         int outsize = 0;
 390         uint16 vuid = SVAL(inbuf,smb_uid);
 391         int pwlen=0;
 392         NTSTATUS nt_status;
 393         char *p;
 394         DATA_BLOB password_blob;
 395
 396         START_PROFILE(SMBtcon);
 397
 398         *service_buf = *password = *dev = 0;
 399
 400         p = smb_buf(inbuf)+1;
 401         p += srvstr_pull_buf(inbuf, service_buf, p, sizeof(service_buf), STR_TERMINATE) + 1;
 402         pwlen = srvstr_pull_buf(inbuf, password, p, sizeof(password), STR_TERMINATE) + 1;
 403         p += pwlen;
 404         p += srvstr_pull_buf(inbuf, dev, p, sizeof(dev), STR_TERMINATE) + 1;
 405
 406         p = strrchr_m(service_buf,'\\');
 407         if (p) {
 408                 service = p+1;
 409         } else {
 410                 service = service_buf;
 411         }
 412
 413         password_blob = data_blob(password, pwlen+1);
 414
 415         conn = make_connection(service,password_blob,dev,vuid,&nt_status);
 416
 417         data_blob_clear_free(&password_blob);
 418
 419         if (!conn) {
 420                 END_PROFILE(SMBtcon);
 421                 return ERROR_NT(nt_status);
 422         }
 423
 424         outsize = set_message(inbuf,outbuf,2,0,True);
 425         SSVAL(outbuf,smb_vwv0,max_recv);
 426         SSVAL(outbuf,smb_vwv1,conn->cnum);
 427         SSVAL(outbuf,smb_tid,conn->cnum);
 428
 429         DEBUG(3,("tcon service=%s cnum=%d\n",
 430                  service, conn->cnum));
 431
 432         END_PROFILE(SMBtcon);
 433         return(outsize);
 434 }
 435
 436 /****************************************************************************
 437  Reply to a tcon and X.
 438  conn POINTER CAN BE NULL HERE !
 439 ****************************************************************************/
 440
 441 int reply_tcon_and_X(connection_struct *conn, char *inbuf,char *outbuf,int length,int bufsize)
 442 {
 443         fstring service;
 444         DATA_BLOB password;
 445
 446         /* what the cleint thinks the device is */
 447         fstring client_devicetype;
 448         /* what the server tells the client the share represents */
 449         const char *server_devicetype;
 450         NTSTATUS nt_status;
 451         uint16 vuid = SVAL(inbuf,smb_uid);
 452         int passlen = SVAL(inbuf,smb_vwv3);
 453         pstring path;
 454         char *p, *q;
 455         uint16 tcon_flags = SVAL(inbuf,smb_vwv2);
 456
 457         START_PROFILE(SMBtconX);
 458
 459         *service = *client_devicetype = 0;
 460
 461         /* we might have to close an old one */
 462         if ((SVAL(inbuf,smb_vwv2) & 0x1) && conn) {
 463                 close_cnum(conn,vuid);
 464         }
 465
 466         if (passlen > MAX_PASS_LEN) {
 467                 return ERROR_DOS(ERRDOS,ERRbuftoosmall);
 468         }
 469
 470         if (global_encrypted_passwords_negotiated) {
 471                 password = data_blob(smb_buf(inbuf),passlen);
 472                 if (lp_security() == SEC_SHARE) {
 473                         /*
 474                          * Security = share always has a pad byte
 475                          * after the password.
 476                          */
 477                         p = smb_buf(inbuf) + passlen + 1;
 478                 } else {
 479                         p = smb_buf(inbuf) + passlen;
 480                 }
 481         } else {
 482                 password = data_blob(smb_buf(inbuf),passlen+1);
 483                 /* Ensure correct termination */
 484                 password.data[passlen]=0;
 485                 p = smb_buf(inbuf) + passlen + 1;
 486         }
 487
 488         p += srvstr_pull_buf(inbuf, path, p, sizeof(path), STR_TERMINATE);
 489
 490         /*
 491          * the service name can be either: \\server\share
 492          * or share directly like on the DELL PowerVault 705
 493          */
 494         if (*path=='\\') {
 495                 q = strchr_m(path+2,'\\');
 496                 if (!q) {
 497                         END_PROFILE(SMBtconX);
 498                         return(ERROR_DOS(ERRDOS,ERRnosuchshare));
 499                 }
 500                 fstrcpy(service,q+1);
 501         }
 502         else
 503                 fstrcpy(service,path);
 504
 505         p += srvstr_pull(inbuf, client_devicetype, p, sizeof(client_devicetype), 6, STR_ASCII);
 506
 507         DEBUG(4,("Client requested device type [%s] for share [%s]\n", client_devicetype, service));
 508
 509         conn = make_connection(service,password,client_devicetype,vuid,&nt_status);
 510
 511         data_blob_clear_free(&password);
 512
 513         if (!conn) {
 514                 END_PROFILE(SMBtconX);
 515                 return ERROR_NT(nt_status);
 516         }
 517
 518         if ( IS_IPC(conn) )
 519                 server_devicetype = "IPC";
 520         else if ( IS_PRINT(conn) )
 521                 server_devicetype = "LPT1:";
 522         else
 523                 server_devicetype = "A:";
 524
 525         if (Protocol < PROTOCOL_NT1) {
 526                 set_message(inbuf,outbuf,2,0,True);
 527                 p = smb_buf(outbuf);
 528                 p += srvstr_push(outbuf, p, server_devicetype, -1,
 529                                  STR_TERMINATE|STR_ASCII);
 530                 set_message_end(inbuf,outbuf,p);
 531         } else {
 532                 /* NT sets the fstype of IPC$ to the null string */
 533                 const char *fstype = IS_IPC(conn) ? "" : lp_fstype(SNUM(conn));
 534
 535                 if (tcon_flags & TCONX_FLAG_EXTENDED_RESPONSE) {
 536                         /* Return permissions. */
 537                         uint32 perm1 = 0;
 538                         uint32 perm2 = 0;
 539
 540                         set_message(inbuf,outbuf,7,0,True);
 541
 542                         if (IS_IPC(conn)) {
 543                                 perm1 = FILE_ALL_ACCESS;
 544                                 perm2 = FILE_ALL_ACCESS;
 545                         } else {
 546                                 perm1 = CAN_WRITE(conn) ?
 547                                                 SHARE_ALL_ACCESS :
 548                                                 SHARE_READ_ONLY;
 549                         }
 550
 551                         SIVAL(outbuf, smb_vwv3, perm1);
 552                         SIVAL(outbuf, smb_vwv5, perm2);
 553                 } else {
 554                         set_message(inbuf,outbuf,3,0,True);
 555                 }
 556
 557                 p = smb_buf(outbuf);
 558                 p += srvstr_push(outbuf, p, server_devicetype, -1,
 559                                  STR_TERMINATE|STR_ASCII);
 560                 p += srvstr_push(outbuf, p, fstype, -1,
 561                                  STR_TERMINATE);
 562
 563                 set_message_end(inbuf,outbuf,p);
 564
 565                 /* what does setting this bit do? It is set by NT4 and
 566                    may affect the ability to autorun mounted cdroms */
 567                 SSVAL(outbuf, smb_vwv2, SMB_SUPPORT_SEARCH_BITS|
 568                                 (lp_csc_policy(SNUM(conn)) << 2));
 569
 570                 init_dfsroot(conn, inbuf, outbuf);
 571         }
 572
 573
 574         DEBUG(3,("tconX service=%s \n",
 575                  service));
 576
 577         /* set the incoming and outgoing tid to the just created one */
 578         SSVAL(inbuf,smb_tid,conn->cnum);
 579         SSVAL(outbuf,smb_tid,conn->cnum);
 580
 581         END_PROFILE(SMBtconX);
 582         return chain_reply(inbuf,outbuf,length,bufsize);
 583 }
 584
 585 /****************************************************************************
 586  Reply to an unknown type.
 587 ****************************************************************************/
 588
 589 int reply_unknown(char *inbuf,char *outbuf)
 590 {
 591         int type;
 592         type = CVAL(inbuf,smb_com);
 593
 594         DEBUG(0,("unknown command type (%s): type=%d (0x%X)\n",
 595                  smb_fn_name(type), type, type));
 596
 597         return(ERROR_DOS(ERRSRV,ERRunknownsmb));
 598 }
 599
 600 /****************************************************************************
 601  Reply to an ioctl.
 602  conn POINTER CAN BE NULL HERE !
 603 ****************************************************************************/
 604
 605 int reply_ioctl(connection_struct *conn,
 606                 char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
 607 {
 608         uint16 device     = SVAL(inbuf,smb_vwv1);
 609         uint16 function   = SVAL(inbuf,smb_vwv2);
 610         uint32 ioctl_code = (device << 16) + function;
 611         int replysize, outsize;
 612         char *p;
 613         START_PROFILE(SMBioctl);
 614
 615         DEBUG(4, ("Received IOCTL (code 0x%x)\n", ioctl_code));
 616
 617         switch (ioctl_code) {
 618             case IOCTL_QUERY_JOB_INFO:
 619                 replysize = 32;
 620                 break;
 621             default:
 622                 END_PROFILE(SMBioctl);
 623                 return(ERROR_DOS(ERRSRV,ERRnosupport));
 624         }
 625
 626         outsize = set_message(inbuf,outbuf,8,replysize+1,True);
 627         SSVAL(outbuf,smb_vwv1,replysize); /* Total data bytes returned */
 628         SSVAL(outbuf,smb_vwv5,replysize); /* Data bytes this buffer */
 629         SSVAL(outbuf,smb_vwv6,52);        /* Offset to data */
 630         p = smb_buf(outbuf) + 1;          /* Allow for alignment */
 631
 632         switch (ioctl_code) {
 633                 case IOCTL_QUERY_JOB_INFO:
 634                 {
 635                         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
 636                         if (!fsp) {
 637                                 END_PROFILE(SMBioctl);
 638                                 return(UNIXERROR(ERRDOS,ERRbadfid));
 639                         }
 640                         SSVAL(p,0,fsp->rap_print_jobid);             /* Job number */
 641                         srvstr_push(outbuf, p+2, global_myname(), 15, STR_TERMINATE|STR_ASCII);
 642                         if (conn) {
 643                                 srvstr_push(outbuf, p+18, lp_servicename(SNUM(conn)), 13, STR_TERMINATE|STR_ASCII);
 644                         }
 645                         break;
 646                 }
 647         }
 648
 649         END_PROFILE(SMBioctl);
 650         return outsize;
 651 }
 652
 653 /****************************************************************************
 654  Strange checkpath NTSTATUS mapping.
 655 ****************************************************************************/
 656
 657 static NTSTATUS map_checkpath_error(const char *inbuf, NTSTATUS status)
 658 {
 659         /* Strange DOS error code semantics only for checkpath... */
 660         if (!(SVAL(inbuf,smb_flg2) & FLAGS2_32_BIT_ERROR_CODES)) {
 661                 if (NT_STATUS_EQUAL(NT_STATUS_OBJECT_NAME_INVALID,status)) {
 662                         /* We need to map to ERRbadpath */
 663                         return NT_STATUS_OBJECT_PATH_NOT_FOUND;
 664                 }
 665         }
 666         return status;
 667 }
 668
 669 /****************************************************************************
 670  Reply to a checkpath.
 671 ****************************************************************************/
 672
 673 int reply_checkpath(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
 674 {
 675         int outsize = 0;
 676         pstring name;
 677         SMB_STRUCT_STAT sbuf;
 678         NTSTATUS status;
 679
 680         START_PROFILE(SMBcheckpath);
 681
 682         srvstr_get_path(inbuf, name, smb_buf(inbuf) + 1, sizeof(name), 0, STR_TERMINATE, &status);
 683         if (!NT_STATUS_IS_OK(status)) {
 684                 END_PROFILE(SMBcheckpath);
 685                 status = map_checkpath_error(inbuf, status);
 686                 return ERROR_NT(status);
 687         }
 688
 689         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, name);
 690         if (!NT_STATUS_IS_OK(status)) {
 691                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
 692                         END_PROFILE(SMBcheckpath);
 693                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
 694                 }
 695                 goto path_err;
 696         }
 697
 698         DEBUG(3,("reply_checkpath %s mode=%d\n", name, (int)SVAL(inbuf,smb_vwv0)));
 699
 700         status = unix_convert(conn, name, False, NULL, &sbuf);
 701         if (!NT_STATUS_IS_OK(status)) {
 702                 goto path_err;
 703         }
 704
 705         status = check_name(conn, name);
 706         if (!NT_STATUS_IS_OK(status)) {
 707                 DEBUG(3,("reply_checkpath: check_name of %s failed (%s)\n",name,nt_errstr(status)));
 708                 goto path_err;
 709         }
 710
 711         if (!VALID_STAT(sbuf) && (SMB_VFS_STAT(conn,name,&sbuf) != 0)) {
 712                 DEBUG(3,("reply_checkpath: stat of %s failed (%s)\n",name,strerror(errno)));
 713                 status = map_nt_error_from_unix(errno);
 714                 goto path_err;
 715         }
 716
 717         if (!S_ISDIR(sbuf.st_mode)) {
 718                 END_PROFILE(SMBcheckpath);
 719                 return ERROR_BOTH(NT_STATUS_NOT_A_DIRECTORY,ERRDOS,ERRbadpath);
 720         }
 721
 722         outsize = set_message(inbuf,outbuf,0,0,False);
 723
 724         END_PROFILE(SMBcheckpath);
 725         return outsize;
 726
 727   path_err:
 728
 729         END_PROFILE(SMBcheckpath);
 730
 731         /* We special case this - as when a Windows machine
 732                 is parsing a path is steps through the components
 733                 one at a time - if a component fails it expects
 734                 ERRbadpath, not ERRbadfile.
 735         */
 736         status = map_checkpath_error(inbuf, status);
 737         if(NT_STATUS_EQUAL(status, NT_STATUS_OBJECT_NAME_NOT_FOUND)) {
 738                 /*
 739                  * Windows returns different error codes if
 740                  * the parent directory is valid but not the
 741                  * last component - it returns NT_STATUS_OBJECT_NAME_NOT_FOUND
 742                  * for that case and NT_STATUS_OBJECT_PATH_NOT_FOUND
 743                  * if the path is invalid.
 744                  */
 745                 return ERROR_BOTH(NT_STATUS_OBJECT_NAME_NOT_FOUND,ERRDOS,ERRbadpath);
 746         }
 747
 748         return ERROR_NT(status);
 749 }
 750
 751 /****************************************************************************
 752  Reply to a getatr.
 753 ****************************************************************************/
 754
 755 int reply_getatr(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
 756 {
 757         pstring fname;
 758         int outsize = 0;
 759         SMB_STRUCT_STAT sbuf;
 760         int mode=0;
 761         SMB_OFF_T size=0;
 762         time_t mtime=0;
 763         char *p;
 764         NTSTATUS status;
 765
 766         START_PROFILE(SMBgetatr);
 767
 768         p = smb_buf(inbuf) + 1;
 769         p += srvstr_get_path(inbuf, fname, p, sizeof(fname), 0, STR_TERMINATE, &status);
 770         if (!NT_STATUS_IS_OK(status)) {
 771                 END_PROFILE(SMBgetatr);
 772                 return ERROR_NT(status);
 773         }
 774
 775         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, fname);
 776         if (!NT_STATUS_IS_OK(status)) {
 777                 END_PROFILE(SMBgetatr);
 778                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
 779                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
 780                 }
 781                 return ERROR_NT(status);
 782         }
 783
 784         /* dos smetimes asks for a stat of "" - it returns a "hidden directory"
 785                 under WfWg - weird! */
 786         if (*fname == '\0') {
 787                 mode = aHIDDEN | aDIR;
 788                 if (!CAN_WRITE(conn)) {
 789                         mode |= aRONLY;
 790                 }
 791                 size = 0;
 792                 mtime = 0;
 793         } else {
 794                 status = unix_convert(conn, fname, False, NULL,&sbuf);
 795                 if (!NT_STATUS_IS_OK(status)) {
 796                         END_PROFILE(SMBgetatr);
 797                         return ERROR_NT(status);
 798                 }
 799                 status = check_name(conn, fname);
 800                 if (!NT_STATUS_IS_OK(status)) {
 801                         DEBUG(3,("reply_getatr: check_name of %s failed (%s)\n",fname,nt_errstr(status)));
 802                         END_PROFILE(SMBgetatr);
 803                         return ERROR_NT(status);
 804                 }
 805                 if (!VALID_STAT(sbuf) && (SMB_VFS_STAT(conn,fname,&sbuf) != 0)) {
 806                         DEBUG(3,("reply_getatr: stat of %s failed (%s)\n",fname,strerror(errno)));
 807                         return UNIXERROR(ERRDOS,ERRbadfile);
 808                 }
 809
 810                 mode = dos_mode(conn,fname,&sbuf);
 811                 size = sbuf.st_size;
 812                 mtime = sbuf.st_mtime;
 813                 if (mode & aDIR) {
 814                         size = 0;
 815                 }
 816         }
 817
 818         outsize = set_message(inbuf,outbuf,10,0,True);
 819
 820         SSVAL(outbuf,smb_vwv0,mode);
 821         if(lp_dos_filetime_resolution(SNUM(conn)) ) {
 822                 srv_put_dos_date3(outbuf,smb_vwv1,mtime & ~1);
 823         } else {
 824                 srv_put_dos_date3(outbuf,smb_vwv1,mtime);
 825         }
 826         SIVAL(outbuf,smb_vwv3,(uint32)size);
 827
 828         if (Protocol >= PROTOCOL_NT1) {
 829                 SSVAL(outbuf,smb_flg2,SVAL(outbuf, smb_flg2) | FLAGS2_IS_LONG_NAME);
 830         }
 831
 832         DEBUG(3,("reply_getatr: name=%s mode=%d size=%u\n", fname, mode, (unsigned int)size ) );
 833
 834         END_PROFILE(SMBgetatr);
 835         return(outsize);
 836 }
 837
 838 /****************************************************************************
 839  Reply to a setatr.
 840 ****************************************************************************/
 841
 842 int reply_setatr(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
 843 {
 844         pstring fname;
 845         int outsize = 0;
 846         int mode;
 847         time_t mtime;
 848         SMB_STRUCT_STAT sbuf;
 849         char *p;
 850         NTSTATUS status;
 851
 852         START_PROFILE(SMBsetatr);
 853
 854         p = smb_buf(inbuf) + 1;
 855         p += srvstr_get_path(inbuf, fname, p, sizeof(fname), 0, STR_TERMINATE, &status);
 856         if (!NT_STATUS_IS_OK(status)) {
 857                 END_PROFILE(SMBsetatr);
 858                 return ERROR_NT(status);
 859         }
 860
 861         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, fname);
 862         if (!NT_STATUS_IS_OK(status)) {
 863                 END_PROFILE(SMBsetatr);
 864                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
 865                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
 866                 }
 867                 return ERROR_NT(status);
 868         }
 869
 870         status = unix_convert(conn, fname, False, NULL, &sbuf);
 871         if (!NT_STATUS_IS_OK(status)) {
 872                 END_PROFILE(SMBsetatr);
 873                 return ERROR_NT(status);
 874         }
 875
 876         status = check_name(conn, fname);
 877         if (!NT_STATUS_IS_OK(status)) {
 878                 END_PROFILE(SMBsetatr);
 879                 return ERROR_NT(status);
 880         }
 881
 882         if (fname[0] == '.' && fname[1] == '\0') {
 883                 /*
 884                  * Not sure here is the right place to catch this
 885                  * condition. Might be moved to somewhere else later -- vl
 886                  */
 887                 END_PROFILE(SMBsetatr);
 888                 return ERROR_NT(NT_STATUS_ACCESS_DENIED);
 889         }
 890
 891         mode = SVAL(inbuf,smb_vwv0);
 892         mtime = srv_make_unix_date3(inbuf+smb_vwv1);
 893
 894         if (mode != FILE_ATTRIBUTE_NORMAL) {
 895                 if (VALID_STAT_OF_DIR(sbuf))
 896                         mode |= aDIR;
 897                 else
 898                         mode &= ~aDIR;
 899
 900                 if (file_set_dosmode(conn,fname,mode,&sbuf,False) != 0) {
 901                         END_PROFILE(SMBsetatr);
 902                         return UNIXERROR(ERRDOS, ERRnoaccess);
 903                 }
 904         }
 905
 906         if (!set_filetime(conn,fname,convert_time_t_to_timespec(mtime))) {
 907                 END_PROFILE(SMBsetatr);
 908                 return UNIXERROR(ERRDOS, ERRnoaccess);
 909         }
 910
 911         outsize = set_message(inbuf,outbuf,0,0,False);
 912
 913         DEBUG( 3, ( "setatr name=%s mode=%d\n", fname, mode ) );
 914
 915         END_PROFILE(SMBsetatr);
 916         return(outsize);
 917 }
 918
 919 /****************************************************************************
 920  Reply to a dskattr.
 921 ****************************************************************************/
 922
 923 int reply_dskattr(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
 924 {
 925         int outsize = 0;
 926         SMB_BIG_UINT dfree,dsize,bsize;
 927         START_PROFILE(SMBdskattr);
 928
 929         if (get_dfree_info(conn,".",True,&bsize,&dfree,&dsize) == (SMB_BIG_UINT)-1) {
 930                 END_PROFILE(SMBdskattr);
 931                 return(UNIXERROR(ERRHRD,ERRgeneral));
 932         }
 933
 934         outsize = set_message(inbuf,outbuf,5,0,True);
 935
 936         if (Protocol <= PROTOCOL_LANMAN2) {
 937                 double total_space, free_space;
 938                 /* we need to scale this to a number that DOS6 can handle. We
 939                    use floating point so we can handle large drives on systems
 940                    that don't have 64 bit integers
 941
 942                    we end up displaying a maximum of 2G to DOS systems
 943                 */
 944                 total_space = dsize * (double)bsize;
 945                 free_space = dfree * (double)bsize;
 946
 947                 dsize = (total_space+63*512) / (64*512);
 948                 dfree = (free_space+63*512) / (64*512);
 949
 950                 if (dsize > 0xFFFF) dsize = 0xFFFF;
 951                 if (dfree > 0xFFFF) dfree = 0xFFFF;
 952
 953                 SSVAL(outbuf,smb_vwv0,dsize);
 954                 SSVAL(outbuf,smb_vwv1,64); /* this must be 64 for dos systems */
 955                 SSVAL(outbuf,smb_vwv2,512); /* and this must be 512 */
 956                 SSVAL(outbuf,smb_vwv3,dfree);
 957         } else {
 958                 SSVAL(outbuf,smb_vwv0,dsize);
 959                 SSVAL(outbuf,smb_vwv1,bsize/512);
 960                 SSVAL(outbuf,smb_vwv2,512);
 961                 SSVAL(outbuf,smb_vwv3,dfree);
 962         }
 963
 964         DEBUG(3,("dskattr dfree=%d\n", (unsigned int)dfree));
 965
 966         END_PROFILE(SMBdskattr);
 967         return(outsize);
 968 }
 969
 970 /****************************************************************************
 971  Reply to a search.
 972  Can be called from SMBsearch, SMBffirst or SMBfunique.
 973 ****************************************************************************/
 974
 975 int reply_search(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
 976 {
 977         pstring mask;
 978         pstring directory;
 979         pstring fname;
 980         SMB_OFF_T size;
 981         uint32 mode;
 982         time_t date;
 983         uint32 dirtype;
 984         int outsize = 0;
 985         unsigned int numentries = 0;
 986         unsigned int maxentries = 0;
 987         BOOL finished = False;
 988         char *p;
 989         int status_len;
 990         pstring path;
 991         char status[21];
 992         int dptr_num= -1;
 993         BOOL check_descend = False;
 994         BOOL expect_close = False;
 995         NTSTATUS nt_status;
 996         BOOL mask_contains_wcard = False;
 997         BOOL allow_long_path_components = (SVAL(inbuf,smb_flg2) & FLAGS2_LONG_PATH_COMPONENTS) ? True : False;
 998
 999         START_PROFILE(SMBsearch);
1000
1001         if (lp_posix_pathnames()) {
1002                 END_PROFILE(SMBsearch);
1003                 return reply_unknown(inbuf, outbuf);
1004         }
1005
1006         *mask = *directory = *fname = 0;
1007
1008         /* If we were called as SMBffirst then we must expect close. */
1009         if(CVAL(inbuf,smb_com) == SMBffirst) {
1010                 expect_close = True;
1011         }
1012
1013         outsize = set_message(inbuf,outbuf,1,3,True);
1014         maxentries = SVAL(inbuf,smb_vwv0);
1015         dirtype = SVAL(inbuf,smb_vwv1);
1016         p = smb_buf(inbuf) + 1;
1017         p += srvstr_get_path_wcard(inbuf, path, p, sizeof(path), 0, STR_TERMINATE, &nt_status, &mask_contains_wcard);
1018         if (!NT_STATUS_IS_OK(nt_status)) {
1019                 END_PROFILE(SMBsearch);
1020                 return ERROR_NT(nt_status);
1021         }
1022
1023         nt_status = resolve_dfspath_wcard(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, path, &mask_contains_wcard);
1024         if (!NT_STATUS_IS_OK(nt_status)) {
1025                 END_PROFILE(SMBsearch);
1026                 if (NT_STATUS_EQUAL(nt_status,NT_STATUS_PATH_NOT_COVERED)) {
1027                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
1028                 }
1029                 return ERROR_NT(nt_status);
1030         }
1031
1032         p++;
1033         status_len = SVAL(p, 0);
1034         p += 2;
1035
1036         /* dirtype &= ~aDIR; */
1037
1038         if (status_len == 0) {
1039                 SMB_STRUCT_STAT sbuf;
1040
1041                 pstrcpy(directory,path);
1042                 nt_status = unix_convert(conn, directory, True, NULL, &sbuf);
1043                 if (!NT_STATUS_IS_OK(nt_status)) {
1044                         END_PROFILE(SMBsearch);
1045                         return ERROR_NT(nt_status);
1046                 }
1047
1048                 nt_status = check_name(conn, directory);
1049                 if (!NT_STATUS_IS_OK(nt_status)) {
1050                         END_PROFILE(SMBsearch);
1051                         return ERROR_NT(nt_status);
1052                 }
1053
1054                 p = strrchr_m(directory,'/');
1055                 if (!p) {
1056                         pstrcpy(mask,directory);
1057                         pstrcpy(directory,".");
1058                 } else {
1059                         *p = 0;
1060                         pstrcpy(mask,p+1);
1061                 }
1062
1063                 if (*directory == '\0') {
1064                         pstrcpy(directory,".");
1065                 }
1066                 memset((char *)status,'\0',21);
1067                 SCVAL(status,0,(dirtype & 0x1F));
1068         } else {
1069                 int status_dirtype;
1070
1071                 memcpy(status,p,21);
1072                 status_dirtype = CVAL(status,0) & 0x1F;
1073                 if (status_dirtype != (dirtype & 0x1F)) {
1074                         dirtype = status_dirtype;
1075                 }
1076
1077                 conn->dirptr = dptr_fetch(status+12,&dptr_num);
1078                 if (!conn->dirptr) {
1079                         goto SearchEmpty;
1080                 }
1081                 string_set(&conn->dirpath,dptr_path(dptr_num));
1082                 pstrcpy(mask, dptr_wcard(dptr_num));
1083                 /*
1084                  * For a 'continue' search we have no string. So
1085                  * check from the initial saved string.
1086                  */
1087                 mask_contains_wcard = ms_has_wild(mask);
1088         }
1089
1090         p = smb_buf(outbuf) + 3;
1091
1092         if (status_len == 0) {
1093                 nt_status = dptr_create(conn,
1094                                         directory,
1095                                         True,
1096                                         expect_close,
1097                                         SVAL(inbuf,smb_pid),
1098                                         mask,
1099                                         mask_contains_wcard,
1100                                         dirtype,
1101                                         &conn->dirptr);
1102                 if (!NT_STATUS_IS_OK(nt_status)) {
1103                         return ERROR_NT(nt_status);
1104                 }
1105                 dptr_num = dptr_dnum(conn->dirptr);
1106         } else {
1107                 dirtype = dptr_attr(dptr_num);
1108         }
1109
1110         DEBUG(4,("dptr_num is %d\n",dptr_num));
1111
1112         if ((dirtype&0x1F) == aVOLID) {
1113                 memcpy(p,status,21);
1114                 make_dir_struct(p,"???????????",volume_label(SNUM(conn)),
1115                                 0,aVOLID,0,!allow_long_path_components);
1116                 dptr_fill(p+12,dptr_num);
1117                 if (dptr_zero(p+12) && (status_len==0)) {
1118                         numentries = 1;
1119                 } else {
1120                         numentries = 0;
1121                 }
1122                 p += DIR_STRUCT_SIZE;
1123         } else {
1124                 unsigned int i;
1125                 maxentries = MIN(maxentries, ((BUFFER_SIZE - (p - outbuf))/DIR_STRUCT_SIZE));
1126
1127                 DEBUG(8,("dirpath=<%s> dontdescend=<%s>\n",
1128                         conn->dirpath,lp_dontdescend(SNUM(conn))));
1129                 if (in_list(conn->dirpath, lp_dontdescend(SNUM(conn)),True)) {
1130                         check_descend = True;
1131                 }
1132
1133                 for (i=numentries;(i<maxentries) && !finished;i++) {
1134                         finished = !get_dir_entry(conn,mask,dirtype,fname,&size,&mode,&date,check_descend);
1135                         if (!finished) {
1136                                 memcpy(p,status,21);
1137                                 make_dir_struct(p,mask,fname,size, mode,date,
1138                                                 !allow_long_path_components);
1139                                 if (!dptr_fill(p+12,dptr_num)) {
1140                                         break;
1141                                 }
1142                                 numentries++;
1143                                 p += DIR_STRUCT_SIZE;
1144                         }
1145                 }
1146         }
1147
1148   SearchEmpty:
1149
1150         /* If we were called as SMBffirst with smb_search_id == NULL
1151                 and no entries were found then return error and close dirptr
1152                 (X/Open spec) */
1153
1154         if (numentries == 0) {
1155                 dptr_close(&dptr_num);
1156         } else if(expect_close && status_len == 0) {
1157                 /* Close the dptr - we know it's gone */
1158                 dptr_close(&dptr_num);
1159         }
1160
1161         /* If we were called as SMBfunique, then we can close the dirptr now ! */
1162         if(dptr_num >= 0 && CVAL(inbuf,smb_com) == SMBfunique) {
1163                 dptr_close(&dptr_num);
1164         }
1165
1166         if ((numentries == 0) && !mask_contains_wcard) {
1167                 return ERROR_BOTH(STATUS_NO_MORE_FILES,ERRDOS,ERRnofiles);
1168         }
1169
1170         SSVAL(outbuf,smb_vwv0,numentries);
1171         SSVAL(outbuf,smb_vwv1,3 + numentries * DIR_STRUCT_SIZE);
1172         SCVAL(smb_buf(outbuf),0,5);
1173         SSVAL(smb_buf(outbuf),1,numentries*DIR_STRUCT_SIZE);
1174
1175         /* The replies here are never long name. */
1176         SSVAL(outbuf,smb_flg2,SVAL(outbuf, smb_flg2) & (~FLAGS2_IS_LONG_NAME));
1177         if (!allow_long_path_components) {
1178                 SSVAL(outbuf,smb_flg2,SVAL(outbuf, smb_flg2) & (~FLAGS2_LONG_PATH_COMPONENTS));
1179         }
1180
1181         /* This SMB *always* returns ASCII names. Remove the unicode bit in flags2. */
1182         SSVAL(outbuf,smb_flg2, (SVAL(outbuf, smb_flg2) & (~FLAGS2_UNICODE_STRINGS)));
1183
1184         outsize += DIR_STRUCT_SIZE*numentries;
1185         smb_setlen(inbuf,outbuf,outsize - 4);
1186
1187         if ((! *directory) && dptr_path(dptr_num))
1188                 slprintf(directory, sizeof(directory)-1, "(%s)",dptr_path(dptr_num));
1189
1190         DEBUG( 4, ( "%s mask=%s path=%s dtype=%d nument=%u of %u\n",
1191                 smb_fn_name(CVAL(inbuf,smb_com)),
1192                 mask, directory, dirtype, numentries, maxentries ) );
1193
1194         END_PROFILE(SMBsearch);
1195         return(outsize);
1196 }
1197
1198 /****************************************************************************
1199  Reply to a fclose (stop directory search).
1200 ****************************************************************************/
1201
1202 int reply_fclose(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
1203 {
1204         int outsize = 0;
1205         int status_len;
1206         pstring path;
1207         char status[21];
1208         int dptr_num= -2;
1209         char *p;
1210         NTSTATUS err;
1211         BOOL path_contains_wcard = False;
1212
1213         START_PROFILE(SMBfclose);
1214
1215         if (lp_posix_pathnames()) {
1216                 END_PROFILE(SMBfclose);
1217                 return reply_unknown(inbuf, outbuf);
1218         }
1219
1220         outsize = set_message(inbuf,outbuf,1,0,True);
1221         p = smb_buf(inbuf) + 1;
1222         p += srvstr_get_path_wcard(inbuf, path, p, sizeof(path), 0, STR_TERMINATE, &err, &path_contains_wcard);
1223         if (!NT_STATUS_IS_OK(err)) {
1224                 END_PROFILE(SMBfclose);
1225                 return ERROR_NT(err);
1226         }
1227         p++;
1228         status_len = SVAL(p,0);
1229         p += 2;
1230
1231         if (status_len == 0) {
1232                 END_PROFILE(SMBfclose);
1233                 return ERROR_DOS(ERRSRV,ERRsrverror);
1234         }
1235
1236         memcpy(status,p,21);
1237
1238         if(dptr_fetch(status+12,&dptr_num)) {
1239                 /*  Close the dptr - we know it's gone */
1240                 dptr_close(&dptr_num);
1241         }
1242
1243         SSVAL(outbuf,smb_vwv0,0);
1244
1245         DEBUG(3,("search close\n"));
1246
1247         END_PROFILE(SMBfclose);
1248         return(outsize);
1249 }
1250
1251 /****************************************************************************
1252  Reply to an open.
1253 ****************************************************************************/
1254
1255 int reply_open(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
1256 {
1257         pstring fname;
1258         int outsize = 0;
1259         uint32 fattr=0;
1260         SMB_OFF_T size = 0;
1261         time_t mtime=0;
1262         int info;
1263         SMB_STRUCT_STAT sbuf;
1264         files_struct *fsp;
1265         int oplock_request = CORE_OPLOCK_REQUEST(inbuf);
1266         int deny_mode;
1267         uint32 dos_attr = SVAL(inbuf,smb_vwv1);
1268         uint32 access_mask;
1269         uint32 share_mode;
1270         uint32 create_disposition;
1271         uint32 create_options = 0;
1272         NTSTATUS status;
1273         START_PROFILE(SMBopen);
1274
1275         deny_mode = SVAL(inbuf,smb_vwv0);
1276
1277         srvstr_get_path(inbuf, fname, smb_buf(inbuf)+1, sizeof(fname), 0, STR_TERMINATE, &status);
1278         if (!NT_STATUS_IS_OK(status)) {
1279                 END_PROFILE(SMBopen);
1280                 return ERROR_NT(status);
1281         }
1282
1283         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, fname);
1284         if (!NT_STATUS_IS_OK(status)) {
1285                 END_PROFILE(SMBopen);
1286                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
1287                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
1288                 }
1289                 return ERROR_NT(status);
1290         }
1291
1292         status = unix_convert(conn, fname, False, NULL, &sbuf);
1293         if (!NT_STATUS_IS_OK(status)) {
1294                 END_PROFILE(SMBopen);
1295                 return ERROR_NT(status);
1296         }
1297
1298         status = check_name(conn, fname);
1299         if (!NT_STATUS_IS_OK(status)) {
1300                 END_PROFILE(SMBopen);
1301                 return ERROR_NT(status);
1302         }
1303
1304         if (!map_open_params_to_ntcreate(fname, deny_mode, OPENX_FILE_EXISTS_OPEN,
1305                         &access_mask, &share_mode, &create_disposition, &create_options)) {
1306                 END_PROFILE(SMBopen);
1307                 return ERROR_NT(NT_STATUS_DOS(ERRDOS, ERRbadaccess));
1308         }
1309
1310         status = open_file_ntcreate(conn,fname,&sbuf,
1311                         access_mask,
1312                         share_mode,
1313                         create_disposition,
1314                         create_options,
1315                         dos_attr,
1316                         oplock_request,
1317                         &info, &fsp);
1318
1319         if (!NT_STATUS_IS_OK(status)) {
1320                 END_PROFILE(SMBopen);
1321                 if (open_was_deferred(SVAL(inbuf,smb_mid))) {
1322                         /* We have re-scheduled this call. */
1323                         return -1;
1324                 }
1325                 return ERROR_NT(status);
1326         }
1327
1328         size = sbuf.st_size;
1329         fattr = dos_mode(conn,fname,&sbuf);
1330         mtime = sbuf.st_mtime;
1331
1332         if (fattr & aDIR) {
1333                 DEBUG(3,("attempt to open a directory %s\n",fname));
1334                 close_file(fsp,ERROR_CLOSE);
1335                 END_PROFILE(SMBopen);
1336                 return ERROR_DOS(ERRDOS,ERRnoaccess);
1337         }
1338
1339         outsize = set_message(inbuf,outbuf,7,0,True);
1340         SSVAL(outbuf,smb_vwv0,fsp->fnum);
1341         SSVAL(outbuf,smb_vwv1,fattr);
1342         if(lp_dos_filetime_resolution(SNUM(conn)) ) {
1343                 srv_put_dos_date3(outbuf,smb_vwv2,mtime & ~1);
1344         } else {
1345                 srv_put_dos_date3(outbuf,smb_vwv2,mtime);
1346         }
1347         SIVAL(outbuf,smb_vwv4,(uint32)size);
1348         SSVAL(outbuf,smb_vwv6,deny_mode);
1349
1350         if (oplock_request && lp_fake_oplocks(SNUM(conn))) {
1351                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1352         }
1353
1354         if(EXCLUSIVE_OPLOCK_TYPE(fsp->oplock_type)) {
1355                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1356         }
1357         END_PROFILE(SMBopen);
1358         return(outsize);
1359 }
1360
1361 /****************************************************************************
1362  Reply to an open and X.
1363 ****************************************************************************/
1364
1365 int reply_open_and_X(connection_struct *conn, char *inbuf,char *outbuf,int length,int bufsize)
1366 {
1367         pstring fname;
1368         uint16 open_flags = SVAL(inbuf,smb_vwv2);
1369         int deny_mode = SVAL(inbuf,smb_vwv3);
1370         uint32 smb_attr = SVAL(inbuf,smb_vwv5);
1371         /* Breakout the oplock request bits so we can set the
1372                 reply bits separately. */
1373         int ex_oplock_request = EXTENDED_OPLOCK_REQUEST(inbuf);
1374         int core_oplock_request = CORE_OPLOCK_REQUEST(inbuf);
1375         int oplock_request = ex_oplock_request | core_oplock_request;
1376 #if 0
1377         int smb_sattr = SVAL(inbuf,smb_vwv4);
1378         uint32 smb_time = make_unix_date3(inbuf+smb_vwv6);
1379 #endif
1380         int smb_ofun = SVAL(inbuf,smb_vwv8);
1381         uint32 fattr=0;
1382         int mtime=0;
1383         SMB_STRUCT_STAT sbuf;
1384         int smb_action = 0;
1385         files_struct *fsp;
1386         NTSTATUS status;
1387         SMB_BIG_UINT allocation_size = (SMB_BIG_UINT)IVAL(inbuf,smb_vwv9);
1388         ssize_t retval = -1;
1389         uint32 access_mask;
1390         uint32 share_mode;
1391         uint32 create_disposition;
1392         uint32 create_options = 0;
1393
1394         START_PROFILE(SMBopenX);
1395
1396         /* If it's an IPC, pass off the pipe handler. */
1397         if (IS_IPC(conn)) {
1398                 if (lp_nt_pipe_support()) {
1399                         END_PROFILE(SMBopenX);
1400                         return reply_open_pipe_and_X(conn, inbuf,outbuf,length,bufsize);
1401                 } else {
1402                         END_PROFILE(SMBopenX);
1403                         return ERROR_DOS(ERRSRV,ERRaccess);
1404                 }
1405         }
1406
1407         /* XXXX we need to handle passed times, sattr and flags */
1408         srvstr_get_path(inbuf, fname, smb_buf(inbuf), sizeof(fname), 0, STR_TERMINATE, &status);
1409         if (!NT_STATUS_IS_OK(status)) {
1410                 END_PROFILE(SMBopenX);
1411                 return ERROR_NT(status);
1412         }
1413
1414         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, fname);
1415         if (!NT_STATUS_IS_OK(status)) {
1416                 END_PROFILE(SMBopenX);
1417                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
1418                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
1419                 }
1420                 return ERROR_NT(status);
1421         }
1422
1423         status = unix_convert(conn, fname, False, NULL, &sbuf);
1424         if (!NT_STATUS_IS_OK(status)) {
1425                 END_PROFILE(SMBopenX);
1426                 return ERROR_NT(status);
1427         }
1428
1429         status = check_name(conn, fname);
1430         if (!NT_STATUS_IS_OK(status)) {
1431                 END_PROFILE(SMBopenX);
1432                 return ERROR_NT(status);
1433         }
1434
1435         if (!map_open_params_to_ntcreate(fname, deny_mode, smb_ofun,
1436                                 &access_mask,
1437                                 &share_mode,
1438                                 &create_disposition,
1439                                 &create_options)) {
1440                 END_PROFILE(SMBopenX);
1441                 return ERROR_NT(NT_STATUS_DOS(ERRDOS, ERRbadaccess));
1442         }
1443
1444         status = open_file_ntcreate(conn,fname,&sbuf,
1445                         access_mask,
1446                         share_mode,
1447                         create_disposition,
1448                         create_options,
1449                         smb_attr,
1450                         oplock_request,
1451                         &smb_action, &fsp);
1452
1453         if (!NT_STATUS_IS_OK(status)) {
1454                 END_PROFILE(SMBopenX);
1455                 if (open_was_deferred(SVAL(inbuf,smb_mid))) {
1456                         /* We have re-scheduled this call. */
1457                         return -1;
1458                 }
1459                 return ERROR_NT(status);
1460         }
1461
1462         /* Setting the "size" field in vwv9 and vwv10 causes the file to be set to this size,
1463            if the file is truncated or created. */
1464         if (((smb_action == FILE_WAS_CREATED) || (smb_action == FILE_WAS_OVERWRITTEN)) && allocation_size) {
1465                 fsp->initial_allocation_size = smb_roundup(fsp->conn, allocation_size);
1466                 if (vfs_allocate_file_space(fsp, fsp->initial_allocation_size) == -1) {
1467                         close_file(fsp,ERROR_CLOSE);
1468                         END_PROFILE(SMBopenX);
1469                         return ERROR_NT(NT_STATUS_DISK_FULL);
1470                 }
1471                 retval = vfs_set_filelen(fsp, (SMB_OFF_T)allocation_size);
1472                 if (retval < 0) {
1473                         close_file(fsp,ERROR_CLOSE);
1474                         END_PROFILE(SMBopenX);
1475                         return ERROR_NT(NT_STATUS_DISK_FULL);
1476                 }
1477                 sbuf.st_size = get_allocation_size(conn,fsp,&sbuf);
1478         }
1479
1480         fattr = dos_mode(conn,fname,&sbuf);
1481         mtime = sbuf.st_mtime;
1482         if (fattr & aDIR) {
1483                 close_file(fsp,ERROR_CLOSE);
1484                 END_PROFILE(SMBopenX);
1485                 return ERROR_DOS(ERRDOS,ERRnoaccess);
1486         }
1487
1488         /* If the caller set the extended oplock request bit
1489                 and we granted one (by whatever means) - set the
1490                 correct bit for extended oplock reply.
1491         */
1492
1493         if (ex_oplock_request && lp_fake_oplocks(SNUM(conn))) {
1494                 smb_action |= EXTENDED_OPLOCK_GRANTED;
1495         }
1496
1497         if(ex_oplock_request && EXCLUSIVE_OPLOCK_TYPE(fsp->oplock_type)) {
1498                 smb_action |= EXTENDED_OPLOCK_GRANTED;
1499         }
1500
1501         /* If the caller set the core oplock request bit
1502                 and we granted one (by whatever means) - set the
1503                 correct bit for core oplock reply.
1504         */
1505
1506         if (core_oplock_request && lp_fake_oplocks(SNUM(conn))) {
1507                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1508         }
1509
1510         if(core_oplock_request && EXCLUSIVE_OPLOCK_TYPE(fsp->oplock_type)) {
1511                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1512         }
1513
1514         if (open_flags & EXTENDED_RESPONSE_REQUIRED) {
1515                 set_message(inbuf,outbuf,19,0,True);
1516         } else {
1517                 set_message(inbuf,outbuf,15,0,True);
1518         }
1519         SSVAL(outbuf,smb_vwv2,fsp->fnum);
1520         SSVAL(outbuf,smb_vwv3,fattr);
1521         if(lp_dos_filetime_resolution(SNUM(conn)) ) {
1522                 srv_put_dos_date3(outbuf,smb_vwv4,mtime & ~1);
1523         } else {
1524                 srv_put_dos_date3(outbuf,smb_vwv4,mtime);
1525         }
1526         SIVAL(outbuf,smb_vwv6,(uint32)sbuf.st_size);
1527         SSVAL(outbuf,smb_vwv8,GET_OPENX_MODE(deny_mode));
1528         SSVAL(outbuf,smb_vwv11,smb_action);
1529
1530         if (open_flags & EXTENDED_RESPONSE_REQUIRED) {
1531                 SIVAL(outbuf, smb_vwv15, STD_RIGHT_ALL_ACCESS);
1532         }
1533
1534         END_PROFILE(SMBopenX);
1535         return chain_reply(inbuf,outbuf,length,bufsize);
1536 }
1537
1538 /****************************************************************************
1539  Reply to a SMBulogoffX.
1540  conn POINTER CAN BE NULL HERE !
1541 ****************************************************************************/
1542
1543 int reply_ulogoffX(connection_struct *conn, char *inbuf,char *outbuf,int length,int bufsize)
1544 {
1545         uint16 vuid = SVAL(inbuf,smb_uid);
1546         user_struct *vuser = get_valid_user_struct(vuid);
1547         START_PROFILE(SMBulogoffX);
1548
1549         if(vuser == 0)
1550                 DEBUG(3,("ulogoff, vuser id %d does not map to user.\n", vuid));
1551
1552         /* in user level security we are supposed to close any files
1553                 open by this user */
1554         if ((vuser != 0) && (lp_security() != SEC_SHARE))
1555                 file_close_user(vuid);
1556
1557         invalidate_vuid(vuid);
1558
1559         set_message(inbuf,outbuf,2,0,True);
1560
1561         DEBUG( 3, ( "ulogoffX vuid=%d\n", vuid ) );
1562
1563         END_PROFILE(SMBulogoffX);
1564         return chain_reply(inbuf,outbuf,length,bufsize);
1565 }
1566
1567 /****************************************************************************
1568  Reply to a mknew or a create.
1569 ****************************************************************************/
1570
1571 int reply_mknew(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
1572 {
1573         pstring fname;
1574         int com;
1575         int outsize = 0;
1576         uint32 fattr = SVAL(inbuf,smb_vwv0);
1577         struct timespec ts[2];
1578         files_struct *fsp;
1579         int oplock_request = CORE_OPLOCK_REQUEST(inbuf);
1580         SMB_STRUCT_STAT sbuf;
1581         NTSTATUS status;
1582         uint32 access_mask = FILE_GENERIC_READ | FILE_GENERIC_WRITE;
1583         uint32 share_mode = FILE_SHARE_READ|FILE_SHARE_WRITE;
1584         uint32 create_disposition;
1585         uint32 create_options = 0;
1586
1587         START_PROFILE(SMBcreate);
1588
1589         com = SVAL(inbuf,smb_com);
1590
1591         ts[1] = convert_time_t_to_timespec(srv_make_unix_date3(inbuf + smb_vwv1)); /* mtime. */
1592
1593         srvstr_get_path(inbuf, fname, smb_buf(inbuf) + 1, sizeof(fname), 0, STR_TERMINATE, &status);
1594         if (!NT_STATUS_IS_OK(status)) {
1595                 END_PROFILE(SMBcreate);
1596                 return ERROR_NT(status);
1597         }
1598
1599         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, fname);
1600         if (!NT_STATUS_IS_OK(status)) {
1601                 END_PROFILE(SMBcreate);
1602                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
1603                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
1604                 }
1605                 return ERROR_NT(status);
1606         }
1607
1608         status = unix_convert(conn, fname, False, NULL, &sbuf);
1609         if (!NT_STATUS_IS_OK(status)) {
1610                 END_PROFILE(SMBcreate);
1611                 return ERROR_NT(status);
1612         }
1613
1614         status = check_name(conn, fname);
1615         if (!NT_STATUS_IS_OK(status)) {
1616                 END_PROFILE(SMBcreate);
1617                 return ERROR_NT(status);
1618         }
1619
1620         if (fattr & aVOLID) {
1621                 DEBUG(0,("Attempt to create file (%s) with volid set - please report this\n",fname));
1622         }
1623
1624         if(com == SMBmknew) {
1625                 /* We should fail if file exists. */
1626                 create_disposition = FILE_CREATE;
1627         } else {
1628                 /* Create if file doesn't exist, truncate if it does. */
1629                 create_disposition = FILE_OVERWRITE_IF;
1630         }
1631
1632         /* Open file using ntcreate. */
1633         status = open_file_ntcreate(conn,fname,&sbuf,
1634                                 access_mask,
1635                                 share_mode,
1636                                 create_disposition,
1637                                 create_options,
1638                                 fattr,
1639                                 oplock_request,
1640                                 NULL, &fsp);
1641
1642         if (!NT_STATUS_IS_OK(status)) {
1643                 END_PROFILE(SMBcreate);
1644                 if (open_was_deferred(SVAL(inbuf,smb_mid))) {
1645                         /* We have re-scheduled this call. */
1646                         return -1;
1647                 }
1648                 return ERROR_NT(status);
1649         }
1650
1651         ts[0] = get_atimespec(&sbuf); /* atime. */
1652         file_ntimes(conn, fname, ts);
1653
1654         outsize = set_message(inbuf,outbuf,1,0,True);
1655         SSVAL(outbuf,smb_vwv0,fsp->fnum);
1656
1657         if (oplock_request && lp_fake_oplocks(SNUM(conn))) {
1658                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1659         }
1660
1661         if(EXCLUSIVE_OPLOCK_TYPE(fsp->oplock_type)) {
1662                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1663         }
1664
1665         DEBUG( 2, ( "reply_mknew: file %s\n", fname ) );
1666         DEBUG( 3, ( "reply_mknew %s fd=%d dmode=0x%x\n", fname, fsp->fh->fd, (unsigned int)fattr ) );
1667
1668         END_PROFILE(SMBcreate);
1669         return(outsize);
1670 }
1671
1672 /****************************************************************************
1673  Reply to a create temporary file.
1674 ****************************************************************************/
1675
1676 int reply_ctemp(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
1677 {
1678         pstring fname;
1679         int outsize = 0;
1680         uint32 fattr = SVAL(inbuf,smb_vwv0);
1681         files_struct *fsp;
1682         int oplock_request = CORE_OPLOCK_REQUEST(inbuf);
1683         int tmpfd;
1684         SMB_STRUCT_STAT sbuf;
1685         char *p, *s;
1686         NTSTATUS status;
1687         unsigned int namelen;
1688
1689         START_PROFILE(SMBctemp);
1690
1691         srvstr_get_path(inbuf, fname, smb_buf(inbuf)+1, sizeof(fname), 0, STR_TERMINATE, &status);
1692         if (!NT_STATUS_IS_OK(status)) {
1693                 END_PROFILE(SMBctemp);
1694                 return ERROR_NT(status);
1695         }
1696         if (*fname) {
1697                 pstrcat(fname,"/TMXXXXXX");
1698         } else {
1699                 pstrcat(fname,"TMXXXXXX");
1700         }
1701
1702         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, fname);
1703         if (!NT_STATUS_IS_OK(status)) {
1704                 END_PROFILE(SMBctemp);
1705                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
1706                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
1707                 }
1708                 return ERROR_NT(status);
1709         }
1710
1711         status = unix_convert(conn, fname, False, NULL, &sbuf);
1712         if (!NT_STATUS_IS_OK(status)) {
1713                 END_PROFILE(SMBctemp);
1714                 return ERROR_NT(status);
1715         }
1716
1717         status = check_name(conn, fname);
1718         if (!NT_STATUS_IS_OK(status)) {
1719                 END_PROFILE(SMBctemp);
1720                 return ERROR_NT(status);
1721         }
1722
1723         tmpfd = smb_mkstemp(fname);
1724         if (tmpfd == -1) {
1725                 END_PROFILE(SMBctemp);
1726                 return(UNIXERROR(ERRDOS,ERRnoaccess));
1727         }
1728
1729         SMB_VFS_STAT(conn,fname,&sbuf);
1730
1731         /* We should fail if file does not exist. */
1732         status = open_file_ntcreate(conn,fname,&sbuf,
1733                                 FILE_GENERIC_READ | FILE_GENERIC_WRITE,
1734                                 FILE_SHARE_READ|FILE_SHARE_WRITE,
1735                                 FILE_OPEN,
1736                                 0,
1737                                 fattr,
1738                                 oplock_request,
1739                                 NULL, &fsp);
1740
1741         /* close fd from smb_mkstemp() */
1742         close(tmpfd);
1743
1744         if (!NT_STATUS_IS_OK(status)) {
1745                 END_PROFILE(SMBctemp);
1746                 if (open_was_deferred(SVAL(inbuf,smb_mid))) {
1747                         /* We have re-scheduled this call. */
1748                         return -1;
1749                 }
1750                 return ERROR_NT(status);
1751         }
1752
1753         outsize = set_message(inbuf,outbuf,1,0,True);
1754         SSVAL(outbuf,smb_vwv0,fsp->fnum);
1755
1756         /* the returned filename is relative to the directory */
1757         s = strrchr_m(fname, '/');
1758         if (!s) {
1759                 s = fname;
1760         } else {
1761                 s++;
1762         }
1763
1764         p = smb_buf(outbuf);
1765 #if 0
1766         /* Tested vs W2K3 - this doesn't seem to be here - null terminated filename is the only
1767            thing in the byte section. JRA */
1768         SSVALS(p, 0, -1); /* what is this? not in spec */
1769 #endif
1770         namelen = srvstr_push(outbuf, p, s, -1, STR_ASCII|STR_TERMINATE);
1771         p += namelen;
1772         outsize = set_message_end(inbuf,outbuf, p);
1773
1774         if (oplock_request && lp_fake_oplocks(SNUM(conn))) {
1775                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1776         }
1777
1778         if (EXCLUSIVE_OPLOCK_TYPE(fsp->oplock_type)) {
1779                 SCVAL(outbuf,smb_flg,CVAL(outbuf,smb_flg)|CORE_OPLOCK_GRANTED);
1780         }
1781
1782         DEBUG( 2, ( "reply_ctemp: created temp file %s\n", fname ) );
1783         DEBUG( 3, ( "reply_ctemp %s fd=%d umode=0%o\n", fname, fsp->fh->fd,
1784                         (unsigned int)sbuf.st_mode ) );
1785
1786         END_PROFILE(SMBctemp);
1787         return(outsize);
1788 }
1789
1790 /*******************************************************************
1791  Check if a user is allowed to rename a file.
1792 ********************************************************************/
1793
1794 static NTSTATUS can_rename(connection_struct *conn, char *fname, uint16 dirtype, SMB_STRUCT_STAT *pst, BOOL self_open)
1795 {
1796         files_struct *fsp;
1797         uint32 fmode;
1798         NTSTATUS status;
1799
1800         if (!CAN_WRITE(conn)) {
1801                 return NT_STATUS_MEDIA_WRITE_PROTECTED;
1802         }
1803
1804         fmode = dos_mode(conn,fname,pst);
1805         if ((fmode & ~dirtype) & (aHIDDEN | aSYSTEM)) {
1806                 return NT_STATUS_NO_SUCH_FILE;
1807         }
1808
1809         if (S_ISDIR(pst->st_mode)) {
1810                 return NT_STATUS_OK;
1811         }
1812
1813         status = open_file_ntcreate(conn, fname, pst,
1814                                 DELETE_ACCESS,
1815                                 /* If we're checking our fsp don't deny for delete. */
1816                                 self_open ?
1817                                         FILE_SHARE_READ|FILE_SHARE_WRITE|FILE_SHARE_DELETE :
1818                                         FILE_SHARE_READ|FILE_SHARE_WRITE,
1819                                 FILE_OPEN,
1820                                 0,
1821                                 FILE_ATTRIBUTE_NORMAL,
1822                                 0,
1823                                 NULL, &fsp);
1824
1825         if (!NT_STATUS_IS_OK(status)) {
1826                 return status;
1827         }
1828         close_file(fsp,NORMAL_CLOSE);
1829         return NT_STATUS_OK;
1830 }
1831
1832 /*******************************************************************
1833  * unlink a file with all relevant access checks
1834  *******************************************************************/
1835
1836 static NTSTATUS do_unlink(connection_struct *conn, char *fname,
1837                           uint32 dirtype, BOOL can_defer)
1838 {
1839         SMB_STRUCT_STAT sbuf;
1840         uint32 fattr;
1841         files_struct *fsp;
1842         uint32 dirtype_orig = dirtype;
1843         NTSTATUS status;
1844
1845         DEBUG(10,("do_unlink: %s, dirtype = %d\n", fname, dirtype ));
1846
1847         if (!CAN_WRITE(conn)) {
1848                 return NT_STATUS_MEDIA_WRITE_PROTECTED;
1849         }
1850
1851         if (SMB_VFS_LSTAT(conn,fname,&sbuf) != 0) {
1852                 return map_nt_error_from_unix(errno);
1853         }
1854
1855         fattr = dos_mode(conn,fname,&sbuf);
1856
1857         if (dirtype & FILE_ATTRIBUTE_NORMAL) {
1858                 dirtype = aDIR|aARCH|aRONLY;
1859         }
1860
1861         dirtype &= (aDIR|aARCH|aRONLY|aHIDDEN|aSYSTEM);
1862         if (!dirtype) {
1863                 return NT_STATUS_NO_SUCH_FILE;
1864         }
1865
1866         if (!dir_check_ftype(conn, fattr, dirtype)) {
1867                 if (fattr & aDIR) {
1868                         return NT_STATUS_FILE_IS_A_DIRECTORY;
1869                 }
1870                 return NT_STATUS_NO_SUCH_FILE;
1871         }
1872
1873         if (dirtype_orig & 0x8000) {
1874                 /* These will never be set for POSIX. */
1875                 return NT_STATUS_NO_SUCH_FILE;
1876         }
1877
1878 #if 0
1879         if ((fattr & dirtype) & FILE_ATTRIBUTE_DIRECTORY) {
1880                 return NT_STATUS_FILE_IS_A_DIRECTORY;
1881         }
1882
1883         if ((fattr & ~dirtype) & (FILE_ATTRIBUTE_HIDDEN|FILE_ATTRIBUTE_SYSTEM)) {
1884                 return NT_STATUS_NO_SUCH_FILE;
1885         }
1886
1887         if (dirtype & 0xFF00) {
1888                 /* These will never be set for POSIX. */
1889                 return NT_STATUS_NO_SUCH_FILE;
1890         }
1891
1892         dirtype &= 0xFF;
1893         if (!dirtype) {
1894                 return NT_STATUS_NO_SUCH_FILE;
1895         }
1896
1897         /* Can't delete a directory. */
1898         if (fattr & aDIR) {
1899                 return NT_STATUS_FILE_IS_A_DIRECTORY;
1900         }
1901 #endif
1902
1903 #if 0 /* JRATEST */
1904         else if (dirtype & aDIR) /* Asked for a directory and it isn't. */
1905                 return NT_STATUS_OBJECT_NAME_INVALID;
1906 #endif /* JRATEST */
1907
1908         /* Fix for bug #3035 from SATOH Fumiyasu <fumiyas@miraclelinux.com>
1909
1910           On a Windows share, a file with read-only dosmode can be opened with
1911           DELETE_ACCESS. But on a Samba share (delete readonly = no), it
1912           fails with NT_STATUS_CANNOT_DELETE error.
1913
1914           This semantic causes a problem that a user can not
1915           rename a file with read-only dosmode on a Samba share
1916           from a Windows command prompt (i.e. cmd.exe, but can rename
1917           from Windows Explorer).
1918         */
1919
1920         if (!lp_delete_readonly(SNUM(conn))) {
1921                 if (fattr & aRONLY) {
1922                         return NT_STATUS_CANNOT_DELETE;
1923                 }
1924         }
1925
1926         /* On open checks the open itself will check the share mode, so
1927            don't do it here as we'll get it wrong. */
1928
1929         status = open_file_ntcreate(conn, fname, &sbuf,
1930                                     DELETE_ACCESS,
1931                                     FILE_SHARE_NONE,
1932                                     FILE_OPEN,
1933                                     0,
1934                                     FILE_ATTRIBUTE_NORMAL,
1935                                     can_defer ? 0 : INTERNAL_OPEN_ONLY,
1936                                     NULL, &fsp);
1937
1938         if (!NT_STATUS_IS_OK(status)) {
1939                 DEBUG(10, ("open_file_ntcreate failed: %s\n",
1940                            nt_errstr(status)));
1941                 return status;
1942         }
1943
1944         /* The set is across all open files on this dev/inode pair. */
1945         if (!set_delete_on_close(fsp, True, &current_user.ut)) {
1946                 close_file(fsp, NORMAL_CLOSE);
1947                 return NT_STATUS_ACCESS_DENIED;
1948         }
1949
1950         return close_file(fsp,NORMAL_CLOSE);
1951 }
1952
1953 /****************************************************************************
1954  The guts of the unlink command, split out so it may be called by the NT SMB
1955  code.
1956 ****************************************************************************/
1957
1958 NTSTATUS unlink_internals(connection_struct *conn, uint32 dirtype,
1959                           char *name, BOOL has_wild, BOOL can_defer)
1960 {
1961         pstring directory;
1962         pstring mask;
1963         char *p;
1964         int count=0;
1965         NTSTATUS status = NT_STATUS_OK;
1966         SMB_STRUCT_STAT sbuf;
1967
1968         *directory = *mask = 0;
1969
1970         status = unix_convert(conn, name, has_wild, NULL, &sbuf);
1971         if (!NT_STATUS_IS_OK(status)) {
1972                 return status;
1973         }
1974
1975         p = strrchr_m(name,'/');
1976         if (!p) {
1977                 pstrcpy(directory,".");
1978                 pstrcpy(mask,name);
1979         } else {
1980                 *p = 0;
1981                 pstrcpy(directory,name);
1982                 pstrcpy(mask,p+1);
1983         }
1984
1985         /*
1986          * We should only check the mangled cache
1987          * here if unix_convert failed. This means
1988          * that the path in 'mask' doesn't exist
1989          * on the file system and so we need to look
1990          * for a possible mangle. This patch from
1991          * Tine Smukavec <valentin.smukavec@hermes.si>.
1992          */
1993
1994         if (!VALID_STAT(sbuf) && mangle_is_mangled(mask,conn->params))
1995                 mangle_check_cache( mask, sizeof(pstring)-1, conn->params );
1996
1997         if (!has_wild) {
1998                 pstrcat(directory,"/");
1999                 pstrcat(directory,mask);
2000                 if (dirtype == 0) {
2001                         dirtype = FILE_ATTRIBUTE_NORMAL;
2002                 }
2003
2004                 status = check_name(conn, directory);
2005                 if (!NT_STATUS_IS_OK(status)) {
2006                         return status;
2007                 }
2008
2009                 status = do_unlink(conn,directory,dirtype,can_defer);
2010                 if (!NT_STATUS_IS_OK(status)) {
2011                         return status;
2012                 }
2013
2014                 count++;
2015         } else {
2016                 struct smb_Dir *dir_hnd = NULL;
2017                 long offset = 0;
2018                 const char *dname;
2019
2020                 if ((dirtype & SAMBA_ATTRIBUTES_MASK) == aDIR) {
2021                         return NT_STATUS_OBJECT_NAME_INVALID;
2022                 }
2023
2024                 if (strequal(mask,"????????.???")) {
2025                         pstrcpy(mask,"*");
2026                 }
2027
2028                 status = check_name(conn, directory);
2029                 if (!NT_STATUS_IS_OK(status)) {
2030                         return status;
2031                 }
2032
2033                 dir_hnd = OpenDir(conn, directory, mask, dirtype);
2034                 if (dir_hnd == NULL) {
2035                         return map_nt_error_from_unix(errno);
2036                 }
2037
2038                 /* XXXX the CIFS spec says that if bit0 of the flags2 field is set then
2039                    the pattern matches against the long name, otherwise the short name
2040                    We don't implement this yet XXXX
2041                 */
2042
2043                 status = NT_STATUS_NO_SUCH_FILE;
2044
2045                 while ((dname = ReadDirName(dir_hnd, &offset))) {
2046                         SMB_STRUCT_STAT st;
2047                         pstring fname;
2048                         pstrcpy(fname,dname);
2049
2050                         if (!is_visible_file(conn, directory, dname, &st, True)) {
2051                                 continue;
2052                         }
2053
2054                         /* Quick check for "." and ".." */
2055                         if (fname[0] == '.') {
2056                                 if (!fname[1] || (fname[1] == '.' && !fname[2])) {
2057                                         continue;
2058                                 }
2059                         }
2060
2061                         if(!mask_match(fname, mask, conn->case_sensitive)) {
2062                                 continue;
2063                         }
2064
2065                         slprintf(fname,sizeof(fname)-1, "%s/%s",directory,dname);
2066
2067                         status = check_name(conn, fname);
2068                         if (!NT_STATUS_IS_OK(status)) {
2069                                 CloseDir(dir_hnd);
2070                                 return status;
2071                         }
2072
2073                         status = do_unlink(conn, fname, dirtype, can_defer);
2074                         if (!NT_STATUS_IS_OK(status)) {
2075                                 continue;
2076                         }
2077
2078                         count++;
2079                         DEBUG(3,("unlink_internals: succesful unlink [%s]\n",
2080                                  fname));
2081                 }
2082                 CloseDir(dir_hnd);
2083         }
2084
2085         if (count == 0 && NT_STATUS_IS_OK(status)) {
2086                 status = map_nt_error_from_unix(errno);
2087         }
2088
2089         return status;
2090 }
2091
2092 /****************************************************************************
2093  Reply to a unlink
2094 ****************************************************************************/
2095
2096 int reply_unlink(connection_struct *conn, char *inbuf,char *outbuf, int dum_size,
2097                  int dum_buffsize)
2098 {
2099         int outsize = 0;
2100         pstring name;
2101         uint32 dirtype;
2102         NTSTATUS status;
2103         BOOL path_contains_wcard = False;
2104
2105         START_PROFILE(SMBunlink);
2106
2107         dirtype = SVAL(inbuf,smb_vwv0);
2108
2109         srvstr_get_path_wcard(inbuf, name, smb_buf(inbuf) + 1, sizeof(name), 0, STR_TERMINATE, &status, &path_contains_wcard);
2110         if (!NT_STATUS_IS_OK(status)) {
2111                 END_PROFILE(SMBunlink);
2112                 return ERROR_NT(status);
2113         }
2114
2115         status = resolve_dfspath_wcard(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, name, &path_contains_wcard);
2116         if (!NT_STATUS_IS_OK(status)) {
2117                 END_PROFILE(SMBunlink);
2118                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
2119                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
2120                 }
2121                 return ERROR_NT(status);
2122         }
2123
2124         DEBUG(3,("reply_unlink : %s\n",name));
2125
2126         status = unlink_internals(conn, dirtype, name, path_contains_wcard,
2127                                   True);
2128         if (!NT_STATUS_IS_OK(status)) {
2129                 if (open_was_deferred(SVAL(inbuf,smb_mid))) {
2130                         /* We have re-scheduled this call. */
2131                         return -1;
2132                 }
2133                 return ERROR_NT(status);
2134         }
2135
2136         outsize = set_message(inbuf,outbuf,0,0,False);
2137
2138         END_PROFILE(SMBunlink);
2139         return outsize;
2140 }
2141
2142 /****************************************************************************
2143  Fail for readbraw.
2144 ****************************************************************************/
2145
2146 static void fail_readraw(void)
2147 {
2148         pstring errstr;
2149         slprintf(errstr, sizeof(errstr)-1, "FAIL ! reply_readbraw: socket write fail (%s)",
2150                 strerror(errno) );
2151         exit_server_cleanly(errstr);
2152 }
2153
2154 /****************************************************************************
2155  Fake (read/write) sendfile. Returns -1 on read or write fail.
2156 ****************************************************************************/
2157
2158 static ssize_t fake_sendfile(files_struct *fsp, SMB_OFF_T startpos, size_t nread, char *buf, size_t bufsize)
2159 {
2160         size_t tosend = nread;
2161
2162         while (tosend > 0) {
2163                 ssize_t ret;
2164                 size_t cur_read;
2165
2166                 if (tosend > bufsize) {
2167                         cur_read = bufsize;
2168                 } else {
2169                         cur_read = tosend;
2170                 }
2171                 ret = read_file(fsp,buf,startpos,cur_read);
2172                 if (ret == -1) {
2173                         return -1;
2174                 }
2175
2176                 /* If we had a short read, fill with zeros. */
2177                 if (ret < cur_read) {
2178                         memset(buf, '\0', cur_read - ret);
2179                 }
2180
2181                 if (write_data(smbd_server_fd(),buf,cur_read) != cur_read) {
2182                         return -1;
2183                 }
2184                 tosend -= cur_read;
2185                 startpos += cur_read;
2186         }
2187
2188         return (ssize_t)nread;
2189 }
2190
2191 /****************************************************************************
2192  Use sendfile in readbraw.
2193 ****************************************************************************/
2194
2195 void send_file_readbraw(connection_struct *conn, files_struct *fsp, SMB_OFF_T startpos, size_t nread,
2196                 ssize_t mincount, char *outbuf, int out_buffsize)
2197 {
2198         ssize_t ret=0;
2199
2200 #if defined(WITH_SENDFILE)
2201         /*
2202          * We can only use sendfile on a non-chained packet
2203          * but we can use on a non-oplocked file. tridge proved this
2204          * on a train in Germany :-). JRA.
2205          * reply_readbraw has already checked the length.
2206          */
2207
2208         if ( (chain_size == 0) && (nread > 0) &&
2209             (fsp->wcp == NULL) && lp_use_sendfile(SNUM(conn)) ) {
2210                 DATA_BLOB header;
2211
2212                 _smb_setlen(outbuf,nread);
2213                 header.data = (uint8 *)outbuf;
2214                 header.length = 4;
2215                 header.free = NULL;
2216
2217                 if ( SMB_VFS_SENDFILE( smbd_server_fd(), fsp, fsp->fh->fd, &header, startpos, nread) == -1) {
2218                         /* Returning ENOSYS means no data at all was sent. Do this as a normal read. */
2219                         if (errno == ENOSYS) {
2220                                 goto normal_readbraw;
2221                         }
2222
2223                         /*
2224                          * Special hack for broken Linux with no working sendfile. If we
2225                          * return EINTR we sent the header but not the rest of the data.
2226                          * Fake this up by doing read/write calls.
2227                          */
2228                         if (errno == EINTR) {
2229                                 /* Ensure we don't do this again. */
2230                                 set_use_sendfile(SNUM(conn), False);
2231                                 DEBUG(0,("send_file_readbraw: sendfile not available. Faking..\n"));
2232
2233                                 if (fake_sendfile(fsp, startpos, nread, outbuf + 4, out_buffsize - 4) == -1) {
2234                                         DEBUG(0,("send_file_readbraw: fake_sendfile failed for file %s (%s).\n",
2235                                                 fsp->fsp_name, strerror(errno) ));
2236                                         exit_server_cleanly("send_file_readbraw fake_sendfile failed");
2237                                 }
2238                                 return;
2239                         }
2240
2241                         DEBUG(0,("send_file_readbraw: sendfile failed for file %s (%s). Terminating\n",
2242                                 fsp->fsp_name, strerror(errno) ));
2243                         exit_server_cleanly("send_file_readbraw sendfile failed");
2244                 }
2245
2246                 return;
2247         }
2248 #endif
2249
2250 normal_readbraw:
2251
2252         if (nread > 0) {
2253                 ret = read_file(fsp,outbuf+4,startpos,nread);
2254 #if 0 /* mincount appears to be ignored in a W2K server. JRA. */
2255                 if (ret < mincount)
2256                         ret = 0;
2257 #else
2258                 if (ret < nread)
2259                         ret = 0;
2260 #endif
2261         }
2262
2263         _smb_setlen(outbuf,ret);
2264         if (write_data(smbd_server_fd(),outbuf,4+ret) != 4+ret)
2265                 fail_readraw();
2266 }
2267
2268 /****************************************************************************
2269  Reply to a readbraw (core+ protocol).
2270 ****************************************************************************/
2271
2272 int reply_readbraw(connection_struct *conn, char *inbuf, char *outbuf, int dum_size, int out_buffsize)
2273 {
2274         ssize_t maxcount,mincount;
2275         size_t nread = 0;
2276         SMB_OFF_T startpos;
2277         char *header = outbuf;
2278         files_struct *fsp;
2279         START_PROFILE(SMBreadbraw);
2280
2281         if (srv_is_signing_active()) {
2282                 exit_server_cleanly("reply_readbraw: SMB signing is active - raw reads/writes are disallowed.");
2283         }
2284
2285         /*
2286          * Special check if an oplock break has been issued
2287          * and the readraw request croses on the wire, we must
2288          * return a zero length response here.
2289          */
2290
2291         fsp = file_fsp(inbuf,smb_vwv0);
2292
2293         if (!FNUM_OK(fsp,conn) || !fsp->can_read) {
2294                 /*
2295                  * fsp could be NULL here so use the value from the packet. JRA.
2296                  */
2297                 DEBUG(3,("fnum %d not open in readbraw - cache prime?\n",(int)SVAL(inbuf,smb_vwv0)));
2298                 _smb_setlen(header,0);
2299                 if (write_data(smbd_server_fd(),header,4) != 4)
2300                         fail_readraw();
2301                 END_PROFILE(SMBreadbraw);
2302                 return(-1);
2303         }
2304
2305         CHECK_FSP(fsp,conn);
2306
2307         flush_write_cache(fsp, READRAW_FLUSH);
2308
2309         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv1);
2310         if(CVAL(inbuf,smb_wct) == 10) {
2311                 /*
2312                  * This is a large offset (64 bit) read.
2313                  */
2314 #ifdef LARGE_SMB_OFF_T
2315
2316                 startpos |= (((SMB_OFF_T)IVAL(inbuf,smb_vwv8)) << 32);
2317
2318 #else /* !LARGE_SMB_OFF_T */
2319
2320                 /*
2321                  * Ensure we haven't been sent a >32 bit offset.
2322                  */
2323
2324                 if(IVAL(inbuf,smb_vwv8) != 0) {
2325                         DEBUG(0,("readbraw - large offset (%x << 32) used and we don't support \
2326 64 bit offsets.\n", (unsigned int)IVAL(inbuf,smb_vwv8) ));
2327                         _smb_setlen(header,0);
2328                         if (write_data(smbd_server_fd(),header,4) != 4)
2329                                 fail_readraw();
2330                         END_PROFILE(SMBreadbraw);
2331                         return(-1);
2332                 }
2333
2334 #endif /* LARGE_SMB_OFF_T */
2335
2336                 if(startpos < 0) {
2337                         DEBUG(0,("readbraw - negative 64 bit readraw offset (%.0f) !\n", (double)startpos ));
2338                         _smb_setlen(header,0);
2339                         if (write_data(smbd_server_fd(),header,4) != 4)
2340                                 fail_readraw();
2341                         END_PROFILE(SMBreadbraw);
2342                         return(-1);
2343                 }
2344         }
2345         maxcount = (SVAL(inbuf,smb_vwv3) & 0xFFFF);
2346         mincount = (SVAL(inbuf,smb_vwv4) & 0xFFFF);
2347
2348         /* ensure we don't overrun the packet size */
2349         maxcount = MIN(65535,maxcount);
2350
2351         if (!is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)maxcount,(SMB_BIG_UINT)startpos, READ_LOCK)) {
2352                 SMB_STRUCT_STAT st;
2353                 SMB_OFF_T size = 0;
2354
2355                 if (SMB_VFS_FSTAT(fsp,fsp->fh->fd,&st) == 0) {
2356                         size = st.st_size;
2357                 }
2358
2359                 if (startpos >= size) {
2360                         nread = 0;
2361                 } else {
2362                         nread = MIN(maxcount,(size - startpos));
2363                 }
2364         }
2365
2366 #if 0 /* mincount appears to be ignored in a W2K server. JRA. */
2367         if (nread < mincount)
2368                 nread = 0;
2369 #endif
2370
2371         DEBUG( 3, ( "readbraw fnum=%d start=%.0f max=%lu min=%lu nread=%lu\n", fsp->fnum, (double)startpos,
2372                                 (unsigned long)maxcount, (unsigned long)mincount, (unsigned long)nread ) );
2373
2374         send_file_readbraw(conn, fsp, startpos, nread, mincount, outbuf, out_buffsize);
2375
2376         DEBUG(5,("readbraw finished\n"));
2377         END_PROFILE(SMBreadbraw);
2378         return -1;
2379 }
2380
2381 #undef DBGC_CLASS
2382 #define DBGC_CLASS DBGC_LOCKING
2383
2384 /****************************************************************************
2385  Reply to a lockread (core+ protocol).
2386 ****************************************************************************/
2387
2388 int reply_lockread(connection_struct *conn, char *inbuf,char *outbuf, int length, int dum_buffsiz)
2389 {
2390         ssize_t nread = -1;
2391         char *data;
2392         int outsize = 0;
2393         SMB_OFF_T startpos;
2394         size_t numtoread;
2395         NTSTATUS status;
2396         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
2397         struct byte_range_lock *br_lck = NULL;
2398         START_PROFILE(SMBlockread);
2399
2400         CHECK_FSP(fsp,conn);
2401         if (!CHECK_READ(fsp,inbuf)) {
2402                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
2403         }
2404
2405         release_level_2_oplocks_on_change(fsp);
2406
2407         numtoread = SVAL(inbuf,smb_vwv1);
2408         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv2);
2409
2410         outsize = set_message(inbuf,outbuf,5,3,True);
2411         numtoread = MIN(BUFFER_SIZE-outsize,numtoread);
2412         data = smb_buf(outbuf) + 3;
2413
2414         /*
2415          * NB. Discovered by Menny Hamburger at Mainsoft. This is a core+
2416          * protocol request that predates the read/write lock concept.
2417          * Thus instead of asking for a read lock here we need to ask
2418          * for a write lock. JRA.
2419          * Note that the requested lock size is unaffected by max_recv.
2420          */
2421
2422         br_lck = do_lock(smbd_messaging_context(),
2423                         fsp,
2424                         (uint32)SVAL(inbuf,smb_pid),
2425                         (SMB_BIG_UINT)numtoread,
2426                         (SMB_BIG_UINT)startpos,
2427                         WRITE_LOCK,
2428                         WINDOWS_LOCK,
2429                         False, /* Non-blocking lock. */
2430                         &status,
2431                         NULL);
2432         TALLOC_FREE(br_lck);
2433
2434         if (NT_STATUS_V(status)) {
2435                 END_PROFILE(SMBlockread);
2436                 return ERROR_NT(status);
2437         }
2438
2439         /*
2440          * However the requested READ size IS affected by max_recv. Insanity.... JRA.
2441          */
2442
2443         if (numtoread > max_recv) {
2444                 DEBUG(0,("reply_lockread: requested read size (%u) is greater than maximum allowed (%u). \
2445 Returning short read of maximum allowed for compatibility with Windows 2000.\n",
2446                         (unsigned int)numtoread, (unsigned int)max_recv ));
2447                 numtoread = MIN(numtoread,max_recv);
2448         }
2449         nread = read_file(fsp,data,startpos,numtoread);
2450
2451         if (nread < 0) {
2452                 END_PROFILE(SMBlockread);
2453                 return(UNIXERROR(ERRDOS,ERRnoaccess));
2454         }
2455
2456         outsize += nread;
2457         SSVAL(outbuf,smb_vwv0,nread);
2458         SSVAL(outbuf,smb_vwv5,nread+3);
2459         SSVAL(smb_buf(outbuf),1,nread);
2460
2461         DEBUG(3,("lockread fnum=%d num=%d nread=%d\n",
2462                  fsp->fnum, (int)numtoread, (int)nread));
2463
2464         END_PROFILE(SMBlockread);
2465         return(outsize);
2466 }
2467
2468 #undef DBGC_CLASS
2469 #define DBGC_CLASS DBGC_ALL
2470
2471 /****************************************************************************
2472  Reply to a read.
2473 ****************************************************************************/
2474
2475 int reply_read(connection_struct *conn, char *inbuf,char *outbuf, int size, int dum_buffsize)
2476 {
2477         size_t numtoread;
2478         ssize_t nread = 0;
2479         char *data;
2480         SMB_OFF_T startpos;
2481         int outsize = 0;
2482         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
2483         START_PROFILE(SMBread);
2484
2485         CHECK_FSP(fsp,conn);
2486         if (!CHECK_READ(fsp,inbuf)) {
2487                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
2488         }
2489
2490         numtoread = SVAL(inbuf,smb_vwv1);
2491         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv2);
2492
2493         outsize = set_message(inbuf,outbuf,5,3,True);
2494         numtoread = MIN(BUFFER_SIZE-outsize,numtoread);
2495         /*
2496          * The requested read size cannot be greater than max_recv. JRA.
2497          */
2498         if (numtoread > max_recv) {
2499                 DEBUG(0,("reply_read: requested read size (%u) is greater than maximum allowed (%u). \
2500 Returning short read of maximum allowed for compatibility with Windows 2000.\n",
2501                         (unsigned int)numtoread, (unsigned int)max_recv ));
2502                 numtoread = MIN(numtoread,max_recv);
2503         }
2504
2505         data = smb_buf(outbuf) + 3;
2506
2507         if (is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)numtoread,(SMB_BIG_UINT)startpos, READ_LOCK)) {
2508                 END_PROFILE(SMBread);
2509                 return ERROR_DOS(ERRDOS,ERRlock);
2510         }
2511
2512         if (numtoread > 0)
2513                 nread = read_file(fsp,data,startpos,numtoread);
2514
2515         if (nread < 0) {
2516                 END_PROFILE(SMBread);
2517                 return(UNIXERROR(ERRDOS,ERRnoaccess));
2518         }
2519
2520         outsize += nread;
2521         SSVAL(outbuf,smb_vwv0,nread);
2522         SSVAL(outbuf,smb_vwv5,nread+3);
2523         SCVAL(smb_buf(outbuf),0,1);
2524         SSVAL(smb_buf(outbuf),1,nread);
2525
2526         DEBUG( 3, ( "read fnum=%d num=%d nread=%d\n",
2527                 fsp->fnum, (int)numtoread, (int)nread ) );
2528
2529         END_PROFILE(SMBread);
2530         return(outsize);
2531 }
2532
2533 /****************************************************************************
2534  Setup readX header.
2535 ****************************************************************************/
2536
2537 static int setup_readX_header(char *inbuf, char *outbuf, size_t smb_maxcnt)
2538 {
2539         int outsize;
2540         char *data = smb_buf(outbuf);
2541
2542         SSVAL(outbuf,smb_vwv2,0xFFFF); /* Remaining - must be -1. */
2543         SSVAL(outbuf,smb_vwv5,smb_maxcnt);
2544         SSVAL(outbuf,smb_vwv6,smb_offset(data,outbuf));
2545         SSVAL(outbuf,smb_vwv7,(smb_maxcnt >> 16));
2546         SSVAL(smb_buf(outbuf),-2,smb_maxcnt);
2547         SCVAL(outbuf,smb_vwv0,0xFF);
2548         outsize = set_message(inbuf, outbuf,12,smb_maxcnt,False);
2549         /* Reset the outgoing length, set_message truncates at 0x1FFFF. */
2550         _smb_setlen_large(outbuf,(smb_size + 12*2 + smb_maxcnt - 4));
2551         return outsize;
2552 }
2553
2554 /****************************************************************************
2555  Reply to a read and X - possibly using sendfile.
2556 ****************************************************************************/
2557
2558 int send_file_readX(connection_struct *conn, char *inbuf,char *outbuf,int length, int len_outbuf,
2559                 files_struct *fsp, SMB_OFF_T startpos, size_t smb_maxcnt)
2560 {
2561         SMB_STRUCT_STAT sbuf;
2562         int outsize = 0;
2563         ssize_t nread = -1;
2564         char *data = smb_buf(outbuf);
2565
2566         if(SMB_VFS_FSTAT(fsp,fsp->fh->fd, &sbuf) == -1) {
2567                 return(UNIXERROR(ERRDOS,ERRnoaccess));
2568         }
2569
2570         if (startpos > sbuf.st_size) {
2571                 smb_maxcnt = 0;
2572         }
2573
2574         if (smb_maxcnt > (sbuf.st_size - startpos)) {
2575                 smb_maxcnt = (sbuf.st_size - startpos);
2576         }
2577
2578         if (smb_maxcnt == 0) {
2579                 goto normal_read;
2580         }
2581
2582 #if defined(WITH_SENDFILE)
2583         /*
2584          * We can only use sendfile on a non-chained packet
2585          * but we can use on a non-oplocked file. tridge proved this
2586          * on a train in Germany :-). JRA.
2587          */
2588
2589         if ((chain_size == 0) && (CVAL(inbuf,smb_vwv0) == 0xFF) &&
2590             lp_use_sendfile(SNUM(conn)) && (fsp->wcp == NULL) ) {
2591                 DATA_BLOB header;
2592
2593                 /*
2594                  * Set up the packet header before send. We
2595                  * assume here the sendfile will work (get the
2596                  * correct amount of data).
2597                  */
2598
2599                 setup_readX_header(inbuf,outbuf,smb_maxcnt);
2600                 set_message(inbuf,outbuf,12,smb_maxcnt,False);
2601                 header.data = (uint8 *)outbuf;
2602                 header.length = data - outbuf;
2603                 header.free = NULL;
2604
2605                 if ((nread = SMB_VFS_SENDFILE( smbd_server_fd(), fsp, fsp->fh->fd, &header, startpos, smb_maxcnt)) == -1) {
2606                         /* Returning ENOSYS means no data at all was sent. Do this as a normal read. */
2607                         if (errno == ENOSYS) {
2608                                 goto normal_read;
2609                         }
2610
2611                         /*
2612                          * Special hack for broken Linux with no working sendfile. If we
2613                          * return EINTR we sent the header but not the rest of the data.
2614                          * Fake this up by doing read/write calls.
2615                          */
2616
2617                         if (errno == EINTR) {
2618                                 /* Ensure we don't do this again. */
2619                                 set_use_sendfile(SNUM(conn), False);
2620                                 DEBUG(0,("send_file_readX: sendfile not available. Faking..\n"));
2621
2622                                 if ((nread = fake_sendfile(fsp, startpos, smb_maxcnt, data,
2623                                                         len_outbuf - (data-outbuf))) == -1) {
2624                                         DEBUG(0,("send_file_readX: fake_sendfile failed for file %s (%s).\n",
2625                                                 fsp->fsp_name, strerror(errno) ));
2626                                         exit_server_cleanly("send_file_readX: fake_sendfile failed");
2627                                 }
2628                                 DEBUG( 3, ( "send_file_readX: fake_sendfile fnum=%d max=%d nread=%d\n",
2629                                         fsp->fnum, (int)smb_maxcnt, (int)nread ) );
2630                                 /* Returning -1 here means successful sendfile. */
2631                                 return -1;
2632                         }
2633
2634                         DEBUG(0,("send_file_readX: sendfile failed for file %s (%s). Terminating\n",
2635                                 fsp->fsp_name, strerror(errno) ));
2636                         exit_server_cleanly("send_file_readX sendfile failed");
2637                 }
2638
2639                 DEBUG( 3, ( "send_file_readX: sendfile fnum=%d max=%d nread=%d\n",
2640                         fsp->fnum, (int)smb_maxcnt, (int)nread ) );
2641                 /* Returning -1 here means successful sendfile. */
2642                 return -1;
2643         }
2644
2645 #endif
2646
2647 normal_read:
2648
2649         if ((smb_maxcnt & 0xFF0000) > 0x10000) {
2650                 int sendlen = setup_readX_header(inbuf,outbuf,smb_maxcnt) - smb_maxcnt;
2651                 /* Send out the header. */
2652                 if (write_data(smbd_server_fd(),outbuf,sendlen) != sendlen) {
2653                         DEBUG(0,("send_file_readX: write_data failed for file %s (%s). Terminating\n",
2654                                 fsp->fsp_name, strerror(errno) ));
2655                         exit_server_cleanly("send_file_readX sendfile failed");
2656                 }
2657                 if ((nread = fake_sendfile(fsp, startpos, smb_maxcnt, data,
2658                                         len_outbuf - (data-outbuf))) == -1) {
2659                         DEBUG(0,("send_file_readX: fake_sendfile failed for file %s (%s).\n",
2660                                 fsp->fsp_name, strerror(errno) ));
2661                         exit_server_cleanly("send_file_readX: fake_sendfile failed");
2662                 }
2663                 return -1;
2664         } else {
2665                 nread = read_file(fsp,data,startpos,smb_maxcnt);
2666
2667                 if (nread < 0) {
2668                         return(UNIXERROR(ERRDOS,ERRnoaccess));
2669                 }
2670
2671                 outsize = setup_readX_header(inbuf, outbuf,nread);
2672
2673                 DEBUG( 3, ( "send_file_readX fnum=%d max=%d nread=%d\n",
2674                         fsp->fnum, (int)smb_maxcnt, (int)nread ) );
2675
2676                 /* Returning the number of bytes we want to send back - including header. */
2677                 return outsize;
2678         }
2679 }
2680
2681 /****************************************************************************
2682  Reply to a read and X.
2683 ****************************************************************************/
2684
2685 int reply_read_and_X(connection_struct *conn, char *inbuf,char *outbuf,int length,int bufsize)
2686 {
2687         files_struct *fsp = file_fsp(inbuf,smb_vwv2);
2688         SMB_OFF_T startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv3);
2689         ssize_t nread = -1;
2690         size_t smb_maxcnt = SVAL(inbuf,smb_vwv5);
2691         BOOL big_readX = False;
2692 #if 0
2693         size_t smb_mincnt = SVAL(inbuf,smb_vwv6);
2694 #endif
2695
2696         START_PROFILE(SMBreadX);
2697
2698         /* If it's an IPC, pass off the pipe handler. */
2699         if (IS_IPC(conn)) {
2700                 END_PROFILE(SMBreadX);
2701                 return reply_pipe_read_and_X(inbuf,outbuf,length,bufsize);
2702         }
2703
2704         CHECK_FSP(fsp,conn);
2705         if (!CHECK_READ(fsp,inbuf)) {
2706                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
2707         }
2708
2709         set_message(inbuf,outbuf,12,0,True);
2710
2711         if (global_client_caps & CAP_LARGE_READX) {
2712                 size_t upper_size = SVAL(inbuf,smb_vwv7);
2713                 smb_maxcnt |= (upper_size<<16);
2714                 if (upper_size > 1) {
2715                         /* Can't do this on a chained packet. */
2716                         if ((CVAL(inbuf,smb_vwv0) != 0xFF)) {
2717                                 return ERROR_NT(NT_STATUS_NOT_SUPPORTED);
2718                         }
2719                         /* We currently don't do this on signed or sealed data. */
2720                         if (srv_is_signing_active() || srv_encryption_on()) {
2721                                 return ERROR_NT(NT_STATUS_NOT_SUPPORTED);
2722                         }
2723                         /* Is there room in the reply for this data ? */
2724                         if (smb_maxcnt > (0xFFFFFF - (smb_size -4 + 12*2)))  {
2725                                 return ERROR_NT(NT_STATUS_INVALID_PARAMETER);
2726                         }
2727                         big_readX = True;
2728                 }
2729         }
2730
2731         if(CVAL(inbuf,smb_wct) == 12) {
2732 #ifdef LARGE_SMB_OFF_T
2733                 /*
2734                  * This is a large offset (64 bit) read.
2735                  */
2736                 startpos |= (((SMB_OFF_T)IVAL(inbuf,smb_vwv10)) << 32);
2737
2738 #else /* !LARGE_SMB_OFF_T */
2739
2740                 /*
2741                  * Ensure we haven't been sent a >32 bit offset.
2742                  */
2743
2744                 if(IVAL(inbuf,smb_vwv10) != 0) {
2745                         DEBUG(0,("reply_read_and_X - large offset (%x << 32) used and we don't support \
2746 64 bit offsets.\n", (unsigned int)IVAL(inbuf,smb_vwv10) ));
2747                         END_PROFILE(SMBreadX);
2748                         return ERROR_DOS(ERRDOS,ERRbadaccess);
2749                 }
2750
2751 #endif /* LARGE_SMB_OFF_T */
2752
2753         }
2754
2755         if (is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)smb_maxcnt,(SMB_BIG_UINT)startpos, READ_LOCK)) {
2756                 END_PROFILE(SMBreadX);
2757                 return ERROR_DOS(ERRDOS,ERRlock);
2758         }
2759
2760         if (!big_readX && schedule_aio_read_and_X(conn, inbuf, outbuf, length, bufsize, fsp, startpos, smb_maxcnt)) {
2761                 END_PROFILE(SMBreadX);
2762                 return -1;
2763         }
2764
2765         nread = send_file_readX(conn, inbuf, outbuf, length, bufsize, fsp, startpos, smb_maxcnt);
2766         /* Only call chain_reply if not an error. */
2767         if (nread != -1 && SVAL(outbuf,smb_rcls) == 0) {
2768                 nread = chain_reply(inbuf,outbuf,length,bufsize);
2769         }
2770
2771         END_PROFILE(SMBreadX);
2772         return nread;
2773 }
2774
2775 /****************************************************************************
2776  Reply to a writebraw (core+ or LANMAN1.0 protocol).
2777 ****************************************************************************/
2778
2779 int reply_writebraw(connection_struct *conn, char *inbuf,char *outbuf, int size, int dum_buffsize)
2780 {
2781         ssize_t nwritten=0;
2782         ssize_t total_written=0;
2783         size_t numtowrite=0;
2784         size_t tcount;
2785         SMB_OFF_T startpos;
2786         char *data=NULL;
2787         BOOL write_through;
2788         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
2789         int outsize = 0;
2790         START_PROFILE(SMBwritebraw);
2791
2792         if (srv_is_signing_active()) {
2793                 exit_server_cleanly("reply_writebraw: SMB signing is active - raw reads/writes are disallowed.");
2794         }
2795
2796         CHECK_FSP(fsp,conn);
2797         if (!CHECK_WRITE(fsp)) {
2798                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
2799         }
2800
2801         tcount = IVAL(inbuf,smb_vwv1);
2802         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv3);
2803         write_through = BITSETW(inbuf+smb_vwv7,0);
2804
2805         /* We have to deal with slightly different formats depending
2806                 on whether we are using the core+ or lanman1.0 protocol */
2807
2808         if(Protocol <= PROTOCOL_COREPLUS) {
2809                 numtowrite = SVAL(smb_buf(inbuf),-2);
2810                 data = smb_buf(inbuf);
2811         } else {
2812                 numtowrite = SVAL(inbuf,smb_vwv10);
2813                 data = smb_base(inbuf) + SVAL(inbuf, smb_vwv11);
2814         }
2815
2816         /* force the error type */
2817         SCVAL(inbuf,smb_com,SMBwritec);
2818         SCVAL(outbuf,smb_com,SMBwritec);
2819
2820         if (is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)tcount,(SMB_BIG_UINT)startpos, WRITE_LOCK)) {
2821                 END_PROFILE(SMBwritebraw);
2822                 return(ERROR_DOS(ERRDOS,ERRlock));
2823         }
2824
2825         if (numtowrite>0)
2826                 nwritten = write_file(fsp,data,startpos,numtowrite);
2827
2828         DEBUG(3,("writebraw1 fnum=%d start=%.0f num=%d wrote=%d sync=%d\n",
2829                 fsp->fnum, (double)startpos, (int)numtowrite, (int)nwritten, (int)write_through));
2830
2831         if (nwritten < (ssize_t)numtowrite)  {
2832                 END_PROFILE(SMBwritebraw);
2833                 return(UNIXERROR(ERRHRD,ERRdiskfull));
2834         }
2835
2836         total_written = nwritten;
2837
2838         /* Return a message to the redirector to tell it to send more bytes */
2839         SCVAL(outbuf,smb_com,SMBwritebraw);
2840         SSVALS(outbuf,smb_vwv0,-1);
2841         outsize = set_message(inbuf,outbuf,Protocol>PROTOCOL_COREPLUS?1:0,0,True);
2842         show_msg(outbuf);
2843         if (!send_smb(smbd_server_fd(),outbuf))
2844                 exit_server_cleanly("reply_writebraw: send_smb failed.");
2845
2846         /* Now read the raw data into the buffer and write it */
2847         if (read_smb_length(smbd_server_fd(),inbuf,SMB_SECONDARY_WAIT) == -1) {
2848                 exit_server_cleanly("secondary writebraw failed");
2849         }
2850
2851         /* Even though this is not an smb message, smb_len returns the generic length of an smb message */
2852         numtowrite = smb_len(inbuf);
2853
2854         /* Set up outbuf to return the correct return */
2855         outsize = set_message(inbuf,outbuf,1,0,True);
2856         SCVAL(outbuf,smb_com,SMBwritec);
2857
2858         if (numtowrite != 0) {
2859
2860                 if (numtowrite > BUFFER_SIZE) {
2861                         DEBUG(0,("reply_writebraw: Oversize secondary write raw requested (%u). Terminating\n",
2862                                 (unsigned int)numtowrite ));
2863                         exit_server_cleanly("secondary writebraw failed");
2864                 }
2865
2866                 if (tcount > nwritten+numtowrite) {
2867                         DEBUG(3,("Client overestimated the write %d %d %d\n",
2868                                 (int)tcount,(int)nwritten,(int)numtowrite));
2869                 }
2870
2871                 if (read_data( smbd_server_fd(), inbuf+4, numtowrite) != numtowrite ) {
2872                         DEBUG(0,("reply_writebraw: Oversize secondary write raw read failed (%s). Terminating\n",
2873                                 strerror(errno) ));
2874                         exit_server_cleanly("secondary writebraw failed");
2875                 }
2876
2877                 nwritten = write_file(fsp,inbuf+4,startpos+nwritten,numtowrite);
2878                 if (nwritten == -1) {
2879                         END_PROFILE(SMBwritebraw);
2880                         return(UNIXERROR(ERRHRD,ERRdiskfull));
2881                 }
2882
2883                 if (nwritten < (ssize_t)numtowrite) {
2884                         SCVAL(outbuf,smb_rcls,ERRHRD);
2885                         SSVAL(outbuf,smb_err,ERRdiskfull);
2886                 }
2887
2888                 if (nwritten > 0)
2889                         total_written += nwritten;
2890         }
2891
2892         SSVAL(outbuf,smb_vwv0,total_written);
2893
2894         sync_file(conn, fsp, write_through);
2895
2896         DEBUG(3,("writebraw2 fnum=%d start=%.0f num=%d wrote=%d\n",
2897                 fsp->fnum, (double)startpos, (int)numtowrite,(int)total_written));
2898
2899         /* we won't return a status if write through is not selected - this follows what WfWg does */
2900         END_PROFILE(SMBwritebraw);
2901         if (!write_through && total_written==tcount) {
2902
2903 #if RABBIT_PELLET_FIX
2904                 /*
2905                  * Fix for "rabbit pellet" mode, trigger an early TCP ack by
2906                  * sending a SMBkeepalive. Thanks to DaveCB at Sun for this. JRA.
2907                  */
2908                 if (!send_keepalive(smbd_server_fd()))
2909                         exit_server_cleanly("reply_writebraw: send of keepalive failed");
2910 #endif
2911                 return(-1);
2912         }
2913
2914         return(outsize);
2915 }
2916
2917 #undef DBGC_CLASS
2918 #define DBGC_CLASS DBGC_LOCKING
2919
2920 /****************************************************************************
2921  Reply to a writeunlock (core+).
2922 ****************************************************************************/
2923
2924 int reply_writeunlock(connection_struct *conn, char *inbuf,char *outbuf,
2925                       int size, int dum_buffsize)
2926 {
2927         ssize_t nwritten = -1;
2928         size_t numtowrite;
2929         SMB_OFF_T startpos;
2930         char *data;
2931         NTSTATUS status = NT_STATUS_OK;
2932         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
2933         int outsize = 0;
2934         START_PROFILE(SMBwriteunlock);
2935
2936         CHECK_FSP(fsp,conn);
2937         if (!CHECK_WRITE(fsp)) {
2938                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
2939         }
2940
2941         numtowrite = SVAL(inbuf,smb_vwv1);
2942         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv2);
2943         data = smb_buf(inbuf) + 3;
2944
2945         if (numtowrite && is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)numtowrite,(SMB_BIG_UINT)startpos, WRITE_LOCK)) {
2946                 END_PROFILE(SMBwriteunlock);
2947                 return ERROR_DOS(ERRDOS,ERRlock);
2948         }
2949
2950         /* The special X/Open SMB protocol handling of
2951            zero length writes is *NOT* done for
2952            this call */
2953         if(numtowrite == 0) {
2954                 nwritten = 0;
2955         } else {
2956                 nwritten = write_file(fsp,data,startpos,numtowrite);
2957         }
2958
2959         sync_file(conn, fsp, False /* write through */);
2960
2961         if(((nwritten == 0) && (numtowrite != 0))||(nwritten < 0)) {
2962                 END_PROFILE(SMBwriteunlock);
2963                 return(UNIXERROR(ERRHRD,ERRdiskfull));
2964         }
2965
2966         if (numtowrite) {
2967                 status = do_unlock(smbd_messaging_context(),
2968                                 fsp,
2969                                 (uint32)SVAL(inbuf,smb_pid),
2970                                 (SMB_BIG_UINT)numtowrite,
2971                                 (SMB_BIG_UINT)startpos,
2972                                 WINDOWS_LOCK);
2973
2974                 if (NT_STATUS_V(status)) {
2975                         END_PROFILE(SMBwriteunlock);
2976                         return ERROR_NT(status);
2977                 }
2978         }
2979
2980         outsize = set_message(inbuf,outbuf,1,0,True);
2981
2982         SSVAL(outbuf,smb_vwv0,nwritten);
2983
2984         DEBUG(3,("writeunlock fnum=%d num=%d wrote=%d\n",
2985                  fsp->fnum, (int)numtowrite, (int)nwritten));
2986
2987         END_PROFILE(SMBwriteunlock);
2988         return outsize;
2989 }
2990
2991 #undef DBGC_CLASS
2992 #define DBGC_CLASS DBGC_ALL
2993
2994 /****************************************************************************
2995  Reply to a write.
2996 ****************************************************************************/
2997
2998 int reply_write(connection_struct *conn, char *inbuf,char *outbuf,int size,int dum_buffsize)
2999 {
3000         size_t numtowrite;
3001         ssize_t nwritten = -1;
3002         SMB_OFF_T startpos;
3003         char *data;
3004         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3005         int outsize = 0;
3006         START_PROFILE(SMBwrite);
3007
3008         /* If it's an IPC, pass off the pipe handler. */
3009         if (IS_IPC(conn)) {
3010                 END_PROFILE(SMBwrite);
3011                 return reply_pipe_write(inbuf,outbuf,size,dum_buffsize);
3012         }
3013
3014         CHECK_FSP(fsp,conn);
3015         if (!CHECK_WRITE(fsp)) {
3016                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
3017         }
3018
3019         numtowrite = SVAL(inbuf,smb_vwv1);
3020         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv2);
3021         data = smb_buf(inbuf) + 3;
3022
3023         if (is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)numtowrite,(SMB_BIG_UINT)startpos, WRITE_LOCK)) {
3024                 END_PROFILE(SMBwrite);
3025                 return ERROR_DOS(ERRDOS,ERRlock);
3026         }
3027
3028         /*
3029          * X/Open SMB protocol says that if smb_vwv1 is
3030          * zero then the file size should be extended or
3031          * truncated to the size given in smb_vwv[2-3].
3032          */
3033
3034         if(numtowrite == 0) {
3035                 /*
3036                  * This is actually an allocate call, and set EOF. JRA.
3037                  */
3038                 nwritten = vfs_allocate_file_space(fsp, (SMB_OFF_T)startpos);
3039                 if (nwritten < 0) {
3040                         END_PROFILE(SMBwrite);
3041                         return ERROR_NT(NT_STATUS_DISK_FULL);
3042                 }
3043                 nwritten = vfs_set_filelen(fsp, (SMB_OFF_T)startpos);
3044                 if (nwritten < 0) {
3045                         END_PROFILE(SMBwrite);
3046                         return ERROR_NT(NT_STATUS_DISK_FULL);
3047                 }
3048         } else
3049                 nwritten = write_file(fsp,data,startpos,numtowrite);
3050
3051         sync_file(conn, fsp, False);
3052
3053         if(((nwritten == 0) && (numtowrite != 0))||(nwritten < 0)) {
3054                 END_PROFILE(SMBwrite);
3055                 return(UNIXERROR(ERRHRD,ERRdiskfull));
3056         }
3057
3058         outsize = set_message(inbuf,outbuf,1,0,True);
3059
3060         SSVAL(outbuf,smb_vwv0,nwritten);
3061
3062         if (nwritten < (ssize_t)numtowrite) {
3063                 SCVAL(outbuf,smb_rcls,ERRHRD);
3064                 SSVAL(outbuf,smb_err,ERRdiskfull);
3065         }
3066
3067         DEBUG(3,("write fnum=%d num=%d wrote=%d\n", fsp->fnum, (int)numtowrite, (int)nwritten));
3068
3069         END_PROFILE(SMBwrite);
3070         return(outsize);
3071 }
3072
3073 /****************************************************************************
3074  Reply to a write and X.
3075 ****************************************************************************/
3076
3077 int reply_write_and_X(connection_struct *conn, char *inbuf,char *outbuf,int length,int bufsize)
3078 {
3079         files_struct *fsp = file_fsp(inbuf,smb_vwv2);
3080         SMB_OFF_T startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv3);
3081         size_t numtowrite = SVAL(inbuf,smb_vwv10);
3082         BOOL write_through = BITSETW(inbuf+smb_vwv7,0);
3083         ssize_t nwritten = -1;
3084         unsigned int smb_doff = SVAL(inbuf,smb_vwv11);
3085         unsigned int smblen = smb_len(inbuf);
3086         char *data;
3087         BOOL large_writeX = ((CVAL(inbuf,smb_wct) == 14) && (smblen > 0xFFFF));
3088         START_PROFILE(SMBwriteX);
3089
3090         /* If it's an IPC, pass off the pipe handler. */
3091         if (IS_IPC(conn)) {
3092                 END_PROFILE(SMBwriteX);
3093                 return reply_pipe_write_and_X(inbuf,outbuf,length,bufsize);
3094         }
3095
3096         CHECK_FSP(fsp,conn);
3097         if (!CHECK_WRITE(fsp)) {
3098                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
3099         }
3100
3101         set_message(inbuf,outbuf,6,0,True);
3102
3103         /* Deal with possible LARGE_WRITEX */
3104         if (large_writeX) {
3105                 numtowrite |= ((((size_t)SVAL(inbuf,smb_vwv9)) & 1 )<<16);
3106         }
3107
3108         if(smb_doff > smblen || (smb_doff + numtowrite > smblen)) {
3109                 END_PROFILE(SMBwriteX);
3110                 return ERROR_DOS(ERRDOS,ERRbadmem);
3111         }
3112
3113         data = smb_base(inbuf) + smb_doff;
3114
3115         if(CVAL(inbuf,smb_wct) == 14) {
3116 #ifdef LARGE_SMB_OFF_T
3117                 /*
3118                  * This is a large offset (64 bit) write.
3119                  */
3120                 startpos |= (((SMB_OFF_T)IVAL(inbuf,smb_vwv12)) << 32);
3121
3122 #else /* !LARGE_SMB_OFF_T */
3123
3124                 /*
3125                  * Ensure we haven't been sent a >32 bit offset.
3126                  */
3127
3128                 if(IVAL(inbuf,smb_vwv12) != 0) {
3129                         DEBUG(0,("reply_write_and_X - large offset (%x << 32) used and we don't support \
3130 64 bit offsets.\n", (unsigned int)IVAL(inbuf,smb_vwv12) ));
3131                         END_PROFILE(SMBwriteX);
3132                         return ERROR_DOS(ERRDOS,ERRbadaccess);
3133                 }
3134
3135 #endif /* LARGE_SMB_OFF_T */
3136         }
3137
3138         if (is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)numtowrite,(SMB_BIG_UINT)startpos, WRITE_LOCK)) {
3139                 END_PROFILE(SMBwriteX);
3140                 return ERROR_DOS(ERRDOS,ERRlock);
3141         }
3142
3143         /* X/Open SMB protocol says that, unlike SMBwrite
3144         if the length is zero then NO truncation is
3145         done, just a write of zero. To truncate a file,
3146         use SMBwrite. */
3147
3148         if(numtowrite == 0) {
3149                 nwritten = 0;
3150         } else {
3151
3152                 if (schedule_aio_write_and_X(conn, inbuf, outbuf, length, bufsize,
3153                                         fsp,data,startpos,numtowrite)) {
3154                         END_PROFILE(SMBwriteX);
3155                         return -1;
3156                 }
3157
3158                 nwritten = write_file(fsp,data,startpos,numtowrite);
3159         }
3160
3161         if(((nwritten == 0) && (numtowrite != 0))||(nwritten < 0)) {
3162                 END_PROFILE(SMBwriteX);
3163                 return(UNIXERROR(ERRHRD,ERRdiskfull));
3164         }
3165
3166         SSVAL(outbuf,smb_vwv2,nwritten);
3167         if (large_writeX)
3168                 SSVAL(outbuf,smb_vwv4,(nwritten>>16)&1);
3169
3170         if (nwritten < (ssize_t)numtowrite) {
3171                 SCVAL(outbuf,smb_rcls,ERRHRD);
3172                 SSVAL(outbuf,smb_err,ERRdiskfull);
3173         }
3174
3175         DEBUG(3,("writeX fnum=%d num=%d wrote=%d\n",
3176                 fsp->fnum, (int)numtowrite, (int)nwritten));
3177
3178         sync_file(conn, fsp, write_through);
3179
3180         END_PROFILE(SMBwriteX);
3181         return chain_reply(inbuf,outbuf,length,bufsize);
3182 }
3183
3184 /****************************************************************************
3185  Reply to a lseek.
3186 ****************************************************************************/
3187
3188 int reply_lseek(connection_struct *conn, char *inbuf,char *outbuf, int size, int dum_buffsize)
3189 {
3190         SMB_OFF_T startpos;
3191         SMB_OFF_T res= -1;
3192         int mode,umode;
3193         int outsize = 0;
3194         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3195         START_PROFILE(SMBlseek);
3196
3197         CHECK_FSP(fsp,conn);
3198
3199         flush_write_cache(fsp, SEEK_FLUSH);
3200
3201         mode = SVAL(inbuf,smb_vwv1) & 3;
3202         /* NB. This doesn't use IVAL_TO_SMB_OFF_T as startpos can be signed in this case. */
3203         startpos = (SMB_OFF_T)IVALS(inbuf,smb_vwv2);
3204
3205         switch (mode) {
3206                 case 0:
3207                         umode = SEEK_SET;
3208                         res = startpos;
3209                         break;
3210                 case 1:
3211                         umode = SEEK_CUR;
3212                         res = fsp->fh->pos + startpos;
3213                         break;
3214                 case 2:
3215                         umode = SEEK_END;
3216                         break;
3217                 default:
3218                         umode = SEEK_SET;
3219                         res = startpos;
3220                         break;
3221         }
3222
3223         if (umode == SEEK_END) {
3224                 if((res = SMB_VFS_LSEEK(fsp,fsp->fh->fd,startpos,umode)) == -1) {
3225                         if(errno == EINVAL) {
3226                                 SMB_OFF_T current_pos = startpos;
3227                                 SMB_STRUCT_STAT sbuf;
3228
3229                                 if(SMB_VFS_FSTAT(fsp,fsp->fh->fd, &sbuf) == -1) {
3230                                         END_PROFILE(SMBlseek);
3231                                         return(UNIXERROR(ERRDOS,ERRnoaccess));
3232                                 }
3233
3234                                 current_pos += sbuf.st_size;
3235                                 if(current_pos < 0)
3236                                         res = SMB_VFS_LSEEK(fsp,fsp->fh->fd,0,SEEK_SET);
3237                         }
3238                 }
3239
3240                 if(res == -1) {
3241                         END_PROFILE(SMBlseek);
3242                         return(UNIXERROR(ERRDOS,ERRnoaccess));
3243                 }
3244         }
3245
3246         fsp->fh->pos = res;
3247
3248         outsize = set_message(inbuf,outbuf,2,0,True);
3249         SIVAL(outbuf,smb_vwv0,res);
3250
3251         DEBUG(3,("lseek fnum=%d ofs=%.0f newpos = %.0f mode=%d\n",
3252                 fsp->fnum, (double)startpos, (double)res, mode));
3253
3254         END_PROFILE(SMBlseek);
3255         return(outsize);
3256 }
3257
3258 /****************************************************************************
3259  Reply to a flush.
3260 ****************************************************************************/
3261
3262 int reply_flush(connection_struct *conn, char *inbuf,char *outbuf, int size, int dum_buffsize)
3263 {
3264         int outsize = set_message(inbuf,outbuf,0,0,False);
3265         uint16 fnum = SVAL(inbuf,smb_vwv0);
3266         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3267         START_PROFILE(SMBflush);
3268
3269         if (fnum != 0xFFFF)
3270                 CHECK_FSP(fsp,conn);
3271
3272         if (!fsp) {
3273                 file_sync_all(conn);
3274         } else {
3275                 sync_file(conn,fsp, True);
3276         }
3277
3278         DEBUG(3,("flush\n"));
3279         END_PROFILE(SMBflush);
3280         return(outsize);
3281 }
3282
3283 /****************************************************************************
3284  Reply to a exit.
3285  conn POINTER CAN BE NULL HERE !
3286 ****************************************************************************/
3287
3288 int reply_exit(connection_struct *conn,
3289                char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3290 {
3291         int outsize;
3292         START_PROFILE(SMBexit);
3293
3294         file_close_pid(SVAL(inbuf,smb_pid),SVAL(inbuf,smb_uid));
3295
3296         outsize = set_message(inbuf,outbuf,0,0,False);
3297
3298         DEBUG(3,("exit\n"));
3299
3300         END_PROFILE(SMBexit);
3301         return(outsize);
3302 }
3303
3304 /****************************************************************************
3305  Reply to a close - has to deal with closing a directory opened by NT SMB's.
3306 ****************************************************************************/
3307
3308 int reply_close(connection_struct *conn, char *inbuf,char *outbuf, int size,
3309                 int dum_buffsize)
3310 {
3311         NTSTATUS status = NT_STATUS_OK;
3312         int outsize = 0;
3313         files_struct *fsp = NULL;
3314         START_PROFILE(SMBclose);
3315
3316         outsize = set_message(inbuf,outbuf,0,0,False);
3317
3318         /* If it's an IPC, pass off to the pipe handler. */
3319         if (IS_IPC(conn)) {
3320                 END_PROFILE(SMBclose);
3321                 return reply_pipe_close(conn, inbuf,outbuf);
3322         }
3323
3324         fsp = file_fsp(inbuf,smb_vwv0);
3325
3326         /*
3327          * We can only use CHECK_FSP if we know it's not a directory.
3328          */
3329
3330         if(!fsp || (fsp->conn != conn) || (fsp->vuid != current_user.vuid)) {
3331                 END_PROFILE(SMBclose);
3332                 return ERROR_DOS(ERRDOS,ERRbadfid);
3333         }
3334
3335         if(fsp->is_directory) {
3336                 /*
3337                  * Special case - close NT SMB directory handle.
3338                  */
3339                 DEBUG(3,("close directory fnum=%d\n", fsp->fnum));
3340                 status = close_file(fsp,NORMAL_CLOSE);
3341         } else {
3342                 /*
3343                  * Close ordinary file.
3344                  */
3345
3346                 DEBUG(3,("close fd=%d fnum=%d (numopen=%d)\n",
3347                          fsp->fh->fd, fsp->fnum,
3348                          conn->num_files_open));
3349
3350                 /*
3351                  * Take care of any time sent in the close.
3352                  */
3353
3354                 fsp_set_pending_modtime(fsp,
3355                                 convert_time_t_to_timespec(srv_make_unix_date3(inbuf+smb_vwv1)));
3356
3357                 /*
3358                  * close_file() returns the unix errno if an error
3359                  * was detected on close - normally this is due to
3360                  * a disk full error. If not then it was probably an I/O error.
3361                  */
3362
3363                 status = close_file(fsp,NORMAL_CLOSE);
3364         }
3365
3366         if(!NT_STATUS_IS_OK(status)) {
3367                 END_PROFILE(SMBclose);
3368                 return ERROR_NT(status);
3369         }
3370
3371         END_PROFILE(SMBclose);
3372         return(outsize);
3373 }
3374
3375 /****************************************************************************
3376  Reply to a writeclose (Core+ protocol).
3377 ****************************************************************************/
3378
3379 int reply_writeclose(connection_struct *conn,
3380                      char *inbuf,char *outbuf, int size, int dum_buffsize)
3381 {
3382         size_t numtowrite;
3383         ssize_t nwritten = -1;
3384         int outsize = 0;
3385         NTSTATUS close_status = NT_STATUS_OK;
3386         SMB_OFF_T startpos;
3387         char *data;
3388         struct timespec mtime;
3389         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3390         START_PROFILE(SMBwriteclose);
3391
3392         CHECK_FSP(fsp,conn);
3393         if (!CHECK_WRITE(fsp)) {
3394                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
3395         }
3396
3397         numtowrite = SVAL(inbuf,smb_vwv1);
3398         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv2);
3399         mtime = convert_time_t_to_timespec(srv_make_unix_date3(inbuf+smb_vwv4));
3400         data = smb_buf(inbuf) + 1;
3401
3402         if (numtowrite && is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)numtowrite,(SMB_BIG_UINT)startpos, WRITE_LOCK)) {
3403                 END_PROFILE(SMBwriteclose);
3404                 return ERROR_DOS(ERRDOS,ERRlock);
3405         }
3406
3407         nwritten = write_file(fsp,data,startpos,numtowrite);
3408
3409         set_filetime(conn, fsp->fsp_name, mtime);
3410
3411         /*
3412          * More insanity. W2K only closes the file if writelen > 0.
3413          * JRA.
3414          */
3415
3416         if (numtowrite) {
3417                 DEBUG(3,("reply_writeclose: zero length write doesn't close file %s\n",
3418                         fsp->fsp_name ));
3419                 close_status = close_file(fsp,NORMAL_CLOSE);
3420         }
3421
3422         DEBUG(3,("writeclose fnum=%d num=%d wrote=%d (numopen=%d)\n",
3423                  fsp->fnum, (int)numtowrite, (int)nwritten,
3424                  conn->num_files_open));
3425
3426         if(((nwritten == 0) && (numtowrite != 0))||(nwritten < 0)) {
3427                 END_PROFILE(SMBwriteclose);
3428                 return(UNIXERROR(ERRHRD,ERRdiskfull));
3429         }
3430
3431         if(!NT_STATUS_IS_OK(close_status)) {
3432                 END_PROFILE(SMBwriteclose);
3433                 return ERROR_NT(close_status);
3434         }
3435
3436         outsize = set_message(inbuf,outbuf,1,0,True);
3437
3438         SSVAL(outbuf,smb_vwv0,nwritten);
3439         END_PROFILE(SMBwriteclose);
3440         return(outsize);
3441 }
3442
3443 #undef DBGC_CLASS
3444 #define DBGC_CLASS DBGC_LOCKING
3445
3446 /****************************************************************************
3447  Reply to a lock.
3448 ****************************************************************************/
3449
3450 int reply_lock(connection_struct *conn,
3451                char *inbuf,char *outbuf, int length, int dum_buffsize)
3452 {
3453         int outsize = set_message(inbuf,outbuf,0,0,False);
3454         SMB_BIG_UINT count,offset;
3455         NTSTATUS status;
3456         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3457         struct byte_range_lock *br_lck = NULL;
3458
3459         START_PROFILE(SMBlock);
3460
3461         CHECK_FSP(fsp,conn);
3462
3463         release_level_2_oplocks_on_change(fsp);
3464
3465         count = (SMB_BIG_UINT)IVAL(inbuf,smb_vwv1);
3466         offset = (SMB_BIG_UINT)IVAL(inbuf,smb_vwv3);
3467
3468         DEBUG(3,("lock fd=%d fnum=%d offset=%.0f count=%.0f\n",
3469                  fsp->fh->fd, fsp->fnum, (double)offset, (double)count));
3470
3471         br_lck = do_lock(smbd_messaging_context(),
3472                         fsp,
3473                         (uint32)SVAL(inbuf,smb_pid),
3474                         count,
3475                         offset,
3476                         WRITE_LOCK,
3477                         WINDOWS_LOCK,
3478                         False, /* Non-blocking lock. */
3479                         &status,
3480                         NULL);
3481
3482         TALLOC_FREE(br_lck);
3483
3484         if (NT_STATUS_V(status)) {
3485                 END_PROFILE(SMBlock);
3486                 return ERROR_NT(status);
3487         }
3488
3489         END_PROFILE(SMBlock);
3490         return(outsize);
3491 }
3492
3493 /****************************************************************************
3494  Reply to a unlock.
3495 ****************************************************************************/
3496
3497 int reply_unlock(connection_struct *conn, char *inbuf,char *outbuf, int size,
3498                  int dum_buffsize)
3499 {
3500         int outsize = set_message(inbuf,outbuf,0,0,False);
3501         SMB_BIG_UINT count,offset;
3502         NTSTATUS status;
3503         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3504         START_PROFILE(SMBunlock);
3505
3506         CHECK_FSP(fsp,conn);
3507
3508         count = (SMB_BIG_UINT)IVAL(inbuf,smb_vwv1);
3509         offset = (SMB_BIG_UINT)IVAL(inbuf,smb_vwv3);
3510
3511         status = do_unlock(smbd_messaging_context(),
3512                         fsp,
3513                         (uint32)SVAL(inbuf,smb_pid),
3514                         count,
3515                         offset,
3516                         WINDOWS_LOCK);
3517
3518         if (NT_STATUS_V(status)) {
3519                 END_PROFILE(SMBunlock);
3520                 return ERROR_NT(status);
3521         }
3522
3523         DEBUG( 3, ( "unlock fd=%d fnum=%d offset=%.0f count=%.0f\n",
3524                     fsp->fh->fd, fsp->fnum, (double)offset, (double)count ) );
3525
3526         END_PROFILE(SMBunlock);
3527         return(outsize);
3528 }
3529
3530 #undef DBGC_CLASS
3531 #define DBGC_CLASS DBGC_ALL
3532
3533 /****************************************************************************
3534  Reply to a tdis.
3535  conn POINTER CAN BE NULL HERE !
3536 ****************************************************************************/
3537
3538 int reply_tdis(connection_struct *conn,
3539                char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3540 {
3541         int outsize = set_message(inbuf,outbuf,0,0,False);
3542         uint16 vuid;
3543         START_PROFILE(SMBtdis);
3544
3545         vuid = SVAL(inbuf,smb_uid);
3546
3547         if (!conn) {
3548                 DEBUG(4,("Invalid connection in tdis\n"));
3549                 END_PROFILE(SMBtdis);
3550                 return ERROR_DOS(ERRSRV,ERRinvnid);
3551         }
3552
3553         conn->used = False;
3554
3555         close_cnum(conn,vuid);
3556
3557         END_PROFILE(SMBtdis);
3558         return outsize;
3559 }
3560
3561 /****************************************************************************
3562  Reply to a echo.
3563  conn POINTER CAN BE NULL HERE !
3564 ****************************************************************************/
3565
3566 int reply_echo(connection_struct *conn,
3567                char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3568 {
3569         int smb_reverb = SVAL(inbuf,smb_vwv0);
3570         int seq_num;
3571         unsigned int data_len = smb_buflen(inbuf);
3572         int outsize = set_message(inbuf,outbuf,1,data_len,True);
3573         START_PROFILE(SMBecho);
3574
3575         if (data_len > BUFFER_SIZE) {
3576                 DEBUG(0,("reply_echo: data_len too large.\n"));
3577                 END_PROFILE(SMBecho);
3578                 return -1;
3579         }
3580
3581         /* copy any incoming data back out */
3582         if (data_len > 0)
3583                 memcpy(smb_buf(outbuf),smb_buf(inbuf),data_len);
3584
3585         if (smb_reverb > 100) {
3586                 DEBUG(0,("large reverb (%d)?? Setting to 100\n",smb_reverb));
3587                 smb_reverb = 100;
3588         }
3589
3590         for (seq_num =1 ; seq_num <= smb_reverb ; seq_num++) {
3591                 SSVAL(outbuf,smb_vwv0,seq_num);
3592
3593                 smb_setlen(inbuf,outbuf,outsize - 4);
3594
3595                 show_msg(outbuf);
3596                 if (!send_smb(smbd_server_fd(),outbuf))
3597                         exit_server_cleanly("reply_echo: send_smb failed.");
3598         }
3599
3600         DEBUG(3,("echo %d times\n", smb_reverb));
3601
3602         smb_echo_count++;
3603
3604         END_PROFILE(SMBecho);
3605         return -1;
3606 }
3607
3608 /****************************************************************************
3609  Reply to a printopen.
3610 ****************************************************************************/
3611
3612 int reply_printopen(connection_struct *conn,
3613                     char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3614 {
3615         int outsize = 0;
3616         files_struct *fsp;
3617         NTSTATUS status;
3618
3619         START_PROFILE(SMBsplopen);
3620
3621         if (!CAN_PRINT(conn)) {
3622                 END_PROFILE(SMBsplopen);
3623                 return ERROR_DOS(ERRDOS,ERRnoaccess);
3624         }
3625
3626         /* Open for exclusive use, write only. */
3627         status = print_fsp_open(conn, NULL, &fsp);
3628
3629         if (!NT_STATUS_IS_OK(status)) {
3630                 END_PROFILE(SMBsplopen);
3631                 return(ERROR_NT(status));
3632         }
3633
3634         outsize = set_message(inbuf,outbuf,1,0,True);
3635         SSVAL(outbuf,smb_vwv0,fsp->fnum);
3636
3637         DEBUG(3,("openprint fd=%d fnum=%d\n",
3638                  fsp->fh->fd, fsp->fnum));
3639
3640         END_PROFILE(SMBsplopen);
3641         return(outsize);
3642 }
3643
3644 /****************************************************************************
3645  Reply to a printclose.
3646 ****************************************************************************/
3647
3648 int reply_printclose(connection_struct *conn,
3649                      char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3650 {
3651         int outsize = set_message(inbuf,outbuf,0,0,False);
3652         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3653         NTSTATUS status;
3654         START_PROFILE(SMBsplclose);
3655
3656         CHECK_FSP(fsp,conn);
3657
3658         if (!CAN_PRINT(conn)) {
3659                 END_PROFILE(SMBsplclose);
3660                 return ERROR_NT(NT_STATUS_DOS(ERRSRV, ERRerror));
3661         }
3662
3663         DEBUG(3,("printclose fd=%d fnum=%d\n",
3664                  fsp->fh->fd,fsp->fnum));
3665
3666         status = close_file(fsp,NORMAL_CLOSE);
3667
3668         if(!NT_STATUS_IS_OK(status)) {
3669                 END_PROFILE(SMBsplclose);
3670                 return ERROR_NT(status);
3671         }
3672
3673         END_PROFILE(SMBsplclose);
3674         return(outsize);
3675 }
3676
3677 /****************************************************************************
3678  Reply to a printqueue.
3679 ****************************************************************************/
3680
3681 int reply_printqueue(connection_struct *conn,
3682                      char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3683 {
3684         int outsize = set_message(inbuf,outbuf,2,3,True);
3685         int max_count = SVAL(inbuf,smb_vwv0);
3686         int start_index = SVAL(inbuf,smb_vwv1);
3687         START_PROFILE(SMBsplretq);
3688
3689         /* we used to allow the client to get the cnum wrong, but that
3690            is really quite gross and only worked when there was only
3691            one printer - I think we should now only accept it if they
3692            get it right (tridge) */
3693         if (!CAN_PRINT(conn)) {
3694                 END_PROFILE(SMBsplretq);
3695                 return ERROR_DOS(ERRDOS,ERRnoaccess);
3696         }
3697
3698         SSVAL(outbuf,smb_vwv0,0);
3699         SSVAL(outbuf,smb_vwv1,0);
3700         SCVAL(smb_buf(outbuf),0,1);
3701         SSVAL(smb_buf(outbuf),1,0);
3702
3703         DEBUG(3,("printqueue start_index=%d max_count=%d\n",
3704                  start_index, max_count));
3705
3706         {
3707                 print_queue_struct *queue = NULL;
3708                 print_status_struct status;
3709                 char *p = smb_buf(outbuf) + 3;
3710                 int count = print_queue_status(SNUM(conn), &queue, &status);
3711                 int num_to_get = ABS(max_count);
3712                 int first = (max_count>0?start_index:start_index+max_count+1);
3713                 int i;
3714
3715                 if (first >= count)
3716                         num_to_get = 0;
3717                 else
3718                         num_to_get = MIN(num_to_get,count-first);
3719
3720
3721                 for (i=first;i<first+num_to_get;i++) {
3722                         srv_put_dos_date2(p,0,queue[i].time);
3723                         SCVAL(p,4,(queue[i].status==LPQ_PRINTING?2:3));
3724                         SSVAL(p,5, queue[i].job);
3725                         SIVAL(p,7,queue[i].size);
3726                         SCVAL(p,11,0);
3727                         srvstr_push(outbuf, p+12, queue[i].fs_user, 16, STR_ASCII);
3728                         p += 28;
3729                 }
3730
3731                 if (count > 0) {
3732                         outsize = set_message(inbuf,outbuf,2,28*count+3,False);
3733                         SSVAL(outbuf,smb_vwv0,count);
3734                         SSVAL(outbuf,smb_vwv1,(max_count>0?first+count:first-1));
3735                         SCVAL(smb_buf(outbuf),0,1);
3736                         SSVAL(smb_buf(outbuf),1,28*count);
3737                 }
3738
3739                 SAFE_FREE(queue);
3740
3741                 DEBUG(3,("%d entries returned in queue\n",count));
3742         }
3743
3744         END_PROFILE(SMBsplretq);
3745         return(outsize);
3746 }
3747
3748 /****************************************************************************
3749  Reply to a printwrite.
3750 ****************************************************************************/
3751
3752 int reply_printwrite(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3753 {
3754         int numtowrite;
3755         int outsize = set_message(inbuf,outbuf,0,0,False);
3756         char *data;
3757         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
3758
3759         START_PROFILE(SMBsplwr);
3760
3761         if (!CAN_PRINT(conn)) {
3762                 END_PROFILE(SMBsplwr);
3763                 return ERROR_DOS(ERRDOS,ERRnoaccess);
3764         }
3765
3766         CHECK_FSP(fsp,conn);
3767         if (!CHECK_WRITE(fsp)) {
3768                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
3769         }
3770
3771         numtowrite = SVAL(smb_buf(inbuf),1);
3772         data = smb_buf(inbuf) + 3;
3773
3774         if (write_file(fsp,data,-1,numtowrite) != numtowrite) {
3775                 END_PROFILE(SMBsplwr);
3776                 return(UNIXERROR(ERRHRD,ERRdiskfull));
3777         }
3778
3779         DEBUG( 3, ( "printwrite fnum=%d num=%d\n", fsp->fnum, numtowrite ) );
3780
3781         END_PROFILE(SMBsplwr);
3782         return(outsize);
3783 }
3784
3785 /****************************************************************************
3786  Reply to a mkdir.
3787 ****************************************************************************/
3788
3789 int reply_mkdir(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
3790 {
3791         pstring directory;
3792         int outsize;
3793         NTSTATUS status;
3794         SMB_STRUCT_STAT sbuf;
3795
3796         START_PROFILE(SMBmkdir);
3797
3798         srvstr_get_path(inbuf, directory, smb_buf(inbuf) + 1, sizeof(directory), 0, STR_TERMINATE, &status);
3799         if (!NT_STATUS_IS_OK(status)) {
3800                 END_PROFILE(SMBmkdir);
3801                 return ERROR_NT(status);
3802         }
3803
3804         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, directory);
3805         if (!NT_STATUS_IS_OK(status)) {
3806                 END_PROFILE(SMBmkdir);
3807                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
3808                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
3809                 }
3810                 return ERROR_NT(status);
3811         }
3812
3813         status = unix_convert(conn, directory, False, NULL, &sbuf);
3814         if (!NT_STATUS_IS_OK(status)) {
3815                 END_PROFILE(SMBmkdir);
3816                 return ERROR_NT(status);
3817         }
3818
3819         status = check_name(conn, directory);
3820         if (!NT_STATUS_IS_OK(status)) {
3821                 END_PROFILE(SMBmkdir);
3822                 return ERROR_NT(status);
3823         }
3824
3825         status = create_directory(conn, directory);
3826
3827         DEBUG(5, ("create_directory returned %s\n", nt_errstr(status)));
3828
3829         if (!NT_STATUS_IS_OK(status)) {
3830
3831                 if (!use_nt_status()
3832                     && NT_STATUS_EQUAL(status,
3833                                        NT_STATUS_OBJECT_NAME_COLLISION)) {
3834                         /*
3835                          * Yes, in the DOS error code case we get a
3836                          * ERRDOS:ERRnoaccess here. See BASE-SAMBA3ERROR
3837                          * samba4 torture test.
3838                          */
3839                         status = NT_STATUS_DOS(ERRDOS, ERRnoaccess);
3840                 }
3841
3842                 END_PROFILE(SMBmkdir);
3843                 return ERROR_NT(status);
3844         }
3845
3846         outsize = set_message(inbuf,outbuf,0,0,False);
3847
3848         DEBUG( 3, ( "mkdir %s ret=%d\n", directory, outsize ) );
3849
3850         END_PROFILE(SMBmkdir);
3851         return(outsize);
3852 }
3853
3854 /****************************************************************************
3855  Static function used by reply_rmdir to delete an entire directory
3856  tree recursively. Return True on ok, False on fail.
3857 ****************************************************************************/
3858
3859 static BOOL recursive_rmdir(connection_struct *conn, char *directory)
3860 {
3861         const char *dname = NULL;
3862         BOOL ret = True;
3863         long offset = 0;
3864         struct smb_Dir *dir_hnd = OpenDir(conn, directory, NULL, 0);
3865
3866         if(dir_hnd == NULL)
3867                 return False;
3868
3869         while((dname = ReadDirName(dir_hnd, &offset))) {
3870                 pstring fullname;
3871                 SMB_STRUCT_STAT st;
3872
3873                 if((strcmp(dname, ".") == 0) || (strcmp(dname, "..")==0))
3874                         continue;
3875
3876                 if (!is_visible_file(conn, directory, dname, &st, False))
3877                         continue;
3878
3879                 /* Construct the full name. */
3880                 if(strlen(directory) + strlen(dname) + 1 >= sizeof(fullname)) {
3881                         errno = ENOMEM;
3882                         ret = False;
3883                         break;
3884                 }
3885
3886                 pstrcpy(fullname, directory);
3887                 pstrcat(fullname, "/");
3888                 pstrcat(fullname, dname);
3889
3890                 if(SMB_VFS_LSTAT(conn,fullname, &st) != 0) {
3891                         ret = False;
3892                         break;
3893                 }
3894
3895                 if(st.st_mode & S_IFDIR) {
3896                         if(!recursive_rmdir(conn, fullname)) {
3897                                 ret = False;
3898                                 break;
3899                         }
3900                         if(SMB_VFS_RMDIR(conn,fullname) != 0) {
3901                                 ret = False;
3902                                 break;
3903                         }
3904                 } else if(SMB_VFS_UNLINK(conn,fullname) != 0) {
3905                         ret = False;
3906                         break;
3907                 }
3908         }
3909         CloseDir(dir_hnd);
3910         return ret;
3911 }
3912
3913 /****************************************************************************
3914  The internals of the rmdir code - called elsewhere.
3915 ****************************************************************************/
3916
3917 NTSTATUS rmdir_internals(connection_struct *conn, const char *directory)
3918 {
3919         int ret;
3920         SMB_STRUCT_STAT st;
3921
3922         /* Might be a symlink. */
3923         if(SMB_VFS_LSTAT(conn, directory, &st) != 0) {
3924                 return map_nt_error_from_unix(errno);
3925         }
3926
3927         if (S_ISLNK(st.st_mode)) {
3928                 /* Is what it points to a directory ? */
3929                 if(SMB_VFS_STAT(conn, directory, &st) != 0) {
3930                         return map_nt_error_from_unix(errno);
3931                 }
3932                 if (!(S_ISDIR(st.st_mode))) {
3933                         return NT_STATUS_NOT_A_DIRECTORY;
3934                 }
3935                 ret = SMB_VFS_UNLINK(conn,directory);
3936         } else {
3937                 ret = SMB_VFS_RMDIR(conn,directory);
3938         }
3939         if (ret == 0) {
3940                 notify_fname(conn, NOTIFY_ACTION_REMOVED,
3941                              FILE_NOTIFY_CHANGE_DIR_NAME,
3942                              directory);
3943                 return NT_STATUS_OK;
3944         }
3945
3946         if(((errno == ENOTEMPTY)||(errno == EEXIST)) && lp_veto_files(SNUM(conn))) {
3947                 /*
3948                  * Check to see if the only thing in this directory are
3949                  * vetoed files/directories. If so then delete them and
3950                  * retry. If we fail to delete any of them (and we *don't*
3951                  * do a recursive delete) then fail the rmdir.
3952                  */
3953                 const char *dname;
3954                 long dirpos = 0;
3955                 struct smb_Dir *dir_hnd = OpenDir(conn, directory, NULL, 0);
3956
3957                 if(dir_hnd == NULL) {
3958                         errno = ENOTEMPTY;
3959                         goto err;
3960                 }
3961
3962                 while ((dname = ReadDirName(dir_hnd,&dirpos))) {
3963                         if((strcmp(dname, ".") == 0) || (strcmp(dname, "..")==0))
3964                                 continue;
3965                         if (!is_visible_file(conn, directory, dname, &st, False))
3966                                 continue;
3967                         if(!IS_VETO_PATH(conn, dname)) {
3968                                 CloseDir(dir_hnd);
3969                                 errno = ENOTEMPTY;
3970                                 goto err;
3971                         }
3972                 }
3973
3974                 /* We only have veto files/directories. Recursive delete. */
3975
3976                 RewindDir(dir_hnd,&dirpos);
3977                 while ((dname = ReadDirName(dir_hnd,&dirpos))) {
3978                         pstring fullname;
3979
3980                         if((strcmp(dname, ".") == 0) || (strcmp(dname, "..")==0))
3981                                 continue;
3982                         if (!is_visible_file(conn, directory, dname, &st, False))
3983                                 continue;
3984
3985                         /* Construct the full name. */
3986                         if(strlen(directory) + strlen(dname) + 1 >= sizeof(fullname)) {
3987                                 errno = ENOMEM;
3988                                 break;
3989                         }
3990
3991                         pstrcpy(fullname, directory);
3992                         pstrcat(fullname, "/");
3993                         pstrcat(fullname, dname);
3994
3995                         if(SMB_VFS_LSTAT(conn,fullname, &st) != 0)
3996                                 break;
3997                         if(st.st_mode & S_IFDIR) {
3998                                 if(lp_recursive_veto_delete(SNUM(conn))) {
3999                                         if(!recursive_rmdir(conn, fullname))
4000                                                 break;
4001                                 }
4002                                 if(SMB_VFS_RMDIR(conn,fullname) != 0)
4003                                         break;
4004                         } else if(SMB_VFS_UNLINK(conn,fullname) != 0)
4005                                 break;
4006                 }
4007                 CloseDir(dir_hnd);
4008                 /* Retry the rmdir */
4009                 ret = SMB_VFS_RMDIR(conn,directory);
4010         }
4011
4012   err:
4013
4014         if (ret != 0) {
4015                 DEBUG(3,("rmdir_internals: couldn't remove directory %s : "
4016                          "%s\n", directory,strerror(errno)));
4017                 return map_nt_error_from_unix(errno);
4018         }
4019
4020         notify_fname(conn, NOTIFY_ACTION_REMOVED,
4021                      FILE_NOTIFY_CHANGE_DIR_NAME,
4022                      directory);
4023
4024         return NT_STATUS_OK;
4025 }
4026
4027 /****************************************************************************
4028  Reply to a rmdir.
4029 ****************************************************************************/
4030
4031 int reply_rmdir(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
4032 {
4033         pstring directory;
4034         int outsize = 0;
4035         SMB_STRUCT_STAT sbuf;
4036         NTSTATUS status;
4037         START_PROFILE(SMBrmdir);
4038
4039         srvstr_get_path(inbuf, directory, smb_buf(inbuf) + 1, sizeof(directory), 0, STR_TERMINATE, &status);
4040         if (!NT_STATUS_IS_OK(status)) {
4041                 END_PROFILE(SMBrmdir);
4042                 return ERROR_NT(status);
4043         }
4044
4045         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, directory);
4046         if (!NT_STATUS_IS_OK(status)) {
4047                 END_PROFILE(SMBrmdir);
4048                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
4049                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
4050                 }
4051                 return ERROR_NT(status);
4052         }
4053
4054         status = unix_convert(conn, directory, False, NULL, &sbuf);
4055         if (!NT_STATUS_IS_OK(status)) {
4056                 END_PROFILE(SMBrmdir);
4057                 return ERROR_NT(status);
4058         }
4059
4060         status = check_name(conn, directory);
4061         if (!NT_STATUS_IS_OK(status)) {
4062                 END_PROFILE(SMBrmdir);
4063                 return ERROR_NT(status);
4064         }
4065
4066         dptr_closepath(directory,SVAL(inbuf,smb_pid));
4067         status = rmdir_internals(conn, directory);
4068         if (!NT_STATUS_IS_OK(status)) {
4069                 END_PROFILE(SMBrmdir);
4070                 return ERROR_NT(status);
4071         }
4072
4073         outsize = set_message(inbuf,outbuf,0,0,False);
4074
4075         DEBUG( 3, ( "rmdir %s\n", directory ) );
4076
4077         END_PROFILE(SMBrmdir);
4078         return(outsize);
4079 }
4080
4081 /*******************************************************************
4082  Resolve wildcards in a filename rename.
4083  Note that name is in UNIX charset and thus potentially can be more
4084  than fstring buffer (255 bytes) especially in default UTF-8 case.
4085  Therefore, we use pstring inside and all calls should ensure that
4086  name2 is at least pstring-long (they do already)
4087 ********************************************************************/
4088
4089 static BOOL resolve_wildcards(const char *name1, char *name2)
4090 {
4091         pstring root1,root2;
4092         pstring ext1,ext2;
4093         char *p,*p2, *pname1, *pname2;
4094         int available_space, actual_space;
4095
4096         pname1 = strrchr_m(name1,'/');
4097         pname2 = strrchr_m(name2,'/');
4098
4099         if (!pname1 || !pname2)
4100                 return(False);
4101
4102         pstrcpy(root1,pname1);
4103         pstrcpy(root2,pname2);
4104         p = strrchr_m(root1,'.');
4105         if (p) {
4106                 *p = 0;
4107                 pstrcpy(ext1,p+1);
4108         } else {
4109                 pstrcpy(ext1,"");
4110         }
4111         p = strrchr_m(root2,'.');
4112         if (p) {
4113                 *p = 0;
4114                 pstrcpy(ext2,p+1);
4115         } else {
4116                 pstrcpy(ext2,"");
4117         }
4118
4119         p = root1;
4120         p2 = root2;
4121         while (*p2) {
4122                 if (*p2 == '?') {
4123                         *p2 = *p;
4124                         p2++;
4125                 } else if (*p2 == '*') {
4126                         pstrcpy(p2, p);
4127                         break;
4128                 } else {
4129                         p2++;
4130                 }
4131                 if (*p)
4132                         p++;
4133         }
4134
4135         p = ext1;
4136         p2 = ext2;
4137         while (*p2) {
4138                 if (*p2 == '?') {
4139                         *p2 = *p;
4140                         p2++;
4141                 } else if (*p2 == '*') {
4142                         pstrcpy(p2, p);
4143                         break;
4144                 } else {
4145                         p2++;
4146                 }
4147                 if (*p)
4148                         p++;
4149         }
4150
4151         available_space = sizeof(pstring) - PTR_DIFF(pname2, name2);
4152
4153         if (ext2[0]) {
4154                 actual_space = snprintf(pname2, available_space - 1, "%s.%s", root2, ext2);
4155                 if (actual_space >= available_space - 1) {
4156                         DEBUG(1,("resolve_wildcards: can't fit resolved name into specified buffer (overrun by %d bytes)\n",
4157                                 actual_space - available_space));
4158                 }
4159         } else {
4160                 pstrcpy_base(pname2, root2, name2);
4161         }
4162
4163         return(True);
4164 }
4165
4166 /****************************************************************************
4167  Ensure open files have their names updated. Updated to notify other smbd's
4168  asynchronously.
4169 ****************************************************************************/
4170
4171 static void rename_open_files(connection_struct *conn,
4172                               struct share_mode_lock *lck,
4173                               const char *newname)
4174 {
4175         files_struct *fsp;
4176         BOOL did_rename = False;
4177
4178         for(fsp = file_find_di_first(lck->id); fsp;
4179             fsp = file_find_di_next(fsp)) {
4180                 /* fsp_name is a relative path under the fsp. To change this for other
4181                    sharepaths we need to manipulate relative paths. */
4182                 /* TODO - create the absolute path and manipulate the newname
4183                    relative to the sharepath. */
4184                 if (fsp->conn != conn) {
4185                         continue;
4186                 }
4187                 DEBUG(10,("rename_open_files: renaming file fnum %d (file_id %s) from %s -> %s\n",
4188                           fsp->fnum, file_id_static_string(&fsp->file_id),
4189                         fsp->fsp_name, newname ));
4190                 string_set(&fsp->fsp_name, newname);
4191                 did_rename = True;
4192         }
4193
4194         if (!did_rename) {
4195                 DEBUG(10,("rename_open_files: no open files on file_id %s for %s\n",
4196                           file_id_static_string(&lck->id), newname ));
4197         }
4198
4199         /* Send messages to all smbd's (not ourself) that the name has changed. */
4200         rename_share_filename(smbd_messaging_context(), lck, conn->connectpath,
4201                               newname);
4202 }
4203
4204 /****************************************************************************
4205  We need to check if the source path is a parent directory of the destination
4206  (ie. a rename of /foo/bar/baz -> /foo/bar/baz/bibble/bobble. If so we must
4207  refuse the rename with a sharing violation. Under UNIX the above call can
4208  *succeed* if /foo/bar/baz is a symlink to another area in the share. We
4209  probably need to check that the client is a Windows one before disallowing
4210  this as a UNIX client (one with UNIX extensions) can know the source is a
4211  symlink and make this decision intelligently. Found by an excellent bug
4212  report from <AndyLiebman@aol.com>.
4213 ****************************************************************************/
4214
4215 static BOOL rename_path_prefix_equal(const char *src, const char *dest)
4216 {
4217         const char *psrc = src;
4218         const char *pdst = dest;
4219         size_t slen;
4220
4221         if (psrc[0] == '.' && psrc[1] == '/') {
4222                 psrc += 2;
4223         }
4224         if (pdst[0] == '.' && pdst[1] == '/') {
4225                 pdst += 2;
4226         }
4227         if ((slen = strlen(psrc)) > strlen(pdst)) {
4228                 return False;
4229         }
4230         return ((memcmp(psrc, pdst, slen) == 0) && pdst[slen] == '/');
4231 }
4232
4233 /****************************************************************************
4234  Rename an open file - given an fsp.
4235 ****************************************************************************/
4236
4237 NTSTATUS rename_internals_fsp(connection_struct *conn, files_struct *fsp, pstring newname, uint32 attrs, BOOL replace_if_exists)
4238 {
4239         SMB_STRUCT_STAT sbuf;
4240         pstring newname_last_component;
4241         NTSTATUS status = NT_STATUS_OK;
4242         struct share_mode_lock *lck = NULL;
4243
4244         ZERO_STRUCT(sbuf);
4245
4246         status = unix_convert(conn, newname, False, newname_last_component, &sbuf);
4247
4248         /* If an error we expect this to be NT_STATUS_OBJECT_PATH_NOT_FOUND */
4249
4250         if (!NT_STATUS_IS_OK(status) && !NT_STATUS_EQUAL(NT_STATUS_OBJECT_PATH_NOT_FOUND, status)) {
4251                 return status;
4252         }
4253
4254         status = check_name(conn, newname);
4255         if (!NT_STATUS_IS_OK(status)) {
4256                 return status;
4257         }
4258
4259         /* Ensure newname contains a '/' */
4260         if(strrchr_m(newname,'/') == 0) {
4261                 pstring tmpstr;
4262
4263                 pstrcpy(tmpstr, "./");
4264                 pstrcat(tmpstr, newname);
4265                 pstrcpy(newname, tmpstr);
4266         }
4267
4268         /*
4269          * Check for special case with case preserving and not
4270          * case sensitive. If the old last component differs from the original
4271          * last component only by case, then we should allow
4272          * the rename (user is trying to change the case of the
4273          * filename).
4274          */
4275
4276         if((conn->case_sensitive == False) && (conn->case_preserve == True) &&
4277                         strequal(newname, fsp->fsp_name)) {
4278                 char *p;
4279                 pstring newname_modified_last_component;
4280
4281                 /*
4282                  * Get the last component of the modified name.
4283                  * Note that we guarantee that newname contains a '/'
4284                  * character above.
4285                  */
4286                 p = strrchr_m(newname,'/');
4287                 pstrcpy(newname_modified_last_component,p+1);
4288
4289                 if(strcsequal(newname_modified_last_component,
4290                               newname_last_component) == False) {
4291                         /*
4292                          * Replace the modified last component with
4293                          * the original.
4294                          */
4295                         pstrcpy(p+1, newname_last_component);
4296                 }
4297         }
4298
4299         /*
4300          * If the src and dest names are identical - including case,
4301          * don't do the rename, just return success.
4302          */
4303
4304         if (strcsequal(fsp->fsp_name, newname)) {
4305                 DEBUG(3,("rename_internals_fsp: identical names in rename %s - returning success\n",
4306                         newname));
4307                 return NT_STATUS_OK;
4308         }
4309
4310         if(!replace_if_exists && vfs_object_exist(conn, newname, NULL)) {
4311                 DEBUG(3,("rename_internals_fsp: dest exists doing rename %s -> %s\n",
4312                         fsp->fsp_name,newname));
4313                 return NT_STATUS_OBJECT_NAME_COLLISION;
4314         }
4315
4316         /* Ensure we have a valid stat struct for the source. */
4317         if (fsp->fh->fd != -1) {
4318                 if (SMB_VFS_FSTAT(fsp,fsp->fh->fd,&sbuf) == -1) {
4319                         return map_nt_error_from_unix(errno);
4320                 }
4321         } else {
4322                 if (SMB_VFS_STAT(conn,fsp->fsp_name,&sbuf) == -1) {
4323                         return map_nt_error_from_unix(errno);
4324                 }
4325         }
4326
4327         status = can_rename(conn,fsp->fsp_name,attrs,&sbuf,True);
4328
4329         if (!NT_STATUS_IS_OK(status)) {
4330                 DEBUG(3,("rename_internals_fsp: Error %s rename %s -> %s\n",
4331                         nt_errstr(status), fsp->fsp_name,newname));
4332                 if (NT_STATUS_EQUAL(status,NT_STATUS_SHARING_VIOLATION))
4333                         status = NT_STATUS_ACCESS_DENIED;
4334                 return status;
4335         }
4336
4337         if (rename_path_prefix_equal(fsp->fsp_name, newname)) {
4338                 return NT_STATUS_ACCESS_DENIED;
4339         }
4340
4341         lck = get_share_mode_lock(NULL, fsp->file_id, NULL, NULL);
4342
4343         /*
4344          * We have the file open ourselves, so not being able to get the
4345          * corresponding share mode lock is a fatal error.
4346          */
4347
4348         SMB_ASSERT(lck != NULL);
4349
4350         if(SMB_VFS_RENAME(conn,fsp->fsp_name, newname) == 0) {
4351                 uint32 create_options = fsp->fh->private_options;
4352
4353                 DEBUG(3,("rename_internals_fsp: succeeded doing rename on %s -> %s\n",
4354                         fsp->fsp_name,newname));
4355
4356                 rename_open_files(conn, lck, newname);
4357
4358                 /*
4359                  * A rename acts as a new file create w.r.t. allowing an initial delete
4360                  * on close, probably because in Windows there is a new handle to the
4361                  * new file. If initial delete on close was requested but not
4362                  * originally set, we need to set it here. This is probably not 100% correct,
4363                  * but will work for the CIFSFS client which in non-posix mode
4364                  * depends on these semantics. JRA.
4365                  */
4366
4367                 set_allow_initial_delete_on_close(lck, fsp, True);
4368
4369                 if (create_options & FILE_DELETE_ON_CLOSE) {
4370                         status = can_set_delete_on_close(fsp, True, 0);
4371
4372                         if (NT_STATUS_IS_OK(status)) {
4373                                 /* Note that here we set the *inital* delete on close flag,
4374                                  * not the regular one. The magic gets handled in close. */
4375                                 fsp->initial_delete_on_close = True;
4376                         }
4377                 }
4378                 TALLOC_FREE(lck);
4379                 return NT_STATUS_OK;
4380         }
4381
4382         TALLOC_FREE(lck);
4383
4384         if (errno == ENOTDIR || errno == EISDIR) {
4385                 status = NT_STATUS_OBJECT_NAME_COLLISION;
4386         } else {
4387                 status = map_nt_error_from_unix(errno);
4388         }
4389
4390         DEBUG(3,("rename_internals_fsp: Error %s rename %s -> %s\n",
4391                 nt_errstr(status), fsp->fsp_name,newname));
4392
4393         return status;
4394 }
4395
4396 /*
4397  * Do the notify calls from a rename
4398  */
4399
4400 static void notify_rename(connection_struct *conn, BOOL is_dir,
4401                           const char *oldpath, const char *newpath)
4402 {
4403         char *olddir, *newdir;
4404         const char *oldname, *newname;
4405         uint32 mask;
4406
4407         mask = is_dir ? FILE_NOTIFY_CHANGE_DIR_NAME
4408                 : FILE_NOTIFY_CHANGE_FILE_NAME;
4409
4410         if (!parent_dirname_talloc(NULL, oldpath, &olddir, &oldname)
4411             || !parent_dirname_talloc(NULL, newpath, &newdir, &newname)) {
4412                 TALLOC_FREE(olddir);
4413                 return;
4414         }
4415
4416         if (strcmp(olddir, newdir) == 0) {
4417                 notify_fname(conn, NOTIFY_ACTION_OLD_NAME, mask, oldpath);
4418                 notify_fname(conn, NOTIFY_ACTION_NEW_NAME, mask, newpath);
4419         }
4420         else {
4421                 notify_fname(conn, NOTIFY_ACTION_REMOVED, mask, oldpath);
4422                 notify_fname(conn, NOTIFY_ACTION_ADDED, mask, newpath);
4423         }
4424         TALLOC_FREE(olddir);
4425         TALLOC_FREE(newdir);
4426
4427         /* this is a strange one. w2k3 gives an additional event for
4428            CHANGE_ATTRIBUTES and CHANGE_CREATION on the new file when renaming
4429            files, but not directories */
4430         if (!is_dir) {
4431                 notify_fname(conn, NOTIFY_ACTION_MODIFIED,
4432                              FILE_NOTIFY_CHANGE_ATTRIBUTES
4433                              |FILE_NOTIFY_CHANGE_CREATION,
4434                              newpath);
4435         }
4436 }
4437
4438 /****************************************************************************
4439  The guts of the rename command, split out so it may be called by the NT SMB
4440  code.
4441 ****************************************************************************/
4442
4443 NTSTATUS rename_internals(connection_struct *conn,
4444                                 pstring name,
4445                                 pstring newname,
4446                                 uint32 attrs,
4447                                 BOOL replace_if_exists,
4448                                 BOOL src_has_wild,
4449                                 BOOL dest_has_wild)
4450 {
4451         pstring directory;
4452         pstring mask;
4453         pstring last_component_src;
4454         pstring last_component_dest;
4455         char *p;
4456         int count=0;
4457         NTSTATUS status = NT_STATUS_OK;
4458         SMB_STRUCT_STAT sbuf1, sbuf2;
4459         struct share_mode_lock *lck = NULL;
4460         struct smb_Dir *dir_hnd = NULL;
4461         const char *dname;
4462         long offset = 0;
4463         pstring destname;
4464
4465         *directory = *mask = 0;
4466
4467         ZERO_STRUCT(sbuf1);
4468         ZERO_STRUCT(sbuf2);
4469
4470         status = unix_convert(conn, name, src_has_wild, last_component_src, &sbuf1);
4471         if (!NT_STATUS_IS_OK(status)) {
4472                 return status;
4473         }
4474
4475         status = unix_convert(conn, newname, dest_has_wild, last_component_dest, &sbuf2);
4476         if (!NT_STATUS_IS_OK(status)) {
4477                 return status;
4478         }
4479
4480         /*
4481          * Split the old name into directory and last component
4482          * strings. Note that unix_convert may have stripped off a
4483          * leading ./ from both name and newname if the rename is
4484          * at the root of the share. We need to make sure either both
4485          * name and newname contain a / character or neither of them do
4486          * as this is checked in resolve_wildcards().
4487          */
4488
4489         p = strrchr_m(name,'/');
4490         if (!p) {
4491                 pstrcpy(directory,".");
4492                 pstrcpy(mask,name);
4493         } else {
4494                 *p = 0;
4495                 pstrcpy(directory,name);
4496                 pstrcpy(mask,p+1);
4497                 *p = '/'; /* Replace needed for exceptional test below. */
4498         }
4499
4500         /*
4501          * We should only check the mangled cache
4502          * here if unix_convert failed. This means
4503          * that the path in 'mask' doesn't exist
4504          * on the file system and so we need to look
4505          * for a possible mangle. This patch from
4506          * Tine Smukavec <valentin.smukavec@hermes.si>.
4507          */
4508
4509         if (!VALID_STAT(sbuf1) && mangle_is_mangled(mask, conn->params)) {
4510                 mangle_check_cache( mask, sizeof(pstring)-1, conn->params );
4511         }
4512
4513         if (!src_has_wild) {
4514                 /*
4515                  * No wildcards - just process the one file.
4516                  */
4517                 BOOL is_short_name = mangle_is_8_3(name, True, conn->params);
4518
4519                 /* Add a terminating '/' to the directory name. */
4520                 pstrcat(directory,"/");
4521                 pstrcat(directory,mask);
4522
4523                 /* Ensure newname contains a '/' also */
4524                 if(strrchr_m(newname,'/') == 0) {
4525                         pstring tmpstr;
4526
4527                         pstrcpy(tmpstr, "./");
4528                         pstrcat(tmpstr, newname);
4529                         pstrcpy(newname, tmpstr);
4530                 }
4531
4532                 DEBUG(3, ("rename_internals: case_sensitive = %d, "
4533                           "case_preserve = %d, short case preserve = %d, "
4534                           "directory = %s, newname = %s, "
4535                           "last_component_dest = %s, is_8_3 = %d\n",
4536                           conn->case_sensitive, conn->case_preserve,
4537                           conn->short_case_preserve, directory,
4538                           newname, last_component_dest, is_short_name));
4539
4540                 /* Ensure the source name is valid for us to access. */
4541                 status = check_name(conn, directory);
4542                 if (!NT_STATUS_IS_OK(status)) {
4543                         return status;
4544                 }
4545
4546                 /* The dest name still may have wildcards. */
4547                 if (dest_has_wild) {
4548                         if (!resolve_wildcards(directory,newname)) {
4549                                 DEBUG(6, ("rename_internals: resolve_wildcards %s %s failed\n",
4550                                           directory,newname));
4551                                 return NT_STATUS_NO_MEMORY;
4552                         }
4553                 }
4554
4555                 /*
4556                  * Check for special case with case preserving and not
4557                  * case sensitive, if directory and newname are identical,
4558                  * and the old last component differs from the original
4559                  * last component only by case, then we should allow
4560                  * the rename (user is trying to change the case of the
4561                  * filename).
4562                  */
4563                 if((conn->case_sensitive == False) &&
4564                    (((conn->case_preserve == True) &&
4565                      (is_short_name == False)) ||
4566                     ((conn->short_case_preserve == True) &&
4567                      (is_short_name == True))) &&
4568                    strcsequal(directory, newname)) {
4569                         pstring modified_last_component;
4570
4571                         /*
4572                          * Get the last component of the modified name.
4573                          * Note that we guarantee that newname contains a '/'
4574                          * character above.
4575                          */
4576                         p = strrchr_m(newname,'/');
4577                         pstrcpy(modified_last_component,p+1);
4578
4579                         if(strcsequal(modified_last_component,
4580                                       last_component_dest) == False) {
4581                                 /*
4582                                  * Replace the modified last component with
4583                                  * the original.
4584                                  */
4585                                 pstrcpy(p+1, last_component_dest);
4586                         }
4587                 }
4588
4589                 /* Ensure the dest name is valid for us to access. */
4590                 status = check_name(conn, newname);
4591                 if (!NT_STATUS_IS_OK(status)) {
4592                         return status;
4593                 }
4594
4595                 /*
4596                  * The source object must exist, and it may not have a
4597                  * conflicting share mode.
4598                  */
4599                 status = can_rename(conn,directory,attrs,&sbuf1,False);
4600
4601                 if (!NT_STATUS_IS_OK(status)) {
4602                         DEBUG(3,("rename_internals: Error %s rename %s -> "
4603                                  "%s\n", nt_errstr(status), directory,
4604                                  newname));
4605                         return status;
4606                 }
4607
4608                 /*
4609                  * If the src and dest names are identical - including case,
4610                  * don't do the rename, just return success.
4611                  */
4612
4613                 if (strcsequal(directory, newname)) {
4614                         DEBUG(3, ("rename_internals: identical names in "
4615                                   "rename %s - returning success\n",
4616                                   directory));
4617                         return NT_STATUS_OK;
4618                 }
4619
4620                 if(!replace_if_exists && vfs_object_exist(conn,newname,NULL)) {
4621                         DEBUG(3,("rename_internals: dest exists doing "
4622                                  "rename %s -> %s\n", directory, newname));
4623                         return NT_STATUS_OBJECT_NAME_COLLISION;
4624                 }
4625
4626                 if (rename_path_prefix_equal(directory, newname)) {
4627                         return NT_STATUS_SHARING_VIOLATION;
4628                 }
4629
4630                 lck = get_share_mode_lock(NULL, file_id_sbuf(&sbuf1),
4631                                           NULL, NULL);
4632
4633                 if(SMB_VFS_RENAME(conn,directory, newname) == 0) {
4634                         DEBUG(3,("rename_internals: succeeded doing rename "
4635                                  "on %s -> %s\n", directory, newname));
4636                         if (lck != NULL) {
4637                                 /*
4638                                  * Only in this case there are open files at
4639                                  * all.
4640                                  */
4641                                 rename_open_files(conn, lck, newname);
4642                         }
4643                         TALLOC_FREE(lck);
4644                         notify_rename(conn, S_ISDIR(sbuf1.st_mode),
4645                                       directory, newname);
4646                         return NT_STATUS_OK;
4647                 }
4648
4649                 TALLOC_FREE(lck);
4650                 if (errno == ENOTDIR || errno == EISDIR) {
4651                         status = NT_STATUS_OBJECT_NAME_COLLISION;
4652                 } else {
4653                         status = map_nt_error_from_unix(errno);
4654                 }
4655
4656                 DEBUG(3,("rename_internals: Error %s rename %s -> %s\n",
4657                         nt_errstr(status), directory,newname));
4658
4659                 return status;
4660         }
4661
4662         /*
4663          * Wildcards - process each file that matches.
4664          */
4665         if (strequal(mask,"????????.???")) {
4666                 pstrcpy(mask,"*");
4667         }
4668
4669         status = check_name(conn, directory);
4670         if (!NT_STATUS_IS_OK(status)) {
4671                 return status;
4672         }
4673
4674         dir_hnd = OpenDir(conn, directory, mask, attrs);
4675         if (dir_hnd == NULL) {
4676                 return map_nt_error_from_unix(errno);
4677         }
4678
4679         status = NT_STATUS_NO_SUCH_FILE;
4680         /*
4681          * Was status = NT_STATUS_OBJECT_NAME_NOT_FOUND;
4682          * - gentest fix. JRA
4683          */
4684
4685         while ((dname = ReadDirName(dir_hnd, &offset))) {
4686                 pstring fname;
4687                 BOOL sysdir_entry = False;
4688
4689                 pstrcpy(fname,dname);
4690
4691                 /* Quick check for "." and ".." */
4692                 if (fname[0] == '.') {
4693                         if (!fname[1] || (fname[1] == '.' && !fname[2])) {
4694                                 if (attrs & aDIR) {
4695                                         sysdir_entry = True;
4696                                 } else {
4697                                         continue;
4698                                 }
4699                         }
4700                 }
4701
4702                 if (!is_visible_file(conn, directory, dname, &sbuf1, False)) {
4703                         continue;
4704                 }
4705
4706                 if(!mask_match(fname, mask, conn->case_sensitive)) {
4707                         continue;
4708                 }
4709
4710                 if (sysdir_entry) {
4711                         status = NT_STATUS_OBJECT_NAME_INVALID;
4712                         break;
4713                 }
4714
4715                 status = NT_STATUS_ACCESS_DENIED;
4716                 slprintf(fname, sizeof(fname)-1, "%s/%s", directory, dname);
4717
4718                 /* Ensure the source name is valid for us to access. */
4719                 status = check_name(conn, fname);
4720                 if (!NT_STATUS_IS_OK(status)) {
4721                         return status;
4722                 }
4723
4724                 /*
4725                  * can_rename does an open_file_ntcreate which needs a valid
4726                  * stat in case the file exists
4727                  */
4728
4729                 ZERO_STRUCT(sbuf1);
4730                 SMB_VFS_STAT(conn, fname, &sbuf1);
4731
4732                 status = can_rename(conn,fname,attrs,&sbuf1,False);
4733
4734                 if (!NT_STATUS_IS_OK(status)) {
4735                         DEBUG(6, ("rename %s refused: %s\n", fname,
4736                                   nt_errstr(status)));
4737                         continue;
4738                 }
4739                 pstrcpy(destname,newname);
4740
4741                 if (!resolve_wildcards(fname,destname)) {
4742                         DEBUG(6, ("resolve_wildcards %s %s failed\n",
4743                                   fname, destname));
4744                         continue;
4745                 }
4746
4747                 /* Ensure the dest name is valid for us to access. */
4748                 status = check_name(conn, destname);
4749                 if (!NT_STATUS_IS_OK(status)) {
4750                         return status;
4751                 }
4752
4753                 if (strcsequal(fname,destname)) {
4754                         DEBUG(3,("rename_internals: identical names "
4755                                  "in wildcard rename %s - success\n",
4756                                  fname));
4757                         count++;
4758                         status = NT_STATUS_OK;
4759                         continue;
4760                 }
4761
4762                 if (!replace_if_exists && vfs_file_exist(conn,destname, NULL)) {
4763                         DEBUG(6,("file_exist %s\n", destname));
4764                         status = NT_STATUS_OBJECT_NAME_COLLISION;
4765                         continue;
4766                 }
4767
4768                 if (rename_path_prefix_equal(fname, destname)) {
4769                         return NT_STATUS_SHARING_VIOLATION;
4770                 }
4771
4772                 lck = get_share_mode_lock(NULL, file_id_sbuf(&sbuf1), NULL,
4773                                           NULL);
4774
4775                 if (!SMB_VFS_RENAME(conn,fname,destname)) {
4776                         if (lck != NULL) {
4777                                 /*
4778                                  * Only in this case there are open files at
4779                                  * all.
4780                                  */
4781                                 rename_open_files(conn, lck, newname);
4782                         }
4783                         count++;
4784                         status = NT_STATUS_OK;
4785                 }
4786                 TALLOC_FREE(lck);
4787                 DEBUG(3,("rename_internals: doing rename on %s -> "
4788                          "%s\n",fname,destname));
4789         }
4790         CloseDir(dir_hnd);
4791
4792         if (count == 0 && NT_STATUS_IS_OK(status)) {
4793                 status = map_nt_error_from_unix(errno);
4794         }
4795
4796         return status;
4797 }
4798
4799 /****************************************************************************
4800  Reply to a mv.
4801 ****************************************************************************/
4802
4803 int reply_mv(connection_struct *conn, char *inbuf,char *outbuf, int dum_size,
4804              int dum_buffsize)
4805 {
4806         int outsize = 0;
4807         pstring name;
4808         pstring newname;
4809         char *p;
4810         uint32 attrs = SVAL(inbuf,smb_vwv0);
4811         NTSTATUS status;
4812         BOOL src_has_wcard = False;
4813         BOOL dest_has_wcard = False;
4814
4815         START_PROFILE(SMBmv);
4816
4817         p = smb_buf(inbuf) + 1;
4818         p += srvstr_get_path_wcard(inbuf, name, p, sizeof(name), 0, STR_TERMINATE, &status, &src_has_wcard);
4819         if (!NT_STATUS_IS_OK(status)) {
4820                 END_PROFILE(SMBmv);
4821                 return ERROR_NT(status);
4822         }
4823         p++;
4824         p += srvstr_get_path_wcard(inbuf, newname, p, sizeof(newname), 0, STR_TERMINATE, &status, &dest_has_wcard);
4825         if (!NT_STATUS_IS_OK(status)) {
4826                 END_PROFILE(SMBmv);
4827                 return ERROR_NT(status);
4828         }
4829
4830         status = resolve_dfspath_wcard(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, name, &src_has_wcard);
4831         if (!NT_STATUS_IS_OK(status)) {
4832                 END_PROFILE(SMBmv);
4833                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
4834                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
4835                 }
4836                 return ERROR_NT(status);
4837         }
4838
4839         status = resolve_dfspath_wcard(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, newname, &dest_has_wcard);
4840         if (!NT_STATUS_IS_OK(status)) {
4841                 END_PROFILE(SMBmv);
4842                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
4843                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
4844                 }
4845                 return ERROR_NT(status);
4846         }
4847
4848         DEBUG(3,("reply_mv : %s -> %s\n",name,newname));
4849
4850         status = rename_internals(conn, name, newname, attrs, False, src_has_wcard, dest_has_wcard);
4851         if (!NT_STATUS_IS_OK(status)) {
4852                 END_PROFILE(SMBmv);
4853                 if (open_was_deferred(SVAL(inbuf,smb_mid))) {
4854                         /* We have re-scheduled this call. */
4855                         return -1;
4856                 }
4857                 return ERROR_NT(status);
4858         }
4859
4860         outsize = set_message(inbuf,outbuf,0,0,False);
4861
4862         END_PROFILE(SMBmv);
4863         return(outsize);
4864 }
4865
4866 /*******************************************************************
4867  Copy a file as part of a reply_copy.
4868 ******************************************************************/
4869
4870 /*
4871  * TODO: check error codes on all callers
4872  */
4873
4874 NTSTATUS copy_file(connection_struct *conn,
4875                         char *src,
4876                         char *dest1,
4877                         int ofun,
4878                         int count,
4879                         BOOL target_is_directory)
4880 {
4881         SMB_STRUCT_STAT src_sbuf, sbuf2;
4882         SMB_OFF_T ret=-1;
4883         files_struct *fsp1,*fsp2;
4884         pstring dest;
4885         uint32 dosattrs;
4886         uint32 new_create_disposition;
4887         NTSTATUS status;
4888
4889         pstrcpy(dest,dest1);
4890         if (target_is_directory) {
4891                 char *p = strrchr_m(src,'/');
4892                 if (p) {
4893                         p++;
4894                 } else {
4895                         p = src;
4896                 }
4897                 pstrcat(dest,"/");
4898                 pstrcat(dest,p);
4899         }
4900
4901         if (!vfs_file_exist(conn,src,&src_sbuf)) {
4902                 return NT_STATUS_OBJECT_NAME_NOT_FOUND;
4903         }
4904
4905         if (!target_is_directory && count) {
4906                 new_create_disposition = FILE_OPEN;
4907         } else {
4908                 if (!map_open_params_to_ntcreate(dest1,0,ofun,
4909                                 NULL, NULL, &new_create_disposition, NULL)) {
4910                         return NT_STATUS_INVALID_PARAMETER;
4911                 }
4912         }
4913
4914         status = open_file_ntcreate(conn,src,&src_sbuf,
4915                         FILE_GENERIC_READ,
4916                         FILE_SHARE_READ|FILE_SHARE_WRITE,
4917                         FILE_OPEN,
4918                         0,
4919                         FILE_ATTRIBUTE_NORMAL,
4920                         INTERNAL_OPEN_ONLY,
4921                         NULL, &fsp1);
4922
4923         if (!NT_STATUS_IS_OK(status)) {
4924                 return status;
4925         }
4926
4927         dosattrs = dos_mode(conn, src, &src_sbuf);
4928         if (SMB_VFS_STAT(conn,dest,&sbuf2) == -1) {
4929                 ZERO_STRUCTP(&sbuf2);
4930         }
4931
4932         status = open_file_ntcreate(conn,dest,&sbuf2,
4933                         FILE_GENERIC_WRITE,
4934                         FILE_SHARE_READ|FILE_SHARE_WRITE,
4935                         new_create_disposition,
4936                         0,
4937                         dosattrs,
4938                         INTERNAL_OPEN_ONLY,
4939                         NULL, &fsp2);
4940
4941         if (!NT_STATUS_IS_OK(status)) {
4942                 close_file(fsp1,ERROR_CLOSE);
4943                 return status;
4944         }
4945
4946         if ((ofun&3) == 1) {
4947                 if(SMB_VFS_LSEEK(fsp2,fsp2->fh->fd,0,SEEK_END) == -1) {
4948                         DEBUG(0,("copy_file: error - vfs lseek returned error %s\n", strerror(errno) ));
4949                         /*
4950                          * Stop the copy from occurring.
4951                          */
4952                         ret = -1;
4953                         src_sbuf.st_size = 0;
4954                 }
4955         }
4956
4957         if (src_sbuf.st_size) {
4958                 ret = vfs_transfer_file(fsp1, fsp2, src_sbuf.st_size);
4959         }
4960
4961         close_file(fsp1,NORMAL_CLOSE);
4962
4963         /* Ensure the modtime is set correctly on the destination file. */
4964         fsp_set_pending_modtime( fsp2, get_mtimespec(&src_sbuf));
4965
4966         /*
4967          * As we are opening fsp1 read-only we only expect
4968          * an error on close on fsp2 if we are out of space.
4969          * Thus we don't look at the error return from the
4970          * close of fsp1.
4971          */
4972         status = close_file(fsp2,NORMAL_CLOSE);
4973
4974         if (!NT_STATUS_IS_OK(status)) {
4975                 return status;
4976         }
4977
4978         if (ret != (SMB_OFF_T)src_sbuf.st_size) {
4979                 return NT_STATUS_DISK_FULL;
4980         }
4981
4982         return NT_STATUS_OK;
4983 }
4984
4985 /****************************************************************************
4986  Reply to a file copy.
4987 ****************************************************************************/
4988
4989 int reply_copy(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
4990 {
4991         int outsize = 0;
4992         pstring name;
4993         pstring directory;
4994         pstring mask,newname;
4995         char *p;
4996         int count=0;
4997         int error = ERRnoaccess;
4998         int err = 0;
4999         int tid2 = SVAL(inbuf,smb_vwv0);
5000         int ofun = SVAL(inbuf,smb_vwv1);
5001         int flags = SVAL(inbuf,smb_vwv2);
5002         BOOL target_is_directory=False;
5003         BOOL source_has_wild = False;
5004         BOOL dest_has_wild = False;
5005         SMB_STRUCT_STAT sbuf1, sbuf2;
5006         NTSTATUS status;
5007         START_PROFILE(SMBcopy);
5008
5009         *directory = *mask = 0;
5010
5011         p = smb_buf(inbuf);
5012         p += srvstr_get_path_wcard(inbuf, name, p, sizeof(name), 0, STR_TERMINATE, &status, &source_has_wild);
5013         if (!NT_STATUS_IS_OK(status)) {
5014                 END_PROFILE(SMBcopy);
5015                 return ERROR_NT(status);
5016         }
5017         p += srvstr_get_path_wcard(inbuf, newname, p, sizeof(newname), 0, STR_TERMINATE, &status, &dest_has_wild);
5018         if (!NT_STATUS_IS_OK(status)) {
5019                 END_PROFILE(SMBcopy);
5020                 return ERROR_NT(status);
5021         }
5022
5023         DEBUG(3,("reply_copy : %s -> %s\n",name,newname));
5024
5025         if (tid2 != conn->cnum) {
5026                 /* can't currently handle inter share copies XXXX */
5027                 DEBUG(3,("Rejecting inter-share copy\n"));
5028                 END_PROFILE(SMBcopy);
5029                 return ERROR_DOS(ERRSRV,ERRinvdevice);
5030         }
5031
5032         status = resolve_dfspath_wcard(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, name, &source_has_wild);
5033         if (!NT_STATUS_IS_OK(status)) {
5034                 END_PROFILE(SMBcopy);
5035                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
5036                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
5037                 }
5038                 return ERROR_NT(status);
5039         }
5040
5041         status = resolve_dfspath_wcard(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, newname, &dest_has_wild);
5042         if (!NT_STATUS_IS_OK(status)) {
5043                 END_PROFILE(SMBcopy);
5044                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
5045                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
5046                 }
5047                 return ERROR_NT(status);
5048         }
5049
5050         status = unix_convert(conn, name, source_has_wild, NULL, &sbuf1);
5051         if (!NT_STATUS_IS_OK(status)) {
5052                 END_PROFILE(SMBcopy);
5053                 return ERROR_NT(status);
5054         }
5055
5056         status = unix_convert(conn, newname, dest_has_wild, NULL, &sbuf2);
5057         if (!NT_STATUS_IS_OK(status)) {
5058                 END_PROFILE(SMBcopy);
5059                 return ERROR_NT(status);
5060         }
5061
5062         target_is_directory = VALID_STAT_OF_DIR(sbuf2);
5063
5064         if ((flags&1) && target_is_directory) {
5065                 END_PROFILE(SMBcopy);
5066                 return ERROR_DOS(ERRDOS,ERRbadfile);
5067         }
5068
5069         if ((flags&2) && !target_is_directory) {
5070                 END_PROFILE(SMBcopy);
5071                 return ERROR_DOS(ERRDOS,ERRbadpath);
5072         }
5073
5074         if ((flags&(1<<5)) && VALID_STAT_OF_DIR(sbuf1)) {
5075                 /* wants a tree copy! XXXX */
5076                 DEBUG(3,("Rejecting tree copy\n"));
5077                 END_PROFILE(SMBcopy);
5078                 return ERROR_DOS(ERRSRV,ERRerror);
5079         }
5080
5081         p = strrchr_m(name,'/');
5082         if (!p) {
5083                 pstrcpy(directory,"./");
5084                 pstrcpy(mask,name);
5085         } else {
5086                 *p = 0;
5087                 pstrcpy(directory,name);
5088                 pstrcpy(mask,p+1);
5089         }
5090
5091         /*
5092          * We should only check the mangled cache
5093          * here if unix_convert failed. This means
5094          * that the path in 'mask' doesn't exist
5095          * on the file system and so we need to look
5096          * for a possible mangle. This patch from
5097          * Tine Smukavec <valentin.smukavec@hermes.si>.
5098          */
5099
5100         if (!VALID_STAT(sbuf1) && mangle_is_mangled(mask, conn->params)) {
5101                 mangle_check_cache( mask, sizeof(pstring)-1, conn->params );
5102         }
5103
5104         if (!source_has_wild) {
5105                 pstrcat(directory,"/");
5106                 pstrcat(directory,mask);
5107                 if (dest_has_wild) {
5108                         if (!resolve_wildcards(directory,newname)) {
5109                                 END_PROFILE(SMBcopy);
5110                                 return ERROR_NT(NT_STATUS_NO_MEMORY);
5111                         }
5112                 }
5113
5114                 status = check_name(conn, directory);
5115                 if (!NT_STATUS_IS_OK(status)) {
5116                         return ERROR_NT(status);
5117                 }
5118
5119                 status = check_name(conn, newname);
5120                 if (!NT_STATUS_IS_OK(status)) {
5121                         return ERROR_NT(status);
5122                 }
5123
5124                 status = copy_file(conn,directory,newname,ofun,
5125                                         count,target_is_directory);
5126
5127                 if(!NT_STATUS_IS_OK(status)) {
5128                         END_PROFILE(SMBcopy);
5129                         return ERROR_NT(status);
5130                 } else {
5131                         count++;
5132                 }
5133         } else {
5134                 struct smb_Dir *dir_hnd = NULL;
5135                 const char *dname;
5136                 long offset = 0;
5137                 pstring destname;
5138
5139                 if (strequal(mask,"????????.???"))
5140                         pstrcpy(mask,"*");
5141
5142                 status = check_name(conn, directory);
5143                 if (!NT_STATUS_IS_OK(status)) {
5144                         return ERROR_NT(status);
5145                 }
5146
5147                 dir_hnd = OpenDir(conn, directory, mask, 0);
5148                 if (dir_hnd == NULL) {
5149                         status = map_nt_error_from_unix(errno);
5150                         return ERROR_NT(status);
5151                 }
5152
5153                 error = ERRbadfile;
5154
5155                 while ((dname = ReadDirName(dir_hnd, &offset))) {
5156                         pstring fname;
5157                         pstrcpy(fname,dname);
5158
5159                         if (!is_visible_file(conn, directory, dname, &sbuf1, False)) {
5160                                 continue;
5161                         }
5162
5163                         if(!mask_match(fname, mask, conn->case_sensitive)) {
5164                                 continue;
5165                         }
5166
5167                         error = ERRnoaccess;
5168                         slprintf(fname,sizeof(fname)-1, "%s/%s",directory,dname);
5169                         pstrcpy(destname,newname);
5170                         if (!resolve_wildcards(fname,destname)) {
5171                                 continue;
5172                         }
5173
5174                         status = check_name(conn, fname);
5175                         if (!NT_STATUS_IS_OK(status)) {
5176                                 return ERROR_NT(status);
5177                         }
5178
5179                         status = check_name(conn, destname);
5180                         if (!NT_STATUS_IS_OK(status)) {
5181                                 return ERROR_NT(status);
5182                         }
5183
5184                         DEBUG(3,("reply_copy : doing copy on %s -> %s\n",fname, destname));
5185
5186                         status = copy_file(conn,fname,destname,ofun,
5187                                         count,target_is_directory);
5188                         if (NT_STATUS_IS_OK(status)) {
5189                                 count++;
5190                         }
5191                 }
5192                 CloseDir(dir_hnd);
5193         }
5194
5195         if (count == 0) {
5196                 if(err) {
5197                         /* Error on close... */
5198                         errno = err;
5199                         END_PROFILE(SMBcopy);
5200                         return(UNIXERROR(ERRHRD,ERRgeneral));
5201                 }
5202
5203                 END_PROFILE(SMBcopy);
5204                 return ERROR_DOS(ERRDOS,error);
5205         }
5206
5207         outsize = set_message(inbuf,outbuf,1,0,True);
5208         SSVAL(outbuf,smb_vwv0,count);
5209
5210         END_PROFILE(SMBcopy);
5211         return(outsize);
5212 }
5213
5214 /****************************************************************************
5215  Reply to a setdir.
5216 ****************************************************************************/
5217
5218 int reply_setdir(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
5219 {
5220         int snum;
5221         int outsize = 0;
5222         pstring newdir;
5223         NTSTATUS status;
5224
5225         START_PROFILE(pathworks_setdir);
5226
5227         snum = SNUM(conn);
5228         if (!CAN_SETDIR(snum)) {
5229                 END_PROFILE(pathworks_setdir);
5230                 return ERROR_DOS(ERRDOS,ERRnoaccess);
5231         }
5232
5233         srvstr_get_path(inbuf, newdir, smb_buf(inbuf) + 1, sizeof(newdir), 0, STR_TERMINATE, &status);
5234         if (!NT_STATUS_IS_OK(status)) {
5235                 END_PROFILE(pathworks_setdir);
5236                 return ERROR_NT(status);
5237         }
5238
5239         status = resolve_dfspath(conn, SVAL(inbuf,smb_flg2) & FLAGS2_DFS_PATHNAMES, newdir);
5240         if (!NT_STATUS_IS_OK(status)) {
5241                 END_PROFILE(pathworks_setdir);
5242                 if (NT_STATUS_EQUAL(status,NT_STATUS_PATH_NOT_COVERED)) {
5243                         return ERROR_BOTH(NT_STATUS_PATH_NOT_COVERED, ERRSRV, ERRbadpath);
5244                 }
5245                 return ERROR_NT(status);
5246         }
5247
5248         if (strlen(newdir) != 0) {
5249                 if (!vfs_directory_exist(conn,newdir,NULL)) {
5250                         END_PROFILE(pathworks_setdir);
5251                         return ERROR_DOS(ERRDOS,ERRbadpath);
5252                 }
5253                 set_conn_connectpath(conn,newdir);
5254         }
5255
5256         outsize = set_message(inbuf,outbuf,0,0,False);
5257         SCVAL(outbuf,smb_reh,CVAL(inbuf,smb_reh));
5258
5259         DEBUG(3,("setdir %s\n", newdir));
5260
5261         END_PROFILE(pathworks_setdir);
5262         return(outsize);
5263 }
5264
5265 #undef DBGC_CLASS
5266 #define DBGC_CLASS DBGC_LOCKING
5267
5268 /****************************************************************************
5269  Get a lock pid, dealing with large count requests.
5270 ****************************************************************************/
5271
5272 uint32 get_lock_pid( char *data, int data_offset, BOOL large_file_format)
5273 {
5274         if(!large_file_format)
5275                 return (uint32)SVAL(data,SMB_LPID_OFFSET(data_offset));
5276         else
5277                 return (uint32)SVAL(data,SMB_LARGE_LPID_OFFSET(data_offset));
5278 }
5279
5280 /****************************************************************************
5281  Get a lock count, dealing with large count requests.
5282 ****************************************************************************/
5283
5284 SMB_BIG_UINT get_lock_count( char *data, int data_offset, BOOL large_file_format)
5285 {
5286         SMB_BIG_UINT count = 0;
5287
5288         if(!large_file_format) {
5289                 count = (SMB_BIG_UINT)IVAL(data,SMB_LKLEN_OFFSET(data_offset));
5290         } else {
5291
5292 #if defined(HAVE_LONGLONG)
5293                 count = (((SMB_BIG_UINT) IVAL(data,SMB_LARGE_LKLEN_OFFSET_HIGH(data_offset))) << 32) |
5294                         ((SMB_BIG_UINT) IVAL(data,SMB_LARGE_LKLEN_OFFSET_LOW(data_offset)));
5295 #else /* HAVE_LONGLONG */
5296
5297                 /*
5298                  * NT4.x seems to be broken in that it sends large file (64 bit)
5299                  * lockingX calls even if the CAP_LARGE_FILES was *not*
5300                  * negotiated. For boxes without large unsigned ints truncate the
5301                  * lock count by dropping the top 32 bits.
5302                  */
5303
5304                 if(IVAL(data,SMB_LARGE_LKLEN_OFFSET_HIGH(data_offset)) != 0) {
5305                         DEBUG(3,("get_lock_count: truncating lock count (high)0x%x (low)0x%x to just low count.\n",
5306                                 (unsigned int)IVAL(data,SMB_LARGE_LKLEN_OFFSET_HIGH(data_offset)),
5307                                 (unsigned int)IVAL(data,SMB_LARGE_LKLEN_OFFSET_LOW(data_offset)) ));
5308                                 SIVAL(data,SMB_LARGE_LKLEN_OFFSET_HIGH(data_offset),0);
5309                 }
5310
5311                 count = (SMB_BIG_UINT)IVAL(data,SMB_LARGE_LKLEN_OFFSET_LOW(data_offset));
5312 #endif /* HAVE_LONGLONG */
5313         }
5314
5315         return count;
5316 }
5317
5318 #if !defined(HAVE_LONGLONG)
5319 /****************************************************************************
5320  Pathetically try and map a 64 bit lock offset into 31 bits. I hate Windows :-).
5321 ****************************************************************************/
5322
5323 static uint32 map_lock_offset(uint32 high, uint32 low)
5324 {
5325         unsigned int i;
5326         uint32 mask = 0;
5327         uint32 highcopy = high;
5328
5329         /*
5330          * Try and find out how many significant bits there are in high.
5331          */
5332
5333         for(i = 0; highcopy; i++)
5334                 highcopy >>= 1;
5335
5336         /*
5337          * We use 31 bits not 32 here as POSIX
5338          * lock offsets may not be negative.
5339          */
5340
5341         mask = (~0) << (31 - i);
5342
5343         if(low & mask)
5344                 return 0; /* Fail. */
5345
5346         high <<= (31 - i);
5347
5348         return (high|low);
5349 }
5350 #endif /* !defined(HAVE_LONGLONG) */
5351
5352 /****************************************************************************
5353  Get a lock offset, dealing with large offset requests.
5354 ****************************************************************************/
5355
5356 SMB_BIG_UINT get_lock_offset( char *data, int data_offset, BOOL large_file_format, BOOL *err)
5357 {
5358         SMB_BIG_UINT offset = 0;
5359
5360         *err = False;
5361
5362         if(!large_file_format) {
5363                 offset = (SMB_BIG_UINT)IVAL(data,SMB_LKOFF_OFFSET(data_offset));
5364         } else {
5365
5366 #if defined(HAVE_LONGLONG)
5367                 offset = (((SMB_BIG_UINT) IVAL(data,SMB_LARGE_LKOFF_OFFSET_HIGH(data_offset))) << 32) |
5368                                 ((SMB_BIG_UINT) IVAL(data,SMB_LARGE_LKOFF_OFFSET_LOW(data_offset)));
5369 #else /* HAVE_LONGLONG */
5370
5371                 /*
5372                  * NT4.x seems to be broken in that it sends large file (64 bit)
5373                  * lockingX calls even if the CAP_LARGE_FILES was *not*
5374                  * negotiated. For boxes without large unsigned ints mangle the
5375                  * lock offset by mapping the top 32 bits onto the lower 32.
5376                  */
5377
5378                 if(IVAL(data,SMB_LARGE_LKOFF_OFFSET_HIGH(data_offset)) != 0) {
5379                         uint32 low = IVAL(data,SMB_LARGE_LKOFF_OFFSET_LOW(data_offset));
5380                         uint32 high = IVAL(data,SMB_LARGE_LKOFF_OFFSET_HIGH(data_offset));
5381                         uint32 new_low = 0;
5382
5383                         if((new_low = map_lock_offset(high, low)) == 0) {
5384                                 *err = True;
5385                                 return (SMB_BIG_UINT)-1;
5386                         }
5387
5388                         DEBUG(3,("get_lock_offset: truncating lock offset (high)0x%x (low)0x%x to offset 0x%x.\n",
5389                                 (unsigned int)high, (unsigned int)low, (unsigned int)new_low ));
5390                         SIVAL(data,SMB_LARGE_LKOFF_OFFSET_HIGH(data_offset),0);
5391                         SIVAL(data,SMB_LARGE_LKOFF_OFFSET_LOW(data_offset),new_low);
5392                 }
5393
5394                 offset = (SMB_BIG_UINT)IVAL(data,SMB_LARGE_LKOFF_OFFSET_LOW(data_offset));
5395 #endif /* HAVE_LONGLONG */
5396         }
5397
5398         return offset;
5399 }
5400
5401 /****************************************************************************
5402  Reply to a lockingX request.
5403 ****************************************************************************/
5404
5405 int reply_lockingX(connection_struct *conn, char *inbuf, char *outbuf,
5406                    int length, int bufsize)
5407 {
5408         files_struct *fsp = file_fsp(inbuf,smb_vwv2);
5409         unsigned char locktype = CVAL(inbuf,smb_vwv3);
5410         unsigned char oplocklevel = CVAL(inbuf,smb_vwv3+1);
5411         uint16 num_ulocks = SVAL(inbuf,smb_vwv6);
5412         uint16 num_locks = SVAL(inbuf,smb_vwv7);
5413         SMB_BIG_UINT count = 0, offset = 0;
5414         uint32 lock_pid;
5415         int32 lock_timeout = IVAL(inbuf,smb_vwv4);
5416         int i;
5417         char *data;
5418         BOOL large_file_format =
5419                 (locktype & LOCKING_ANDX_LARGE_FILES)?True:False;
5420         BOOL err;
5421         NTSTATUS status = NT_STATUS_UNSUCCESSFUL;
5422
5423         START_PROFILE(SMBlockingX);
5424
5425         CHECK_FSP(fsp,conn);
5426
5427         data = smb_buf(inbuf);
5428
5429         if (locktype & LOCKING_ANDX_CHANGE_LOCKTYPE) {
5430                 /* we don't support these - and CANCEL_LOCK makes w2k
5431                    and XP reboot so I don't really want to be
5432                    compatible! (tridge) */
5433                 return ERROR_NT(NT_STATUS_DOS(ERRDOS, ERRnoatomiclocks));
5434         }
5435
5436         /* Check if this is an oplock break on a file
5437            we have granted an oplock on.
5438         */
5439         if ((locktype & LOCKING_ANDX_OPLOCK_RELEASE)) {
5440                 /* Client can insist on breaking to none. */
5441                 BOOL break_to_none = (oplocklevel == 0);
5442                 BOOL result;
5443
5444                 DEBUG(5,("reply_lockingX: oplock break reply (%u) from client "
5445                          "for fnum = %d\n", (unsigned int)oplocklevel,
5446                          fsp->fnum ));
5447
5448                 /*
5449                  * Make sure we have granted an exclusive or batch oplock on
5450                  * this file.
5451                  */
5452
5453                 if (fsp->oplock_type == 0) {
5454
5455                         /* The Samba4 nbench simulator doesn't understand
5456                            the difference between break to level2 and break
5457                            to none from level2 - it sends oplock break
5458                            replies in both cases. Don't keep logging an error
5459                            message here - just ignore it. JRA. */
5460
5461                         DEBUG(5,("reply_lockingX: Error : oplock break from "
5462                                  "client for fnum = %d (oplock=%d) and no "
5463                                  "oplock granted on this file (%s).\n",
5464                                  fsp->fnum, fsp->oplock_type, fsp->fsp_name));
5465
5466                         /* if this is a pure oplock break request then don't
5467                          * send a reply */
5468                         if (num_locks == 0 && num_ulocks == 0) {
5469                                 END_PROFILE(SMBlockingX);
5470                                 return -1;
5471                         } else {
5472                                 END_PROFILE(SMBlockingX);
5473                                 return ERROR_DOS(ERRDOS,ERRlock);
5474                         }
5475                 }
5476
5477                 if ((fsp->sent_oplock_break == BREAK_TO_NONE_SENT) ||
5478                     (break_to_none)) {
5479                         result = remove_oplock(fsp);
5480                 } else {
5481                         result = downgrade_oplock(fsp);
5482                 }
5483
5484                 if (!result) {
5485                         DEBUG(0, ("reply_lockingX: error in removing "
5486                                   "oplock on file %s\n", fsp->fsp_name));
5487                         /* Hmmm. Is this panic justified? */
5488                         smb_panic("internal tdb error");
5489                 }
5490
5491                 reply_to_oplock_break_requests(fsp);
5492
5493                 /* if this is a pure oplock break request then don't send a
5494                  * reply */
5495                 if (num_locks == 0 && num_ulocks == 0) {
5496                         /* Sanity check - ensure a pure oplock break is not a
5497                            chained request. */
5498                         if(CVAL(inbuf,smb_vwv0) != 0xff)
5499                                 DEBUG(0,("reply_lockingX: Error : pure oplock "
5500                                          "break is a chained %d request !\n",
5501                                          (unsigned int)CVAL(inbuf,smb_vwv0) ));
5502                         END_PROFILE(SMBlockingX);
5503                         return -1;
5504                 }
5505         }
5506
5507         /*
5508          * We do this check *after* we have checked this is not a oplock break
5509          * response message. JRA.
5510          */
5511
5512         release_level_2_oplocks_on_change(fsp);
5513
5514         /* Data now points at the beginning of the list
5515            of smb_unlkrng structs */
5516         for(i = 0; i < (int)num_ulocks; i++) {
5517                 lock_pid = get_lock_pid( data, i, large_file_format);
5518                 count = get_lock_count( data, i, large_file_format);
5519                 offset = get_lock_offset( data, i, large_file_format, &err);
5520
5521                 /*
5522                  * There is no error code marked "stupid client bug".... :-).
5523                  */
5524                 if(err) {
5525                         END_PROFILE(SMBlockingX);
5526                         return ERROR_DOS(ERRDOS,ERRnoaccess);
5527                 }
5528
5529                 DEBUG(10,("reply_lockingX: unlock start=%.0f, len=%.0f for "
5530                           "pid %u, file %s\n", (double)offset, (double)count,
5531                           (unsigned int)lock_pid, fsp->fsp_name ));
5532
5533                 status = do_unlock(smbd_messaging_context(),
5534                                 fsp,
5535                                 lock_pid,
5536                                 count,
5537                                 offset,
5538                                 WINDOWS_LOCK);
5539
5540                 if (NT_STATUS_V(status)) {
5541                         END_PROFILE(SMBlockingX);
5542                         return ERROR_NT(status);
5543                 }
5544         }
5545
5546         /* Setup the timeout in seconds. */
5547
5548         if (!lp_blocking_locks(SNUM(conn))) {
5549                 lock_timeout = 0;
5550         }
5551
5552         /* Now do any requested locks */
5553         data += ((large_file_format ? 20 : 10)*num_ulocks);
5554
5555         /* Data now points at the beginning of the list
5556            of smb_lkrng structs */
5557
5558         for(i = 0; i < (int)num_locks; i++) {
5559                 enum brl_type lock_type = ((locktype & LOCKING_ANDX_SHARED_LOCK) ?
5560                                 READ_LOCK:WRITE_LOCK);
5561                 lock_pid = get_lock_pid( data, i, large_file_format);
5562                 count = get_lock_count( data, i, large_file_format);
5563                 offset = get_lock_offset( data, i, large_file_format, &err);
5564
5565                 /*
5566                  * There is no error code marked "stupid client bug".... :-).
5567                  */
5568                 if(err) {
5569                         END_PROFILE(SMBlockingX);
5570                         return ERROR_DOS(ERRDOS,ERRnoaccess);
5571                 }
5572
5573                 DEBUG(10,("reply_lockingX: lock start=%.0f, len=%.0f for pid "
5574                           "%u, file %s timeout = %d\n", (double)offset,
5575                           (double)count, (unsigned int)lock_pid,
5576                           fsp->fsp_name, (int)lock_timeout ));
5577
5578                 if (locktype & LOCKING_ANDX_CANCEL_LOCK) {
5579                         if (lp_blocking_locks(SNUM(conn))) {
5580
5581                                 /* Schedule a message to ourselves to
5582                                    remove the blocking lock record and
5583                                    return the right error. */
5584
5585                                 if (!blocking_lock_cancel(fsp,
5586                                                 lock_pid,
5587                                                 offset,
5588                                                 count,
5589                                                 WINDOWS_LOCK,
5590                                                 locktype,
5591                                                 NT_STATUS_FILE_LOCK_CONFLICT)) {
5592                                         END_PROFILE(SMBlockingX);
5593                                         return ERROR_NT(NT_STATUS_DOS(ERRDOS, ERRcancelviolation));
5594                                 }
5595                         }
5596                         /* Remove a matching pending lock. */
5597                         status = do_lock_cancel(fsp,
5598                                                 lock_pid,
5599                                                 count,
5600                                                 offset,
5601                                                 WINDOWS_LOCK);
5602                 } else {
5603                         BOOL blocking_lock = lock_timeout ? True : False;
5604                         BOOL defer_lock = False;
5605                         struct byte_range_lock *br_lck;
5606                         uint32 block_smbpid;
5607
5608                         br_lck = do_lock(smbd_messaging_context(),
5609                                         fsp,
5610                                         lock_pid,
5611                                         count,
5612                                         offset,
5613                                         lock_type,
5614                                         WINDOWS_LOCK,
5615                                         blocking_lock,
5616                                         &status,
5617                                         &block_smbpid);
5618
5619                         if (br_lck && blocking_lock && ERROR_WAS_LOCK_DENIED(status)) {
5620                                 /* Windows internal resolution for blocking locks seems
5621                                    to be about 200ms... Don't wait for less than that. JRA. */
5622                                 if (lock_timeout != -1 && lock_timeout < lp_lock_spin_time()) {
5623                                         lock_timeout = lp_lock_spin_time();
5624                                 }
5625                                 defer_lock = True;
5626                         }
5627
5628                         /* This heuristic seems to match W2K3 very well. If a
5629                            lock sent with timeout of zero would fail with NT_STATUS_FILE_LOCK_CONFLICT
5630                            it pretends we asked for a timeout of between 150 - 300 milliseconds as
5631                            far as I can tell. Replacement for do_lock_spin(). JRA. */
5632
5633                         if (br_lck && lp_blocking_locks(SNUM(conn)) && !blocking_lock &&
5634                                         NT_STATUS_EQUAL((status), NT_STATUS_FILE_LOCK_CONFLICT)) {
5635                                 defer_lock = True;
5636                                 lock_timeout = lp_lock_spin_time();
5637                         }
5638
5639                         if (br_lck && defer_lock) {
5640                                 /*
5641                                  * A blocking lock was requested. Package up
5642                                  * this smb into a queued request and push it
5643                                  * onto the blocking lock queue.
5644                                  */
5645                                 if(push_blocking_lock_request(br_lck,
5646                                                         inbuf, length,
5647                                                         fsp,
5648                                                         lock_timeout,
5649                                                         i,
5650                                                         lock_pid,
5651                                                         lock_type,
5652                                                         WINDOWS_LOCK,
5653                                                         offset,
5654                                                         count,
5655                                                         block_smbpid)) {
5656                                         TALLOC_FREE(br_lck);
5657                                         END_PROFILE(SMBlockingX);
5658                                         return -1;
5659                                 }
5660                         }
5661
5662                         TALLOC_FREE(br_lck);
5663                 }
5664
5665                 if (NT_STATUS_V(status)) {
5666                         END_PROFILE(SMBlockingX);
5667                         return ERROR_NT(status);
5668                 }
5669         }
5670
5671         /* If any of the above locks failed, then we must unlock
5672            all of the previous locks (X/Open spec). */
5673
5674         if (!(locktype & LOCKING_ANDX_CANCEL_LOCK) &&
5675                         (i != num_locks) &&
5676                         (num_locks != 0)) {
5677                 /*
5678                  * Ensure we don't do a remove on the lock that just failed,
5679                  * as under POSIX rules, if we have a lock already there, we
5680                  * will delete it (and we shouldn't) .....
5681                  */
5682                 for(i--; i >= 0; i--) {
5683                         lock_pid = get_lock_pid( data, i, large_file_format);
5684                         count = get_lock_count( data, i, large_file_format);
5685                         offset = get_lock_offset( data, i, large_file_format,
5686                                                   &err);
5687
5688                         /*
5689                          * There is no error code marked "stupid client
5690                          * bug".... :-).
5691                          */
5692                         if(err) {
5693                                 END_PROFILE(SMBlockingX);
5694                                 return ERROR_DOS(ERRDOS,ERRnoaccess);
5695                         }
5696
5697                         do_unlock(smbd_messaging_context(),
5698                                 fsp,
5699                                 lock_pid,
5700                                 count,
5701                                 offset,
5702                                 WINDOWS_LOCK);
5703                 }
5704                 END_PROFILE(SMBlockingX);
5705                 return ERROR_NT(status);
5706         }
5707
5708         set_message(inbuf,outbuf,2,0,True);
5709
5710         DEBUG(3, ("lockingX fnum=%d type=%d num_locks=%d num_ulocks=%d\n",
5711                   fsp->fnum, (unsigned int)locktype, num_locks, num_ulocks));
5712
5713         END_PROFILE(SMBlockingX);
5714         return chain_reply(inbuf,outbuf,length,bufsize);
5715 }
5716
5717 #undef DBGC_CLASS
5718 #define DBGC_CLASS DBGC_ALL
5719
5720 /****************************************************************************
5721  Reply to a SMBreadbmpx (read block multiplex) request.
5722 ****************************************************************************/
5723
5724 int reply_readbmpx(connection_struct *conn, char *inbuf,char *outbuf,int length,int bufsize)
5725 {
5726         ssize_t nread = -1;
5727         ssize_t total_read;
5728         char *data;
5729         SMB_OFF_T startpos;
5730         int outsize;
5731         size_t maxcount;
5732         int max_per_packet;
5733         size_t tcount;
5734         int pad;
5735         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
5736         START_PROFILE(SMBreadBmpx);
5737
5738         /* this function doesn't seem to work - disable by default */
5739         if (!lp_readbmpx()) {
5740                 END_PROFILE(SMBreadBmpx);
5741                 return ERROR_DOS(ERRSRV,ERRuseSTD);
5742         }
5743
5744         outsize = set_message(inbuf,outbuf,8,0,True);
5745
5746         CHECK_FSP(fsp,conn);
5747         if (!CHECK_READ(fsp,inbuf)) {
5748                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
5749         }
5750
5751         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv1);
5752         maxcount = SVAL(inbuf,smb_vwv3);
5753
5754         data = smb_buf(outbuf);
5755         pad = ((long)data)%4;
5756         if (pad)
5757                 pad = 4 - pad;
5758         data += pad;
5759
5760         max_per_packet = bufsize-(outsize+pad);
5761         tcount = maxcount;
5762         total_read = 0;
5763
5764         if (is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)maxcount,(SMB_BIG_UINT)startpos, READ_LOCK)) {
5765                 END_PROFILE(SMBreadBmpx);
5766                 return ERROR_DOS(ERRDOS,ERRlock);
5767         }
5768
5769         do {
5770                 size_t N = MIN(max_per_packet,tcount-total_read);
5771
5772                 nread = read_file(fsp,data,startpos,N);
5773
5774                 if (nread <= 0)
5775                         nread = 0;
5776
5777                 if (nread < (ssize_t)N)
5778                         tcount = total_read + nread;
5779
5780                 set_message(inbuf,outbuf,8,nread+pad,False);
5781                 SIVAL(outbuf,smb_vwv0,startpos);
5782                 SSVAL(outbuf,smb_vwv2,tcount);
5783                 SSVAL(outbuf,smb_vwv6,nread);
5784                 SSVAL(outbuf,smb_vwv7,smb_offset(data,outbuf));
5785
5786                 show_msg(outbuf);
5787                 if (!send_smb(smbd_server_fd(),outbuf))
5788                         exit_server_cleanly("reply_readbmpx: send_smb failed.");
5789
5790                 total_read += nread;
5791                 startpos += nread;
5792         } while (total_read < (ssize_t)tcount);
5793
5794         END_PROFILE(SMBreadBmpx);
5795         return(-1);
5796 }
5797
5798 /****************************************************************************
5799  Reply to a SMBsetattrE.
5800 ****************************************************************************/
5801
5802 int reply_setattrE(connection_struct *conn, char *inbuf,char *outbuf, int size, int dum_buffsize)
5803 {
5804         struct timespec ts[2];
5805         int outsize = 0;
5806         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
5807         START_PROFILE(SMBsetattrE);
5808
5809         outsize = set_message(inbuf,outbuf,0,0,False);
5810
5811         if(!fsp || (fsp->conn != conn)) {
5812                 END_PROFILE(SMBsetattrE);
5813                 return ERROR_DOS(ERRDOS,ERRbadfid);
5814         }
5815
5816         /*
5817          * Convert the DOS times into unix times. Ignore create
5818          * time as UNIX can't set this.
5819          */
5820
5821         ts[0] = convert_time_t_to_timespec(srv_make_unix_date2(inbuf+smb_vwv3)); /* atime. */
5822         ts[1] = convert_time_t_to_timespec(srv_make_unix_date2(inbuf+smb_vwv5)); /* mtime. */
5823
5824         /*
5825          * Patch from Ray Frush <frush@engr.colostate.edu>
5826          * Sometimes times are sent as zero - ignore them.
5827          */
5828
5829         if (null_timespec(ts[0]) && null_timespec(ts[1])) {
5830                 /* Ignore request */
5831                 if( DEBUGLVL( 3 ) ) {
5832                         dbgtext( "reply_setattrE fnum=%d ", fsp->fnum);
5833                         dbgtext( "ignoring zero request - not setting timestamps of 0\n" );
5834                 }
5835                 END_PROFILE(SMBsetattrE);
5836                 return(outsize);
5837         } else if (!null_timespec(ts[0]) && null_timespec(ts[1])) {
5838                 /* set modify time = to access time if modify time was unset */
5839                 ts[1] = ts[0];
5840         }
5841
5842         /* Set the date on this file */
5843         /* Should we set pending modtime here ? JRA */
5844         if(file_ntimes(conn, fsp->fsp_name, ts)) {
5845                 END_PROFILE(SMBsetattrE);
5846                 return ERROR_DOS(ERRDOS,ERRnoaccess);
5847         }
5848
5849         DEBUG( 3, ( "reply_setattrE fnum=%d actime=%u modtime=%u\n",
5850                 fsp->fnum,
5851                 (unsigned int)ts[0].tv_sec,
5852                 (unsigned int)ts[1].tv_sec));
5853
5854         END_PROFILE(SMBsetattrE);
5855         return(outsize);
5856 }
5857
5858
5859 /* Back from the dead for OS/2..... JRA. */
5860
5861 /****************************************************************************
5862  Reply to a SMBwritebmpx (write block multiplex primary) request.
5863 ****************************************************************************/
5864
5865 int reply_writebmpx(connection_struct *conn, char *inbuf,char *outbuf, int size, int dum_buffsize)
5866 {
5867         size_t numtowrite;
5868         ssize_t nwritten = -1;
5869         int outsize = 0;
5870         SMB_OFF_T startpos;
5871         size_t tcount;
5872         BOOL write_through;
5873         int smb_doff;
5874         char *data;
5875         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
5876         START_PROFILE(SMBwriteBmpx);
5877
5878         CHECK_FSP(fsp,conn);
5879         if (!CHECK_WRITE(fsp)) {
5880                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
5881         }
5882         if (HAS_CACHED_ERROR(fsp)) {
5883                 return(CACHED_ERROR(fsp));
5884         }
5885
5886         tcount = SVAL(inbuf,smb_vwv1);
5887         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv3);
5888         write_through = BITSETW(inbuf+smb_vwv7,0);
5889         numtowrite = SVAL(inbuf,smb_vwv10);
5890         smb_doff = SVAL(inbuf,smb_vwv11);
5891
5892         data = smb_base(inbuf) + smb_doff;
5893
5894         /* If this fails we need to send an SMBwriteC response,
5895                 not an SMBwritebmpx - set this up now so we don't forget */
5896         SCVAL(outbuf,smb_com,SMBwritec);
5897
5898         if (is_locked(fsp,(uint32)SVAL(inbuf,smb_pid),(SMB_BIG_UINT)tcount,(SMB_BIG_UINT)startpos,WRITE_LOCK)) {
5899                 END_PROFILE(SMBwriteBmpx);
5900                 return(ERROR_DOS(ERRDOS,ERRlock));
5901         }
5902
5903         nwritten = write_file(fsp,data,startpos,numtowrite);
5904
5905         sync_file(conn, fsp, write_through);
5906
5907         if(nwritten < (ssize_t)numtowrite) {
5908                 END_PROFILE(SMBwriteBmpx);
5909                 return(UNIXERROR(ERRHRD,ERRdiskfull));
5910         }
5911
5912         /* If the maximum to be written to this file
5913                 is greater than what we just wrote then set
5914                 up a secondary struct to be attached to this
5915                 fd, we will use this to cache error messages etc. */
5916
5917         if((ssize_t)tcount > nwritten) {
5918                 write_bmpx_struct *wbms;
5919                 if(fsp->wbmpx_ptr != NULL)
5920                         wbms = fsp->wbmpx_ptr; /* Use an existing struct */
5921                 else
5922                         wbms = SMB_MALLOC_P(write_bmpx_struct);
5923                 if(!wbms) {
5924                         DEBUG(0,("Out of memory in reply_readmpx\n"));
5925                         END_PROFILE(SMBwriteBmpx);
5926                         return(ERROR_DOS(ERRSRV,ERRnoresource));
5927                 }
5928                 wbms->wr_mode = write_through;
5929                 wbms->wr_discard = False; /* No errors yet */
5930                 wbms->wr_total_written = nwritten;
5931                 wbms->wr_errclass = 0;
5932                 wbms->wr_error = 0;
5933                 fsp->wbmpx_ptr = wbms;
5934         }
5935
5936         /* We are returning successfully, set the message type back to
5937                 SMBwritebmpx */
5938         SCVAL(outbuf,smb_com,SMBwriteBmpx);
5939
5940         outsize = set_message(inbuf,outbuf,1,0,True);
5941
5942         SSVALS(outbuf,smb_vwv0,-1); /* We don't support smb_remaining */
5943
5944         DEBUG( 3, ( "writebmpx fnum=%d num=%d wrote=%d\n",
5945                         fsp->fnum, (int)numtowrite, (int)nwritten ) );
5946
5947         if (write_through && tcount==nwritten) {
5948                 /* We need to send both a primary and a secondary response */
5949                 smb_setlen(inbuf,outbuf,outsize - 4);
5950                 show_msg(outbuf);
5951                 if (!send_smb(smbd_server_fd(),outbuf))
5952                         exit_server_cleanly("reply_writebmpx: send_smb failed.");
5953
5954                 /* Now the secondary */
5955                 outsize = set_message(inbuf,outbuf,1,0,True);
5956                 SCVAL(outbuf,smb_com,SMBwritec);
5957                 SSVAL(outbuf,smb_vwv0,nwritten);
5958         }
5959
5960         END_PROFILE(SMBwriteBmpx);
5961         return(outsize);
5962 }
5963
5964 /****************************************************************************
5965  Reply to a SMBwritebs (write block multiplex secondary) request.
5966 ****************************************************************************/
5967
5968 int reply_writebs(connection_struct *conn, char *inbuf,char *outbuf, int dum_size, int dum_buffsize)
5969 {
5970         size_t numtowrite;
5971         ssize_t nwritten = -1;
5972         int outsize = 0;
5973         SMB_OFF_T startpos;
5974         size_t tcount;
5975         BOOL write_through;
5976         int smb_doff;
5977         char *data;
5978         write_bmpx_struct *wbms;
5979         BOOL send_response = False;
5980         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
5981         START_PROFILE(SMBwriteBs);
5982
5983         CHECK_FSP(fsp,conn);
5984         if (!CHECK_WRITE(fsp)) {
5985                 return(ERROR_DOS(ERRDOS,ERRbadaccess));
5986         }
5987
5988         tcount = SVAL(inbuf,smb_vwv1);
5989         startpos = IVAL_TO_SMB_OFF_T(inbuf,smb_vwv2);
5990         numtowrite = SVAL(inbuf,smb_vwv6);
5991         smb_doff = SVAL(inbuf,smb_vwv7);
5992
5993         data = smb_base(inbuf) + smb_doff;
5994
5995         /* We need to send an SMBwriteC response, not an SMBwritebs */
5996         SCVAL(outbuf,smb_com,SMBwritec);
5997
5998         /* This fd should have an auxiliary struct attached,
5999                 check that it does */
6000         wbms = fsp->wbmpx_ptr;
6001         if(!wbms) {
6002                 END_PROFILE(SMBwriteBs);
6003                 return(-1);
6004         }
6005
6006         /* If write through is set we can return errors, else we must cache them */
6007         write_through = wbms->wr_mode;
6008
6009         /* Check for an earlier error */
6010         if(wbms->wr_discard) {
6011                 END_PROFILE(SMBwriteBs);
6012                 return -1; /* Just discard the packet */
6013         }
6014
6015         nwritten = write_file(fsp,data,startpos,numtowrite);
6016
6017         sync_file(conn, fsp, write_through);
6018
6019         if (nwritten < (ssize_t)numtowrite) {
6020                 if(write_through) {
6021                         /* We are returning an error - we can delete the aux struct */
6022                         if (wbms)
6023                                 free((char *)wbms);
6024                         fsp->wbmpx_ptr = NULL;
6025                         END_PROFILE(SMBwriteBs);
6026                         return(ERROR_DOS(ERRHRD,ERRdiskfull));
6027                 }
6028                 wbms->wr_errclass = ERRHRD;
6029                 wbms->wr_error = ERRdiskfull;
6030                 wbms->wr_status = NT_STATUS_DISK_FULL;
6031                 wbms->wr_discard = True;
6032                 END_PROFILE(SMBwriteBs);
6033                 return -1;
6034         }
6035
6036         /* Increment the total written, if this matches tcount
6037                 we can discard the auxiliary struct (hurrah !) and return a writeC */
6038         wbms->wr_total_written += nwritten;
6039         if(wbms->wr_total_written >= tcount) {
6040                 if (write_through) {
6041                         outsize = set_message(inbuf,outbuf,1,0,True);
6042                         SSVAL(outbuf,smb_vwv0,wbms->wr_total_written);
6043                         send_response = True;
6044                 }
6045
6046                 free((char *)wbms);
6047                 fsp->wbmpx_ptr = NULL;
6048         }
6049
6050         if(send_response) {
6051                 END_PROFILE(SMBwriteBs);
6052                 return(outsize);
6053         }
6054
6055         END_PROFILE(SMBwriteBs);
6056         return(-1);
6057 }
6058
6059 /****************************************************************************
6060  Reply to a SMBgetattrE.
6061 ****************************************************************************/
6062
6063 int reply_getattrE(connection_struct *conn, char *inbuf,char *outbuf, int size, int dum_buffsize)
6064 {
6065         SMB_STRUCT_STAT sbuf;
6066         int outsize = 0;
6067         int mode;
6068         files_struct *fsp = file_fsp(inbuf,smb_vwv0);
6069         START_PROFILE(SMBgetattrE);
6070
6071         outsize = set_message(inbuf,outbuf,11,0,True);
6072
6073         if(!fsp || (fsp->conn != conn)) {
6074                 END_PROFILE(SMBgetattrE);
6075                 return ERROR_DOS(ERRDOS,ERRbadfid);
6076         }
6077
6078         /* Do an fstat on this file */
6079         if(fsp_stat(fsp, &sbuf)) {
6080                 END_PROFILE(SMBgetattrE);
6081                 return(UNIXERROR(ERRDOS,ERRnoaccess));
6082         }
6083
6084         mode = dos_mode(conn,fsp->fsp_name,&sbuf);
6085
6086         /*
6087          * Convert the times into dos times. Set create
6088          * date to be last modify date as UNIX doesn't save
6089          * this.
6090          */
6091
6092         srv_put_dos_date2(outbuf,smb_vwv0,get_create_time(&sbuf,lp_fake_dir_create_times(SNUM(conn))));
6093         srv_put_dos_date2(outbuf,smb_vwv2,sbuf.st_atime);
6094         /* Should we check pending modtime here ? JRA */
6095         srv_put_dos_date2(outbuf,smb_vwv4,sbuf.st_mtime);
6096
6097         if (mode & aDIR) {
6098                 SIVAL(outbuf,smb_vwv6,0);
6099                 SIVAL(outbuf,smb_vwv8,0);
6100         } else {
6101                 uint32 allocation_size = get_allocation_size(conn,fsp, &sbuf);
6102                 SIVAL(outbuf,smb_vwv6,(uint32)sbuf.st_size);
6103                 SIVAL(outbuf,smb_vwv8,allocation_size);
6104         }
6105         SSVAL(outbuf,smb_vwv10, mode);
6106
6107         DEBUG( 3, ( "reply_getattrE fnum=%d\n", fsp->fnum));
6108
6109         END_PROFILE(SMBgetattrE);
6110         return(outsize);
6111 }