]> rtime.felk.cvut.cz Git - orte.git/blobdiff - orte/examples/hello/HelloWorldSubscriber.c
CygWin, MSVC hack
[orte.git] / orte / examples / hello / HelloWorldSubscriber.c
index 4ff21f910f93cb497f3d8c70f25154b2bf89610a..4359a73106e6d73633db216df03bd1deb99ffde0 100644 (file)
@@ -56,7 +56,7 @@ subscriberCreate(void *arg) {
   NtpTime             deadline,minimumSeparation;
 
   ORTETypeRegisterAdd(d,"HelloMsg",NULL,NULL,64);
-  NTPTIME_BUILD(deadline,20);
+  NTPTIME_BUILD(deadline,10);
   NTPTIME_BUILD(minimumSeparation,0);
   s=ORTESubscriptionCreate(
        d,
@@ -90,8 +90,10 @@ main(int argc, char *args[]) {
 }
 
 #else
-
-char manager[MAX_STRING_IPADDRESS_LENGTH]="127.0.0.1";
+char *verbosity="";
+MODULE_PARM(verbosity,"1s");
+MODULE_PARM_DESC(verbosity,"set verbosity level SECTION, up to LEVEL:...");
+char *manager="127.0.0.1";
 MODULE_PARM(manager,"s");
 MODULE_PARM_DESC(manager,"IP address of local manager");
 MODULE_LICENSE("GPL");
@@ -108,12 +110,15 @@ int
 init_module(void) {
   ORTEDomainProp      dp;
 
+  ORTEInit();
   ORTEDomainPropDefaultGet(&dp);
+  ORTEVerbositySetOptions(verbosity);
   dp.appLocalManager=StringToIPAddress(manager);
   d=ORTEDomainAppCreate(ORTE_DEFAULT_DOMAIN,&dp,NULL,ORTE_FALSE);
-  if (d) 
-    pthread_create(&thread,NULL,&subscriberCreate,NULL);
-  else
+  if (d) {
+    if (pthread_create(&thread,NULL,&subscriberCreate,NULL)!=0)
+      printf("pthread_create failed!\n");    
+  } else
     printf("ORTEDomainAppCreate failed!\n");
   return 0;
 }