- memcpy(this_iov+1, state->iov+1,
- sizeof(struct iovec) * (state->iov_count-1));
- this_iov += state->iov_count;
- chain_padding = next_padding;
- }
-
- 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;
- }
-
- return NT_STATUS_OK;
-}
-
-uint8_t *cli_smb_inbuf(struct tevent_req *req)
-{
- struct cli_smb_state *state = tevent_req_data(
- req, struct cli_smb_state);
- return state->inbuf;
-}
-
-bool cli_has_async_calls(struct cli_state *cli)
-{
- return ((tevent_queue_length(cli->outgoing) != 0)
- || (talloc_array_length(cli->pending) != 0));
-}
-
-struct cli_smb_oplock_break_waiter_state {
- uint16_t fnum;
- uint8_t level;
-};
-
-static void cli_smb_oplock_break_waiter_done(struct tevent_req *subreq);
-
-struct tevent_req *cli_smb_oplock_break_waiter_send(TALLOC_CTX *mem_ctx,
- struct event_context *ev,
- struct cli_state *cli)
-{
- struct tevent_req *req, *subreq;
- struct cli_smb_oplock_break_waiter_state *state;
- struct cli_smb_state *smb_state;
-
- req = tevent_req_create(mem_ctx, &state,
- struct cli_smb_oplock_break_waiter_state);
- if (req == NULL) {
- return NULL;
- }
-
- /*
- * Create a fake SMB request that we will never send out. This is only
- * used to be set into the pending queue with the right mid.
- */
- subreq = cli_smb_req_create(mem_ctx, ev, cli, 0, 0, 0, NULL, 0, NULL);
- if (tevent_req_nomem(subreq, req)) {
- return tevent_req_post(req, ev);
- }
- smb_state = tevent_req_data(subreq, struct cli_smb_state);
- SSVAL(smb_state->header, smb_mid, 0xffff);
-
- if (!cli_smb_req_set_pending(subreq)) {
- tevent_req_nterror(req, NT_STATUS_NO_MEMORY);
- return tevent_req_post(req, ev);
- }
- tevent_req_set_callback(subreq, cli_smb_oplock_break_waiter_done, req);
- return req;
-}
-
-static void cli_smb_oplock_break_waiter_done(struct tevent_req *subreq)
-{
- struct tevent_req *req = tevent_req_callback_data(
- subreq, struct tevent_req);
- struct cli_smb_oplock_break_waiter_state *state = tevent_req_data(
- req, struct cli_smb_oplock_break_waiter_state);
- uint8_t wct;
- uint16_t *vwv;
- uint32_t num_bytes;
- uint8_t *bytes;
- uint8_t *inbuf;
- NTSTATUS status;
-
- status = cli_smb_recv(subreq, state, &inbuf, 8, &wct, &vwv,
- &num_bytes, &bytes);
- TALLOC_FREE(subreq);
- if (!NT_STATUS_IS_OK(status)) {
- tevent_req_nterror(req, status);
- return;
- }
- state->fnum = SVAL(vwv+2, 0);
- state->level = CVAL(vwv+3, 1);
- tevent_req_done(req);
-}
-
-NTSTATUS cli_smb_oplock_break_waiter_recv(struct tevent_req *req,
- uint16_t *pfnum,
- uint8_t *plevel)
-{
- struct cli_smb_oplock_break_waiter_state *state = tevent_req_data(
- req, struct cli_smb_oplock_break_waiter_state);
- NTSTATUS status;
-
- if (tevent_req_is_nterror(req, &status)) {
- return status;
- }
- *pfnum = state->fnum;
- *plevel = state->level;
- return NT_STATUS_OK;
-}
-
-
-struct cli_session_request_state {
- struct tevent_context *ev;
- int sock;
- uint32 len_hdr;
- struct iovec iov[3];
- uint8_t nb_session_response;
-};
-
-static void cli_session_request_sent(struct tevent_req *subreq);
-static void cli_session_request_recvd(struct tevent_req *subreq);
-
-struct tevent_req *cli_session_request_send(TALLOC_CTX *mem_ctx,
- struct tevent_context *ev,
- int sock,
- const struct nmb_name *called,
- const struct nmb_name *calling)
-{
- struct tevent_req *req, *subreq;
- struct cli_session_request_state *state;
-
- req = tevent_req_create(mem_ctx, &state,
- struct cli_session_request_state);
- if (req == NULL) {
- return NULL;
- }
- state->ev = ev;
- state->sock = sock;
-
- state->iov[1].iov_base = name_mangle(
- state, called->name, called->name_type);
- if (tevent_req_nomem(state->iov[1].iov_base, req)) {
- return tevent_req_post(req, ev);
- }
- state->iov[1].iov_len = name_len(
- (unsigned char *)state->iov[1].iov_base,
- talloc_get_size(state->iov[1].iov_base));
-
- state->iov[2].iov_base = name_mangle(
- state, calling->name, calling->name_type);
- if (tevent_req_nomem(state->iov[2].iov_base, req)) {
- return tevent_req_post(req, ev);
- }
- state->iov[2].iov_len = name_len(
- (unsigned char *)state->iov[2].iov_base,
- talloc_get_size(state->iov[2].iov_base));
-
- _smb_setlen(((char *)&state->len_hdr),
- state->iov[1].iov_len + state->iov[2].iov_len);
- SCVAL((char *)&state->len_hdr, 0, 0x81);
-
- state->iov[0].iov_base = &state->len_hdr;
- state->iov[0].iov_len = sizeof(state->len_hdr);
-
- subreq = writev_send(state, ev, NULL, sock, true, state->iov, 3);
- if (tevent_req_nomem(subreq, req)) {
- return tevent_req_post(req, ev);
- }
- tevent_req_set_callback(subreq, cli_session_request_sent, req);
- return req;
-}
-
-static void cli_session_request_sent(struct tevent_req *subreq)
-{
- struct tevent_req *req = tevent_req_callback_data(
- subreq, struct tevent_req);
- struct cli_session_request_state *state = tevent_req_data(
- req, struct cli_session_request_state);
- ssize_t ret;
- int err;
-
- ret = writev_recv(subreq, &err);
- TALLOC_FREE(subreq);
- if (ret == -1) {
- tevent_req_error(req, err);
- return;
- }
- subreq = read_smb_send(state, state->ev, state->sock);
- if (tevent_req_nomem(subreq, req)) {
- return;
- }
- tevent_req_set_callback(subreq, cli_session_request_recvd, req);
-}
-
-static void cli_session_request_recvd(struct tevent_req *subreq)
-{
- struct tevent_req *req = tevent_req_callback_data(
- subreq, struct tevent_req);
- struct cli_session_request_state *state = tevent_req_data(
- req, struct cli_session_request_state);
- uint8_t *buf;
- ssize_t ret;
- int err;
-
- ret = read_smb_recv(subreq, talloc_tos(), &buf, &err);
- TALLOC_FREE(subreq);
-
- if (ret < 4) {
- ret = -1;
- err = EIO;
- }
- if (ret == -1) {
- tevent_req_error(req, err);
- return;