sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-10-22 07:33:16 +03:00
Code Activity

Convert rpc_cli_transport->read to tevent_req

Browse Source
This commit is contained in:
Volker Lendecke
2009-03-23 23:03:37 +01:00
parent 1724f2ff31
commit 22badee4bf
5 changed files with 85 additions and 93 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
source3/rpc_client/rpc_transport_sock.c
View File

@@ -41,19 +41,18 @@ struct rpc_sock_read_state {
static void rpc_sock_read_done(struct tevent_req *subreq);
static struct async_req *rpc_sock_read_send(TALLOC_CTX *mem_ctx,
struct event_context *ev,
uint8_t *data, size_t size,
void *priv)
static struct tevent_req *rpc_sock_read_send(TALLOC_CTX *mem_ctx,
struct event_context *ev,
uint8_t *data, size_t size,
void *priv)
{
struct rpc_transport_sock_state *sock_transp = talloc_get_type_abort(
priv, struct rpc_transport_sock_state);
struct async_req *result;
struct tevent_req *subreq;
struct tevent_req *req, *subreq;
struct rpc_sock_read_state *state;
if (!async_req_setup(mem_ctx, &result, &state,
struct rpc_sock_read_state)) {
req = tevent_req_create(mem_ctx, &state, struct rpc_sock_read_state);
if (req == NULL) {
return NULL;
}
@@ -61,36 +60,36 @@ static struct async_req *rpc_sock_read_send(TALLOC_CTX *mem_ctx,
if (subreq == NULL) {
goto fail;
}
tevent_req_set_callback(subreq, rpc_sock_read_done, result);
return result;
tevent_req_set_callback(subreq, rpc_sock_read_done, req);
return req;
fail:
TALLOC_FREE(result);
TALLOC_FREE(req);
return NULL;
}
static void rpc_sock_read_done(struct tevent_req *subreq)
{
struct async_req *req =
tevent_req_callback_data(subreq, struct async_req);
struct rpc_sock_read_state *state = talloc_get_type_abort(
req->private_data, struct rpc_sock_read_state);
struct tevent_req *req = tevent_req_callback_data(
subreq, struct tevent_req);
struct rpc_sock_read_state *state = tevent_req_data(
req, struct rpc_sock_read_state);
int err;
state->received = async_recv_recv(subreq, &err);
if (state->received == -1) {
async_req_nterror(req, map_nt_error_from_unix(err));
tevent_req_nterror(req, map_nt_error_from_unix(err));
return;
}
async_req_done(req);
tevent_req_done(req);
}
static NTSTATUS rpc_sock_read_recv(struct async_req *req, ssize_t *preceived)
static NTSTATUS rpc_sock_read_recv(struct tevent_req *req, ssize_t *preceived)
{
struct rpc_sock_read_state *state = talloc_get_type_abort(
req->private_data, struct rpc_sock_read_state);
struct rpc_sock_read_state *state = tevent_req_data(
req, struct rpc_sock_read_state);
NTSTATUS status;
if (async_req_is_nterror(req, &status)) {
if (tevent_req_is_nterror(req, &status)) {
return status;
}
*preceived = state->received;