/* * Ivy probe * * Copyright (C) 1997-2000 * Centre d'Études de la Navigation Aérienne * * Main and only file * * Authors: François-Régis Colin * * $Id$ * * Please refer to file version.h for the * copyright notice regarding this software */ #define IVYMAINLOOP #ifdef XTMAINLOOP #undef IVYMAINLOOP #endif #ifdef GTKMAINLOOP #undef IVYMAINLOOP #endif #ifdef GLUTMAINLOOP #undef IVYMAINLOOP #endif #include #include #include #ifdef WIN32 #include #ifdef __MINGW32__ #include #include #endif #else #include #include #ifdef __INTERIX extern char *optarg; extern int optind; #endif #include #endif #ifdef XTMAINLOOP #include "ivyxtloop.h" #endif #ifdef GTKMAINLOOP #include "ivygtkloop.h" #endif #ifdef GLUTMAINLOOP #include "ivyglutloop.h" #endif #ifdef IVYMAINLOOP #include "ivyloop.h" #endif #include "ivysocket.h" #include "ivy.h" #include "timer.h" #ifdef XTMAINLOOP #include XtAppContext cntx; #endif int app_count = 0; int wait_count = 0; void DirectCallback(IvyClientPtr app, void *user_data, int id, char *msg ) { printf("%s sent a direct message, id=%d, message=%s\n", IvyGetApplicationName(app),id,msg); } void Callback (IvyClientPtr app, void *user_data, int argc, char *argv[]) { int i; printf ("%s sent ",IvyGetApplicationName(app)); for (i = 0; i < argc; i++) printf(" '%s'",argv[i]); printf("\n"); } char * Chop(char *arg) { int len; if (arg==NULL) return arg; len=strlen(arg)-1; if ((*(arg+len))=='\n') *(arg+len)=0; return arg; } void HandleStdin (Channel channel, HANDLE fd, void *data) { char buf[4096]; char *line; char *cmd; char *arg; int id; IvyClientPtr app; int err; line = fgets(buf, 4096, stdin); if (!line) { #ifdef XTMAINLOOP IvyXtChannelClose (channel); #endif #ifdef GTKMAINLOOP IvyGtkChannelClose(channel); #endif #ifdef GLUTMAINLOOP IvyGlutChannelClose(channel); #endif #ifdef IVYMAINLOOP IvyChannelClose (channel); IvyStop(); #endif return; } if (*line == '.') { cmd = strtok (line, ".: \n"); if (strcmp (cmd, "die") == 0) { arg = strtok (NULL, " \n"); if (arg) { app = IvyGetApplication (arg); if (app) IvySendDieMsg (app); else printf ("No Application %s!!!\n",arg); } } else if (strcmp(cmd, "dieall-yes-i-am-sure") == 0) { arg = IvyGetApplicationList(); arg = strtok (arg, " \n"); while (arg) { app = IvyGetApplication (arg); if (app) IvySendDieMsg (app); else printf ("No Application %s!!!\n",arg); arg = strtok (NULL, " "); } } else if (strcmp(cmd, "bind") == 0) { arg = strtok (NULL, "'"); if (arg) { regex_t reg; int err; Chop(arg); if (err=regcomp(®,arg,REG_ICASE|REG_EXTENDED)!=0) { char errbuf[4096]; regerror (err, ®, errbuf, 4096); printf("Error compiling '%s', %s, not bound\n", arg, errbuf); } else { IvyBindMsg (Callback, NULL, Chop(arg)); } } } else if (strcmp(cmd, "where") == 0) { arg = strtok (NULL, " \n"); if (arg) { app = IvyGetApplication (arg); if (app) printf ("Application %s on %s\n",arg, IvyGetApplicationHost (app)); else printf ("No Application %s!!!\n",arg); } } else if (strcmp(cmd, "direct") == 0) { arg = strtok (NULL, " \n"); if (arg) { app = IvyGetApplication (arg); if (app) { arg = strtok (NULL, " "); id = atoi (arg) ; arg = strtok (NULL, "'"); IvySendDirectMsg (app, id, Chop(arg)); } else printf ("No Application %s!!!\n",arg); } } else if (strcmp(cmd, "who") == 0) { printf("Apps: %s\n", IvyGetApplicationList()); } else if (strcmp(cmd, "help") == 0) { fprintf(stderr,"Commands list:\n"); printf(" .help - this help\n"); printf(" .quit - terminate this application\n"); printf(" .die appname - send die msg to appname\n"); printf(" .dieall-yes-i-am-sure - send die msg to all applis\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"); } else if (strcmp(cmd, "quit") == 0) { exit(0); } } else { cmd = strtok (buf, "\n"); err = IvySendMsg (cmd); printf("-> Sent to %d peer%s\n", err, err == 1 ? "" : "s"); } } void ApplicationCallback (IvyClientPtr app, void *user_data, IvyApplicationEvent event) { char *appname; char *host; char **msgList; appname = IvyGetApplicationName (app); host = IvyGetApplicationHost (app); switch (event) { case IvyApplicationConnected: app_count++; printf("%s connected from %s\n", appname, host); /* printf("Application(%s): Begin Messages\n", appname);*/ msgList = IvyGetApplicationMessages (app); while (*msgList ) printf("%s subscribes to '%s'\n",appname,*msgList++); /* printf("Application(%s): End Messages\n",appname);*/ if (app_count == wait_count) #ifdef XTMAINLOOP IvyXtChannelSetUp (0, NULL, NULL, HandleStdin); #endif #ifdef GTKMAINLLOP IvyGtkChannelSetUp( 0, NULL, NULL, HandleStdin); #endif #ifdef GLUTMAINLLOP IvyGlutChannelSetUp( 0, NULL, NULL, HandleStdin); #endif #ifdef IVYMAINLOOP IvyChannelSetUp (0, NULL, NULL, HandleStdin); #endif break; case IvyApplicationDisconnected: app_count--; printf("%s disconnected from %s\n", appname, host); break; default: printf("%s: unkown event %d\n", appname, event); break; } } #ifndef XTMAINLOOP void TimerCall(TimerId id, void *user_data, unsigned long delta) { printf("Timer callback: %d delta %lu ms\n", (int)user_data, delta); IvySendMsg ("TEST TIMER %d", (int)user_data); /*if ((int)user_data == 5) TimerModify (id, 2000);*/ } #endif #ifdef GLUTMAINLLOP void display(void) { glClear(GL_COLOR_BUFFER_BIT); glFlush(); } #endif int main(int argc, char *argv[]) { int c; int timer_test = 0; char busbuf [1024] = ""; const char* bus = 0; while ((c = getopt(argc, argv, "d:b:w:t")) != EOF) switch (c) { case 'b': strcpy (busbuf, optarg); bus = busbuf; break; case 'w': wait_count = atoi(optarg) ; break; case 't': timer_test = 1; break; } /* Mainloop management */ #ifdef XTMAINLOOP /*XtToolkitInitialize();*/ cntx = XtCreateApplicationContext(); IvyXtChannelAppContext (cntx); #endif #ifdef GLUTMAINLLOOP glutInit(&argc, argv); glutCreateWindow("IvyProbe Test"); glClearColor(0.49, 0.62, 0.75, 0.0); glutDisplayFunc(display); #endif IvyInit ("IVYPROBE", "IVYPROBE READY", ApplicationCallback,NULL,NULL,NULL); IvyBindDirectMsg( DirectCallback,NULL); for (; optind < argc; optind++) IvyBindMsg (Callback, NULL, argv[optind]); if (wait_count == 0) #ifdef XTMAINLOOP IvyXtChannelSetUp (0, NULL, NULL, HandleStdin); #endif #ifdef GTKMAINLOOP IvyGtkChannelSetUp (0, NULL, NULL, HandleStdin); #endif #ifdef GLUTMAINLOOP IvyGlutChannelSetUp (0, NULL, NULL, HandleStdin); #endif #ifdef IVYMAINLOOP #ifndef WIN32 /* Stdin not compatible with select , select only accept socket */ IvyChannelSetUp (0, NULL, NULL, HandleStdin); #endif #endif IvyStart (bus); if (timer_test) { #ifdef IVYMAINLOOP TimerRepeatAfter (TIMER_LOOP, 1000, TimerCall, (void*)1); TimerRepeatAfter (5, 5000, TimerCall, (void*)5); #endif } #ifdef XTMAINLOOP XtAppMainLoop (cntx); #endif #ifdef GTKMAINLOOP gtk_main(); #endif #ifdef GLUTMAINLOOP glutMainLoop(); #endif #ifdef IVYMAINLOOP IvyMainLoop (0); #endif return 0; }