summaryrefslogtreecommitdiff
path: root/source3/rpc_server
diff options
context:
space:
mode:
authorStefan Metzmacher <metze@samba.org>2010-06-22 18:01:45 -0400
committerStefan Metzmacher <metze@samba.org>2010-12-15 15:26:05 +0100
commite55426fe7926ae6f8afe5fa6cfc009e0c3b54e38 (patch)
tree8e9f3fe35f41ebc96b008fe59bc3b9a60d72f1d7 /source3/rpc_server
parent07ba35adcbb9feb551125034f091e8d4cb4aa0e8 (diff)
downloadsamba-e55426fe7926ae6f8afe5fa6cfc009e0c3b54e38.tar.gz
samba-e55426fe7926ae6f8afe5fa6cfc009e0c3b54e38.tar.bz2
samba-e55426fe7926ae6f8afe5fa6cfc009e0c3b54e38.zip
s3:rpc_client: let rpc_transport_tstream_init() create read and write queue
metze
Diffstat (limited to 'source3/rpc_server')
-rw-r--r--source3/rpc_server/rpc_ncacn_np.c16
1 files changed, 1 insertions, 15 deletions
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;