From 344dbced50dda7ad788b2e1908896ae926ae471a Mon Sep 17 00:00:00 2001
From: Volker Lendecke <vl@samba.org>
Date: Sun, 28 Jun 2009 15:29:38 +0200
Subject: [PATCH] If the connection is down, don't try another write.

---
 source3/include/tldap.h |  1 +
 source3/lib/tldap.c     | 17 +++++++++++++++++
 2 files changed, 18 insertions(+)

diff --git a/source3/include/tldap.h b/source3/include/tldap.h
index 1d920f8adce0..cd502985698e 100644
--- a/source3/include/tldap.h
+++ b/source3/include/tldap.h
@@ -48,6 +48,7 @@ struct tldap_mod {
 bool tevent_req_is_ldap_error(struct tevent_req *req, int *perr);
 
 struct tldap_context *tldap_context_create(TALLOC_CTX *mem_ctx, int fd);
+bool tldap_connection_ok(struct tldap_context *ld);
 bool tldap_context_setattr(struct tldap_context *ld,
 			   const char *name, const void *pptr);
 void *tldap_context_getattr(struct tldap_context *ld, const char *name);
diff --git a/source3/lib/tldap.c b/source3/lib/tldap.c
index cbd964800702..451bc18d2e7e 100644
--- a/source3/lib/tldap.c
+++ b/source3/lib/tldap.c
@@ -55,6 +55,7 @@ struct tldap_context {
 	int ld_sizelimit;
 	int ld_timelimit;
 	struct tstream_context *conn;
+	bool server_down;
 	int msgid;
 	struct tevent_queue *outgoing;
 	struct tevent_req **pending;
@@ -153,6 +154,14 @@ struct tldap_context *tldap_context_create(TALLOC_CTX *mem_ctx, int fd)
 	return ctx;
 }
 
+bool tldap_connection_ok(struct tldap_context *ld)
+{
+	if (ld == NULL) {
+		return false;
+	}
+	return !ld->server_down;
+}
+
 static struct tldap_ctx_attribute *tldap_context_findattr(
 	struct tldap_context *ld, const char *name)
 {
@@ -395,6 +404,11 @@ static struct tevent_req *tldap_msg_send(TALLOC_CTX *mem_ctx,
 	state->ev = ev;
 	state->id = id;
 
+	if (state->ld->server_down) {
+		tevent_req_error(req, TLDAP_SERVER_DOWN);
+		return tevent_req_post(req, ev);
+	}
+
 	tldap_push_controls(data, sctrls, num_sctrls);
 
 	asn1_pop_tag(data);
@@ -507,12 +521,15 @@ static void tldap_msg_sent(struct tevent_req *subreq)
 {
 	struct tevent_req *req = tevent_req_callback_data(
 		subreq, struct tevent_req);
+	struct tldap_msg_state *state = tevent_req_data(
+		req, struct tldap_msg_state);
 	ssize_t nwritten;
 	int err;
 
 	nwritten = tstream_writev_queue_recv(subreq, &err);
 	TALLOC_FREE(subreq);
 	if (nwritten == -1) {
+		state->ld->server_down = true;
 		tevent_req_error(req, TLDAP_SERVER_DOWN);
 		return;
 	}
-- 
2.34.1