From cf647de6a1aa54bfbe0be1c43726d065b436ccac Mon Sep 17 00:00:00 2001
From: Luis Ontanon <luis.ontanon@gmail.com>
Date: Fri, 28 Jun 2013 21:10:52 +0000
Subject: MS: new child MS: ping child MS: set/get child parameter

svn path=/trunk/; revision=50218
---
 echld_test.c | 98 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 file changed, 91 insertions(+), 7 deletions(-)

(limited to 'echld_test.c')

diff --git a/echld_test.c b/echld_test.c
index 8218f80a3c..dd0a6407c3 100644
--- a/echld_test.c
+++ b/echld_test.c
@@ -68,22 +68,27 @@ void ping_cb(long usec, void* data _U_) {
 	}
 }
 
+int got_param = 0;
+
 void param_cb(const char* param, const char* value, const char* error, void* data _U_) {
 	if (error) {
 		fprintf(stderr, "Param Set Error msg=%s\n", error );
+		got_param = 0;
 		return;
 	}
 
+	got_param = 1;
 	fprintf(stderr, "Param: param='%s' val='%s'\n", param, value );
-
 }
 
 
 int main(int argc _U_, char** argv _U_) {
 	struct timeval tv;
 	int tot_cycles = 0;
-	int max_cycles = 20;
-	int npings = 2;
+	int max_cycles = 50;
+	int child = -1;
+	int keep_going = 1;
+
 	tv.tv_sec = 0;
 	tv.tv_usec = 250000;
 
@@ -92,15 +97,94 @@ int main(int argc _U_, char** argv _U_) {
 	echld_initialize(ECHLD_ENCODING_JSON,argv[0],main);
 
 	do {
-		if ( (tot_cycles > 2) && npings > 0 && npings-- ) echld_ping(0,ping_cb,NULL);
+		if ( tot_cycles == 2 ) echld_ping(0,ping_cb,NULL);
+
+		if ( tot_cycles == 4 ) {
+			if (pings!=1) {
+				fprintf(stderr, "No Dispatcher PONG 0\n");
+				break;
+			}
+			echld_ping(0,ping_cb,NULL);
+		}
+
+		if ( tot_cycles == 6 ) {
+			if (pings!=2) {
+				fprintf(stderr, "No Dispatcher PONG 1\n");
+				break;
+			}
+
+			echld_set_param(0,"dbg_level","5",param_cb,NULL);
+		}
+
+		if ( tot_cycles == 8) {
+			if (! got_param ) {
+				fprintf(stderr, "Set Dispatcher Param Failed\n");
+				break;
+			}
+
+			echld_get_param(0,"interfaces",param_cb,NULL);
+		}
+
+		if ( tot_cycles == 10) {
+			if (! got_param ) {
+				fprintf(stderr, "Set Dispatcher Param Failed\n");
+				break;
+			}
+
+			child = echld_new(NULL);
+			
+			fprintf(stderr, "New chld_id=%d\n",child);
+
+			if (child <= 0) {
+				fprintf(stderr, "No child\n");
+				break;
+			}
+		}
+
+
+		if ( tot_cycles == 16 ) echld_ping(child,ping_cb,NULL);
+
+		if ( tot_cycles == 18 ) {
+			if (pings!=3) {
+				fprintf(stderr, "No Child PONG 0\n");
+				break;
+			}
+			echld_ping(child,ping_cb,NULL);
+		}
+
+
+
+		if ( tot_cycles == 20 ) {
+			if (pings!=4) {
+				fprintf(stderr, "No Child PONG 1\n");
+				break;
+			}
+
+			echld_set_param(child,"cookie","hello-hello",param_cb,NULL);
+		}
+
+
+		if ( tot_cycles == 22 ) {
+			if (!got_param) {
+				fprintf(stderr, "Set Child Param Failed\n");
+				break;
+			}
+
+			echld_get_param(child,"dbg_level",param_cb,NULL);
+		}
 
-		if ( tot_cycles == 10) echld_set_param(0,"dbg_level","5",param_cb,NULL);
+		if ( tot_cycles == 24 ) {
+			if (!got_param) {
+				fprintf(stderr, "Get Child Param Failed\n");
+				break;
+			}
 
-		if ( tot_cycles == 12) echld_get_param(0,"interfaces",param_cb,NULL);
+			keep_going = 0;
+		}
 
 		tot_cycles++;
 		echld_wait(&tv);
-	} while( (pings < npings) || (tot_cycles < max_cycles));
+	} while( keep_going && (tot_cycles < max_cycles));
 
 	fprintf(stderr, "Done: pings=%d errors=%d tot_cycles=%d\n", pings, errors ,tot_cycles );
 
-- 
cgit v1.2.3