1a90cf9f2SGordon Ross /*
2a90cf9f2SGordon Ross * CDDL HEADER START
3a90cf9f2SGordon Ross *
4a90cf9f2SGordon Ross * The contents of this file are subject to the terms of the
5a90cf9f2SGordon Ross * Common Development and Distribution License (the "License").
6a90cf9f2SGordon Ross * You may not use this file except in compliance with the License.
7a90cf9f2SGordon Ross *
8a90cf9f2SGordon Ross * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9a90cf9f2SGordon Ross * or http://www.opensolaris.org/os/licensing.
10a90cf9f2SGordon Ross * See the License for the specific language governing permissions
11a90cf9f2SGordon Ross * and limitations under the License.
12a90cf9f2SGordon Ross *
13a90cf9f2SGordon Ross * When distributing Covered Code, include this CDDL HEADER in each
14a90cf9f2SGordon Ross * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15a90cf9f2SGordon Ross * If applicable, add the following below this CDDL HEADER, with the
16a90cf9f2SGordon Ross * fields enclosed by brackets "[]" replaced with your own identifying
17a90cf9f2SGordon Ross * information: Portions Copyright [yyyy] [name of copyright owner]
18a90cf9f2SGordon Ross *
19a90cf9f2SGordon Ross * CDDL HEADER END
20a90cf9f2SGordon Ross */
21a90cf9f2SGordon Ross
22a90cf9f2SGordon Ross /*
23a90cf9f2SGordon Ross * Copyright (c) 2007, 2010, Oracle and/or its affiliates.
24148d1a41SMatt Barden * Copyright 2018 Nexenta Systems, Inc. All rights reserved.
25*b202d9e7SGordon Ross * Copyright 2022 RackTop Systems, Inc.
26a90cf9f2SGordon Ross */
27a90cf9f2SGordon Ross
28a90cf9f2SGordon Ross /*
29a90cf9f2SGordon Ross * Dispatch function for SMB2_CHANGE_NOTIFY
30a90cf9f2SGordon Ross */
31a90cf9f2SGordon Ross
32a90cf9f2SGordon Ross #include <smbsrv/smb2_kproto.h>
33a90cf9f2SGordon Ross
34bfe5e737SGordon Ross /* For the output DataOffset fields in here. */
35bfe5e737SGordon Ross #define DATA_OFF (SMB2_HDR_SIZE + 8)
36bfe5e737SGordon Ross
37a90cf9f2SGordon Ross smb_sdrc_t
smb2_change_notify(smb_request_t * sr)38a90cf9f2SGordon Ross smb2_change_notify(smb_request_t *sr)
39a90cf9f2SGordon Ross {
40a90cf9f2SGordon Ross uint16_t StructSize;
41a90cf9f2SGordon Ross uint16_t iFlags;
42a90cf9f2SGordon Ross uint32_t oBufLength;
43a90cf9f2SGordon Ross smb2fid_t smb2fid;
44a90cf9f2SGordon Ross uint32_t CompletionFilter;
45a90cf9f2SGordon Ross uint32_t reserved;
46a90cf9f2SGordon Ross uint32_t status;
47a90cf9f2SGordon Ross int rc = 0;
48a90cf9f2SGordon Ross
49a90cf9f2SGordon Ross /*
50a90cf9f2SGordon Ross * SMB2 Change Notify request
51a90cf9f2SGordon Ross */
52a90cf9f2SGordon Ross rc = smb_mbc_decodef(
53a90cf9f2SGordon Ross &sr->smb_data, "wwlqqll",
54a90cf9f2SGordon Ross &StructSize, /* w */
55a90cf9f2SGordon Ross &iFlags, /* w */
56a90cf9f2SGordon Ross &oBufLength, /* l */
57a90cf9f2SGordon Ross &smb2fid.persistent, /* q */
58a90cf9f2SGordon Ross &smb2fid.temporal, /* q */
59a90cf9f2SGordon Ross &CompletionFilter, /* l */
60a90cf9f2SGordon Ross &reserved); /* l */
61a90cf9f2SGordon Ross if (rc || StructSize != 32)
62a90cf9f2SGordon Ross return (SDRC_ERROR);
63a90cf9f2SGordon Ross
64a90cf9f2SGordon Ross status = smb2sr_lookup_fid(sr, &smb2fid);
6593bc28dbSGordon Ross DTRACE_SMB2_START(op__ChangeNotify, smb_request_t *, sr);
6693bc28dbSGordon Ross
67bfe5e737SGordon Ross if (status != 0)
6893bc28dbSGordon Ross goto errout; /* Bad FID */
69a90cf9f2SGordon Ross
70148d1a41SMatt Barden /*
71148d1a41SMatt Barden * Only deal with change notify last in a compound,
72148d1a41SMatt Barden * because it blocks indefinitely. This status gets
73148d1a41SMatt Barden * "sticky" handling in smb2sr_work().
74148d1a41SMatt Barden */
75148d1a41SMatt Barden if (sr->smb2_next_command != 0) {
76148d1a41SMatt Barden status = NT_STATUS_INSUFFICIENT_RESOURCES;
77148d1a41SMatt Barden goto errout;
78148d1a41SMatt Barden }
79148d1a41SMatt Barden
80a90cf9f2SGordon Ross CompletionFilter &= FILE_NOTIFY_VALID_MASK;
81a90cf9f2SGordon Ross if (iFlags & SMB2_WATCH_TREE)
82bfe5e737SGordon Ross CompletionFilter |= FILE_NOTIFY_CHANGE_EV_SUBDIR;
83a90cf9f2SGordon Ross
84*b202d9e7SGordon Ross if (oBufLength > smb2_max_trans) {
85*b202d9e7SGordon Ross status = NT_STATUS_INVALID_PARAMETER;
86*b202d9e7SGordon Ross goto errout;
87*b202d9e7SGordon Ross }
88a90cf9f2SGordon Ross
89bfe5e737SGordon Ross /*
90bfe5e737SGordon Ross * Check for events and consume, non-blocking.
91bfe5e737SGordon Ross * Special return STATUS_PENDING means:
92bfe5e737SGordon Ross * No events; caller must call "act2" next.
93148d1a41SMatt Barden * SMB2 does that in "async mode".
94bfe5e737SGordon Ross */
95bfe5e737SGordon Ross status = smb_notify_act1(sr, oBufLength, CompletionFilter);
96bfe5e737SGordon Ross if (status == NT_STATUS_PENDING) {
97148d1a41SMatt Barden status = smb2sr_go_async(sr);
98148d1a41SMatt Barden if (status != 0)
99148d1a41SMatt Barden goto errout;
100148d1a41SMatt Barden status = smb_notify_act2(sr);
101148d1a41SMatt Barden if (status == NT_STATUS_PENDING) {
102148d1a41SMatt Barden /* See next: smb2_change_notify_finish */
103148d1a41SMatt Barden return (SDRC_SR_KEPT);
104148d1a41SMatt Barden }
105bfe5e737SGordon Ross }
106bfe5e737SGordon Ross
10793bc28dbSGordon Ross errout:
108bfe5e737SGordon Ross sr->smb2_status = status;
10993bc28dbSGordon Ross DTRACE_SMB2_DONE(op__ChangeNotify, smb_request_t *, sr);
110bfe5e737SGordon Ross
11193bc28dbSGordon Ross if (NT_SC_SEVERITY(status) == NT_STATUS_SEVERITY_SUCCESS) {
112bfe5e737SGordon Ross oBufLength = sr->raw_data.chain_offset;
113bfe5e737SGordon Ross (void) smb_mbc_encodef(
114bfe5e737SGordon Ross &sr->reply, "wwlC",
115bfe5e737SGordon Ross 9, /* StructSize */ /* w */
116bfe5e737SGordon Ross DATA_OFF, /* w */
117bfe5e737SGordon Ross oBufLength, /* l */
118bfe5e737SGordon Ross &sr->raw_data); /* C */
119bfe5e737SGordon Ross } else {
120a90cf9f2SGordon Ross smb2sr_put_error(sr, status);
121bfe5e737SGordon Ross }
122bfe5e737SGordon Ross
123a90cf9f2SGordon Ross return (SDRC_SUCCESS);
124a90cf9f2SGordon Ross }
125a90cf9f2SGordon Ross
126a90cf9f2SGordon Ross /*
127bfe5e737SGordon Ross * This is called via taskq_dispatch in smb_notify.c
128bfe5e737SGordon Ross * to finish up an NT transact notify change request.
129bfe5e737SGordon Ross * Build an SMB2 Change Notify reply and send it.
130bfe5e737SGordon Ross */
131bfe5e737SGordon Ross void
smb2_change_notify_finish(void * arg)132bfe5e737SGordon Ross smb2_change_notify_finish(void *arg)
133bfe5e737SGordon Ross {
134bfe5e737SGordon Ross smb_request_t *sr = arg;
135148d1a41SMatt Barden smb_disp_stats_t *sds;
136bfe5e737SGordon Ross uint32_t status;
137bfe5e737SGordon Ross uint32_t oBufLength;
138bfe5e737SGordon Ross
139bfe5e737SGordon Ross SMB_REQ_VALID(sr);
140bfe5e737SGordon Ross
141bfe5e737SGordon Ross /*
142bfe5e737SGordon Ross * Common part of notify, puts data in sr->raw_data
143bfe5e737SGordon Ross */
144bfe5e737SGordon Ross status = smb_notify_act3(sr);
145bfe5e737SGordon Ross
146148d1a41SMatt Barden /*
147148d1a41SMatt Barden * The prior thread returned SDRC_SR_KEPT and skiped
148148d1a41SMatt Barden * the dtrace DONE probe, so fire that here.
149148d1a41SMatt Barden */
15093bc28dbSGordon Ross sr->smb2_status = status;
15193bc28dbSGordon Ross DTRACE_SMB2_DONE(op__ChangeNotify, smb_request_t *, sr);
15293bc28dbSGordon Ross
15393bc28dbSGordon Ross if (NT_SC_SEVERITY(status) == NT_STATUS_SEVERITY_SUCCESS) {
154bfe5e737SGordon Ross oBufLength = sr->raw_data.chain_offset;
155bfe5e737SGordon Ross (void) smb_mbc_encodef(
156bfe5e737SGordon Ross &sr->reply, "wwlC",
157bfe5e737SGordon Ross 9, /* StructSize */ /* w */
158bfe5e737SGordon Ross DATA_OFF, /* w */
159bfe5e737SGordon Ross oBufLength, /* l */
160bfe5e737SGordon Ross &sr->raw_data); /* C */
161bfe5e737SGordon Ross } else {
162bfe5e737SGordon Ross smb2sr_put_error(sr, status);
163bfe5e737SGordon Ross }
164bfe5e737SGordon Ross
165148d1a41SMatt Barden /*
166148d1a41SMatt Barden * Record some statistics: (just tx bytes here)
167148d1a41SMatt Barden */
168148d1a41SMatt Barden sds = &sr->session->s_server->sv_disp_stats2[SMB2_CHANGE_NOTIFY];
169148d1a41SMatt Barden atomic_add_64(&sds->sdt_txb, (int64_t)(sr->reply.chain_offset));
170148d1a41SMatt Barden
171148d1a41SMatt Barden /*
172148d1a41SMatt Barden * Put (overwrite) the final SMB2 header,
173148d1a41SMatt Barden * sign, send.
174148d1a41SMatt Barden */
175148d1a41SMatt Barden (void) smb2_encode_header(sr, B_TRUE);
176148d1a41SMatt Barden if (sr->smb2_hdr_flags & SMB2_FLAGS_SIGNED)
177148d1a41SMatt Barden smb2_sign_reply(sr);
178148d1a41SMatt Barden smb2_send_reply(sr);
179148d1a41SMatt Barden
180148d1a41SMatt Barden mutex_enter(&sr->sr_mutex);
181148d1a41SMatt Barden sr->sr_state = SMB_REQ_STATE_COMPLETED;
182148d1a41SMatt Barden mutex_exit(&sr->sr_mutex);
183148d1a41SMatt Barden
184148d1a41SMatt Barden smb_request_free(sr);
185bfe5e737SGordon Ross }
186