From e55426fe7926ae6f8afe5fa6cfc009e0c3b54e38 Mon Sep 17 00:00:00 2001 From: Stefan Metzmacher Date: Tue, 22 Jun 2010 18:01:45 -0400 Subject: s3:rpc_client: let rpc_transport_tstream_init() create read and write queue metze --- source3/rpc_server/rpc_ncacn_np.c | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) (limited to 'source3/rpc_server') diff --git a/source3/rpc_server/rpc_ncacn_np.c b/source3/rpc_server/rpc_ncacn_np.c index f4c47fc3e3..71ac69fe15 100644 --- a/source3/rpc_server/rpc_ncacn_np.c +++ b/source3/rpc_server/rpc_ncacn_np.c @@ -606,18 +606,6 @@ struct np_proxy_state *make_external_rpc_pipe_p(TALLOC_CTX *mem_ctx, return NULL; } - result->read_queue = tevent_queue_create(result, "np_read"); - if (result->read_queue == NULL) { - DEBUG(0, ("tevent_queue_create failed\n")); - goto fail; - } - - result->write_queue = tevent_queue_create(result, "np_write"); - if (result->write_queue == NULL) { - DEBUG(0, ("tevent_queue_create failed\n")); - goto fail; - } - ev = s3_tevent_context_init(talloc_tos()); if (ev == NULL) { DEBUG(0, ("s3_tevent_context_init failed\n")); @@ -756,9 +744,7 @@ static NTSTATUS rpc_pipe_open_external(TALLOC_CTX *mem_ctx, result->max_recv_frag = RPC_MAX_PDU_FRAG_LEN; status = rpc_transport_tstream_init(result, - proxy_state->npipe, - proxy_state->read_queue, - proxy_state->write_queue, + &proxy_state->npipe, &result->transport); if (!NT_STATUS_IS_OK(status)) { goto done; -- cgit