source4/libcli/smb2/create.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3
   4    SMB2 client tree handling
   5
   6    Copyright (C) Andrew Tridgell 2005
   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 3 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, see <http://www.gnu.org/licenses/>.
  20 */
  21
  22 #include "includes.h"
  23 #include "libcli/raw/libcliraw.h"
  24 #include "libcli/raw/raw_proto.h"
  25 #include "libcli/smb2/smb2.h"
  26 #include "libcli/smb2/smb2_calls.h"
  27 #include "librpc/gen_ndr/ndr_security.h"
  28
  29 /*
  30   send a create request
  31 */
  32 struct smb2_request *smb2_create_send(struct smb2_tree *tree, struct smb2_create *io)
  33 {
  34         struct smb2_request *req;
  35         NTSTATUS status;
  36         DATA_BLOB blob;
  37         struct smb2_create_blobs blobs;
  38         int i;
  39
  40         ZERO_STRUCT(blobs);
  41
  42         req = smb2_request_init_tree(tree, SMB2_OP_CREATE, 0x38, true, 0);
  43         if (req == NULL) return NULL;
  44
  45         SCVAL(req->out.body, 0x02, io->in.security_flags);
  46         SCVAL(req->out.body, 0x03, io->in.oplock_level);
  47         SIVAL(req->out.body, 0x04, io->in.impersonation_level);
  48         SBVAL(req->out.body, 0x08, io->in.create_flags);
  49         SBVAL(req->out.body, 0x10, io->in.reserved);
  50         SIVAL(req->out.body, 0x18, io->in.desired_access);
  51         SIVAL(req->out.body, 0x1C, io->in.file_attributes);
  52         SIVAL(req->out.body, 0x20, io->in.share_access);
  53         SIVAL(req->out.body, 0x24, io->in.create_disposition);
  54         SIVAL(req->out.body, 0x28, io->in.create_options);
  55
  56         status = smb2_push_o16s16_string(&req->out, 0x2C, io->in.fname);
  57         if (!NT_STATUS_IS_OK(status)) {
  58                 talloc_free(req);
  59                 return NULL;
  60         }
  61
  62         /* now add all the optional blobs */
  63         if (io->in.eas.num_eas != 0) {
  64                 DATA_BLOB b = data_blob_talloc(req, NULL,
  65                                                ea_list_size_chained(io->in.eas.num_eas, io->in.eas.eas, 4));
  66                 ea_put_list_chained(b.data, io->in.eas.num_eas, io->in.eas.eas, 4);
  67                 status = smb2_create_blob_add(req, &blobs,
  68                                               SMB2_CREATE_TAG_EXTA, b);
  69                 if (!NT_STATUS_IS_OK(status)) {
  70                         talloc_free(req);
  71                         return NULL;
  72                 }
  73                 data_blob_free(&b);
  74         }
  75
  76         /* an empty MxAc tag seems to be used to ask the server to
  77            return the maximum access mask allowed on the file */
  78         if (io->in.query_maximal_access) {
  79                 /* TODO: MS-SMB2 2.2.13.2.5 says this can contain a timestamp? What to do
  80                    with that if it doesn't match? */
  81                 status = smb2_create_blob_add(req, &blobs,
  82                                               SMB2_CREATE_TAG_MXAC, data_blob(NULL, 0));
  83                 if (!NT_STATUS_IS_OK(status)) {
  84                         talloc_free(req);
  85                         return NULL;
  86                 }
  87         }
  88
  89         if (io->in.alloc_size != 0) {
  90                 uint8_t data[8];
  91                 SBVAL(data, 0, io->in.alloc_size);
  92                 status = smb2_create_blob_add(req, &blobs,
  93                                               SMB2_CREATE_TAG_ALSI, data_blob_const(data, 8));
  94                 if (!NT_STATUS_IS_OK(status)) {
  95                         talloc_free(req);
  96                         return NULL;
  97                 }
  98         }
  99
 100         if (io->in.durable_open) {
 101                 status = smb2_create_blob_add(req, &blobs,
 102                                               SMB2_CREATE_TAG_DHNQ, data_blob_talloc_zero(req, 16));
 103                 if (!NT_STATUS_IS_OK(status)) {
 104                         talloc_free(req);
 105                         return NULL;
 106                 }
 107         }
 108
 109         if (io->in.durable_open_v2) {
 110                 uint8_t data[32];
 111                 uint32_t flags = 0;
 112                 struct GUID_ndr_buf guid_buf = { .buf = {0}, };
 113
 114                 SIVAL(data, 0, io->in.timeout);
 115                 if (io->in.persistent_open) {
 116                         flags = SMB2_DHANDLE_FLAG_PERSISTENT;
 117                 }
 118                 SIVAL(data, 4, flags);
 119                 SBVAL(data, 8, 0x0); /* reserved */
 120                 GUID_to_ndr_buf(&io->in.create_guid, &guid_buf);
 121                 memcpy(data+16, guid_buf.buf, sizeof(guid_buf.buf));
 122
 123                 status = smb2_create_blob_add(req, &blobs,
 124                                               SMB2_CREATE_TAG_DH2Q,
 125                                               data_blob_const(data, 32));
 126                 if (!NT_STATUS_IS_OK(status)) {
 127                         talloc_free(req);
 128                         return NULL;
 129                 }
 130         }
 131
 132         if (io->in.durable_handle) {
 133                 uint8_t data[16];
 134                 smb2_push_handle(data, io->in.durable_handle);
 135                 status = smb2_create_blob_add(req, &blobs,
 136                                               SMB2_CREATE_TAG_DHNC, data_blob_const(data, 16));
 137                 if (!NT_STATUS_IS_OK(status)) {
 138                         talloc_free(req);
 139                         return NULL;
 140                 }
 141         }
 142
 143         if (io->in.durable_handle_v2) {
 144                 uint8_t data[36];
 145                 struct GUID_ndr_buf guid_buf = { .buf = {0}, };
 146                 uint32_t flags = 0;
 147
 148                 smb2_push_handle(data, io->in.durable_handle_v2);
 149                 GUID_to_ndr_buf(&io->in.create_guid, &guid_buf);
 150                 memcpy(data+16, guid_buf.buf, sizeof(guid_buf.buf));
 151                 if (io->in.persistent_open) {
 152                         flags = SMB2_DHANDLE_FLAG_PERSISTENT;
 153                 }
 154                 SIVAL(data, 32, flags);
 155
 156                 status = smb2_create_blob_add(req, &blobs,
 157                                               SMB2_CREATE_TAG_DH2C,
 158                                               data_blob_const(data, 36));
 159                 if (!NT_STATUS_IS_OK(status)) {
 160                         talloc_free(req);
 161                         return NULL;
 162                 }
 163         }
 164
 165         if (io->in.timewarp) {
 166                 uint8_t data[8];
 167                 SBVAL(data, 0, io->in.timewarp);
 168                 status = smb2_create_blob_add(req, &blobs,
 169                                               SMB2_CREATE_TAG_TWRP, data_blob_const(data, 8));
 170                 if (!NT_STATUS_IS_OK(status)) {
 171                         talloc_free(req);
 172                         return NULL;
 173                 }
 174         }
 175
 176         if (io->in.sec_desc) {
 177                 enum ndr_err_code ndr_err;
 178                 DATA_BLOB sd_blob;
 179                 ndr_err = ndr_push_struct_blob(&sd_blob, req, io->in.sec_desc,
 180                                                (ndr_push_flags_fn_t)ndr_push_security_descriptor);
 181                 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
 182                         talloc_free(req);
 183                         return NULL;
 184                 }
 185                 status = smb2_create_blob_add(req, &blobs,
 186                                               SMB2_CREATE_TAG_SECD, sd_blob);
 187                 if (!NT_STATUS_IS_OK(status)) {
 188                         talloc_free(req);
 189                         return NULL;
 190                 }
 191         }
 192
 193         if (io->in.query_on_disk_id) {
 194                 status = smb2_create_blob_add(req, &blobs,
 195                                               SMB2_CREATE_TAG_QFID, data_blob(NULL, 0));
 196                 if (!NT_STATUS_IS_OK(status)) {
 197                         talloc_free(req);
 198                         return NULL;
 199                 }
 200         }
 201
 202         if (io->in.lease_request) {
 203                 uint8_t data[32];
 204
 205                 if (!smb2_lease_push(io->in.lease_request, data,
 206                                      sizeof(data))) {
 207                         TALLOC_FREE(req);
 208                         return NULL;
 209                 }
 210
 211                 status = smb2_create_blob_add(
 212                         req, &blobs, SMB2_CREATE_TAG_RQLS,
 213                         data_blob_const(data, sizeof(data)));
 214                 if (!NT_STATUS_IS_OK(status)) {
 215                         talloc_free(req);
 216                         return NULL;
 217                 }
 218         }
 219
 220         if (io->in.lease_request_v2) {
 221                 uint8_t data[52];
 222
 223                 if (!smb2_lease_push(io->in.lease_request_v2, data,
 224                                      sizeof(data))) {
 225                         TALLOC_FREE(req);
 226                         return NULL;
 227                 }
 228
 229                 status = smb2_create_blob_add(
 230                         req, &blobs, SMB2_CREATE_TAG_RQLS,
 231                         data_blob_const(data, sizeof(data)));
 232                 if (!NT_STATUS_IS_OK(status)) {
 233                         talloc_free(req);
 234                         return NULL;
 235                 }
 236         }
 237
 238         if (io->in.app_instance_id) {
 239                 uint8_t data[20];
 240                 struct GUID_ndr_buf guid_buf = { .buf = {0}, };
 241
 242                 SSVAL(data, 0, 20); /* structure size */
 243                 SSVAL(data, 2, 0);  /* reserved */
 244
 245                 GUID_to_ndr_buf(io->in.app_instance_id, &guid_buf);
 246                 memcpy(data+4, guid_buf.buf, sizeof(guid_buf.buf));
 247
 248                 status = smb2_create_blob_add(req, &blobs,
 249                                               SMB2_CREATE_TAG_APP_INSTANCE_ID,
 250                                               data_blob_const(data, 20));
 251                 if (!NT_STATUS_IS_OK(status)) {
 252                         talloc_free(req);
 253                         return NULL;
 254                 }
 255         }
 256
 257         /* and any custom blobs */
 258         for (i=0;i<io->in.blobs.num_blobs;i++) {
 259                 status = smb2_create_blob_add(req, &blobs,
 260                                               io->in.blobs.blobs[i].tag,
 261                                               io->in.blobs.blobs[i].data);
 262                 if (!NT_STATUS_IS_OK(status)) {
 263                         talloc_free(req);
 264                         return NULL;
 265                 }
 266         }
 267
 268
 269         status = smb2_create_blob_push(req, &blob, blobs);
 270         if (!NT_STATUS_IS_OK(status)) {
 271                 talloc_free(req);
 272                 return NULL;
 273         }
 274
 275         status = smb2_push_o32s32_blob(&req->out, 0x30, blob);
 276         if (!NT_STATUS_IS_OK(status)) {
 277                 talloc_free(req);
 278                 return NULL;
 279         }
 280
 281         if (((io->in.fname == NULL) || (strlen(io->in.fname) == 0)) &&
 282             (blob.length == 0)) {
 283                 struct smb2_request_buffer *buf = &req->out;
 284
 285                 status = smb2_grow_buffer(buf, 1);
 286                 if (!NT_STATUS_IS_OK(status)) {
 287                         talloc_free(req);
 288                         return NULL;
 289                 }
 290                 buf->dynamic[0] = 0;
 291                 buf->dynamic += 1;
 292                 buf->body_size += 1;
 293                 buf->size += 1;
 294         }
 295
 296         data_blob_free(&blob);
 297
 298         smb2_transport_send(req);
 299
 300         return req;
 301 }
 302
 303
 304 /*
 305   recv a create reply
 306 */
 307 NTSTATUS smb2_create_recv(struct smb2_request *req, TALLOC_CTX *mem_ctx, struct smb2_create *io)
 308 {
 309         NTSTATUS status;
 310         DATA_BLOB blob;
 311         int i;
 312
 313         if (!smb2_request_receive(req) ||
 314             !smb2_request_is_ok(req)) {
 315                 return smb2_request_destroy(req);
 316         }
 317
 318         SMB2_CHECK_PACKET_RECV(req, 0x58, true);
 319         ZERO_STRUCT(io->out);
 320         io->out.oplock_level   = CVAL(req->in.body, 0x02);
 321         io->out.reserved       = CVAL(req->in.body, 0x03);
 322         io->out.create_action  = IVAL(req->in.body, 0x04);
 323         io->out.create_time    = smbcli_pull_nttime(req->in.body, 0x08);
 324         io->out.access_time    = smbcli_pull_nttime(req->in.body, 0x10);
 325         io->out.write_time     = smbcli_pull_nttime(req->in.body, 0x18);
 326         io->out.change_time    = smbcli_pull_nttime(req->in.body, 0x20);
 327         io->out.alloc_size     = BVAL(req->in.body, 0x28);
 328         io->out.size           = BVAL(req->in.body, 0x30);
 329         io->out.file_attr      = IVAL(req->in.body, 0x38);
 330         io->out.reserved2      = IVAL(req->in.body, 0x3C);
 331         smb2_pull_handle(req->in.body+0x40, &io->out.file.handle);
 332         status = smb2_pull_o32s32_blob(&req->in, mem_ctx, req->in.body+0x50, &blob);
 333         if (!NT_STATUS_IS_OK(status)) {
 334                 smb2_request_destroy(req);
 335                 return status;
 336         }
 337
 338         status = smb2_create_blob_parse(mem_ctx, blob, &io->out.blobs);
 339         if (!NT_STATUS_IS_OK(status)) {
 340                 smb2_request_destroy(req);
 341                 return status;
 342         }
 343
 344         /* pull out the parsed blobs */
 345         for (i=0;i<io->out.blobs.num_blobs;i++) {
 346                 if (strcmp(io->out.blobs.blobs[i].tag, SMB2_CREATE_TAG_MXAC) == 0) {
 347                         if (io->out.blobs.blobs[i].data.length != 8) {
 348                                 smb2_request_destroy(req);
 349                                 return NT_STATUS_INVALID_NETWORK_RESPONSE;
 350                         }
 351                         io->out.maximal_access_status =
 352                                 IVAL(io->out.blobs.blobs[i].data.data, 0);
 353                         io->out.maximal_access = IVAL(io->out.blobs.blobs[i].data.data, 4);
 354                 }
 355                 if (strcmp(io->out.blobs.blobs[i].tag, SMB2_CREATE_TAG_QFID) == 0) {
 356                         if (io->out.blobs.blobs[i].data.length != 32) {
 357                                 smb2_request_destroy(req);
 358                                 return NT_STATUS_INVALID_NETWORK_RESPONSE;
 359                         }
 360                         memcpy(io->out.on_disk_id, io->out.blobs.blobs[i].data.data, 32);
 361                 }
 362                 if (strcmp(io->out.blobs.blobs[i].tag, SMB2_CREATE_TAG_RQLS) == 0) {
 363                         struct smb2_lease *ls = NULL;
 364                         uint8_t *data;
 365
 366                         ZERO_STRUCT(io->out.lease_response);
 367                         ZERO_STRUCT(io->out.lease_response_v2);
 368
 369                         switch (io->out.blobs.blobs[i].data.length) {
 370                         case 32:
 371                                 ls = &io->out.lease_response;
 372                                 ls->lease_version = 1;
 373                                 break;
 374                         case 52:
 375                                 ls = &io->out.lease_response_v2;
 376                                 ls->lease_version = 2;
 377                                 break;
 378                         default:
 379                                 smb2_request_destroy(req);
 380                                 return NT_STATUS_INVALID_NETWORK_RESPONSE;
 381                         }
 382
 383                         data = io->out.blobs.blobs[i].data.data;
 384                         memcpy(&ls->lease_key, data, 16);
 385                         ls->lease_state = IVAL(data, 16);
 386                         ls->lease_flags = IVAL(data, 20);
 387                         ls->lease_duration = BVAL(data, 24);
 388
 389                         if (io->out.blobs.blobs[i].data.length == 52) {
 390                                 memcpy(&ls->parent_lease_key, data+32, 16);
 391                                 ls->lease_epoch = SVAL(data, 48);
 392                         }
 393                 }
 394                 if (strcmp(io->out.blobs.blobs[i].tag, SMB2_CREATE_TAG_DHNQ) == 0) {
 395                         if (io->out.blobs.blobs[i].data.length != 8) {
 396                                 smb2_request_destroy(req);
 397                                 return NT_STATUS_INVALID_NETWORK_RESPONSE;
 398                         }
 399                         io->out.durable_open = true;
 400                 }
 401                 if (strcmp(io->out.blobs.blobs[i].tag, SMB2_CREATE_TAG_DH2Q) == 0) {
 402                         uint32_t flags;
 403                         uint8_t *data;
 404
 405                         if (io->out.blobs.blobs[i].data.length != 8) {
 406                                 smb2_request_destroy(req);
 407                                 return NT_STATUS_INVALID_NETWORK_RESPONSE;
 408                         }
 409
 410                         io->out.durable_open = false;
 411                         io->out.durable_open_v2 = true;
 412
 413                         data = io->out.blobs.blobs[i].data.data;
 414                         io->out.timeout = IVAL(data, 0);
 415                         flags = IVAL(data, 4);
 416                         if ((flags & SMB2_DHANDLE_FLAG_PERSISTENT) != 0) {
 417                                 io->out.persistent_open = true;
 418                         }
 419                 }
 420         }
 421
 422         data_blob_free(&blob);
 423
 424         return smb2_request_destroy(req);
 425 }
 426
 427 /*
 428   sync create request
 429 */
 430 NTSTATUS smb2_create(struct smb2_tree *tree, TALLOC_CTX *mem_ctx, struct smb2_create *io)
 431 {
 432         struct smb2_request *req = smb2_create_send(tree, io);
 433         return smb2_create_recv(req, mem_ctx, io);
 434 }