2 Unix SMB/CIFS implementation.
5 Copyright (C) Stefan Metzmacher 2009
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 3 of the License, or
10 (at your option) any later version.
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with this program. If not, see <http://www.gnu.org/licenses/>.
22 #include "smbd/globals.h"
23 #include "../source4/libcli/smb2/smb2_constants.h"
25 static struct tevent_req
*smbd_smb2_flush_send(TALLOC_CTX
*mem_ctx
,
26 struct tevent_context
*ev
,
27 struct smbd_smb2_request
*smb2req
,
28 uint64_t in_file_id_volatile
);
29 static NTSTATUS
smbd_smb2_flush_recv(struct tevent_req
*req
);
31 static void smbd_smb2_request_flush_done(struct tevent_req
*subreq
);
32 NTSTATUS
smbd_smb2_request_process_flush(struct smbd_smb2_request
*req
)
35 const uint8_t *inbody
;
36 int i
= req
->current_idx
;
37 size_t expected_body_size
= 0x18;
39 uint64_t in_file_id_persistent
;
40 uint64_t in_file_id_volatile
;
41 struct tevent_req
*subreq
;
43 inhdr
= (const uint8_t *)req
->in
.vector
[i
+0].iov_base
;
44 if (req
->in
.vector
[i
+1].iov_len
!= (expected_body_size
& 0xFFFFFFFE)) {
45 return smbd_smb2_request_error(req
, NT_STATUS_INVALID_PARAMETER
);
48 inbody
= (const uint8_t *)req
->in
.vector
[i
+1].iov_base
;
50 body_size
= SVAL(inbody
, 0x00);
51 if (body_size
!= expected_body_size
) {
52 return smbd_smb2_request_error(req
, NT_STATUS_INVALID_PARAMETER
);
55 in_file_id_persistent
= BVAL(inbody
, 0x08);
56 in_file_id_volatile
= BVAL(inbody
, 0x10);
58 if (req
->compat_chain_fsp
) {
60 } else if (in_file_id_persistent
!= 0) {
61 return smbd_smb2_request_error(req
, NT_STATUS_FILE_CLOSED
);
64 subreq
= smbd_smb2_flush_send(req
,
65 req
->conn
->smb2
.event_ctx
,
69 return smbd_smb2_request_error(req
, NT_STATUS_NO_MEMORY
);
71 tevent_req_set_callback(subreq
, smbd_smb2_request_flush_done
, req
);
75 static void smbd_smb2_request_flush_done(struct tevent_req
*subreq
)
77 struct smbd_smb2_request
*req
= tevent_req_callback_data(subreq
,
78 struct smbd_smb2_request
);
81 NTSTATUS error
; /* transport error */
83 status
= smbd_smb2_flush_recv(subreq
);
85 if (!NT_STATUS_IS_OK(status
)) {
86 error
= smbd_smb2_request_error(req
, status
);
87 if (!NT_STATUS_IS_OK(error
)) {
88 smbd_server_connection_terminate(req
->conn
,
95 outbody
= data_blob_talloc(req
->out
.vector
, NULL
, 0x10);
96 if (outbody
.data
== NULL
) {
97 error
= smbd_smb2_request_error(req
, NT_STATUS_NO_MEMORY
);
98 if (!NT_STATUS_IS_OK(error
)) {
99 smbd_server_connection_terminate(req
->conn
,
106 SSVAL(outbody
.data
, 0x00, 0x04); /* struct size */
107 SSVAL(outbody
.data
, 0x02, 0); /* reserved */
109 error
= smbd_smb2_request_done(req
, outbody
, NULL
);
110 if (!NT_STATUS_IS_OK(error
)) {
111 smbd_server_connection_terminate(req
->conn
,
117 struct smbd_smb2_flush_state
{
118 struct smbd_smb2_request
*smb2req
;
121 static struct tevent_req
*smbd_smb2_flush_send(TALLOC_CTX
*mem_ctx
,
122 struct tevent_context
*ev
,
123 struct smbd_smb2_request
*smb2req
,
124 uint64_t in_file_id_volatile
)
126 struct tevent_req
*req
;
127 struct smbd_smb2_flush_state
*state
;
129 struct smb_request
*smbreq
;
132 req
= tevent_req_create(mem_ctx
, &state
,
133 struct smbd_smb2_flush_state
);
137 state
->smb2req
= smb2req
;
139 DEBUG(10,("smbd_smb2_flush: file_id[0x%016llX]\n",
140 (unsigned long long)in_file_id_volatile
));
142 smbreq
= smbd_smb2_fake_smb_request(smb2req
);
143 if (tevent_req_nomem(smbreq
, req
)) {
144 return tevent_req_post(req
, ev
);
147 if (IS_IPC(smbreq
->conn
)) {
148 tevent_req_nterror(req
, NT_STATUS_NOT_IMPLEMENTED
);
149 return tevent_req_post(req
, ev
);
152 fsp
= file_fsp(smbreq
, (uint16_t)in_file_id_volatile
);
154 tevent_req_nterror(req
, NT_STATUS_FILE_CLOSED
);
155 return tevent_req_post(req
, ev
);
157 if (smbreq
->conn
!= fsp
->conn
) {
158 tevent_req_nterror(req
, NT_STATUS_FILE_CLOSED
);
159 return tevent_req_post(req
, ev
);
161 if (smb2req
->session
->vuid
!= fsp
->vuid
) {
162 tevent_req_nterror(req
, NT_STATUS_FILE_CLOSED
);
163 return tevent_req_post(req
, ev
);
166 if (!CHECK_WRITE(fsp
)) {
167 tevent_req_nterror(req
, NT_STATUS_ACCESS_DENIED
);
168 return tevent_req_post(req
, ev
);
171 status
= sync_file(smbreq
->conn
, fsp
, true);
172 if (!NT_STATUS_IS_OK(status
)) {
173 DEBUG(5,("smbd_smb2_flush: sync_file for %s returned %s\n",
174 fsp
->fsp_name
, nt_errstr(status
)));
175 tevent_req_nterror(req
, status
);
176 return tevent_req_post(req
, ev
);
179 tevent_req_done(req
);
180 return tevent_req_post(req
, ev
);
183 static NTSTATUS
smbd_smb2_flush_recv(struct tevent_req
*req
)
187 if (tevent_req_is_nterror(req
, &status
)) {
188 tevent_req_received(req
);
192 tevent_req_received(req
);