*/
#include "includes.h"
-#include "client.h"
-#include "async_smb.h"
+#include "system/network.h"
+#include "../lib/util/tevent_ntstatus.h"
+#include "../libcli/smb/smb_common.h"
#include "../libcli/smb/smbXcli_base.h"
-#include "smb2cli.h"
-#include "libsmb/proto.h"
-#include "lib/util/tevent_ntstatus.h"
struct smb2cli_tcon_state {
- struct cli_state *cli;
+ struct smbXcli_conn *conn;
+ struct smbXcli_session *session;
+ struct smbXcli_tcon *tcon;
uint8_t fixed[8];
uint8_t dyn_pad[1];
};
struct tevent_req *smb2cli_tcon_send(TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
- struct cli_state *cli,
- const char *share)
+ struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon,
+ uint16_t flags,
+ const char *unc)
{
struct tevent_req *req, *subreq;
struct smb2cli_tcon_state *state;
uint8_t *fixed;
- const char *tcon_share;
uint8_t *dyn;
size_t dyn_len;
uint32_t additional_flags = 0;
if (req == NULL) {
return NULL;
}
- state->cli = cli;
+ state->conn = conn;
+ state->session = session;
+ state->tcon = tcon;
- tcon_share = talloc_asprintf(state, "\\\\%s\\%s",
- smbXcli_conn_remote_name(cli->conn),
- share);
- if (tevent_req_nomem(tcon_share, req)) {
- return tevent_req_post(req, ev);
- }
if (!convert_string_talloc(state, CH_UNIX, CH_UTF16,
- tcon_share, strlen(tcon_share),
+ unc, strlen(unc),
&dyn, &dyn_len)) {
tevent_req_oom(req);
return tevent_req_post(req, ev);
}
- if (strlen(tcon_share) == 0) {
+ if (strlen(unc) == 0) {
TALLOC_FREE(dyn);
dyn_len = 0;
}
dyn_len = sizeof(state->dyn_pad);
}
- if (smbXcli_session_is_authenticated(cli->smb2.session)) {
+ if (smbXcli_session_is_authenticated(state->session)) {
additional_flags |= SMB2_HDR_FLAG_SIGNED;
}
- subreq = smb2cli_req_send(state, ev, cli->conn, SMB2_OP_TCON,
+ subreq = smb2cli_req_send(state, ev, conn, SMB2_OP_TCON,
additional_flags, clear_flags,
- cli->timeout,
+ timeout_msec,
NULL, /* tcon */
- cli->smb2.session,
+ session,
state->fixed, sizeof(state->fixed),
dyn, dyn_len,
0); /* max_dyn_len */
subreq, struct tevent_req);
struct smb2cli_tcon_state *state = tevent_req_data(
req, struct smb2cli_tcon_state);
- struct cli_state *cli = state->cli;
NTSTATUS status;
struct iovec *iov;
uint8_t *body;
share_capabilities = IVAL(body, 0x08);
maximal_access = IVAL(body, 0x0C);
- cli->smb2.tcon = smbXcli_tcon_create(cli);
- if (tevent_req_nomem(cli->smb2.tcon, req)) {
- return;
- }
-
- smb2cli_tcon_set_values(cli->smb2.tcon,
- cli->smb2.session,
+ smb2cli_tcon_set_values(state->tcon,
+ state->session,
tcon_id,
share_type,
share_flags,
return tevent_req_simple_recv_ntstatus(req);
}
-NTSTATUS smb2cli_tcon(struct cli_state *cli, const char *share)
+NTSTATUS smb2cli_tcon(struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon,
+ uint16_t flags,
+ const char *unc)
{
TALLOC_CTX *frame = talloc_stackframe();
struct tevent_context *ev;
struct tevent_req *req;
NTSTATUS status = NT_STATUS_NO_MEMORY;
- if (smbXcli_conn_has_async_calls(cli->conn)) {
+ if (smbXcli_conn_has_async_calls(conn)) {
/*
* Can't use sync call while an async call is in flight
*/
if (ev == NULL) {
goto fail;
}
- req = smb2cli_tcon_send(frame, ev, cli, share);
+ req = smb2cli_tcon_send(frame, ev, conn,
+ timeout_msec, session, tcon,
+ flags, unc);
if (req == NULL) {
goto fail;
}
}
struct smb2cli_tdis_state {
- struct cli_state *cli;
+ struct smbXcli_tcon *tcon;
uint8_t fixed[4];
};
static void smb2cli_tdis_done(struct tevent_req *subreq);
struct tevent_req *smb2cli_tdis_send(TALLOC_CTX *mem_ctx,
- struct tevent_context *ev,
- struct cli_state *cli)
+ struct tevent_context *ev,
+ struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon)
{
struct tevent_req *req, *subreq;
struct smb2cli_tdis_state *state;
if (req == NULL) {
return NULL;
}
- state->cli = cli;
+ state->tcon = tcon;
+
SSVAL(state->fixed, 0, 4);
- subreq = smb2cli_req_send(state, ev, cli->conn, SMB2_OP_TDIS,
+ subreq = smb2cli_req_send(state, ev, conn, SMB2_OP_TDIS,
0, 0, /* flags */
- cli->timeout,
- cli->smb2.tcon,
- cli->smb2.session,
+ timeout_msec,
+ tcon, session,
state->fixed, sizeof(state->fixed),
NULL, 0, /* dyn* */
0); /* max_dyn_len */
if (tevent_req_nterror(req, status)) {
return;
}
- smb2cli_tcon_set_values(state->cli->smb2.tcon, NULL,
+ smb2cli_tcon_set_values(state->tcon, NULL,
UINT32_MAX, 0, 0, 0, 0);
tevent_req_done(req);
}
return tevent_req_simple_recv_ntstatus(req);
}
-NTSTATUS smb2cli_tdis(struct cli_state *cli)
+NTSTATUS smb2cli_tdis(struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon)
{
TALLOC_CTX *frame = talloc_stackframe();
struct tevent_context *ev;
struct tevent_req *req;
NTSTATUS status = NT_STATUS_NO_MEMORY;
- if (smbXcli_conn_has_async_calls(cli->conn)) {
+ if (smbXcli_conn_has_async_calls(conn)) {
/*
* Can't use sync call while an async call is in flight
*/
if (ev == NULL) {
goto fail;
}
- req = smb2cli_tdis_send(frame, ev, cli);
+ req = smb2cli_tdis_send(frame, ev, conn,
+ timeout_msec, session, tcon);
if (req == NULL) {
goto fail;
}
uint32_t timeout_msec,
struct smbXcli_session *session);
+struct tevent_req *smb2cli_tcon_send(TALLOC_CTX *mem_ctx,
+ struct tevent_context *ev,
+ struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon,
+ uint16_t flags,
+ const char *unc);
+NTSTATUS smb2cli_tcon_recv(struct tevent_req *req);
+NTSTATUS smb2cli_tcon(struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon,
+ uint16_t flags,
+ const char *unc);
+
+struct tevent_req *smb2cli_tdis_send(TALLOC_CTX *mem_ctx,
+ struct tevent_context *ev,
+ struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon);
+NTSTATUS smb2cli_tdis_recv(struct tevent_req *req);
+NTSTATUS smb2cli_tdis(struct smbXcli_conn *conn,
+ uint32_t timeout_msec,
+ struct smbXcli_session *session,
+ struct smbXcli_tcon *tcon);
+
struct tevent_req *smb2cli_create_send(
TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
}
if (smbXcli_conn_protocol(cli->conn) >= PROTOCOL_SMB2_02) {
- subreq = smb2cli_tcon_send(state, ev, cli, share);
+ char *unc;
+
+ cli->smb2.tcon = smbXcli_tcon_create(cli);
+ if (tevent_req_nomem(cli->smb2.tcon, req)) {
+ return tevent_req_post(req, ev);
+ }
+
+ unc = talloc_asprintf(state, "\\\\%s\\%s",
+ smbXcli_conn_remote_name(cli->conn),
+ share);
+ if (tevent_req_nomem(unc, req)) {
+ return tevent_req_post(req, ev);
+ }
+
+ subreq = smb2cli_tcon_send(state, ev, cli->conn, cli->timeout,
+ cli->smb2.session, cli->smb2.tcon,
+ 0, /* flags */
+ unc);
if (tevent_req_nomem(subreq, req)) {
return tevent_req_post(req, ev);
}
NTSTATUS status = NT_STATUS_NO_MEMORY;
if (smbXcli_conn_protocol(cli->conn) >= PROTOCOL_SMB2_02) {
- return smb2cli_tdis(cli);
+ return smb2cli_tdis(cli->conn,
+ cli->timeout,
+ cli->smb2.session,
+ cli->smb2.tcon);
}
if (smbXcli_conn_has_async_calls(cli->conn)) {