From: Marko Kreen <markokr@gmail.com>
Date: Wed, 6 Aug 2008 06:31:42 +0000 (+0000)
Subject: asynctest: check if result comes back ok
X-Git-Tag: pgbouncer_1_2_2~3
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=e236c589c0c53b15312593a4a7ab95f05e9456a7;p=pgbouncer

asynctest: check if result comes back ok
---

diff --git a/test/asynctest.c b/test/asynctest.c
index 79545a2..c2e8cc7 100644
--- a/test/asynctest.c
+++ b/test/asynctest.c
@@ -30,6 +30,7 @@ typedef struct DbConn {
 	//time_t		connect_time;
 	int	query_count;
 	//const char	*query;
+	int _arglen;
 } DbConn;
 
 #define QT_SIMPLE  1
@@ -42,7 +43,7 @@ static uint64_t SqlErrorCount = 0;
 static uint64_t QueryCount = 0;
 
 static char *bulk_data;
-static int bulk_data_max = 4*1024;  /* power of 2 */
+static int bulk_data_max = 128*1024;  /* power of 2 */
 static int verbose = 0;
 static int throttle_connects = 0;
 static int throttle_queries = 0;
@@ -185,7 +186,7 @@ static void conn_error(DbConn *db, const char *desc)
 	static int ecount = 0;
 	if (db->con) {
 		if (ecount++ < 3)
-			printf("\r%s\n", PQerrorMessage(db->con));
+			printf("\r%s (arglen=%d)\n", PQerrorMessage(db->con), db->_arglen);
 		disconnect(db, true, "%s: %s", desc, PQerrorMessage(db->con));
 	} else {
 		printf("random error: %s\n", desc);
@@ -214,6 +215,13 @@ static bool another_result(DbConn *db)
 	switch (PQresultStatus(res)) {
 	case PGRES_TUPLES_OK:
 		// todo: check result
+		if (db->_arglen > 0) {
+			int curlen = strlen(PQgetvalue(res, 0, 0));
+			if (curlen != db->_arglen) {
+				printf("result does not match: sent=%d got=%d\n",
+				       db->_arglen, curlen);
+			}
+		}
 	case PGRES_COMMAND_OK:
 		PQclear(res);
 		break;
@@ -277,7 +285,9 @@ static int send_query_bigdata(DbConn *db)
 	int arglen;
 	char *q = "select $1::text";
 
-	arglen = random() & (bulk_data_max - 1);
+	arglen = 30458; // one of the values that breaks
+	arglen = random() % bulk_data_max;
+	db->_arglen = arglen;
 	values[0] = bulk_data + bulk_data_max - arglen;
 	lengths[0] = arglen;
 	fmts[0] = 1;