From 667d43d4c8916043e6474418a57aaa0d03aee078 Mon Sep 17 00:00:00 2001 From: Andreas Schneider Date: Wed, 28 Jul 2010 10:16:34 +0200 Subject: s3-rpc_pipe: Use struct pipes_struct. --- source3/rpc_server/srv_pipe.c | 49 ++++++++++++++++++++------------------- source3/rpc_server/srv_pipe_hnd.c | 8 +++---- 2 files changed, 29 insertions(+), 28 deletions(-) (limited to 'source3/rpc_server') diff --git a/source3/rpc_server/srv_pipe.c b/source3/rpc_server/srv_pipe.c index 056bf5845a..ea9e3de6da 100644 --- a/source3/rpc_server/srv_pipe.c +++ b/source3/rpc_server/srv_pipe.c @@ -111,7 +111,7 @@ static DATA_BLOB generic_session_key(void) Handle NTLMSSP. ********************************************************************/ -static bool add_ntlmssp_auth(pipes_struct *p) +static bool add_ntlmssp_auth(struct pipes_struct *p) { enum dcerpc_AuthLevel auth_level = p->auth.auth_level; DATA_BLOB auth_blob = data_blob_null; @@ -184,7 +184,7 @@ static bool add_ntlmssp_auth(pipes_struct *p) Append a schannel authenticated fragment. ********************************************************************/ -static bool add_schannel_auth(pipes_struct *p) +static bool add_schannel_auth(struct pipes_struct *p) { DATA_BLOB auth_blob = data_blob_null; NTSTATUS status; @@ -247,7 +247,7 @@ static bool add_schannel_auth(pipes_struct *p) Generate the next PDU to be returned from the data. ********************************************************************/ -static bool create_next_packet(pipes_struct *p, +static bool create_next_packet(struct pipes_struct *p, enum dcerpc_AuthType auth_type, enum dcerpc_AuthLevel auth_level, size_t auth_length) @@ -396,7 +396,7 @@ static bool create_next_packet(pipes_struct *p, Generate the next PDU to be returned from the data in p->rdata. ********************************************************************/ -bool create_next_pdu(pipes_struct *p) +bool create_next_pdu(struct pipes_struct *p) { enum dcerpc_AuthType auth_type = map_pipe_auth_type_to_rpc_auth_type(p->auth.auth_type); @@ -461,7 +461,8 @@ bool create_next_pdu(pipes_struct *p) the pipe struct. *******************************************************************/ -static bool pipe_ntlmssp_verify_final(pipes_struct *p, DATA_BLOB *p_resp_blob) +static bool pipe_ntlmssp_verify_final(struct pipes_struct *p, + DATA_BLOB *p_resp_blob) { DATA_BLOB session_key, reply; NTSTATUS status; @@ -550,7 +551,7 @@ static bool pipe_ntlmssp_verify_final(pipes_struct *p, DATA_BLOB *p_resp_blob) This is the "stage3" NTLMSSP response after a bind request and reply. *******************************************************************/ -bool api_pipe_bind_auth3(pipes_struct *p, struct ncacn_packet *pkt) +bool api_pipe_bind_auth3(struct pipes_struct *p, struct ncacn_packet *pkt) { struct dcerpc_auth auth_info; NTSTATUS status; @@ -615,13 +616,13 @@ bool api_pipe_bind_auth3(pipes_struct *p, struct ncacn_packet *pkt) return False; } -static bool pipe_init_outgoing_data(pipes_struct *p); +static bool pipe_init_outgoing_data(struct pipes_struct *p); /******************************************************************* Marshall a bind_nak pdu. *******************************************************************/ -static bool setup_bind_nak(pipes_struct *p, struct ncacn_packet *pkt) +static bool setup_bind_nak(struct pipes_struct *p, struct ncacn_packet *pkt) { NTSTATUS status; union dcerpc_payload u; @@ -670,7 +671,7 @@ static bool setup_bind_nak(pipes_struct *p, struct ncacn_packet *pkt) Marshall a fault pdu. *******************************************************************/ -bool setup_fault_pdu(pipes_struct *p, NTSTATUS fault_status) +bool setup_fault_pdu(struct pipes_struct *p, NTSTATUS fault_status) { NTSTATUS status; union dcerpc_payload u; @@ -805,7 +806,7 @@ bool is_known_pipename(const char *cli_filename, struct ndr_syntax_id *syntax) Handle a SPNEGO krb5 bind auth. *******************************************************************/ -static bool pipe_spnego_auth_bind_kerberos(pipes_struct *p, +static bool pipe_spnego_auth_bind_kerberos(struct pipes_struct *p, TALLOC_CTX *mem_ctx, struct dcerpc_auth *pauth_info, DATA_BLOB *psecblob, @@ -818,7 +819,7 @@ static bool pipe_spnego_auth_bind_kerberos(pipes_struct *p, Handle the first part of a SPNEGO bind auth. *******************************************************************/ -static bool pipe_spnego_auth_bind_negotiate(pipes_struct *p, +static bool pipe_spnego_auth_bind_negotiate(struct pipes_struct *p, TALLOC_CTX *mem_ctx, struct dcerpc_auth *pauth_info, DATA_BLOB *response) @@ -937,7 +938,7 @@ static bool pipe_spnego_auth_bind_negotiate(pipes_struct *p, Handle the second part of a SPNEGO bind auth. *******************************************************************/ -static bool pipe_spnego_auth_bind_continue(pipes_struct *p, +static bool pipe_spnego_auth_bind_continue(struct pipes_struct *p, TALLOC_CTX *mem_ctx, struct dcerpc_auth *pauth_info, DATA_BLOB *response) @@ -1002,7 +1003,7 @@ static bool pipe_spnego_auth_bind_continue(pipes_struct *p, Handle an schannel bind auth. *******************************************************************/ -static bool pipe_schannel_auth_bind(pipes_struct *p, +static bool pipe_schannel_auth_bind(struct pipes_struct *p, TALLOC_CTX *mem_ctx, struct dcerpc_auth *auth_info, DATA_BLOB *response) @@ -1121,7 +1122,7 @@ static bool pipe_schannel_auth_bind(pipes_struct *p, Handle an NTLMSSP bind auth. *******************************************************************/ -static bool pipe_ntlmssp_auth_bind(pipes_struct *p, +static bool pipe_ntlmssp_auth_bind(struct pipes_struct *p, TALLOC_CTX *mem_ctx, struct dcerpc_auth *auth_info, DATA_BLOB *response) @@ -1182,7 +1183,7 @@ static bool pipe_ntlmssp_auth_bind(pipes_struct *p, Respond to a pipe bind request. *******************************************************************/ -bool api_pipe_bind_req(pipes_struct *p, struct ncacn_packet *pkt) +bool api_pipe_bind_req(struct pipes_struct *p, struct ncacn_packet *pkt) { struct dcerpc_auth auth_info; uint16 assoc_gid; @@ -1462,7 +1463,7 @@ bool api_pipe_bind_req(pipes_struct *p, struct ncacn_packet *pkt) SPNEGO calls. ****************************************************************************/ -bool api_pipe_alter_context(pipes_struct *p, struct ncacn_packet *pkt) +bool api_pipe_alter_context(struct pipes_struct *p, struct ncacn_packet *pkt) { struct dcerpc_auth auth_info; uint16 assoc_gid; @@ -1694,7 +1695,7 @@ void free_pipe_rpc_context( PIPE_RPC_FNS *list ) return; } -static bool api_rpcTNP(pipes_struct *p, struct ncacn_packet *pkt, +static bool api_rpcTNP(struct pipes_struct *p, struct ncacn_packet *pkt, const struct api_struct *api_rpc_cmds, int n_cmds); /**************************************************************************** @@ -1703,7 +1704,7 @@ static bool api_rpcTNP(pipes_struct *p, struct ncacn_packet *pkt, before doing the call. ****************************************************************************/ -bool api_pipe_request(pipes_struct *p, struct ncacn_packet *pkt) +bool api_pipe_request(struct pipes_struct *p, struct ncacn_packet *pkt) { bool ret = False; bool changed_user = False; @@ -1751,7 +1752,7 @@ bool api_pipe_request(pipes_struct *p, struct ncacn_packet *pkt) Calls the underlying RPC function for a named pipe. ********************************************************************/ -static bool api_rpcTNP(pipes_struct *p, struct ncacn_packet *pkt, +static bool api_rpcTNP(struct pipes_struct *p, struct ncacn_packet *pkt, const struct api_struct *api_rpc_cmds, int n_cmds) { int fn_num; @@ -1845,7 +1846,7 @@ static bool api_rpcTNP(pipes_struct *p, struct ncacn_packet *pkt, Initialise an outgoing packet. ****************************************************************************/ -static bool pipe_init_outgoing_data(pipes_struct *p) +static bool pipe_init_outgoing_data(struct pipes_struct *p) { output_data *o_data = &p->out_data; @@ -1865,7 +1866,7 @@ static bool pipe_init_outgoing_data(pipes_struct *p) Sets the fault state on incoming packets. ****************************************************************************/ -void set_incoming_fault(pipes_struct *p) +void set_incoming_fault(struct pipes_struct *p) { data_blob_free(&p->in_data.data); p->in_data.pdu_needed_len = 0; @@ -1875,7 +1876,7 @@ void set_incoming_fault(pipes_struct *p) get_pipe_name_from_syntax(talloc_tos(), &p->syntax))); } -static bool dcesrv_auth_request(pipes_struct *p, struct ncacn_packet *pkt) +static bool dcesrv_auth_request(struct pipes_struct *p, struct ncacn_packet *pkt) { NTSTATUS status; size_t hdr_size = DCERPC_REQUEST_LENGTH; @@ -2033,7 +2034,7 @@ static bool dcesrv_auth_request(pipes_struct *p, struct ncacn_packet *pkt) appends the data into the complete stream if the LAST flag is not set. ****************************************************************************/ -static bool process_request_pdu(pipes_struct *p, struct ncacn_packet *pkt) +static bool process_request_pdu(struct pipes_struct *p, struct ncacn_packet *pkt) { DATA_BLOB data; @@ -2110,7 +2111,7 @@ static bool process_request_pdu(pipes_struct *p, struct ncacn_packet *pkt) Processes a finished PDU stored in p->in_data.pdu. ****************************************************************************/ -void process_complete_pdu(pipes_struct *p) +void process_complete_pdu(struct pipes_struct *p) { struct ncacn_packet *pkt = NULL; NTSTATUS status; diff --git a/source3/rpc_server/srv_pipe_hnd.c b/source3/rpc_server/srv_pipe_hnd.c index 7c4895fe7c..4bfcd4062a 100644 --- a/source3/rpc_server/srv_pipe_hnd.c +++ b/source3/rpc_server/srv_pipe_hnd.c @@ -32,7 +32,7 @@ Ensures we have at least RPC_HEADER_LEN amount of data in the incoming buffer. ****************************************************************************/ -static ssize_t fill_rpc_header(pipes_struct *p, char *data, size_t data_to_copy) +static ssize_t fill_rpc_header(struct pipes_struct *p, char *data, size_t data_to_copy) { size_t len_needed_to_complete_hdr = MIN(data_to_copy, RPC_HEADER_LEN - p->in_data.pdu.length); @@ -59,7 +59,7 @@ static ssize_t fill_rpc_header(pipes_struct *p, char *data, size_t data_to_copy) return (ssize_t)len_needed_to_complete_hdr; } -static bool get_pdu_size(pipes_struct *p) +static bool get_pdu_size(struct pipes_struct *p) { uint16_t frag_len; /* the fill_rpc_header() call insures we copy only @@ -105,7 +105,7 @@ static bool get_pdu_size(pipes_struct *p) PDU's). ****************************************************************************/ -static void free_pipe_context(pipes_struct *p) +static void free_pipe_context(struct pipes_struct *p) { data_blob_free(&p->out_data.frag); data_blob_free(&p->out_data.rdata); @@ -121,7 +121,7 @@ static void free_pipe_context(pipes_struct *p) Accepts incoming data on an rpc pipe. Processes the data in pdu sized units. ****************************************************************************/ -static ssize_t process_incoming_data(pipes_struct *p, char *data, size_t n) +static ssize_t process_incoming_data(struct pipes_struct *p, char *data, size_t n) { size_t data_to_copy = MIN(n, RPC_MAX_PDU_FRAG_LEN - p->in_data.pdu.length); -- cgit