Line data Source code
1 : /*
2 : Unix SMB/CIFS implementation.
3 :
4 : SMB2 client notify calls
5 :
6 : Copyright (C) Stefan Metzmacher 2006
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 :
28 : /*
29 : send a notify request
30 : */
31 1726 : struct smb2_request *smb2_notify_send(struct smb2_tree *tree, struct smb2_notify *io)
32 : {
33 18 : struct smb2_request *req;
34 18 : uint32_t old_timeout;
35 :
36 1726 : req = smb2_request_init_tree(tree, SMB2_OP_NOTIFY, 0x20, false, 0);
37 1726 : if (req == NULL) return NULL;
38 :
39 1726 : SSVAL(req->out.hdr, SMB2_HDR_CREDIT, 0x0030);
40 :
41 1726 : SSVAL(req->out.body, 0x02, io->in.recursive);
42 1726 : SIVAL(req->out.body, 0x04, io->in.buffer_size);
43 1726 : smb2_push_handle(req->out.body+0x08, &io->in.file.handle);
44 1726 : SIVAL(req->out.body, 0x18, io->in.completion_filter);
45 1726 : SIVAL(req->out.body, 0x1C, io->in.unknown);
46 :
47 1726 : req->credit_charge = (MAX(io->in.buffer_size, 1) - 1)/ 65536 + 1;
48 :
49 1726 : old_timeout = req->transport->options.request_timeout;
50 1726 : req->transport->options.request_timeout = 0;
51 1726 : smb2_transport_send(req);
52 1726 : req->transport->options.request_timeout = old_timeout;
53 :
54 1726 : return req;
55 : }
56 :
57 :
58 : /*
59 : recv a notify reply
60 : */
61 1724 : NTSTATUS smb2_notify_recv(struct smb2_request *req, TALLOC_CTX *mem_ctx,
62 : struct smb2_notify *io)
63 : {
64 18 : NTSTATUS status;
65 18 : DATA_BLOB blob;
66 18 : uint32_t ofs, i;
67 :
68 1742 : if (!smb2_request_receive(req) ||
69 1722 : !smb2_request_is_ok(req)) {
70 1632 : return smb2_request_destroy(req);
71 : }
72 :
73 92 : SMB2_CHECK_PACKET_RECV(req, 0x08, true);
74 :
75 92 : status = smb2_pull_o16s32_blob(&req->in, mem_ctx, req->in.body+0x02, &blob);
76 92 : if (!NT_STATUS_IS_OK(status)) {
77 0 : return status;
78 : }
79 :
80 92 : io->out.changes = NULL;
81 92 : io->out.num_changes = 0;
82 :
83 : /* count them */
84 562 : for (ofs=0; blob.length - ofs > 12; ) {
85 562 : uint32_t next = IVAL(blob.data, ofs);
86 562 : io->out.num_changes++;
87 562 : if (next == 0 || (ofs + next) >= blob.length) break;
88 470 : ofs += next;
89 : }
90 :
91 : /* allocate array */
92 92 : io->out.changes = talloc_array(mem_ctx, struct notify_changes, io->out.num_changes);
93 92 : if (!io->out.changes) {
94 0 : return NT_STATUS_NO_MEMORY;
95 : }
96 :
97 654 : for (i=ofs=0; i<io->out.num_changes; i++) {
98 562 : io->out.changes[i].action = IVAL(blob.data, ofs+4);
99 562 : smbcli_blob_pull_string(NULL, mem_ctx, &blob,
100 562 : &io->out.changes[i].name,
101 562 : ofs+8, ofs+12, STR_UNICODE);
102 562 : ofs += IVAL(blob.data, ofs);
103 : }
104 :
105 92 : return smb2_request_destroy(req);
106 : }
107 :
108 : /*
109 : sync notify request
110 : */
111 10 : NTSTATUS smb2_notify(struct smb2_tree *tree, TALLOC_CTX *mem_ctx,
112 : struct smb2_notify *io)
113 : {
114 10 : struct smb2_request *req = smb2_notify_send(tree, io);
115 10 : return smb2_notify_recv(req, mem_ctx, io);
116 : }
|