From: Yoshiyuki Asaba <y-asaba at pgfoundry.org>
Date: Tue, 15 May 2007 02:32:28 +0000 (+0000)
Subject: Delay buffer flush in SimpleForwardToBackend().
X-Git-Tag: V3_3~15
X-Git-Url: http://git.postgresql.org/gitweb/?a=commitdiff_plain;h=610d42b4a522ea9e0af9946a66eedf998affdb13;p=pgpool1.git

Delay buffer flush in SimpleForwardToBackend().
---

diff --git a/pool_process_query.c b/pool_process_query.c
index 15d7b5a..ea0be17 100644
--- a/pool_process_query.c
+++ b/pool_process_query.c
@@ -2743,10 +2743,10 @@ POOL_STATUS SimpleForwardToBackend(char kind, POOL_CONNECTION *frontend, POOL_CO
 	if (p == NULL)
 		return POOL_END;
 
-	if (pool_write_and_flush(MASTER(backend), p, len))
+	if (pool_write(MASTER(backend), p, len))
 		return POOL_END;
 	if (REPLICATION)
-		if (pool_write_and_flush(SECONDARY(backend), p, len))
+		if (pool_write(SECONDARY(backend), p, len))
 			return POOL_END;
 
 	if (kind == 'P') /* Parse message? */
@@ -2895,6 +2895,15 @@ POOL_STATUS SimpleForwardToBackend(char kind, POOL_CONNECTION *frontend, POOL_CO
 		SimpleForwardToFrontend(kind1, frontend, backend);
 		return pool_flush(frontend);
 	}
+	else
+	{
+		if (pool_flush(MASTER(backend)))
+			return POOL_END;
+
+		if (REPLICATION)
+			if (pool_flush(SECONDARY(backend)))
+				return POOL_END;
+	}
 
 	return POOL_CONTINUE;
 }