From: erickson <erickson@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Fri, 4 Feb 2005 22:51:04 +0000 (+0000)
Subject: added child killing code
X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=38f6f64b41f381158556db27ba0411d31e8e351f;p=working%2FOpenSRF.git

added child killing code


git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@10 9efc2488-bf62-4759-914b-345cdb29e865
---

diff --git a/src/libtransport/basic_client.c b/src/libtransport/basic_client.c
index c41b8af..bf5ac0a 100644
--- a/src/libtransport/basic_client.c
+++ b/src/libtransport/basic_client.c
@@ -1,10 +1,11 @@
 #include "opensrf/transport_client.h"
+#include "signal.h"
 
-/**
-  * Simple jabber client
-  */
-
-
+pid_t pid;
+void sig_int( int sig ) {
+	fprintf(stderr, "Killing child %d\n", pid );
+	kill( pid, SIGKILL );
+}
 
 /* connects and registers with the router */
 int main( int argc, char** argv ) {
@@ -23,8 +24,9 @@ int main( int argc, char** argv ) {
 	 else  
 		fatal_handler( "NOT Connected...\n" ); 
 	
-	if( fork() ) {
+	if( (pid=fork()) ) { /* parent */
 
+		signal(SIGINT, sig_int);
 		fprintf(stderr, "Listener: %d\n", getpid() );	
 		char buf[300];
 		memset(buf, 0, 300);
@@ -46,6 +48,8 @@ int main( int argc, char** argv ) {
 			printf("\n=> ");
 			memset(buf, 0, 300);
 		}
+		fprintf(stderr, "Killing child %d\n", pid );
+		kill( pid, SIGKILL );
 		return 0;
 
 	} else {
@@ -56,7 +60,8 @@ int main( int argc, char** argv ) {
 		while( (recv=client_recv( client, -1)) ) {
 			if( recv->is_error )
 				fprintf( stderr, "\nReceived Error\t: ------------------\nFrom:\t\t"
-					"%s\nRouterFrom:\t%s\nBody:\t\t%s\nType %s\nCode %d\n=> ", recv->sender, recv->router_from, recv->body, recv->error_type, recv->error_code );
+					"%s\nRouterFrom:\t%s\nBody:\t\t%s\nType %s\nCode %d\n=> ", 
+					recv->sender, recv->router_from, recv->body, recv->error_type, recv->error_code );
 			else
 				fprintf( stderr, "\nReceived\t: ------------------\nFrom:\t\t"
 					"%s\nRouterFrom:\t%s\nBody:\t\t%s\n=> ", recv->sender, recv->router_from, recv->body );