pgpool2.git / summary / log / commit / refs

commit    b7de4e7509747f1d0eea7a3c17dac4ca7d72724b
Author:   Yoshiyuki Asaba <y-asaba at pgfoundry.org>
Date:     Thu Jun 07 02:38:12 2007 +0000

    Fix handling nullmap (V2 only).


 pool_process_query.c | 21 ++++++++++++---------
 1 file changed, 12 insertions(+), 9 deletions(-)

diff --git a/pool_process_query.c b/pool_process_query.c
index 3963aa749..d21fd1963 100644
--- a/pool_process_query.c
+++ b/pool_process_query.c
@@ -1631,17 +1631,17 @@ static POOL_STATUS AsciiRow(POOL_CONNECTION *frontend,
 					buf = pool_read2(CONNECTION(backend, j), size);
 					if (buf == NULL)
 						return POOL_END;
+
+					if (IS_MASTER_NODE_ID(j))
+					{
+						pool_write(frontend, buf, size);
+						snprintf(msgbuf, Min(sizeof(msgbuf), size+1), "%s", buf);
+						pool_debug("AsciiRow: len: %d data: %s", size, msgbuf);
+					}
 				}
 			}
 		}
 
-		if (buf)
-		{
-			pool_write(frontend, buf, size);
-			snprintf(msgbuf, Min(sizeof(msgbuf), size+1), "%s", buf);
-			pool_debug("AsciiRow: len: %d data: %s", size, msgbuf);
-		}
-
 		mask >>= 1;
 	}
 	return POOL_CONTINUE;
@@ -1745,10 +1745,13 @@ static POOL_STATUS BinaryRow(POOL_CONNECTION *frontend,
 					buf = pool_read2(MASTER(backend), size);
 					if (buf == NULL)
 						return POOL_END;
+
+					if (IS_MASTER_NODE_ID(j))
+					{
+						pool_write(frontend, buf, size);
+					}
 				}
 			}
-			if (buf)
-				pool_write(frontend, buf, size);
 
 			mask >>= 1;
 		}


[parent: a6e05abcc480]