2 Unix SMB/CIFS implementation.
3 SMB client oplock functions
4 Copyright (C) Andrew Tridgell 2001
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 3 of the License, or
9 (at your option) any later version.
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with this program. If not, see <http://www.gnu.org/licenses/>.
21 #include "../lib/util/tevent_ntstatus.h"
22 #include "async_smb.h"
23 #include "libsmb/libsmb.h"
25 /****************************************************************************
26 send an ack for an oplock break request
27 ****************************************************************************/
29 struct cli_oplock_ack_state
{
33 static void cli_oplock_ack_done(struct tevent_req
*subreq
);
35 struct tevent_req
*cli_oplock_ack_send(TALLOC_CTX
*mem_ctx
,
36 struct tevent_context
*ev
,
37 struct cli_state
*cli
,
38 uint16_t fnum
, uint8_t level
)
40 struct tevent_req
*req
, *subreq
;
41 struct cli_oplock_ack_state
*state
;
43 req
= tevent_req_create(mem_ctx
, &state
, struct cli_oplock_ack_state
);
47 SCVAL(state
->vwv
+0, 0, 0xff);
48 SCVAL(state
->vwv
+0, 1, 0);
49 SSVAL(state
->vwv
+1, 0, 0);
50 SSVAL(state
->vwv
+2, 0, fnum
);
51 SCVAL(state
->vwv
+3, 0, LOCKING_ANDX_OPLOCK_RELEASE
);
52 SCVAL(state
->vwv
+3, 1, level
);
53 SIVAL(state
->vwv
+4, 0, 0); /* timeout */
54 SSVAL(state
->vwv
+6, 0, 0); /* unlockcount */
55 SSVAL(state
->vwv
+7, 0, 0); /* lockcount */
57 subreq
= cli_smb_send(state
, ev
, cli
, SMBlockingX
, 0, 8, state
->vwv
,
59 if (tevent_req_nomem(subreq
, req
)) {
60 return tevent_req_post(req
, ev
);
62 tevent_req_set_callback(subreq
, cli_oplock_ack_done
, req
);
66 static void cli_oplock_ack_done(struct tevent_req
*subreq
)
68 struct tevent_req
*req
= tevent_req_callback_data(
69 subreq
, struct tevent_req
);
72 status
= cli_smb_recv(subreq
, NULL
, NULL
, 0, NULL
, NULL
, NULL
, NULL
);
74 if (!NT_STATUS_IS_OK(status
)) {
75 tevent_req_nterror(req
, status
);
81 NTSTATUS
cli_oplock_ack_recv(struct tevent_req
*req
)
83 return tevent_req_simple_recv_ntstatus(req
);
86 NTSTATUS
cli_oplock_ack(struct cli_state
*cli
, uint16_t fnum
, unsigned char level
)
88 TALLOC_CTX
*frame
= talloc_stackframe();
89 struct event_context
*ev
;
90 struct tevent_req
*req
;
91 NTSTATUS status
= NT_STATUS_OK
;
93 if (cli_has_async_calls(cli
)) {
95 * Can't use sync call while an async call is in flight
97 status
= NT_STATUS_INVALID_PARAMETER
;
101 ev
= event_context_init(frame
);
103 status
= NT_STATUS_NO_MEMORY
;
107 req
= cli_oplock_ack_send(frame
, ev
, cli
, fnum
, level
);
109 status
= NT_STATUS_NO_MEMORY
;
113 if (!tevent_req_poll(req
, ev
)) {
114 status
= map_nt_error_from_unix(errno
);
118 status
= cli_oplock_ack_recv(req
);
124 /****************************************************************************
125 set the oplock handler for a connection
126 ****************************************************************************/
128 void cli_oplock_handler(struct cli_state
*cli
,
129 NTSTATUS (*handler
)(struct cli_state
*, uint16_t, unsigned char))
131 cli
->oplock_handler
= handler
;