*/
#include "includes.h"
-
-static void cli_state_handler(struct event_context *event_ctx,
- struct fd_event *event, uint16 flags, void *p);
-
-/**
- * Fetch an error out of a NBT packet
- * @param[in] buf The SMB packet
- * @retval The error, converted to NTSTATUS
- */
-
-NTSTATUS cli_pull_error(char *buf)
+#include "libsmb/libsmb.h"
+#include "../lib/async_req/async_sock.h"
+#include "../lib/util/tevent_ntstatus.h"
+#include "../lib/util/tevent_unix.h"
+#include "async_smb.h"
+#include "smb_crypt.h"
+#include "libsmb/nmblib.h"
+#include "read_smb.h"
+
+static NTSTATUS cli_pull_raw_error(const uint8_t *buf)
{
uint32_t flags2 = SVAL(buf, smb_flg2);
+ NTSTATUS status = NT_STATUS(IVAL(buf, smb_rcls));
- if (flags2 & FLAGS2_32_BIT_ERROR_CODES) {
- return NT_STATUS(IVAL(buf, smb_rcls));
+ if (NT_STATUS_IS_OK(status)) {
+ return NT_STATUS_OK;
}
- /* if the client uses dos errors, but there is no error,
- we should return no error here, otherwise it looks
- like an unknown bad NT_STATUS. jmcd */
- if (CVAL(buf, smb_rcls) == 0)
- return NT_STATUS_OK;
+ if (flags2 & FLAGS2_32_BIT_ERROR_CODES) {
+ return status;
+ }
return NT_STATUS_DOS(CVAL(buf, smb_rcls), SVAL(buf,smb_err));
}
/**
- * Compatibility helper for the sync APIs: Fake NTSTATUS in cli->inbuf
- * @param[in] cli The client connection that just received an error
- * @param[in] status The error to set on "cli"
+ * Figure out if there is an andx command behind the current one
+ * @param[in] buf The smb buffer to look at
+ * @param[in] ofs The offset to the wct field that is followed by the cmd
+ * @retval Is there a command following?
*/
-void cli_set_error(struct cli_state *cli, NTSTATUS status)
+static bool have_andx_command(const char *buf, uint16_t ofs)
{
- uint32_t flags2 = SVAL(cli->inbuf, smb_flg2);
+ uint8_t wct;
+ size_t buflen = talloc_get_size(buf);
- if (NT_STATUS_IS_DOS(status)) {
- SSVAL(cli->inbuf, smb_flg2,
- flags2 & ~FLAGS2_32_BIT_ERROR_CODES);
- SCVAL(cli->inbuf, smb_rcls, NT_STATUS_DOS_CLASS(status));
- SSVAL(cli->inbuf, smb_err, NT_STATUS_DOS_CODE(status));
- return;
+ if ((ofs == buflen-1) || (ofs == buflen)) {
+ return false;
}
- SSVAL(cli->inbuf, smb_flg2, flags2 | FLAGS2_32_BIT_ERROR_CODES);
- SIVAL(cli->inbuf, smb_rcls, NT_STATUS_V(status));
- return;
+ wct = CVAL(buf, ofs);
+ if (wct < 2) {
+ /*
+ * Not enough space for the command and a following pointer
+ */
+ return false;
+ }
+ return (CVAL(buf, ofs+1) != 0xff);
}
-/**
- * Allocate a new mid
- * @param[in] cli The client connection
- * @retval The new, unused mid
- */
+#define MAX_SMB_IOV 5
+
+struct cli_smb_state {
+ struct tevent_context *ev;
+ struct cli_state *cli;
+ uint8_t header[smb_wct+1]; /* Space for the header including the wct */
+
+ /*
+ * For normal requests, cli_smb_req_send chooses a mid. Secondary
+ * trans requests need to use the mid of the primary request, so we
+ * need a place to store it. Assume it's set if != 0.
+ */
+ uint16_t mid;
+
+ uint16_t *vwv;
+ uint8_t bytecount_buf[2];
+
+ struct iovec iov[MAX_SMB_IOV+3];
+ int iov_count;
-static uint16_t cli_new_mid(struct cli_state *cli)
+ uint8_t *inbuf;
+ uint32_t seqnum;
+ int chain_num;
+ int chain_length;
+ struct tevent_req **chained_requests;
+
+ bool one_way;
+};
+
+static uint16_t cli_alloc_mid(struct cli_state *cli)
{
+ int num_pending = talloc_array_length(cli->conn.pending);
uint16_t result;
- struct cli_request *req;
while (true) {
- result = cli->mid++;
- if (result == 0) {
+ int i;
+
+ result = cli->conn.smb1.mid++;
+ if ((result == 0) || (result == 0xffff)) {
continue;
}
- for (req = cli->outstanding_requests; req; req = req->next) {
- if (result == req->mid) {
+ for (i=0; i<num_pending; i++) {
+ if (result == cli_smb_req_mid(cli->conn.pending[i])) {
break;
}
}
- if (req == NULL) {
+ if (i == num_pending) {
return result;
}
}
}
-/**
- * Print an async req that happens to be a cli_request
- * @param[in] mem_ctx The TALLOC_CTX to put the result on
- * @param[in] req The request to print
- * @retval The string representation of "req"
- */
-
-static char *cli_request_print(TALLOC_CTX *mem_ctx, struct async_req *req)
+void cli_smb_req_unset_pending(struct tevent_req *req)
{
- char *result = async_req_print(mem_ctx, req);
- struct cli_request *cli_req = talloc_get_type_abort(
- req->private_data, struct cli_request);
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ struct cli_state *cli = state->cli;
+ int num_pending = talloc_array_length(cli->conn.pending);
+ int i;
- if (result == NULL) {
- return NULL;
+ if (state->mid != 0) {
+ /*
+ * This is a [nt]trans[2] request which waits
+ * for more than one reply.
+ */
+ return;
}
- return talloc_asprintf_append_buffer(
- result, "mid=%d\n", cli_req->mid);
-}
+ talloc_set_destructor(req, NULL);
-/**
- * Destroy a cli_request
- * @param[in] req The cli_request to kill
- * @retval Can't fail
- */
+ if (num_pending == 1) {
+ /*
+ * The pending read_smb tevent_req is a child of
+ * cli->pending. So if nothing is pending anymore, we need to
+ * delete the socket read fde.
+ */
+ TALLOC_FREE(cli->conn.pending);
+ cli->conn.read_smb_req = NULL;
+ return;
+ }
-static int cli_request_destructor(struct cli_request *req)
-{
- if (req->enc_state != NULL) {
- common_free_enc_buffer(req->enc_state, (char *)req->outbuf);
+ for (i=0; i<num_pending; i++) {
+ if (req == cli->conn.pending[i]) {
+ break;
+ }
}
- DLIST_REMOVE(req->cli->outstanding_requests, req);
- if (req->cli->outstanding_requests == NULL) {
- TALLOC_FREE(req->cli->fd_event);
+ if (i == num_pending) {
+ /*
+ * Something's seriously broken. Just returning here is the
+ * right thing nevertheless, the point of this routine is to
+ * remove ourselves from cli->conn.pending.
+ */
+ return;
}
- return 0;
-}
-
-/**
- * Are there already requests waiting in the chain_accumulator?
- * @param[in] cli The cli_state we want to check
- * @retval reply :-)
- */
-bool cli_in_chain(struct cli_state *cli)
-{
- if (cli->chain_accumulator == NULL) {
- return false;
+ /*
+ * Remove ourselves from the cli->conn.pending array
+ */
+ for (; i < (num_pending - 1); i++) {
+ cli->conn.pending[i] = cli->conn.pending[i+1];
}
- return (cli->chain_accumulator->num_async != 0);
+ /*
+ * No NULL check here, we're shrinking by sizeof(void *), and
+ * talloc_realloc just adjusts the size for this.
+ */
+ cli->conn.pending = talloc_realloc(NULL, cli->conn.pending,
+ struct tevent_req *,
+ num_pending - 1);
+ return;
}
-/**
- * Is the SMB command able to hold an AND_X successor
- * @param[in] cmd The SMB command in question
- * @retval Can we add a chained request after "cmd"?
- */
-
-static bool is_andx_req(uint8_t cmd)
+static int cli_smb_req_destructor(struct tevent_req *req)
{
- switch (cmd) {
- case SMBtconX:
- case SMBlockingX:
- case SMBopenX:
- case SMBreadX:
- case SMBwriteX:
- case SMBsesssetupX:
- case SMBulogoffX:
- case SMBntcreateX:
- return true;
- break;
- default:
- break;
- }
-
- return false;
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ /*
+ * Make sure we really remove it from
+ * the pending array on destruction.
+ */
+ state->mid = 0;
+ cli_smb_req_unset_pending(req);
+ return 0;
}
-/**
- * @brief Find the smb_cmd offset of the last command pushed
- * @param[in] buf The buffer we're building up
- * @retval Where can we put our next andx cmd?
- *
- * While chaining requests, the "next" request we're looking at needs to put
- * its SMB_Command before the data the previous request already built up added
- * to the chain. Find the offset to the place where we have to put our cmd.
- */
+static bool cli_state_receive_next(struct cli_state *cli);
+static void cli_state_notify_pending(struct cli_state *cli, NTSTATUS status);
-static bool find_andx_cmd_ofs(uint8_t *buf, size_t *pofs)
+bool cli_smb_req_set_pending(struct tevent_req *req)
{
- uint8_t cmd;
- size_t ofs;
-
- cmd = CVAL(buf, smb_com);
-
- SMB_ASSERT(is_andx_req(cmd));
-
- ofs = smb_vwv0;
-
- while (CVAL(buf, ofs) != 0xff) {
-
- if (!is_andx_req(CVAL(buf, ofs))) {
- return false;
- }
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ struct cli_state *cli;
+ struct tevent_req **pending;
+ int num_pending;
+
+ cli = state->cli;
+ num_pending = talloc_array_length(cli->conn.pending);
+
+ pending = talloc_realloc(cli, cli->conn.pending, struct tevent_req *,
+ num_pending+1);
+ if (pending == NULL) {
+ return false;
+ }
+ pending[num_pending] = req;
+ cli->conn.pending = pending;
+ talloc_set_destructor(req, cli_smb_req_destructor);
+ if (!cli_state_receive_next(cli)) {
/*
- * ofs is from start of smb header, so add the 4 length
- * bytes. The next cmd is right after the wct field.
+ * the caller should notify the current request
+ *
+ * And all other pending requests get notified
+ * by cli_state_notify_pending().
*/
- ofs = SVAL(buf, ofs+2) + 4 + 1;
-
- SMB_ASSERT(ofs+4 < talloc_get_size(buf));
+ cli_smb_req_unset_pending(req);
+ cli_state_notify_pending(cli, NT_STATUS_NO_MEMORY);
+ return false;
}
- *pofs = ofs;
return true;
}
-/**
- * @brief Do the smb chaining at a buffer level
- * @param[in] poutbuf Pointer to the talloc'ed buffer to be modified
- * @param[in] smb_command The command that we want to issue
- * @param[in] wct How many words?
- * @param[in] vwv The words, already in network order
- * @param[in] bytes_alignment How shall we align "bytes"?
- * @param[in] num_bytes How many bytes?
- * @param[in] bytes The data the request ships
- *
- * smb_splice_chain() adds the vwv and bytes to the request already present in
- * *poutbuf.
- */
+static void cli_smb_received(struct tevent_req *subreq);
+static NTSTATUS cli_state_dispatch_smb1(struct cli_state *cli,
+ TALLOC_CTX *frame,
+ uint8_t *inbuf);
-bool smb_splice_chain(uint8_t **poutbuf, uint8_t smb_command,
- uint8_t wct, const uint16_t *vwv,
- size_t bytes_alignment,
- uint32_t num_bytes, const uint8_t *bytes)
+static bool cli_state_receive_next(struct cli_state *cli)
{
- uint8_t *outbuf;
- size_t old_size, new_size;
- size_t ofs;
- size_t chain_padding = 0;
- size_t bytes_padding = 0;
- bool first_request;
-
- old_size = talloc_get_size(*poutbuf);
-
- /*
- * old_size == smb_wct means we're pushing the first request in for
- * libsmb/
- */
-
- first_request = (old_size == smb_wct);
+ size_t num_pending = talloc_array_length(cli->conn.pending);
+ struct tevent_req *req;
+ struct cli_smb_state *state;
- if (!first_request && ((old_size % 4) != 0)) {
- /*
- * Align the wct field of subsequent requests to a 4-byte
- * boundary
- */
- chain_padding = 4 - (old_size % 4);
- }
-
- /*
- * After the old request comes the new wct field (1 byte), the vwv's
- * and the num_bytes field. After at we might need to align the bytes
- * given to us to "bytes_alignment", increasing the num_bytes value.
- */
-
- new_size = old_size + chain_padding + 1 + wct * sizeof(uint16_t) + 2;
-
- if ((bytes_alignment != 0) && ((new_size % bytes_alignment) != 0)) {
- bytes_padding = bytes_alignment - (new_size % bytes_alignment);
+ if (cli->conn.read_smb_req != NULL) {
+ return true;
}
- new_size += bytes_padding + num_bytes;
-
- if ((smb_command != SMBwriteX) && (new_size > 0xffff)) {
- DEBUG(1, ("splice_chain: %u bytes won't fit\n",
- (unsigned)new_size));
- return false;
+ if (num_pending == 0) {
+ return true;
}
- outbuf = TALLOC_REALLOC_ARRAY(NULL, *poutbuf, uint8_t, new_size);
- if (outbuf == NULL) {
- DEBUG(0, ("talloc failed\n"));
- return false;
- }
- *poutbuf = outbuf;
+ req = cli->conn.pending[0];
+ state = tevent_req_data(req, struct cli_smb_state);
- if (first_request) {
- SCVAL(outbuf, smb_com, smb_command);
- } else {
- size_t andx_cmd_ofs;
-
- if (!find_andx_cmd_ofs(outbuf, &andx_cmd_ofs)) {
- DEBUG(1, ("invalid command chain\n"));
- *poutbuf = TALLOC_REALLOC_ARRAY(
- NULL, *poutbuf, uint8_t, old_size);
- return false;
- }
-
- if (chain_padding != 0) {
- memset(outbuf + old_size, 0, chain_padding);
- old_size += chain_padding;
- }
-
- SCVAL(outbuf, andx_cmd_ofs, smb_command);
- SSVAL(outbuf, andx_cmd_ofs + 2, old_size - 4);
- }
-
- ofs = old_size;
+ cli->conn.dispatch_incoming = cli_state_dispatch_smb1;
/*
- * Push the chained request:
- *
- * wct field
+ * We're the first ones, add the read_smb request that waits for the
+ * answer from the server
*/
+ cli->conn.read_smb_req = read_smb_send(cli->conn.pending, state->ev,
+ cli->conn.fd);
+ if (cli->conn.read_smb_req == NULL) {
+ return false;
+ }
+ tevent_req_set_callback(cli->conn.read_smb_req, cli_smb_received, cli);
+ return true;
+}
- SCVAL(outbuf, ofs, wct);
- ofs += 1;
+static void cli_state_notify_pending(struct cli_state *cli, NTSTATUS status)
+{
+ cli_state_disconnect(cli);
/*
- * vwv array
+ * Cancel all pending requests. We do not do a for-loop walking
+ * cli->conn.pending because that array changes in
+ * cli_smb_req_destructor().
*/
+ while (talloc_array_length(cli->conn.pending) > 0) {
+ struct tevent_req *req;
+ struct cli_smb_state *state;
- memcpy(outbuf + ofs, vwv, sizeof(uint16_t) * wct);
- ofs += sizeof(uint16_t) * wct;
+ req = cli->conn.pending[0];
+ state = tevent_req_data(req, struct cli_smb_state);
- /*
- * bcc (byte count)
- */
-
- SSVAL(outbuf, ofs, num_bytes + bytes_padding);
- ofs += sizeof(uint16_t);
+ /*
+ * We're dead. No point waiting for trans2
+ * replies.
+ */
+ state->mid = 0;
- /*
- * padding
- */
+ cli_smb_req_unset_pending(req);
- if (bytes_padding != 0) {
- memset(outbuf + ofs, 0, bytes_padding);
- ofs += bytes_padding;
+ /*
+ * we need to defer the callback, because we may notify more
+ * then one caller.
+ */
+ tevent_req_defer_callback(req, state->ev);
+ tevent_req_nterror(req, status);
}
-
- /*
- * The bytes field
- */
-
- memcpy(outbuf + ofs, bytes, num_bytes);
-
- return true;
}
-/**
- * @brief Destroy an async_req that is the visible part of a cli_request
- * @param[in] req The request to kill
- * @retval Return 0 to make talloc happy
- *
- * This destructor is a bit tricky: Because a cli_request can host more than
- * one async_req for chained requests, we need to make sure that the
- * "cli_request" that we were part of is correctly destroyed at the right
- * time. This is done by NULLing out ourself from the "async" member of our
- * "cli_request". If there is none left, then also TALLOC_FREE() the
- * cli_request, which was a talloc child of the client connection cli_state.
+/*
+ * Fetch a smb request's mid. Only valid after the request has been sent by
+ * cli_smb_req_send().
*/
-
-static int cli_async_req_destructor(struct async_req *req)
+uint16_t cli_smb_req_mid(struct tevent_req *req)
{
- struct cli_request *cli_req = talloc_get_type_abort(
- req->private_data, struct cli_request);
- int i, pending;
- bool found = false;
-
- pending = 0;
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
- for (i=0; i<cli_req->num_async; i++) {
- if (cli_req->async[i] == req) {
- cli_req->async[i] = NULL;
- found = true;
- }
- if (cli_req->async[i] != NULL) {
- pending += 1;
- }
- }
-
- SMB_ASSERT(found);
-
- if (pending == 0) {
- TALLOC_FREE(cli_req);
+ if (state->mid != 0) {
+ return state->mid;
}
- return 0;
+ return SVAL(state->header, smb_mid);
}
-/**
- * @brief Chain up a request
- * @param[in] mem_ctx The TALLOC_CTX for the result
- * @param[in] ev The event context that will call us back
- * @param[in] cli The cli_state we queue the request up for
- * @param[in] smb_command The command that we want to issue
- * @param[in] additional_flags open_and_x wants to add oplock header flags
- * @param[in] wct How many words?
- * @param[in] vwv The words, already in network order
- * @param[in] bytes_alignment How shall we align "bytes"?
- * @param[in] num_bytes How many bytes?
- * @param[in] bytes The data the request ships
- *
- * cli_request_chain() is the core of the SMB request marshalling routine. It
- * will create a new async_req structure in the cli->chain_accumulator->async
- * array and marshall the smb_cmd, the vwv array and the bytes into
- * cli->chain_accumulator->outbuf.
- */
+void cli_smb_req_set_mid(struct tevent_req *req, uint16_t mid)
+{
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ state->mid = mid;
+}
-static struct async_req *cli_request_chain(TALLOC_CTX *mem_ctx,
- struct event_context *ev,
- struct cli_state *cli,
- uint8_t smb_command,
- uint8_t additional_flags,
- uint8_t wct, const uint16_t *vwv,
- size_t bytes_alignment,
- uint32_t num_bytes,
- const uint8_t *bytes)
+uint32_t cli_smb_req_seqnum(struct tevent_req *req)
{
- struct async_req **tmp_reqs;
- struct cli_request *req;
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ return state->seqnum;
+}
- req = cli->chain_accumulator;
+void cli_smb_req_set_seqnum(struct tevent_req *req, uint32_t seqnum)
+{
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ state->seqnum = seqnum;
+}
- tmp_reqs = TALLOC_REALLOC_ARRAY(req, req->async, struct async_req *,
- req->num_async + 1);
- if (tmp_reqs == NULL) {
- DEBUG(0, ("talloc failed\n"));
- return NULL;
+static size_t iov_len(const struct iovec *iov, int count)
+{
+ size_t result = 0;
+ int i;
+ for (i=0; i<count; i++) {
+ result += iov[i].iov_len;
}
- req->async = tmp_reqs;
- req->num_async += 1;
+ return result;
+}
+
+static uint8_t *iov_concat(TALLOC_CTX *mem_ctx, const struct iovec *iov,
+ int count)
+{
+ size_t len = iov_len(iov, count);
+ size_t copied;
+ uint8_t *buf;
+ int i;
- req->async[req->num_async-1] = async_req_new(mem_ctx, ev);
- if (req->async[req->num_async-1] == NULL) {
- DEBUG(0, ("async_req_new failed\n"));
- req->num_async -= 1;
+ buf = talloc_array(mem_ctx, uint8_t, len);
+ if (buf == NULL) {
return NULL;
}
- req->async[req->num_async-1]->private_data = req;
- req->async[req->num_async-1]->print = cli_request_print;
- talloc_set_destructor(req->async[req->num_async-1],
- cli_async_req_destructor);
-
- if (!smb_splice_chain(&req->outbuf, smb_command, wct, vwv,
- bytes_alignment, num_bytes, bytes)) {
- goto fail;
+ copied = 0;
+ for (i=0; i<count; i++) {
+ memcpy(buf+copied, iov[i].iov_base, iov[i].iov_len);
+ copied += iov[i].iov_len;
}
-
- return req->async[req->num_async-1];
-
- fail:
- TALLOC_FREE(req->async[req->num_async-1]);
- req->num_async -= 1;
- return NULL;
+ return buf;
}
-/**
- * @brief prepare a cli_state to accept a chain of requests
- * @param[in] cli The cli_state we want to queue up in
- * @param[in] ev The event_context that will call us back for the socket
- * @param[in] size_hint How many bytes are expected, just an optimization
- * @retval Did we have enough memory?
- *
- * cli_chain_cork() sets up a new cli_request in cli->chain_accumulator. If
- * cli is used in an async fashion, i.e. if we have outstanding requests, then
- * we do not have to create a fd event. If cli is used only with the sync
- * helpers, we need to create the fd_event here.
- *
- * If you want to issue a chained request to the server, do a
- * cli_chain_cork(), then do you cli_open_send(), cli_read_and_x_send(),
- * cli_close_send() and so on. The async requests that come out of
- * cli_xxx_send() are normal async requests with the difference that they
- * won't be shipped individually. But the event_context will still trigger the
- * req->async.fn to be called on every single request.
- *
- * You have to take care yourself that you only issue chainable requests in
- * the middle of the chain.
- */
-
-bool cli_chain_cork(struct cli_state *cli, struct event_context *ev,
- size_t size_hint)
+struct tevent_req *cli_smb_req_create(TALLOC_CTX *mem_ctx,
+ struct event_context *ev,
+ struct cli_state *cli,
+ uint8_t smb_command,
+ uint8_t additional_flags,
+ uint8_t wct, uint16_t *vwv,
+ int iov_count,
+ struct iovec *bytes_iov)
{
- struct cli_request *req = NULL;
-
- SMB_ASSERT(cli->chain_accumulator == NULL);
+ struct tevent_req *result;
+ struct cli_smb_state *state;
+ struct timeval endtime;
- if (cli->fd == -1) {
- DEBUG(10, ("cli->fd closed\n"));
- return false;
+ if (iov_count > MAX_SMB_IOV) {
+ /*
+ * Should not happen :-)
+ */
+ return NULL;
}
- if (cli->fd_event == NULL) {
- SMB_ASSERT(cli->outstanding_requests == NULL);
- cli->fd_event = event_add_fd(ev, cli, cli->fd,
- EVENT_FD_READ,
- cli_state_handler, cli);
- if (cli->fd_event == NULL) {
- return false;
- }
+ result = tevent_req_create(mem_ctx, &state, struct cli_smb_state);
+ if (result == NULL) {
+ return NULL;
}
-
- req = talloc(cli, struct cli_request);
- if (req == NULL) {
- goto fail;
+ state->ev = ev;
+ state->cli = cli;
+ state->mid = 0; /* Set to auto-choose in cli_smb_req_send */
+ state->chain_num = 0;
+ state->chained_requests = NULL;
+
+ cli_setup_packet_buf(cli, (char *)state->header);
+ SCVAL(state->header, smb_com, smb_command);
+ SSVAL(state->header, smb_tid, cli->smb1.tid);
+ SCVAL(state->header, smb_wct, wct);
+
+ state->vwv = vwv;
+
+ SSVAL(state->bytecount_buf, 0, iov_len(bytes_iov, iov_count));
+
+ state->iov[0].iov_base = (void *)state->header;
+ state->iov[0].iov_len = sizeof(state->header);
+ state->iov[1].iov_base = (void *)state->vwv;
+ state->iov[1].iov_len = wct * sizeof(uint16_t);
+ state->iov[2].iov_base = (void *)state->bytecount_buf;
+ state->iov[2].iov_len = sizeof(uint16_t);
+
+ if (iov_count != 0) {
+ memcpy(&state->iov[3], bytes_iov,
+ iov_count * sizeof(*bytes_iov));
}
- req->cli = cli;
+ state->iov_count = iov_count + 3;
- if (size_hint == 0) {
- size_hint = 100;
+ if (cli->timeout) {
+ endtime = timeval_current_ofs_msec(cli->timeout);
+ if (!tevent_req_set_endtime(result, ev, endtime)) {
+ return result;
+ }
}
- req->outbuf = talloc_array(req, uint8_t, smb_wct + size_hint);
- if (req->outbuf == NULL) {
- goto fail;
+
+ switch (smb_command) {
+ case SMBtranss:
+ case SMBtranss2:
+ case SMBnttranss:
+ case SMBntcancel:
+ state->one_way = true;
+ break;
+ case SMBlockingX:
+ if ((wct == 8) &&
+ (CVAL(vwv+3, 0) == LOCKING_ANDX_OPLOCK_RELEASE)) {
+ state->one_way = true;
+ }
+ break;
}
- req->outbuf = TALLOC_REALLOC_ARRAY(NULL, req->outbuf, uint8_t,
- smb_wct);
- req->num_async = 0;
- req->async = NULL;
+ return result;
+}
- req->enc_state = NULL;
- req->recv_helper.fn = NULL;
+static NTSTATUS cli_signv(struct cli_state *cli, struct iovec *iov, int count,
+ uint32_t *seqnum)
+{
+ uint8_t *buf;
- SSVAL(req->outbuf, smb_tid, cli->cnum);
- cli_setup_packet_buf(cli, (char *)req->outbuf);
+ /*
+ * Obvious optimization: Make cli_calculate_sign_mac work with struct
+ * iovec directly. MD5Update would do that just fine.
+ */
- req->mid = cli_new_mid(cli);
+ if ((count <= 0) || (iov[0].iov_len < smb_wct)) {
+ return NT_STATUS_INVALID_PARAMETER;
+ }
- cli->chain_accumulator = req;
+ buf = iov_concat(talloc_tos(), iov, count);
+ if (buf == NULL) {
+ return NT_STATUS_NO_MEMORY;
+ }
- DEBUG(10, ("cli_chain_cork: mid=%d\n", req->mid));
+ cli_calculate_sign_mac(cli, (char *)buf, seqnum);
+ memcpy(iov[0].iov_base, buf, iov[0].iov_len);
- return true;
- fail:
- TALLOC_FREE(req);
- if (cli->outstanding_requests == NULL) {
- TALLOC_FREE(cli->fd_event);
- }
- return false;
+ TALLOC_FREE(buf);
+ return NT_STATUS_OK;
}
-/**
- * Ship a request queued up via cli_request_chain()
- * @param[in] cl The connection
- */
+static void cli_smb_sent(struct tevent_req *subreq);
-void cli_chain_uncork(struct cli_state *cli)
+static NTSTATUS cli_smb_req_iov_send(struct tevent_req *req,
+ struct cli_smb_state *state,
+ struct iovec *iov, int iov_count)
{
- struct cli_request *req = cli->chain_accumulator;
- size_t smblen;
-
- SMB_ASSERT(req != NULL);
+ struct tevent_req *subreq;
+ NTSTATUS status;
- DLIST_ADD_END(cli->outstanding_requests, req, struct cli_request *);
- talloc_set_destructor(req, cli_request_destructor);
+ if (!cli_state_is_connected(state->cli)) {
+ return NT_STATUS_CONNECTION_DISCONNECTED;
+ }
- cli->chain_accumulator = NULL;
+ if (iov[0].iov_len < smb_wct) {
+ return NT_STATUS_INVALID_PARAMETER;
+ }
- SSVAL(req->outbuf, smb_mid, req->mid);
+ if (state->mid != 0) {
+ SSVAL(iov[0].iov_base, smb_mid, state->mid);
+ } else {
+ uint16_t mid = cli_alloc_mid(state->cli);
+ SSVAL(iov[0].iov_base, smb_mid, mid);
+ }
- smblen = talloc_get_size(req->outbuf) - 4;
+ smb_setlen((char *)iov[0].iov_base, iov_len(iov, iov_count) - 4);
- smb_setlen((char *)req->outbuf, smblen);
+ status = cli_signv(state->cli, iov, iov_count, &state->seqnum);
- if (smblen > 0x1ffff) {
- /*
- * This is a POSIX 14 word large write. Overwrite just the
- * size field, the '0xFFSMB' has been set by smb_setlen which
- * _smb_setlen_large does not do.
- */
- _smb_setlen_large(((char *)req->outbuf), smblen);
+ if (!NT_STATUS_IS_OK(status)) {
+ return status;
}
- cli_calculate_sign_mac(cli, (char *)req->outbuf);
+ if (cli_state_encryption_on(state->cli)) {
+ char *buf, *enc_buf;
- if (cli_encryption_on(cli)) {
- NTSTATUS status;
- char *enc_buf;
-
- status = cli_encrypt_message(cli, (char *)req->outbuf,
- &enc_buf);
+ buf = (char *)iov_concat(talloc_tos(), iov, iov_count);
+ if (buf == NULL) {
+ return NT_STATUS_NO_MEMORY;
+ }
+ status = common_encrypt_buffer(state->cli->trans_enc_state,
+ (char *)buf, &enc_buf);
+ TALLOC_FREE(buf);
if (!NT_STATUS_IS_OK(status)) {
- DEBUG(0, ("Error in encrypting client message. "
- "Error %s\n", nt_errstr(status)));
- TALLOC_FREE(req);
- return;
+ DEBUG(0, ("Error in encrypting client message: %s\n",
+ nt_errstr(status)));
+ return status;
+ }
+ buf = (char *)talloc_memdup(state, enc_buf,
+ smb_len(enc_buf)+4);
+ SAFE_FREE(enc_buf);
+ if (buf == NULL) {
+ return NT_STATUS_NO_MEMORY;
}
- req->outbuf = (uint8_t *)enc_buf;
- req->enc_state = cli->trans_enc_state;
+ iov[0].iov_base = (void *)buf;
+ iov[0].iov_len = talloc_get_size(buf);
+ iov_count = 1;
}
-
- req->sent = 0;
-
- event_fd_set_writeable(cli->fd_event);
+ subreq = writev_send(state, state->ev, state->cli->conn.outgoing,
+ state->cli->conn.fd, false, iov, iov_count);
+ if (subreq == NULL) {
+ return NT_STATUS_NO_MEMORY;
+ }
+ tevent_req_set_callback(subreq, cli_smb_sent, req);
+ return NT_STATUS_OK;
}
-/**
- * @brief Send a request to the server
- * @param[in] mem_ctx The TALLOC_CTX for the result
- * @param[in] ev The event context that will call us back
- * @param[in] cli The cli_state we queue the request up for
- * @param[in] smb_command The command that we want to issue
- * @param[in] additional_flags open_and_x wants to add oplock header flags
- * @param[in] wct How many words?
- * @param[in] vwv The words, already in network order
- * @param[in] bytes_alignment How shall we align "bytes"?
- * @param[in] num_bytes How many bytes?
- * @param[in] bytes The data the request ships
- *
- * This is the generic routine to be used by the cli_xxx_send routines.
- */
-
-struct async_req *cli_request_send(TALLOC_CTX *mem_ctx,
- struct event_context *ev,
- struct cli_state *cli,
- uint8_t smb_command,
- uint8_t additional_flags,
- uint8_t wct, const uint16_t *vwv,
- size_t bytes_alignment,
- uint32_t num_bytes, const uint8_t *bytes)
+NTSTATUS cli_smb_req_send(struct tevent_req *req)
{
- struct async_req *result;
- bool uncork = false;
-
- if (cli->chain_accumulator == NULL) {
- if (!cli_chain_cork(cli, ev,
- wct * sizeof(uint16_t) + num_bytes + 3)) {
- DEBUG(1, ("cli_chain_cork failed\n"));
- return NULL;
- }
- uncork = true;
- }
-
- result = cli_request_chain(mem_ctx, ev, cli, smb_command,
- additional_flags, wct, vwv, bytes_alignment,
- num_bytes, bytes);
-
- if (result == NULL) {
- DEBUG(1, ("cli_request_chain failed\n"));
- }
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
- if (uncork) {
- cli_chain_uncork(cli);
+ if (!tevent_req_is_in_progress(req)) {
+ return NT_STATUS_INTERNAL_ERROR;
}
- return result;
+ return cli_smb_req_iov_send(req, state, state->iov, state->iov_count);
}
-/**
- * Calculate the current ofs to wct for requests like write&x
- * @param[in] req The smb request we're currently building
- * @retval how many bytes offset have we accumulated?
- */
-
-uint16_t cli_wct_ofs(const struct cli_state *cli)
+struct tevent_req *cli_smb_send(TALLOC_CTX *mem_ctx,
+ struct event_context *ev,
+ struct cli_state *cli,
+ uint8_t smb_command,
+ uint8_t additional_flags,
+ uint8_t wct, uint16_t *vwv,
+ uint32_t num_bytes,
+ const uint8_t *bytes)
{
- size_t buf_size;
-
- if (cli->chain_accumulator == NULL) {
- return smb_wct - 4;
- }
+ struct tevent_req *req;
+ struct iovec iov;
+ NTSTATUS status;
- buf_size = talloc_get_size(cli->chain_accumulator->outbuf);
+ iov.iov_base = discard_const_p(void, bytes);
+ iov.iov_len = num_bytes;
- if (buf_size == smb_wct) {
- return smb_wct - 4;
+ req = cli_smb_req_create(mem_ctx, ev, cli, smb_command,
+ additional_flags, wct, vwv, 1, &iov);
+ if (req == NULL) {
+ return NULL;
}
-
- /*
- * Add alignment for subsequent requests
- */
-
- if ((buf_size % 4) != 0) {
- buf_size += (4 - (buf_size % 4));
+ if (!tevent_req_is_in_progress(req)) {
+ return tevent_req_post(req, ev);
}
-
- return buf_size - 4;
+ status = cli_smb_req_send(req);
+ if (!NT_STATUS_IS_OK(status)) {
+ tevent_req_nterror(req, status);
+ return tevent_req_post(req, ev);
+ }
+ return req;
}
-/**
- * Figure out if there is an andx command behind the current one
- * @param[in] buf The smb buffer to look at
- * @param[in] ofs The offset to the wct field that is followed by the cmd
- * @retval Is there a command following?
- */
-
-static bool have_andx_command(const char *buf, uint16_t ofs)
+static void cli_smb_sent(struct tevent_req *subreq)
{
- uint8_t wct;
- size_t buflen = talloc_get_size(buf);
+ struct tevent_req *req = tevent_req_callback_data(
+ subreq, struct tevent_req);
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ ssize_t nwritten;
+ int err;
+
+ nwritten = writev_recv(subreq, &err);
+ TALLOC_FREE(subreq);
+ if (nwritten == -1) {
+ NTSTATUS status = map_nt_error_from_unix(err);
+ cli_state_notify_pending(state->cli, status);
+ return;
+ }
- if ((ofs == buflen-1) || (ofs == buflen)) {
- return false;
+ if (state->one_way) {
+ state->inbuf = NULL;
+ tevent_req_done(req);
+ return;
}
- wct = CVAL(buf, ofs);
- if (wct < 2) {
- /*
- * Not enough space for the command and a following pointer
- */
- return false;
+ if (!cli_smb_req_set_pending(req)) {
+ tevent_req_nterror(req, NT_STATUS_NO_MEMORY);
+ return;
}
- return (CVAL(buf, ofs+1) != 0xff);
}
-/**
- * @brief Pull reply data out of a request
- * @param[in] req The request that we just received a reply for
- * @param[out] pwct How many words did the server send?
- * @param[out] pvwv The words themselves
- * @param[out] pnum_bytes How many bytes did the server send?
- * @param[out] pbytes The bytes themselves
- * @retval Was the reply formally correct?
- */
-
-NTSTATUS cli_pull_reply(struct async_req *req,
- uint8_t *pwct, uint16_t **pvwv,
- uint16_t *pnum_bytes, uint8_t **pbytes)
+static void cli_smb_received(struct tevent_req *subreq)
{
- struct cli_request *cli_req = talloc_get_type_abort(
- req->private_data, struct cli_request);
- uint8_t wct, cmd;
- uint16_t num_bytes;
- size_t wct_ofs, bytes_offset;
- int i, j;
+ struct cli_state *cli = tevent_req_callback_data(
+ subreq, struct cli_state);
+ TALLOC_CTX *frame = talloc_stackframe();
NTSTATUS status;
-
- for (i = 0; i < cli_req->num_async; i++) {
- if (req == cli_req->async[i]) {
- break;
- }
- }
-
- if (i == cli_req->num_async) {
- cli_set_error(cli_req->cli, NT_STATUS_INVALID_PARAMETER);
- return NT_STATUS_INVALID_PARAMETER;
+ uint8_t *inbuf;
+ ssize_t received;
+ int err;
+
+ if (subreq != cli->conn.read_smb_req) {
+ DEBUG(1, ("Internal error: cli_smb_received called with "
+ "unexpected subreq\n"));
+ status = NT_STATUS_INTERNAL_ERROR;
+ cli_state_notify_pending(cli, status);
+ TALLOC_FREE(frame);
+ return;
}
- /**
- * The status we pull here is only relevant for the last reply in the
- * chain.
- */
-
- status = cli_pull_error(cli_req->inbuf);
-
- if (i == 0) {
- if (NT_STATUS_IS_ERR(status)
- && !have_andx_command(cli_req->inbuf, smb_wct)) {
- cli_set_error(cli_req->cli, status);
- return status;
- }
- wct_ofs = smb_wct;
- goto done;
+ received = read_smb_recv(subreq, frame, &inbuf, &err);
+ TALLOC_FREE(subreq);
+ cli->conn.read_smb_req = NULL;
+ if (received == -1) {
+ status = map_nt_error_from_unix(err);
+ cli_state_notify_pending(cli, status);
+ TALLOC_FREE(frame);
+ return;
}
- cmd = CVAL(cli_req->inbuf, smb_com);
- wct_ofs = smb_wct;
-
- for (j = 0; j < i; j++) {
- if (j < i-1) {
- if (cmd == 0xff) {
- return NT_STATUS_REQUEST_ABORTED;
- }
- if (!is_andx_req(cmd)) {
- return NT_STATUS_INVALID_NETWORK_RESPONSE;
- }
- }
-
- if (!have_andx_command(cli_req->inbuf, wct_ofs)) {
- /*
- * This request was not completed because a previous
- * request in the chain had received an error.
- */
- return NT_STATUS_REQUEST_ABORTED;
- }
-
- wct_ofs = SVAL(cli_req->inbuf, wct_ofs + 3);
-
+ status = cli->conn.dispatch_incoming(cli, frame, inbuf);
+ TALLOC_FREE(frame);
+ if (NT_STATUS_IS_OK(status)) {
/*
- * Skip the all-present length field. No overflow, we've just
- * put a 16-bit value into a size_t.
+ * We should not do any more processing
+ * as the dispatch function called
+ * tevent_req_done().
*/
- wct_ofs += 4;
-
- if (wct_ofs+2 > talloc_get_size(cli_req->inbuf)) {
- return NT_STATUS_INVALID_NETWORK_RESPONSE;
- }
-
- cmd = CVAL(cli_req->inbuf, wct_ofs + 1);
- }
-
- if (!have_andx_command(cli_req->inbuf, wct_ofs)
- && NT_STATUS_IS_ERR(status)) {
+ return;
+ } else if (!NT_STATUS_EQUAL(status, NT_STATUS_RETRY)) {
/*
- * The last command takes the error code. All further commands
- * down the requested chain will get a
- * NT_STATUS_REQUEST_ABORTED.
+ * We got an error, so notify all pending requests
*/
- return status;
+ cli_state_notify_pending(cli, status);
+ return;
}
- done:
- wct = CVAL(cli_req->inbuf, wct_ofs);
-
- bytes_offset = wct_ofs + 1 + wct * sizeof(uint16_t);
- num_bytes = SVAL(cli_req->inbuf, bytes_offset);
-
/*
- * wct_ofs is a 16-bit value plus 4, wct is a 8-bit value, num_bytes
- * is a 16-bit value. So bytes_offset being size_t should be far from
- * wrapping.
+ * We got NT_STATUS_RETRY, so we may ask for a
+ * next incoming pdu.
*/
-
- if ((bytes_offset + 2 > talloc_get_size(cli_req->inbuf))
- || (bytes_offset > 0xffff)) {
- return NT_STATUS_INVALID_NETWORK_RESPONSE;
+ if (!cli_state_receive_next(cli)) {
+ cli_state_notify_pending(cli, NT_STATUS_NO_MEMORY);
}
-
- *pwct = wct;
- *pvwv = (uint16_t *)(cli_req->inbuf + wct_ofs + 1);
- *pnum_bytes = num_bytes;
- *pbytes = (uint8_t *)cli_req->inbuf + bytes_offset + 2;
-
- return NT_STATUS_OK;
}
-/**
- * Decrypt a PDU, check the signature
- * @param[in] cli The cli_state that received something
- * @param[in] pdu The incoming bytes
- * @retval error code
- */
-
-
-static NTSTATUS validate_smb_crypto(struct cli_state *cli, char *pdu)
+static NTSTATUS cli_state_dispatch_smb1(struct cli_state *cli,
+ TALLOC_CTX *frame,
+ uint8_t *inbuf)
{
+ struct tevent_req *req;
+ struct cli_smb_state *state;
NTSTATUS status;
+ int num_pending;
+ int i;
+ uint16_t mid;
+ bool oplock_break;
- if ((IVAL(pdu, 4) != 0x424d53ff) /* 0xFF"SMB" */
- && (SVAL(pdu, 4) != 0x45ff)) /* 0xFF"E" */ {
+ if ((IVAL(inbuf, 4) != 0x424d53ff) /* 0xFF"SMB" */
+ && (SVAL(inbuf, 4) != 0x45ff)) /* 0xFF"E" */ {
DEBUG(10, ("Got non-SMB PDU\n"));
return NT_STATUS_INVALID_NETWORK_RESPONSE;
}
- if (cli_encryption_on(cli) && CVAL(pdu, 0) == 0) {
+ if (cli_state_encryption_on(cli) && (CVAL(inbuf, 0) == 0)) {
uint16_t enc_ctx_num;
- status = get_enc_ctx_num((uint8_t *)pdu, &enc_ctx_num);
+ status = get_enc_ctx_num(inbuf, &enc_ctx_num);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(10, ("get_enc_ctx_num returned %s\n",
nt_errstr(status)));
return NT_STATUS_INVALID_HANDLE;
}
- status = common_decrypt_buffer(cli->trans_enc_state, pdu);
+ status = common_decrypt_buffer(cli->trans_enc_state,
+ (char *)inbuf);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(10, ("common_decrypt_buffer returned %s\n",
nt_errstr(status)));
}
}
- if (!cli_check_sign_mac(cli, pdu)) {
- DEBUG(10, ("cli_check_sign_mac failed\n"));
- return NT_STATUS_ACCESS_DENIED;
+ mid = SVAL(inbuf, smb_mid);
+ num_pending = talloc_array_length(cli->conn.pending);
+
+ for (i=0; i<num_pending; i++) {
+ if (mid == cli_smb_req_mid(cli->conn.pending[i])) {
+ break;
+ }
+ }
+ if (i == num_pending) {
+ /* Dump unexpected reply */
+ return NT_STATUS_RETRY;
}
- return NT_STATUS_OK;
-}
+ oplock_break = false;
-/**
- * A PDU has arrived on cli->evt_inbuf
- * @param[in] cli The cli_state that received something
- */
+ if (mid == 0xffff) {
+ /*
+ * Paranoia checks that this is really an oplock break request.
+ */
+ oplock_break = (smb_len(inbuf) == 51); /* hdr + 8 words */
+ oplock_break &= ((CVAL(inbuf, smb_flg) & FLAG_REPLY) == 0);
+ oplock_break &= (CVAL(inbuf, smb_com) == SMBlockingX);
+ oplock_break &= (SVAL(inbuf, smb_vwv6) == 0);
+ oplock_break &= (SVAL(inbuf, smb_vwv7) == 0);
+
+ if (!oplock_break) {
+ /* Dump unexpected reply */
+ return NT_STATUS_RETRY;
+ }
+ }
-static void handle_incoming_pdu(struct cli_state *cli)
-{
- struct cli_request *req;
- uint16_t mid;
- size_t raw_pdu_len, buf_len, pdu_len, rest_len;
- char *pdu;
- int i;
- NTSTATUS status;
+ req = cli->conn.pending[i];
+ state = tevent_req_data(req, struct cli_smb_state);
- int num_async;
+ if (!oplock_break /* oplock breaks are not signed */
+ && !cli_check_sign_mac(cli, (char *)inbuf, state->seqnum+1)) {
+ DEBUG(10, ("cli_check_sign_mac failed\n"));
+ return NT_STATUS_ACCESS_DENIED;
+ }
- /*
- * The encrypted PDU len might differ from the unencrypted one
- */
- raw_pdu_len = smb_len(cli->evt_inbuf) + 4;
- buf_len = talloc_get_size(cli->evt_inbuf);
- rest_len = buf_len - raw_pdu_len;
+ if (state->chained_requests != NULL) {
+ struct tevent_req **chain = talloc_move(frame,
+ &state->chained_requests);
+ int num_chained = talloc_array_length(chain);
- if (buf_len == raw_pdu_len) {
/*
- * Optimal case: Exactly one PDU was in the socket buffer
+ * We steal the inbuf to the chain,
+ * so that it will stay until all
+ * requests of the chain are finished.
+ *
+ * Each requests in the chain will
+ * hold a talloc reference to the chain.
+ * This way we do not expose the talloc_reference()
+ * behavior to the callers.
*/
- pdu = cli->evt_inbuf;
- cli->evt_inbuf = NULL;
- }
- else {
- DEBUG(11, ("buf_len = %d, raw_pdu_len = %d, splitting "
- "buffer\n", (int)buf_len, (int)raw_pdu_len));
+ talloc_steal(chain, inbuf);
+
+ for (i=0; i<num_chained; i++) {
+ struct tevent_req **ref;
+
+ req = chain[i];
+ state = tevent_req_data(req, struct cli_smb_state);
+
+ cli_smb_req_unset_pending(req);
- if (raw_pdu_len < rest_len) {
/*
- * The PDU is shorter, talloc_memdup that one.
+ * as we finish multiple requests here
+ * we need to defer the callbacks as
+ * they could destroy our current stack state.
*/
- pdu = (char *)talloc_memdup(
- cli, cli->evt_inbuf, raw_pdu_len);
+ tevent_req_defer_callback(req, state->ev);
+
+ ref = talloc_reference(state, chain);
+ if (tevent_req_nomem(ref, req)) {
+ continue;
+ }
+
+ state->inbuf = inbuf;
+ state->chain_num = i;
+ state->chain_length = num_chained;
+
+ tevent_req_done(req);
+ }
+
+ return NT_STATUS_RETRY;
+ }
+
+ cli_smb_req_unset_pending(req);
+
+ state->inbuf = talloc_move(state, &inbuf);
+ state->chain_num = 0;
+ state->chain_length = 1;
+
+ if (talloc_array_length(cli->conn.pending) == 0) {
+ tevent_req_done(req);
+ return NT_STATUS_OK;
+ }
+
+ tevent_req_defer_callback(req, state->ev);
+ tevent_req_done(req);
+ return NT_STATUS_RETRY;
+}
- memmove(cli->evt_inbuf, cli->evt_inbuf + raw_pdu_len,
- buf_len - raw_pdu_len);
+NTSTATUS cli_smb_recv(struct tevent_req *req,
+ TALLOC_CTX *mem_ctx, uint8_t **pinbuf,
+ uint8_t min_wct, uint8_t *pwct, uint16_t **pvwv,
+ uint32_t *pnum_bytes, uint8_t **pbytes)
+{
+ struct cli_smb_state *state = tevent_req_data(
+ req, struct cli_smb_state);
+ NTSTATUS status = NT_STATUS_OK;
+ uint8_t cmd, wct;
+ uint16_t num_bytes;
+ size_t wct_ofs, bytes_offset;
+ int i;
+
+ if (tevent_req_is_nterror(req, &status)) {
+ return status;
+ }
+
+ if (state->inbuf == NULL) {
+ if (min_wct != 0) {
+ return NT_STATUS_INVALID_NETWORK_RESPONSE;
+ }
+ if (pinbuf) {
+ *pinbuf = NULL;
+ }
+ if (pwct) {
+ *pwct = 0;
+ }
+ if (pvwv) {
+ *pvwv = NULL;
+ }
+ if (pnum_bytes) {
+ *pnum_bytes = 0;
+ }
+ if (pbytes) {
+ *pbytes = NULL;
+ }
+ /* This was a request without a reply */
+ return NT_STATUS_OK;
+ }
- cli->evt_inbuf = TALLOC_REALLOC_ARRAY(
- NULL, cli->evt_inbuf, char, rest_len);
+ wct_ofs = smb_wct;
+ cmd = CVAL(state->inbuf, smb_com);
- if (pdu == NULL) {
- status = NT_STATUS_NO_MEMORY;
- goto invalidate_requests;
+ for (i=0; i<state->chain_num; i++) {
+ if (i < state->chain_num-1) {
+ if (cmd == 0xff) {
+ return NT_STATUS_REQUEST_ABORTED;
+ }
+ if (!is_andx_req(cmd)) {
+ return NT_STATUS_INVALID_NETWORK_RESPONSE;
}
}
- else {
+
+ if (!have_andx_command((char *)state->inbuf, wct_ofs)) {
/*
- * The PDU is larger than the rest, talloc_memdup the
- * rest
+ * This request was not completed because a previous
+ * request in the chain had received an error.
*/
- pdu = cli->evt_inbuf;
+ return NT_STATUS_REQUEST_ABORTED;
+ }
- cli->evt_inbuf = (char *)talloc_memdup(
- cli, pdu + raw_pdu_len, rest_len);
+ wct_ofs = SVAL(state->inbuf, wct_ofs + 3);
- if (cli->evt_inbuf == NULL) {
- status = NT_STATUS_NO_MEMORY;
- goto invalidate_requests;
- }
+ /*
+ * Skip the all-present length field. No overflow, we've just
+ * put a 16-bit value into a size_t.
+ */
+ wct_ofs += 4;
+
+ if (wct_ofs+2 > talloc_get_size(state->inbuf)) {
+ return NT_STATUS_INVALID_NETWORK_RESPONSE;
}
+
+ cmd = CVAL(state->inbuf, wct_ofs + 1);
}
- status = validate_smb_crypto(cli, pdu);
- if (!NT_STATUS_IS_OK(status)) {
- goto invalidate_requests;
+ state->cli->raw_status = cli_pull_raw_error(state->inbuf);
+ if (NT_STATUS_IS_DOS(state->cli->raw_status)) {
+ uint8_t eclass = NT_STATUS_DOS_CLASS(state->cli->raw_status);
+ uint16_t ecode = NT_STATUS_DOS_CODE(state->cli->raw_status);
+ /*
+ * TODO: is it really a good idea to do a mapping here?
+ *
+ * The old cli_pull_error() also does it, so I do not change
+ * the behavior yet.
+ */
+ status = dos_to_ntstatus(eclass, ecode);
+ } else {
+ status = state->cli->raw_status;
}
- mid = SVAL(pdu, smb_mid);
+ if (!have_andx_command((char *)state->inbuf, wct_ofs)) {
- DEBUG(10, ("handle_incoming_pdu: got mid %d\n", mid));
+ if ((cmd == SMBsesssetupX)
+ && NT_STATUS_EQUAL(
+ status, NT_STATUS_MORE_PROCESSING_REQUIRED)) {
+ /*
+ * NT_STATUS_MORE_PROCESSING_REQUIRED is a
+ * valid return code for session setup
+ */
+ goto no_err;
+ }
- for (req = cli->outstanding_requests; req; req = req->next) {
- if (req->mid == mid) {
- break;
+ if (NT_STATUS_IS_ERR(status)) {
+ /*
+ * The last command takes the error code. All
+ * further commands down the requested chain
+ * will get a NT_STATUS_REQUEST_ABORTED.
+ */
+ return status;
}
}
- pdu_len = smb_len(pdu) + 4;
+no_err:
- if (req == NULL) {
- DEBUG(3, ("Request for mid %d not found, dumping PDU\n", mid));
+ wct = CVAL(state->inbuf, wct_ofs);
+ bytes_offset = wct_ofs + 1 + wct * sizeof(uint16_t);
+ num_bytes = SVAL(state->inbuf, bytes_offset);
- TALLOC_FREE(pdu);
- return;
+ if (wct < min_wct) {
+ return NT_STATUS_INVALID_NETWORK_RESPONSE;
}
- req->inbuf = talloc_move(req, &pdu);
-
/*
- * Freeing the last async_req will free the req (see
- * cli_async_req_destructor). So make a copy of req->num_async, we
- * can't reference it in the last round.
+ * wct_ofs is a 16-bit value plus 4, wct is a 8-bit value, num_bytes
+ * is a 16-bit value. So bytes_offset being size_t should be far from
+ * wrapping.
*/
+ if ((bytes_offset + 2 > talloc_get_size(state->inbuf))
+ || (bytes_offset > 0xffff)) {
+ return NT_STATUS_INVALID_NETWORK_RESPONSE;
+ }
- num_async = req->num_async;
-
- for (i=0; i<num_async; i++) {
- /**
- * A request might have been talloc_free()'ed before we arrive
- * here. It will have removed itself from req->async via its
- * destructor cli_async_req_destructor().
- */
- if (req->async[i] != NULL) {
- if (req->recv_helper.fn != NULL) {
- req->recv_helper.fn(req->async[i]);
- } else {
- async_req_done(req->async[i]);
- }
+ if (pwct != NULL) {
+ *pwct = wct;
+ }
+ if (pvwv != NULL) {
+ *pvwv = (uint16_t *)(state->inbuf + wct_ofs + 1);
+ }
+ if (pnum_bytes != NULL) {
+ *pnum_bytes = num_bytes;
+ }
+ if (pbytes != NULL) {
+ *pbytes = (uint8_t *)state->inbuf + bytes_offset + 2;
+ }
+ if ((mem_ctx != NULL) && (pinbuf != NULL)) {
+ if (state->chain_num == state->chain_length-1) {
+ *pinbuf = talloc_move(mem_ctx, &state->inbuf);
+ } else {
+ *pinbuf = state->inbuf;
}
}
- return;
- invalidate_requests:
+ return status;
+}
- DEBUG(10, ("handle_incoming_pdu: Aborting with %s\n",
- nt_errstr(status)));
+size_t cli_smb_wct_ofs(struct tevent_req **reqs, int num_reqs)
+{
+ size_t wct_ofs;
+ int i;
- for (req = cli->outstanding_requests; req; req = req->next) {
- async_req_error(req->async[0], status);
+ wct_ofs = smb_wct - 4;
+
+ for (i=0; i<num_reqs; i++) {
+ struct cli_smb_state *state;
+ state = tevent_req_data(reqs[i], struct cli_smb_state);
+ wct_ofs += iov_len(state->iov+1, state->iov_count-1);
+ wct_ofs = (wct_ofs + 3) & ~3;
}
- return;
+ return wct_ofs;
}
-/**
- * fd event callback. This is the basic connection to the socket
- * @param[in] event_ctx The event context that called us
- * @param[in] event The event that fired
- * @param[in] flags EVENT_FD_READ | EVENT_FD_WRITE
- * @param[in] p private_data, in this case the cli_state
- */
-
-static void cli_state_handler(struct event_context *event_ctx,
- struct fd_event *event, uint16 flags, void *p)
+NTSTATUS cli_smb_chain_send(struct tevent_req **reqs, int num_reqs)
{
- struct cli_state *cli = (struct cli_state *)p;
- struct cli_request *req;
+ struct cli_smb_state *first_state = tevent_req_data(
+ reqs[0], struct cli_smb_state);
+ struct cli_smb_state *last_state = tevent_req_data(
+ reqs[num_reqs-1], struct cli_smb_state);
+ struct cli_smb_state *state;
+ size_t wct_offset;
+ size_t chain_padding = 0;
+ int i, iovlen;
+ struct iovec *iov = NULL;
+ struct iovec *this_iov;
NTSTATUS status;
- DEBUG(11, ("cli_state_handler called with flags %d\n", flags));
-
- if (flags & EVENT_FD_WRITE) {
- size_t to_send;
- ssize_t sent;
-
- for (req = cli->outstanding_requests; req; req = req->next) {
- to_send = smb_len(req->outbuf)+4;
- if (to_send > req->sent) {
- break;
- }
- }
-
- if (req == NULL) {
- if (cli->fd_event != NULL) {
- event_fd_set_not_writeable(cli->fd_event);
- }
- return;
+ iovlen = 0;
+ for (i=0; i<num_reqs; i++) {
+ if (!tevent_req_is_in_progress(reqs[i])) {
+ return NT_STATUS_INTERNAL_ERROR;
}
- sent = sys_send(cli->fd, req->outbuf + req->sent,
- to_send - req->sent, 0);
-
- if (sent < 0) {
- status = map_nt_error_from_unix(errno);
- goto sock_error;
- }
+ state = tevent_req_data(reqs[i], struct cli_smb_state);
+ iovlen += state->iov_count;
+ }
- req->sent += sent;
+ iov = talloc_array(last_state, struct iovec, iovlen);
+ if (iov == NULL) {
+ return NT_STATUS_NO_MEMORY;
+ }
- if (req->sent == to_send) {
- return;
- }
+ first_state->chained_requests = (struct tevent_req **)talloc_memdup(
+ last_state, reqs, sizeof(*reqs) * num_reqs);
+ if (first_state->chained_requests == NULL) {
+ TALLOC_FREE(iov);
+ return NT_STATUS_NO_MEMORY;
}
- if (flags & EVENT_FD_READ) {
- int res, available;
- size_t old_size, new_size;
- char *tmp;
+ wct_offset = smb_wct - 4;
+ this_iov = iov;
- res = ioctl(cli->fd, FIONREAD, &available);
- if (res == -1) {
- DEBUG(10, ("ioctl(FIONREAD) failed: %s\n",
- strerror(errno)));
- status = map_nt_error_from_unix(errno);
- goto sock_error;
- }
+ for (i=0; i<num_reqs; i++) {
+ size_t next_padding = 0;
+ uint16_t *vwv;
- if (available == 0) {
- /* EOF */
- status = NT_STATUS_END_OF_FILE;
- goto sock_error;
- }
-
- old_size = talloc_get_size(cli->evt_inbuf);
- new_size = old_size + available;
+ state = tevent_req_data(reqs[i], struct cli_smb_state);
- if (new_size < old_size) {
- /* wrap */
- status = NT_STATUS_UNEXPECTED_IO_ERROR;
- goto sock_error;
+ if (i < num_reqs-1) {
+ if (!is_andx_req(CVAL(state->header, smb_com))
+ || CVAL(state->header, smb_wct) < 2) {
+ TALLOC_FREE(iov);
+ TALLOC_FREE(first_state->chained_requests);
+ return NT_STATUS_INVALID_PARAMETER;
+ }
}
- tmp = TALLOC_REALLOC_ARRAY(cli, cli->evt_inbuf, char,
- new_size);
- if (tmp == NULL) {
- /* nomem */
- status = NT_STATUS_NO_MEMORY;
- goto sock_error;
+ wct_offset += iov_len(state->iov+1, state->iov_count-1) + 1;
+ if ((wct_offset % 4) != 0) {
+ next_padding = 4 - (wct_offset % 4);
}
- cli->evt_inbuf = tmp;
-
- res = sys_recv(cli->fd, cli->evt_inbuf + old_size, available, 0);
- if (res == -1) {
- DEBUG(10, ("recv failed: %s\n", strerror(errno)));
- status = map_nt_error_from_unix(errno);
- goto sock_error;
+ wct_offset += next_padding;
+ vwv = state->vwv;
+
+ if (i < num_reqs-1) {
+ struct cli_smb_state *next_state = tevent_req_data(
+ reqs[i+1], struct cli_smb_state);
+ SCVAL(vwv+0, 0, CVAL(next_state->header, smb_com));
+ SCVAL(vwv+0, 1, 0);
+ SSVAL(vwv+1, 0, wct_offset);
+ } else if (is_andx_req(CVAL(state->header, smb_com))) {
+ /* properly end the chain */
+ SCVAL(vwv+0, 0, 0xff);
+ SCVAL(vwv+0, 1, 0xff);
+ SSVAL(vwv+1, 0, 0);
}
- DEBUG(11, ("cli_state_handler: received %d bytes, "
- "smb_len(evt_inbuf) = %d\n", (int)res,
- smb_len(cli->evt_inbuf)));
-
- /* recv *might* have returned less than announced */
- new_size = old_size + res;
-
- /* shrink, so I don't expect errors here */
- cli->evt_inbuf = TALLOC_REALLOC_ARRAY(cli, cli->evt_inbuf,
- char, new_size);
-
- while ((cli->evt_inbuf != NULL)
- && ((smb_len(cli->evt_inbuf) + 4) <= new_size)) {
+ if (i == 0) {
+ this_iov[0] = state->iov[0];
+ } else {
/*
- * we've got a complete NBT level PDU in evt_inbuf
+ * This one is a bit subtle. We have to add
+ * chain_padding bytes between the requests, and we
+ * have to also include the wct field of the
+ * subsequent requests. We use the subsequent header
+ * for the padding, it contains the wct field in its
+ * last byte.
*/
- handle_incoming_pdu(cli);
- new_size = talloc_get_size(cli->evt_inbuf);
+ this_iov[0].iov_len = chain_padding+1;
+ this_iov[0].iov_base = (void *)&state->header[
+ sizeof(state->header) - this_iov[0].iov_len];
+ memset(this_iov[0].iov_base, 0, this_iov[0].iov_len-1);
}
+ memcpy(this_iov+1, state->iov+1,
+ sizeof(struct iovec) * (state->iov_count-1));
+ this_iov += state->iov_count;
+ chain_padding = next_padding;
}
- return;
-
- sock_error:
- for (req = cli->outstanding_requests; req; req = req->next) {
- int i;
- for (i=0; i<req->num_async; i++) {
- async_req_error(req->async[i], status);
- }
+ status = cli_smb_req_iov_send(reqs[0], last_state, iov, iovlen);
+ if (!NT_STATUS_IS_OK(status)) {
+ TALLOC_FREE(iov);
+ TALLOC_FREE(first_state->chained_requests);
+ return status;
}
- TALLOC_FREE(cli->fd_event);
- close(cli->fd);
- cli->fd = -1;
+
+ return NT_STATUS_OK;
+}
+
+bool cli_has_async_calls(struct cli_state *cli)
+{
+ return ((tevent_queue_length(cli->conn.outgoing) != 0)
+ || (talloc_array_length(cli->conn.pending) != 0));
}
git.samba.org / rusty / samba.git / blobdiff