From d1ba047b7f8748ffa22bdbea29e4515e8be97d8b Mon Sep 17 00:00:00 2001
From: Ronnie Sahlberg <sahlberg@ronnie>
Date: Fri, 19 Oct 2007 08:58:30 +1000
Subject: add a new transport method so that when a node is marked as dead, we
 shut down and restart the transport

othervise, if we use the tcp transport the tcp connection might try to
retransmit the queued data during the time the node is unavailable.
this together with the exponential backoff for tcp means that the tcp
connection quickly reaches the maximum backoff rto which is often 60 or
120 seconds.   this would mean that it could take up to 60/120 seconds
before the tcp layer detects that the connection is dead and it has to
be reestablished.

(This used to be ctdb commit 0256db470879ce556b0f00070f7ebeaf37e529ab)
---
 ctdb/tcp/tcp_init.c | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

(limited to 'ctdb/tcp')

diff --git a/ctdb/tcp/tcp_init.c b/ctdb/tcp/tcp_init.c
index f5d4e4c1d6b..98a4c493f2e 100644
--- a/ctdb/tcp/tcp_init.c
+++ b/ctdb/tcp/tcp_init.c
@@ -88,6 +88,28 @@ static int ctdb_tcp_start(struct ctdb_context *ctdb)
 	return 0;
 }
 
+/*
+  shutdown and try to restart a connection to a node after it has been
+  disconnected
+*/
+static void ctdb_tcp_restart(struct ctdb_node *node)
+{
+	struct ctdb_tcp_node *tnode = talloc_get_type(
+		node->private_data, struct ctdb_tcp_node);
+
+	DEBUG(0,("Tearing down connection to dead node :%d\n", node->pnn));
+
+	if (tnode->fd == -1) {
+		close(tnode->fd);
+		tnode->fd = -1;
+	}
+
+	ctdb_queue_set_fd(tnode->out_queue, -1);
+
+	event_add_timed(node->ctdb->ev, tnode, timeval_zero(), 
+			ctdb_tcp_node_connect, node);
+}
+
 
 /*
   shutdown the transport
@@ -121,6 +143,7 @@ static const struct ctdb_methods ctdb_tcp_methods = {
 	.add_node     = ctdb_tcp_add_node,
 	.allocate_pkt = ctdb_tcp_allocate_pkt,
 	.shutdown     = ctdb_tcp_shutdown,
+	.restart      = ctdb_tcp_restart,
 };
 
 /*
-- 
cgit