2 Unix SMB/CIFS implementation.
3 Utilities around tsocket
4 Copyright (C) Volker Lendecke 2009
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/>.
22 struct tstream_read_packet_state {
23 struct tevent_context *ev;
24 struct tstream_context *stream;
25 ssize_t (*more)(uint8_t *buf, size_t buflen, void *private_data);
31 static void tstream_read_packet_done(struct tevent_req *subreq);
33 struct tevent_req *tstream_read_packet_send(TALLOC_CTX *mem_ctx,
34 struct tevent_context *ev,
35 struct tstream_context *stream,
37 ssize_t (*more)(uint8_t *buf,
42 struct tevent_req *req, *subreq;
43 struct tstream_read_packet_state *state;
45 req = tevent_req_create(mem_ctx, &state,
46 struct tstream_read_packet_state);
50 state->buf = talloc_array(state, uint8_t, initial);
51 if (tevent_req_nomem(state->buf, req)) {
52 return tevent_req_post(req, ev);
54 state->iov.iov_base = state->buf;
55 state->iov.iov_len = initial;
58 state->stream = stream;
60 state->private_data = private_data;
62 subreq = tstream_readv_send(state, ev, stream, &state->iov, 1);
63 if (tevent_req_nomem(subreq, req)) {
64 return tevent_req_post(req, ev);
66 tevent_req_set_callback(subreq, tstream_read_packet_done, req);
71 static void tstream_read_packet_done(struct tevent_req *subreq)
73 struct tevent_req *req = tevent_req_callback_data(
74 subreq, struct tevent_req);
75 struct tstream_read_packet_state *state = tevent_req_data(
76 req, struct tstream_read_packet_state);
82 ret = tstream_readv_recv(subreq, &err);
88 tevent_req_error(req, err);
92 if (state->more == NULL) {
93 /* Nobody to ask, this is a async read_data */
97 total = talloc_array_length(state->buf);
99 more = state->more(state->buf, total, state->private_data);
101 /* We got an invalid packet, tell the caller */
102 tevent_req_error(req, EIO);
106 /* We're done, full packet received */
107 tevent_req_done(req);
111 tmp = talloc_realloc(state, state->buf, uint8_t, total+more);
112 if (tevent_req_nomem(tmp, req)) {
117 state->iov.iov_base = state->buf + total;
118 state->iov.iov_len = more;
120 subreq = tstream_readv_send(state, state->ev, state->stream,
122 if (tevent_req_nomem(subreq, req)) {
125 tevent_req_set_callback(subreq, tstream_read_packet_done, req);
128 ssize_t tstream_read_packet_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx,
129 uint8_t **pbuf, int *perrno)
131 struct tstream_read_packet_state *state =
132 tevent_req_data(req, struct tstream_read_packet_state);
134 if (tevent_req_is_unix_error(req, perrno)) {
137 *pbuf = talloc_move(mem_ctx, &state->buf);
138 return talloc_array_length(*pbuf);