svn commit: samba r12796 - in branches/SAMBA_4_0/source/wrepl_server: .

[metze at samba.org]

Author: metze
Date: 2006-01-09 17:03:17 +0000 (Mon, 09 Jan 2006)
New Revision: 12796

WebSVN: http://websvn.samba.org/cgi-bin/viewcvs.cgi?view=rev&root=samba&rev=12796

Log:
use the correct address as initiator

metze
Modified:
   branches/SAMBA_4_0/source/wrepl_server/wrepl_in_call.c
   branches/SAMBA_4_0/source/wrepl_server/wrepl_in_connection.c
   branches/SAMBA_4_0/source/wrepl_server/wrepl_out_helpers.c
   branches/SAMBA_4_0/source/wrepl_server/wrepl_server.h


Changeset:
Modified: branches/SAMBA_4_0/source/wrepl_server/wrepl_in_call.c
===================================================================
--- branches/SAMBA_4_0/source/wrepl_server/wrepl_in_call.c	2006-01-09 16:20:02 UTC (rev 12795)
+++ branches/SAMBA_4_0/source/wrepl_server/wrepl_in_call.c	2006-01-09 17:03:17 UTC (rev 12796)
@@ -109,12 +109,11 @@
 	struct wreplsrv_service *service = call->wreplconn->service;
 	struct wrepl_replication *repl_out = &call->rep_packet.message.replication;
 	struct wrepl_table *table_out = &call->rep_packet.message.replication.info.table;
-	const char *our_ip = call->wreplconn->our_ip;
 
 	repl_out->command = WREPL_REPL_TABLE_REPLY;
 
 	return wreplsrv_fill_wrepl_table(service, call, table_out,
-					 our_ip, True);
+					 service->wins_db->local_owner, True);
 }
 
 static int wreplsrv_in_sort_wins_name(struct wrepl_wins_name *n1,
@@ -126,7 +125,6 @@
 }
 
 static NTSTATUS wreplsrv_record2wins_name(TALLOC_CTX *mem_ctx,
-					  const char *our_address,
 					  struct wrepl_wins_name *name,
 					  struct winsdb_record *rec)
 {
@@ -264,7 +262,7 @@
 		status = winsdb_record(service->wins_db, res->msgs[i], call, &rec);
 		NT_STATUS_NOT_OK_RETURN(status);
 
-		status = wreplsrv_record2wins_name(names, call->wreplconn->our_ip, &names[i], rec);
+		status = wreplsrv_record2wins_name(names, &names[i], rec);
 		NT_STATUS_NOT_OK_RETURN(status);
 		talloc_free(rec);
 		talloc_free(res->msgs[i]);

Modified: branches/SAMBA_4_0/source/wrepl_server/wrepl_in_connection.c
===================================================================
--- branches/SAMBA_4_0/source/wrepl_server/wrepl_in_connection.c	2006-01-09 16:20:02 UTC (rev 12795)
+++ branches/SAMBA_4_0/source/wrepl_server/wrepl_in_connection.c	2006-01-09 17:03:17 UTC (rev 12796)
@@ -167,11 +167,6 @@
 
 	wreplconn->conn		= conn;
 	wreplconn->service	= service;
-	wreplconn->our_ip	= socket_get_my_addr(conn->socket, wreplconn);
-	if (!wreplconn->our_ip) {
-		wreplsrv_terminate_in_connection(wreplconn, "wreplsrv_accept: out of memory");
-		return;
-	}
 
 	peer_ip	= socket_get_peer_addr(conn->socket, wreplconn);
 	if (!peer_ip) {
@@ -221,8 +216,6 @@
 
 	wrepl_in->service	= service;
 	wrepl_in->partner	= partner;
-	wrepl_in->our_ip	= socket_get_my_addr(sock, wrepl_in);
-	NT_STATUS_HAVE_NO_MEMORY(wrepl_in->our_ip);
 
 	status = stream_new_connection_merge(service->task->event_ctx, model_ops,
 					     sock, &wreplsrv_stream_ops, service->task->msg_ctx,

Modified: branches/SAMBA_4_0/source/wrepl_server/wrepl_out_helpers.c
===================================================================
--- branches/SAMBA_4_0/source/wrepl_server/wrepl_out_helpers.c	2006-01-09 16:20:02 UTC (rev 12795)
+++ branches/SAMBA_4_0/source/wrepl_server/wrepl_out_helpers.c	2006-01-09 17:03:17 UTC (rev 12796)
@@ -27,6 +27,7 @@
 #include "smbd/service_stream.h"
 #include "librpc/gen_ndr/ndr_winsrepl.h"
 #include "wrepl_server/wrepl_server.h"
+#include "nbt_server/wins/winsdb.h"
 #include "libcli/composite/composite.h"
 #include "libcli/wrepl/winsrepl.h"
 
@@ -825,7 +826,6 @@
 	struct socket_context *sock;
 	struct packet_context *packet;
 	uint16_t fde_flags;
-	const char *our_ip;
 
 	/* prepare the outgoing request */
 	req->opcode	= WREPL_OPCODE_BITS;
@@ -834,11 +834,8 @@
 
 	repl_out->command = state->command;
 
-	our_ip = socket_get_my_addr(state->wreplconn->sock->sock, state);
-	NT_STATUS_HAVE_NO_MEMORY(our_ip);
-
 	status = wreplsrv_fill_wrepl_table(service, state, table_out,
-					   our_ip, state->full_table);
+					   service->wins_db->local_owner, state->full_table);
 	NT_STATUS_NOT_OK_RETURN(status);
 
 	/* queue the request */
@@ -911,7 +908,6 @@
 	struct wrepl_replication *repl_out = &state->req_packet.message.replication;
 	struct wrepl_table *table_out = &state->req_packet.message.replication.info.table;
 	NTSTATUS status;
-	const char *our_ip;
 
 	req->opcode	= WREPL_OPCODE_BITS;
 	req->assoc_ctx	= state->wreplconn->assoc_ctx.peer_ctx;
@@ -919,11 +915,8 @@
 
 	repl_out->command = state->command;
 
-	our_ip = socket_get_my_addr(state->wreplconn->sock->sock, state);
-	NT_STATUS_HAVE_NO_MEMORY(our_ip);
-
 	status = wreplsrv_fill_wrepl_table(service, state, table_out,
-					   our_ip, state->full_table);
+					   service->wins_db->local_owner, state->full_table);
 	NT_STATUS_NOT_OK_RETURN(status);
 
 	/* we won't get a reply to a inform message */

Modified: branches/SAMBA_4_0/source/wrepl_server/wrepl_server.h
===================================================================
--- branches/SAMBA_4_0/source/wrepl_server/wrepl_server.h	2006-01-09 16:20:02 UTC (rev 12795)
+++ branches/SAMBA_4_0/source/wrepl_server/wrepl_server.h	2006-01-09 17:03:17 UTC (rev 12796)
@@ -56,13 +56,6 @@
 	 */
 	struct wreplsrv_partner *partner;
 
-	/*
-	 * we need to take care of our own ip address,
-	 * as this is the WINS-Owner ID the peer expect
-	 * from us.
-	 */
-	const char *our_ip;
-
 	/* keep track of the assoc_ctx's */
 	struct {
 		BOOL stopped;