sendCallBack,
NULL,
&delay);
+ if (p == NULL) {
+ printf("ORTEPublicationCreate failed\n");
+ }
return arg;
}
recvCallBack,
NULL,
IPADDRESS_INVALID);
+ if (s == NULL) {
+ printf("ORTESubscriptionCreate failed\n");
+ }
return arg;
}
static ORTEDomain *d = NULL;
static char instance2Recv[64];
-int maxDataSize(ORTEGetMaxSizeParam *gms) {
+int maxDataSize(ORTEGetMaxSizeParam *gms, int num) {
return gms->max_size;
}
recvCallBack,
NULL,
StringToIPAddress("225.0.0.2"));
+ if (s == NULL) {
+ printf("ORTESubscriptionCreate failed\n");
+ }
return arg;
}
#include <getopt.h>
#endif
+#ifdef HAVE_INTTYPES_H
+ #include <inttypes.h>
+#endif /*HAVE_INTTYPES_H*/
+
+#ifndef PRIu32
+ #define PRIu32 x
+#endif
+
#ifdef MAIN_RENAMED
#define main orte_ping_main
#define exit return
switch (info->status) {
case NEW_DATA:
if (!quite)
- printf("received fresh issue %d\n",*instance);
+ printf("received fresh issue %"PRIu32"\n",*instance);
break;
case DEADLINE:
printf("deadline occurred\n");
case NEED_DATA:
(*instance)++;
if (!quite)
- printf("sent issue %d\n",*instance);
+ printf("sent issue %"PRIu32"\n",*instance);
break;
case CQL: //criticalQueueLevel
break;
sendCallBack,
NULL,
&delay);
+ if (p == NULL) {
+ printf("ORTEPublicationCreate failed\n");
+ exit(1);
+ }
}
if (haveSubscriber) {
NTPTIME_BUILD(deadline,3);
recvCallBack,
NULL,
smIPAddress);
+ if (s == NULL) {
+ printf("ORTESubscriptionCreate failed\n");
+ exit(1);
+ }
}
//never ending loop
while (!regfail)
sendCallBack,
NULL,
&repeating);
+ if (p == NULL) {
+ printf("ORTEPublicationCreate failed\n");
+ return 1;
+ }
#ifndef CONFIG_ORTE_RT
while(1) {
ORTESleepMs(1000);
recvCallBack,
NULL,
IPADDRESS_INVALID);
+ if (s == NULL) {
+ printf("ORTESubscriptionCreate failed\n");
+ return 1;
+ }
#ifndef CONFIG_ORTE_RT
while (1)
ORTESleepMs(1000);
recvCallBack,
NULL,
IPADDRESS_INVALID);
+ if (s == NULL) {
+ printf("ORTESubscriptionCreate failed\n");
+ return 1;
+ }
#ifndef CONFIG_ORTE_RT
while (1)
ORTESleepMs(1000);
static ORTEDomain *d = NULL;
static char instance2Recv[64];
-int maxDataSize(ORTEGetMaxSizeParam *gms) {
+int maxDataSize(ORTEGetMaxSizeParam *gms, int num) {
return gms->max_size;
}
// StringToIPAddress("225.0.0.2")
IPADDRESS_INVALID
);
+ if (s == NULL) {
+ printf("ORTESubscriptionCreate failed\n");
+ }
return arg;
}
}
freeifaddrs(ifa);
-
+ return 0;
#elif defined(SOCK_BSD)
#define SOCK_SIOCGIFCONF_SA_LEN_UNCONDITIONAL 1 /* seems to be required for RTEMS*/
#include "orte_all.h"
+#ifdef HAVE_INTTYPES_H
+ #include <inttypes.h>
+ #if defined(PRIx32) && !defined(ORTE_PRI_HostId)
+ #define ORTE_PRI_HostId PRIx32
+ #define ORTE_PRI_AppId PRIx32
+ #endif
+#endif /*HAVE_INTTYPES_H*/
+
+#ifndef ORTE_PRI_HostId
+ #define ORTE_PRI_HostId x
+ #define ORTE_PRI_AppId x
+#endif
+
#ifdef MAIN_RENAMED
#define main ortemanager_main
#define exit return
//event system
Boolean
onMgrAppRemoteNew(const struct ORTEAppInfo *appInfo, void *param) {
- printf("%s 0x%x-0x%x was accepted\n",
+ printf("%s 0x%"ORTE_PRI_HostId"-0x%"ORTE_PRI_AppId" was accepted\n",
(appInfo->appId & 0x3)==MANAGER ? "manager" : "application",
appInfo->hostId,appInfo->appId);
return ORTE_TRUE;
void
onMgrAppDelete(const struct ORTEAppInfo *appInfo, void *param) {
- printf("%s 0x%x-0x%x was deleted\n",
+ printf("%s 0x%"ORTE_PRI_HostId"-0x%"ORTE_PRI_AppId" was deleted\n",
(appInfo->appId & 0x3)==MANAGER ? "manager" : "application",
appInfo->hostId,appInfo->appId);
}