s3:rpc_client: add dispatch_send/recv() to struct rpc_pipe_client

metze

diff --git a/source3/include/client.h b/source3/include/client.h
index 6f56468274405d87e817927dab24f48e37eee982..203198fed831d26b29aca4996c6ecb02d5d29b11 100644 (file)
--- a/source3/include/client.h
+++ b/source3/include/client.h
@@ -124,6 +124,17 @@ struct rpc_pipe_client {
                        const struct ndr_interface_table *table,
                        uint32_t opnum, void *r);
 
+       struct tevent_req *(*dispatch_send)(
+               TALLOC_CTX *mem_ctx,
+               struct tevent_context *ev,
+               struct rpc_pipe_client *cli,
+               const struct ndr_interface_table *table,
+               uint32_t opnum,
+               void *r);
+       NTSTATUS (*dispatch_recv)(struct tevent_req *req,
+                                 TALLOC_CTX *mem_ctx);
+
+
        char *desthost;
        char *srv_name_slash;
 

diff --git a/source3/rpc_client/cli_pipe.c b/source3/rpc_client/cli_pipe.c
index be375f1ba50cdca026c62e1893ac54c520634cd8..0f6471901813d173cb2554555346c574da6769ae 100644 (file)
--- a/source3/rpc_client/cli_pipe.c
+++ b/source3/rpc_client/cli_pipe.c
@@ -3159,6 +3159,8 @@ static NTSTATUS rpc_pipe_open_tcp_port(TALLOC_CTX *mem_ctx, const char *host,
        result->abstract_syntax = *abstract_syntax;
        result->transfer_syntax = ndr_transfer_syntax;
        result->dispatch = cli_do_rpc_ndr;
+       result->dispatch_send = cli_do_rpc_ndr_send;
+       result->dispatch_recv = cli_do_rpc_ndr_recv;
 
        result->desthost = talloc_strdup(result, host);
        result->srv_name_slash = talloc_asprintf_strupper_m(
@@ -3371,6 +3373,8 @@ NTSTATUS rpc_pipe_open_ncalrpc(TALLOC_CTX *mem_ctx, const char *socket_path,
        result->abstract_syntax = *abstract_syntax;
        result->transfer_syntax = ndr_transfer_syntax;
        result->dispatch = cli_do_rpc_ndr;
+       result->dispatch_send = cli_do_rpc_ndr_send;
+       result->dispatch_recv = cli_do_rpc_ndr_recv;
 
        result->desthost = get_myname(result);
        result->srv_name_slash = talloc_asprintf_strupper_m(
@@ -3459,6 +3463,8 @@ static NTSTATUS rpc_pipe_open_np(struct cli_state *cli,
        result->abstract_syntax = *abstract_syntax;
        result->transfer_syntax = ndr_transfer_syntax;
        result->dispatch = cli_do_rpc_ndr;
+       result->dispatch_send = cli_do_rpc_ndr_send;
+       result->dispatch_recv = cli_do_rpc_ndr_recv;
        result->desthost = talloc_strdup(result, cli->desthost);
        result->srv_name_slash = talloc_asprintf_strupper_m(
                result, "\\\\%s", result->desthost);
@@ -3501,6 +3507,8 @@ NTSTATUS rpc_pipe_open_local(TALLOC_CTX *mem_ctx,
        result->abstract_syntax = *syntax;
        result->transfer_syntax = ndr_transfer_syntax;
        result->dispatch = cli_do_rpc_ndr;
+       result->dispatch_send = cli_do_rpc_ndr_send;
+       result->dispatch_recv = cli_do_rpc_ndr_recv;
        result->max_xmit_frag = RPC_MAX_PDU_FRAG_LEN;
        result->max_recv_frag = RPC_MAX_PDU_FRAG_LEN;