From 15f64af8e3d5aa889a9c9fb852a3357237ba9972 Mon Sep 17 00:00:00 2001 From: Andreas Schneider Date: Thu, 3 Jun 2010 22:04:08 +0200 Subject: s3-rpc: Create a file with all functions for a internal named pipe. This makes it possible to use the samr rpc server in winbind without linking in smbd. Reviewed-by: Simo Sorce --- source3/rpc_server/srv_pipe_hnd.c | 203 -------------------------------------- 1 file changed, 203 deletions(-) (limited to 'source3/rpc_server/srv_pipe_hnd.c') diff --git a/source3/rpc_server/srv_pipe_hnd.c b/source3/rpc_server/srv_pipe_hnd.c index 5ba9477b07..0a8b715b98 100644 --- a/source3/rpc_server/srv_pipe_hnd.c +++ b/source3/rpc_server/srv_pipe_hnd.c @@ -27,36 +27,6 @@ #undef DBGC_CLASS #define DBGC_CLASS DBGC_RPC_SRV -static int pipes_open; - -static pipes_struct *InternalPipes; - -/* TODO - * the following prototypes are declared here to avoid - * code being moved about too much for a patch to be - * disrupted / less obvious. - * - * these functions, and associated functions that they - * call, should be moved behind a .so module-loading - * system _anyway_. so that's the next step... - */ - -static int close_internal_rpc_pipe_hnd(struct pipes_struct *p); - -/**************************************************************************** - Internal Pipe iterator functions. -****************************************************************************/ - -pipes_struct *get_first_internal_pipe(void) -{ - return InternalPipes; -} - -pipes_struct *get_next_internal_pipe(pipes_struct *p) -{ - return p->next; -} - /**************************************************************************** Initialise an outgoing packet. ****************************************************************************/ @@ -86,85 +56,6 @@ static bool pipe_init_outgoing_data(pipes_struct *p) return True; } -/**************************************************************************** - Make an internal namedpipes structure -****************************************************************************/ - -static struct pipes_struct *make_internal_rpc_pipe_p(TALLOC_CTX *mem_ctx, - const struct ndr_syntax_id *syntax, - const char *client_address, - struct auth_serversupplied_info *server_info) -{ - pipes_struct *p; - - DEBUG(4,("Create pipe requested %s\n", - get_pipe_name_from_syntax(talloc_tos(), syntax))); - - p = TALLOC_ZERO_P(mem_ctx, struct pipes_struct); - - if (!p) { - DEBUG(0,("ERROR! no memory for pipes_struct!\n")); - return NULL; - } - - p->mem_ctx = talloc_named(p, 0, "pipe %s %p", - get_pipe_name_from_syntax(talloc_tos(), - syntax), p); - if (p->mem_ctx == NULL) { - DEBUG(0,("open_rpc_pipe_p: talloc_init failed.\n")); - TALLOC_FREE(p); - return NULL; - } - - if (!init_pipe_handle_list(p, syntax)) { - DEBUG(0,("open_rpc_pipe_p: init_pipe_handles failed.\n")); - TALLOC_FREE(p); - return NULL; - } - - /* - * Initialize the incoming RPC data buffer with one PDU worth of memory. - * We cheat here and say we're marshalling, as we intend to add incoming - * data directly into the prs_struct and we want it to auto grow. We will - * change the type to UNMARSALLING before processing the stream. - */ - - if(!prs_init(&p->in_data.data, 128, p->mem_ctx, MARSHALL)) { - DEBUG(0,("open_rpc_pipe_p: malloc fail for in_data struct.\n")); - close_policy_by_pipe(p); - TALLOC_FREE(p); - return NULL; - } - - p->server_info = copy_serverinfo(p, server_info); - if (p->server_info == NULL) { - DEBUG(0, ("open_rpc_pipe_p: copy_serverinfo failed\n")); - close_policy_by_pipe(p); - TALLOC_FREE(p); - return NULL; - } - - DLIST_ADD(InternalPipes, p); - - memcpy(p->client_address, client_address, sizeof(p->client_address)); - - p->endian = RPC_LITTLE_ENDIAN; - - /* - * Initialize the outgoing RPC data buffer with no memory. - */ - prs_init_empty(&p->out_data.rdata, p->mem_ctx, MARSHALL); - - p->syntax = *syntax; - - DEBUG(4,("Created internal pipe %s (pipes_open=%d)\n", - get_pipe_name_from_syntax(talloc_tos(), syntax), pipes_open)); - - talloc_set_destructor(p, close_internal_rpc_pipe_hnd); - - return p; -} - /**************************************************************************** Sets the fault state on incoming packets. ****************************************************************************/ @@ -911,37 +802,6 @@ static ssize_t read_from_internal_pipe(struct pipes_struct *p, char *data, size_ return data_returned; } -/**************************************************************************** - Close an rpc pipe. -****************************************************************************/ - -static int close_internal_rpc_pipe_hnd(struct pipes_struct *p) -{ - if (!p) { - DEBUG(0,("Invalid pipe in close_internal_rpc_pipe_hnd\n")); - return False; - } - - prs_mem_free(&p->out_data.frag); - prs_mem_free(&p->out_data.rdata); - prs_mem_free(&p->in_data.data); - - if (p->auth.auth_data_free_func) { - (*p->auth.auth_data_free_func)(&p->auth); - } - - free_pipe_rpc_context( p->contexts ); - - /* Free the handles database. */ - close_policy_by_pipe(p); - - DLIST_REMOVE(InternalPipes, p); - - ZERO_STRUCTP(p); - - return 0; -} - bool fsp_is_np(struct files_struct *fsp) { enum FAKE_FILE_TYPE type; @@ -1451,69 +1311,6 @@ NTSTATUS np_read_recv(struct tevent_req *req, ssize_t *nread, return NT_STATUS_OK; } -/** - * @brief Create a new RPC client context which uses a local dispatch function. - * - * @param[in] mem_ctx The memory context to use. - * - * @param[in] abstract_syntax Normally the syntax_id of the autogenerated - * ndr_table_. - * - * @param[in] dispatch The corresponding autogenerated dispatch function - * rpc__dispatch. - * - * @param[in] serversupplied_info The server supplied authentication function. - * - * @param[out] presult A pointer to store the connected rpc client pipe. - * - * @return NT_STATUS_OK on success, a corresponding NT status if an - * error occured. - * - * @code - * struct rpc_pipe_client *winreg_pipe; - * NTSTATUS status; - * - * status = rpc_pipe_open_internal(tmp_ctx, - * &ndr_table_winreg.syntax_id, - * rpc_winreg_dispatch, - * p->server_info, - * &winreg_pipe); - * @endcode - */ -NTSTATUS rpc_pipe_open_internal(TALLOC_CTX *mem_ctx, - const struct ndr_syntax_id *abstract_syntax, - NTSTATUS (*dispatch) (struct rpc_pipe_client *cli, - TALLOC_CTX *mem_ctx, - const struct ndr_interface_table *table, - uint32_t opnum, void *r), - struct auth_serversupplied_info *serversupplied_info, - struct rpc_pipe_client **presult) -{ - struct rpc_pipe_client *result; - - result = TALLOC_ZERO_P(mem_ctx, struct rpc_pipe_client); - if (result == NULL) { - return NT_STATUS_NO_MEMORY; - } - - result->abstract_syntax = *abstract_syntax; - result->transfer_syntax = ndr_transfer_syntax; - result->dispatch = dispatch; - - result->pipes_struct = make_internal_rpc_pipe_p( - result, abstract_syntax, "", serversupplied_info); - if (result->pipes_struct == NULL) { - TALLOC_FREE(result); - return NT_STATUS_NO_MEMORY; - } - - result->max_xmit_frag = -1; - result->max_recv_frag = -1; - - *presult = result; - return NT_STATUS_OK; -} - /** * @brief Create a new RPC client context which uses a local dispatch function. * -- cgit