s3: get_pipe_name_from_iface -> get_pipe_name_from_syntax

3 files changed, 66 insertions, 41 deletions

diff --git a/source3/rpc_server/srv_lsa_hnd.c b/source3/rpc_server/srv_lsa_hnd.c
index 94e73fb54d..695164679f 100644
--- a/source3/rpc_server/srv_lsa_hnd.c
+++ b/source3/rpc_server/srv_lsa_hnd.c
@@ -110,7 +110,8 @@ bool init_pipe_handle_list(pipes_struct *p, const struct ndr_syntax_id *syntax)
 		ZERO_STRUCTP(hl);
 
 		DEBUG(10,("init_pipe_handles: created handle list for "
-			  "pipe %s\n", get_pipe_name_from_iface(syntax)));
+			  "pipe %s\n",
+			  get_pipe_name_from_syntax(talloc_tos(), syntax)));
 	}
 
 	/*
@@ -127,7 +128,7 @@ bool init_pipe_handle_list(pipes_struct *p, const struct ndr_syntax_id *syntax)
 
 	DEBUG(10,("init_pipe_handles: pipe_handles ref count = %lu for pipe %s\n",
 		  (unsigned long)p->pipe_handles->pipe_ref_count,
-		  get_pipe_name_from_iface(syntax)));
+		  get_pipe_name_from_syntax(talloc_tos(), syntax)));
 
 	return True;
 }
@@ -285,7 +286,8 @@ void close_policy_by_pipe(pipes_struct *p)
 
 		SAFE_FREE(p->pipe_handles);
 		DEBUG(10,("close_policy_by_pipe: deleted handle list for "
-			  "pipe %s\n", get_pipe_name_from_iface(&p->syntax)));
+			  "pipe %s\n",
+			  get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 	}
 }
 
@@ -327,7 +329,7 @@ void *_policy_handle_create(struct pipes_struct *p, struct policy_handle *hnd,
 	if (p->pipe_handles->count > MAX_OPEN_POLS) {
 		DEBUG(0, ("policy_handle_create: ERROR: too many handles (%d) "
 			  "on pipe %s.\n", (int)p->pipe_handles->count,
-			  get_pipe_name_from_iface(&p->syntax)));
+			  get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 		*pstatus = NT_STATUS_INSUFFICIENT_RESOURCES;
 		return NULL;
 	}
diff --git a/source3/rpc_server/srv_pipe.c b/source3/rpc_server/srv_pipe.c
index a246b6db50..90eb4f96c3 100644
--- a/source3/rpc_server/srv_pipe.c
+++ b/source3/rpc_server/srv_pipe.c
@@ -647,7 +647,7 @@ static bool pipe_ntlmssp_verify_final(pipes_struct *p, DATA_BLOB *p_resp_blob)
 	bool ret;
 
 	DEBUG(5,("pipe_ntlmssp_verify_final: pipe %s checking user details\n",
-		 get_pipe_name_from_iface(&p->syntax)));
+		 get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 
 	ZERO_STRUCT(reply);
 
@@ -671,7 +671,8 @@ static bool pipe_ntlmssp_verify_final(pipes_struct *p, DATA_BLOB *p_resp_blob)
 		if (!(a->ntlmssp_state->neg_flags & NTLMSSP_NEGOTIATE_SIGN)) {
 			DEBUG(0,("pipe_ntlmssp_verify_final: pipe %s : packet integrity requested "
 				"but client declined signing.\n",
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			return False;
 		}
 	}
@@ -679,7 +680,8 @@ static bool pipe_ntlmssp_verify_final(pipes_struct *p, DATA_BLOB *p_resp_blob)
 		if (!(a->ntlmssp_state->neg_flags & NTLMSSP_NEGOTIATE_SEAL)) {
 			DEBUG(0,("pipe_ntlmssp_verify_final: pipe %s : packet privacy requested "
 				"but client declined sealing.\n",
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			return False;
 		}
 	}
@@ -995,7 +997,7 @@ static bool check_bind_req(struct pipes_struct *p,
 	struct pipe_rpc_fns *context_fns;
 
 	DEBUG(3,("check_bind_req for %s\n",
-		 get_pipe_name_from_iface(&p->syntax)));
+		 get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 
 	/* we have to check all now since win2k introduced a new UUID on the lsaprpc pipe */
 
@@ -1607,7 +1609,8 @@ bool api_pipe_bind_req(pipes_struct *p, prs_struct *rpc_in_p)
 	/* No rebinds on a bound pipe - use alter context. */
 	if (p->pipe_bound) {
 		DEBUG(2,("api_pipe_bind_req: rejecting bind request on bound "
-			 "pipe %s.\n", get_pipe_name_from_iface(&p->syntax)));
+			 "pipe %s.\n",
+			 get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 		return setup_bind_nak(p);
 	}
 
@@ -1672,12 +1675,15 @@ bool api_pipe_bind_req(pipes_struct *p, prs_struct *rpc_in_p)
 		NTSTATUS status;
 
 		status = smb_probe_module(
-			"rpc", get_pipe_name_from_iface(
+			"rpc", get_pipe_name_from_syntax(
+				talloc_tos(),
 				&hdr_rb.rpc_context[0].abstract));
 
 		if (NT_STATUS_IS_ERR(status)) {
                        DEBUG(3,("api_pipe_bind_req: Unknown pipe name %s in bind request.\n",
-                                get_pipe_name_from_iface(&hdr_rb.rpc_context[0].abstract)));
+                                get_pipe_name_from_syntax(
+					talloc_tos(),
+					&hdr_rb.rpc_context[0].abstract)));
 			prs_mem_free(&p->out_data.frag);
 			prs_mem_free(&out_hdr_ba);
 			prs_mem_free(&out_auth);
@@ -1687,7 +1693,8 @@ bool api_pipe_bind_req(pipes_struct *p, prs_struct *rpc_in_p)
 
                 for (i = 0; i < rpc_lookup_size; i++) {
                        if (strequal(rpc_lookup[i].pipe.clnt,
-				    get_pipe_name_from_iface(&p->syntax))) {
+				    get_pipe_name_from_syntax(talloc_tos(),
+							      &p->syntax))) {
                                DEBUG(3, ("api_pipe_bind_req: \\PIPE\\%s -> \\PIPE\\%s\n",
                                          rpc_lookup[i].pipe.clnt, rpc_lookup[i].pipe.srv));
                                break;
@@ -1697,8 +1704,10 @@ bool api_pipe_bind_req(pipes_struct *p, prs_struct *rpc_in_p)
 		if (i == rpc_lookup_size) {
 			DEBUG(0, ("module %s doesn't provide functions for "
 				  "pipe %s!\n",
-				  get_pipe_name_from_iface(&p->syntax),
-				  get_pipe_name_from_iface(&p->syntax)));
+				  get_pipe_name_from_syntax(talloc_tos(),
+							    &p->syntax),
+				  get_pipe_name_from_syntax(talloc_tos(),
+							    &p->syntax)));
 			goto err_exit;
 		}
 	}
@@ -2356,7 +2365,7 @@ bool api_pipe_request(pipes_struct *p)
 	}
 
 	DEBUG(5, ("Requested \\PIPE\\%s\n",
-		  get_pipe_name_from_iface(&p->syntax)));
+		  get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 
 	/* get the set of RPC functions for this context */
 
@@ -2370,7 +2379,7 @@ bool api_pipe_request(pipes_struct *p)
 	else {
 		DEBUG(0,("api_pipe_request: No rpc function table associated with context [%d] on pipe [%s]\n",
 			p->hdr_req.context_id,
-			get_pipe_name_from_iface(&p->syntax)));
+			 get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 	}
 
 	if (changed_user) {
@@ -2392,12 +2401,13 @@ static bool api_rpcTNP(pipes_struct *p,
 
 	/* interpret the command */
 	DEBUG(4,("api_rpcTNP: %s op 0x%x - ",
-		 get_pipe_name_from_iface(&p->syntax), p->hdr_req.opnum));
+		 get_pipe_name_from_syntax(talloc_tos(), &p->syntax),
+		 p->hdr_req.opnum));
 
 	if (DEBUGLEVEL >= 50) {
 		fstring name;
 		slprintf(name, sizeof(name)-1, "in_%s",
-			 get_pipe_name_from_iface(&p->syntax));
+			 get_pipe_name_from_syntax(talloc_tos(), &p->syntax));
 		prs_dump(name, p->hdr_req.opnum, &p->in_data.data);
 	}
 
@@ -2426,7 +2436,7 @@ static bool api_rpcTNP(pipes_struct *p,
 	/* do the actual command */
 	if(!api_rpc_cmds[fn_num].fn(p)) {
 		DEBUG(0,("api_rpcTNP: %s: %s failed.\n",
-			 get_pipe_name_from_iface(&p->syntax),
+			 get_pipe_name_from_syntax(talloc_tos(), &p->syntax),
 			 api_rpc_cmds[fn_num].name));
 		prs_mem_free(&p->out_data.rdata);
 		return False;
@@ -2451,13 +2461,13 @@ static bool api_rpcTNP(pipes_struct *p,
 	if (DEBUGLEVEL >= 50) {
 		fstring name;
 		slprintf(name, sizeof(name)-1, "out_%s",
-			 get_pipe_name_from_iface(&p->syntax));
+			 get_pipe_name_from_syntax(talloc_tos(), &p->syntax));
 		prs_dump(name, p->hdr_req.opnum, &p->out_data.rdata);
 	}
 	prs_set_offset(&p->out_data.rdata, offset2);
 
 	DEBUG(5,("api_rpcTNP: called %s successfully\n",
-		 get_pipe_name_from_iface(&p->syntax)));
+		 get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 
 	/* Check for buffer underflow in rpc parsing */
 
diff --git a/source3/rpc_server/srv_pipe_hnd.c b/source3/rpc_server/srv_pipe_hnd.c
index 0c858c203e..5d5eb0eeb1 100644
--- a/source3/rpc_server/srv_pipe_hnd.c
+++ b/source3/rpc_server/srv_pipe_hnd.c
@@ -96,7 +96,7 @@ static struct pipes_struct *make_internal_rpc_pipe_p(TALLOC_CTX *mem_ctx,
 	pipes_struct *p;
 
 	DEBUG(4,("Create pipe requested %s\n",
-		 get_pipe_name_from_iface(syntax)));
+		 get_pipe_name_from_syntax(talloc_tos(), syntax)));
 
 	p = TALLOC_ZERO_P(mem_ctx, struct pipes_struct);
 
@@ -105,9 +105,10 @@ static struct pipes_struct *make_internal_rpc_pipe_p(TALLOC_CTX *mem_ctx,
 		return NULL;
 	}
 
-	if ((p->mem_ctx = talloc_init("pipe %s %p",
-				      get_pipe_name_from_iface(syntax),
-				      p)) == NULL) {
+	p->mem_ctx = talloc_init("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;
@@ -158,7 +159,7 @@ static struct pipes_struct *make_internal_rpc_pipe_p(TALLOC_CTX *mem_ctx,
 	p->syntax = *syntax;
 
 	DEBUG(4,("Created internal pipe %s (pipes_open=%d)\n",
-		 get_pipe_name_from_iface(syntax), pipes_open));
+		 get_pipe_name_from_syntax(talloc_tos(), syntax), pipes_open));
 
 	talloc_set_destructor(p, close_internal_rpc_pipe_hnd);
 
@@ -176,7 +177,7 @@ static void set_incoming_fault(pipes_struct *p)
 	p->in_data.pdu_received_len = 0;
 	p->fault_state = True;
 	DEBUG(10, ("set_incoming_fault: Setting fault state on pipe %s\n",
-		   get_pipe_name_from_iface(&p->syntax)));
+		   get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 }
 
 /****************************************************************************
@@ -344,7 +345,9 @@ static void free_pipe_context(pipes_struct *p)
 		talloc_free_children(p->mem_ctx);
 	} else {
 		p->mem_ctx = talloc_init(
-			"pipe %s %p", get_pipe_name_from_iface(&p->syntax), p);
+			"pipe %s %p", get_pipe_name_from_syntax(talloc_tos(),
+								&p->syntax),
+			p);
 		if (p->mem_ctx == NULL) {
 			p->fault_state = True;
 		}
@@ -512,7 +515,7 @@ static void process_complete_pdu(pipes_struct *p)
 
 	if(p->fault_state) {
 		DEBUG(10,("process_complete_pdu: pipe %s in fault state.\n",
-			 get_pipe_name_from_iface(&p->syntax)));
+			  get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 		set_incoming_fault(p);
 		setup_fault_pdu(p, NT_STATUS(DCERPC_FAULT_OP_RNG_ERROR));
 		return;
@@ -541,12 +544,14 @@ static void process_complete_pdu(pipes_struct *p)
 		case DCERPC_PKT_PING: /* CL request - ignore... */
 			DEBUG(0,("process_complete_pdu: Error. Connectionless packet type %u received on pipe %s.\n",
 				(unsigned int)p->hdr.pkt_type,
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			break;
 
 		case DCERPC_PKT_RESPONSE: /* No responses here. */
 			DEBUG(0,("process_complete_pdu: Error. DCERPC_PKT_RESPONSE received from client on pipe %s.\n",
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			break;
 
 		case DCERPC_PKT_FAULT:
@@ -559,7 +564,8 @@ static void process_complete_pdu(pipes_struct *p)
 		case DCERPC_PKT_CANCEL_ACK:
 			DEBUG(0,("process_complete_pdu: Error. Connectionless packet type %u received on pipe %s.\n",
 				(unsigned int)p->hdr.pkt_type,
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			break;
 
 		case DCERPC_PKT_BIND:
@@ -575,7 +581,8 @@ static void process_complete_pdu(pipes_struct *p)
 		case DCERPC_PKT_BIND_NAK:
 			DEBUG(0,("process_complete_pdu: Error. DCERPC_PKT_BINDACK/DCERPC_PKT_BINDNACK packet type %u received on pipe %s.\n",
 				(unsigned int)p->hdr.pkt_type,
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			break;
 
 
@@ -590,7 +597,8 @@ static void process_complete_pdu(pipes_struct *p)
 
 		case DCERPC_PKT_ALTER_RESP:
 			DEBUG(0,("process_complete_pdu: Error. DCERPC_PKT_ALTER_RESP on pipe %s: Should only be server -> client.\n",
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			break;
 
 		case DCERPC_PKT_AUTH3:
@@ -604,7 +612,8 @@ static void process_complete_pdu(pipes_struct *p)
 
 		case DCERPC_PKT_SHUTDOWN:
 			DEBUG(0,("process_complete_pdu: Error. DCERPC_PKT_SHUTDOWN on pipe %s: Should only be server -> client.\n",
-				get_pipe_name_from_iface(&p->syntax)));
+				 get_pipe_name_from_syntax(talloc_tos(),
+							   &p->syntax)));
 			break;
 
 		case DCERPC_PKT_CO_CANCEL:
@@ -643,7 +652,8 @@ static void process_complete_pdu(pipes_struct *p)
 
 	if (!reply) {
 		DEBUG(3,("process_complete_pdu: DCE/RPC fault sent on "
-			 "pipe %s\n", get_pipe_name_from_iface(&p->syntax)));
+			 "pipe %s\n", get_pipe_name_from_syntax(talloc_tos(),
+								&p->syntax)));
 		set_incoming_fault(p);
 		setup_fault_pdu(p, NT_STATUS(DCERPC_FAULT_OP_RNG_ERROR));
 		prs_mem_free(&rpc_in);
@@ -798,7 +808,8 @@ static ssize_t read_from_internal_pipe(struct pipes_struct *p, char *data, size_
 		return -1;		
 	}
 
-	DEBUG(6,(" name: %s len: %u\n", get_pipe_name_from_iface(&p->syntax),
+	DEBUG(6,(" name: %s len: %u\n",
+		 get_pipe_name_from_syntax(talloc_tos(), &p->syntax),
 		 (unsigned int)n));
 
 	/*
@@ -815,7 +826,8 @@ static ssize_t read_from_internal_pipe(struct pipes_struct *p, char *data, size_
 	if(n > RPC_MAX_PDU_FRAG_LEN) {
                 DEBUG(5,("read_from_pipe: too large read (%u) requested on "
 			 "pipe %s. We can only service %d sized reads.\n",
-			 (unsigned int)n, get_pipe_name_from_iface(&p->syntax),
+			 (unsigned int)n,
+			 get_pipe_name_from_syntax(talloc_tos(), &p->syntax),
 			 RPC_MAX_PDU_FRAG_LEN ));
 		n = RPC_MAX_PDU_FRAG_LEN;
 	}
@@ -836,7 +848,7 @@ static ssize_t read_from_internal_pipe(struct pipes_struct *p, char *data, size_
 
 		DEBUG(10,("read_from_pipe: %s: current_pdu_len = %u, "
 			  "current_pdu_sent = %u returning %d bytes.\n",
-			  get_pipe_name_from_iface(&p->syntax),
+			  get_pipe_name_from_syntax(talloc_tos(), &p->syntax),
 			  (unsigned int)prs_offset(&p->out_data.frag),
 			  (unsigned int)p->out_data.current_pdu_sent,
 			  (int)data_returned));
@@ -857,7 +869,8 @@ static ssize_t read_from_internal_pipe(struct pipes_struct *p, char *data, size_
 
 	DEBUG(10,("read_from_pipe: %s: fault_state = %d : data_sent_length "
 		  "= %u, prs_offset(&p->out_data.rdata) = %u.\n",
-		  get_pipe_name_from_iface(&p->syntax), (int)p->fault_state,
+		  get_pipe_name_from_syntax(talloc_tos(), &p->syntax),
+		  (int)p->fault_state,
 		  (unsigned int)p->out_data.data_sent_length,
 		  (unsigned int)prs_offset(&p->out_data.rdata) ));
 
@@ -878,7 +891,7 @@ static ssize_t read_from_internal_pipe(struct pipes_struct *p, char *data, size_
 
 	if(!create_next_pdu(p)) {
 		DEBUG(0,("read_from_pipe: %s: create_next_pdu failed.\n",
-			 get_pipe_name_from_iface(&p->syntax)));
+			 get_pipe_name_from_syntax(talloc_tos(), &p->syntax)));
 		return -1;
 	}