From dc706ef662bda4a843aa088696132078472400d5 Mon Sep 17 00:00:00 2001
From: ihm
Date: Thu, 5 Mar 1998 17:31:32 +0000
Subject: Initial revision

---
 testbus.c | 184 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 184 insertions(+)
 create mode 100644 testbus.c

(limited to 'testbus.c')

diff --git a/testbus.c b/testbus.c
new file mode 100644
index 0000000..a2b3323
--- /dev/null
+++ b/testbus.c
@@ -0,0 +1,184 @@
+#include <stdio.h>
+#include <sys/time.h>
+#include <unistd.h>
+#include "socket.h"
+#include "bus.h"
+#include "timer.h"
+#ifdef XTMAINLOOP
+#include <X11/Intrinsic.h>
+#endif
+
+int app_count = 0;
+int wait_count = 0;
+
+void Callback( BusClientPtr app, void *user_data, int argc, char *argv[])
+{
+	int i;
+	printf(" %s Called function %d args:",GetApplicationName(app),argc);
+	for ( i = 0; i < argc; i++ )
+			printf(" '%s'",argv[i]);
+	printf("\n");
+}
+void HandleStdin( Channel channel, int fd, void *data)
+{
+	char buf[4096];
+	char *line;
+	char *cmd;
+	char *arg;
+	int id;
+	BusClientPtr app;
+	int err;
+	line = gets( buf);
+	if ( !line )
+		{
+		ChannelClose( channel );
+		ChannelStop();
+		return;
+		}
+	if ( *line == '.' )
+	{
+		cmd = strtok( line, ".: ");
+		if ( strcmp(cmd, "die" ) == 0 )
+			{
+			arg = strtok( NULL, " " );
+			if ( arg )
+				{
+				app = GetApplication( arg );
+				if ( app )
+					SendDieMsg( app );
+					else printf( "No Application %s!!!\n",arg);
+				}
+			}
+		if ( strcmp(cmd,  "bind" ) == 0 )
+			{
+			arg = strtok( NULL, "'" );
+			if ( arg )
+				{
+				BindMsg( Callback, NULL, arg );
+				}
+			}
+		if ( strcmp(cmd,  "where" ) == 0 )
+			{
+			arg = strtok( NULL, " " );
+			if ( arg )
+				{
+				app = GetApplication( arg );
+				if ( app )
+					printf( "Application %s on %s\n",arg, GetApplicationHost( app ));
+					else printf( "No Application %s!!!\n",arg);
+				}
+			}
+		if ( strcmp(cmd, "direct" ) == 0 )
+			{
+			arg = strtok( NULL, " " );
+			if ( arg )
+				{
+				app = GetApplication( arg );
+				if ( app )
+					{
+					arg = strtok( NULL, " " );
+					id = atoi( arg ) ;
+					arg = strtok( NULL, "'" );
+					SendDirectMsg( app, id, arg );
+					}
+				else printf( "No Application %s!!!\n",arg);
+				}
+			
+			}
+		if ( strcmp(cmd, "who") == 0 )
+			{
+			printf("Apps: %s\n", GetApplicationList());
+			}
+		if ( strcmp(cmd, "help") == 0 )
+			{
+			printf("Commands list:\n");
+			printf("	.help					 - this help\n");
+			printf("	.quit					 - terminate this application\n");
+			printf("	.die appname			 - send die msg to appname\n");
+			printf("	.direct appname	id 'arg' - send direct msg to appname\n");
+			printf("	.where appname			 - on which host is appname\n");
+			printf("	.bind 'regexp'			 - add a msg to receive\n");
+			printf("	.who					 - who is on the bus\n");
+			}
+		if ( strcmp(cmd, "quit") == 0 )
+			{
+			exit(0);
+			}
+	}
+	else 
+	{
+	err = SendMsg( buf );
+	printf("Sent:%d\n",err);
+	}
+}
+
+void ApplicationCallback( BusClientPtr app, void *user_data, BusApplicationEvent event)
+{
+	char *appname;
+	char *host;
+	appname = GetApplicationName( app );
+	host = GetApplicationHost( app );
+	switch ( event )  {
+	case BusApplicationConnected:
+		app_count++;
+		printf("Application(%d): %s ready on %s\n",app_count, appname, host);
+		if ( app_count == wait_count )
+			ChannelSetUp( 0, NULL, NULL, HandleStdin);
+		break;
+	case BusApplicationDisconnected:
+		app_count--;
+		printf("Application(%d): %s bye on %s\n",app_count, appname, host);
+		break;
+	default:
+		printf("Application(%d): %s unkown event %d\n", app_count, appname, event);
+		break;
+	}
+
+}
+void TimerCall(TimerId id, void *user_data, unsigned long delta)
+{
+	printf("Timer callback: %d delta %lu ms\n", (int)user_data, delta );
+	SendMsg( "TEST TIMER %d", (int)user_data);
+	/*if ( (int)user_data == 5 ) TimerModify( id, 2000 );*/
+}
+int main(int argc, char *argv[])
+{
+	
+	unsigned short bport = DEFAULT_BUS;
+	int c;
+	int timer_test = 0;
+	while ((c = getopt(argc, argv, "b:w:t")) != EOF)
+			switch (c)
+					{
+					case 'b':
+							bport = atoi(optarg) ;
+							break;
+					case 'w':
+							wait_count = atoi(optarg) ;
+							break;
+					case 't':
+							timer_test = 1;
+							break;
+					}
+#ifdef XTMAINLOOP
+	XtToolkitInitialize();
+
+#endif
+	BusInit("TEST",bport,"TEST READY",ApplicationCallback,NULL,NULL,NULL);
+	for ( ; optind < argc; optind++ )
+			BindMsg( Callback, NULL, argv[optind] );
+	if ( wait_count == 0 )
+		ChannelSetUp( 0, NULL, NULL, HandleStdin);
+	BusStart( );
+	if ( timer_test )
+		{
+		TimerRepeatAfter( TIMER_LOOP, 1000, TimerCall, (void*)1 );
+		TimerRepeatAfter( 5, 5000, TimerCall, (void*)5 );
+		}
+#ifdef XTMAINLOOP
+	XtMainLoop();
+#else
+	BusLoop();
+#endif
+	return 0;
+}
-- 
cgit v1.1