diff options
| author | Andreas Schneider <asn@samba.org> | 2011-03-09 10:17:06 +0100 |
|---|---|---|
| committer | Simo Sorce <idra@samba.org> | 2011-03-23 17:19:22 +0100 |
| commit | 81a2046879299a051e69fd4d78b3a8e49b690f1b (patch) | |
| tree | 92d377f22c785a3fab3481b648dd4ad51a16192a /source3/rpc_server | |
| parent | d6a1469f4350fa24204e11bb9aee0e33f8d21c34 (diff) | |
| download | samba-81a2046879299a051e69fd4d78b3a8e49b690f1b.tar.gz samba-81a2046879299a051e69fd4d78b3a8e49b690f1b.tar.bz2 samba-81a2046879299a051e69fd4d78b3a8e49b690f1b.zip | |
s3-librpc: Leave the epm registration connection open.
Diffstat (limited to 'source3/rpc_server')
| -rw-r--r-- | source3/rpc_server/rpc_ep_setup.c | 32 |
1 files changed, 22 insertions, 10 deletions
diff --git a/source3/rpc_server/rpc_ep_setup.c b/source3/rpc_server/rpc_ep_setup.c index 19eba17ef5..6ffcf10b9b 100644 --- a/source3/rpc_server/rpc_ep_setup.c +++ b/source3/rpc_server/rpc_ep_setup.c @@ -149,14 +149,16 @@ static NTSTATUS _rpc_ep_unregister(const struct ndr_interface_table *iface) } static void rpc_ep_setup_register_loop(struct tevent_req *subreq); -static NTSTATUS rpc_ep_setup_try_register(struct tevent_context *ev_ctx, +static NTSTATUS rpc_ep_setup_try_register(TALLOC_CTX *mem_ctx, + struct tevent_context *ev_ctx, struct messaging_context *msg_ctx, const struct ndr_interface_table *iface, const char *name, - uint16_t port); + uint16_t port, + struct dcerpc_binding_handle **pbh); struct rpc_ep_regsiter_state { - uint32_t wait_time; + struct dcerpc_binding_handle *h; struct tevent_context *ev_ctx; struct messaging_context *msg_ctx; @@ -165,6 +167,8 @@ struct rpc_ep_regsiter_state { const char *ncalrpc; uint16_t port; + + uint32_t wait_time; }; static NTSTATUS rpc_ep_setup_register(struct tevent_context *ev_ctx, @@ -209,14 +213,17 @@ static void rpc_ep_setup_register_loop(struct tevent_req *req) ok = tevent_wakeup_recv(req); TALLOC_FREE(req); if (!ok) { + talloc_free(state); return; } - status = rpc_ep_setup_try_register(state->ev_ctx, + status = rpc_ep_setup_try_register(state, + state->ev_ctx, state->msg_ctx, state->iface, state->ncalrpc, - state->port); + state->port, + &state->h); if (NT_STATUS_IS_OK(status)) { talloc_free(state); return; @@ -240,16 +247,18 @@ static void rpc_ep_setup_register_loop(struct tevent_req *req) return; } -static NTSTATUS rpc_ep_setup_try_register(struct tevent_context *ev_ctx, +static NTSTATUS rpc_ep_setup_try_register(TALLOC_CTX *mem_ctx, + struct tevent_context *ev_ctx, struct messaging_context *msg_ctx, const struct ndr_interface_table *iface, const char *name, - uint16_t port) + uint16_t port, + struct dcerpc_binding_handle **pbh) { struct dcerpc_binding_vector *v = NULL; NTSTATUS status; - status = dcerpc_binding_vector_create(talloc_tos(), + status = dcerpc_binding_vector_create(mem_ctx, iface, port, name, @@ -258,10 +267,13 @@ static NTSTATUS rpc_ep_setup_try_register(struct tevent_context *ev_ctx, return status; } - status = dcerpc_ep_register(iface, + status = dcerpc_ep_register(mem_ctx, + iface, v, &iface->syntax_id.uuid, - name); + name, + pbh); + talloc_free(v); if (!NT_STATUS_IS_OK(status)) { return status; } |