/*
- * $Id: orteping.c,v 0.0.0.1 2003/10/07
+ * $Id: orteping.c,v 0.0.0.1 2003/10/07
*
* DEBUG: section orteping
*
- * -------------------------------------------------------------------
- * ORTE
- * Open Real-Time Ethernet
- *
- * Copyright (C) 2001-2006
- * Department of Control Engineering FEE CTU Prague, Czech Republic
- * http://dce.felk.cvut.cz
- * http://www.ocera.org
- *
- * Author: Petr Smolik petr@smoliku.cz
- * Advisor: Pavel Pisa
- * Project Responsible: Zdenek Hanzalek
+ * -------------------------------------------------------------------
+ * ORTE
+ * Open Real-Time Ethernet
+ *
+ * Copyright (C) 2001-2006
+ * Department of Control Engineering FEE CTU Prague, Czech Republic
+ * http://dce.felk.cvut.cz
+ * http://www.ocera.org
+ *
+ * Author: Petr Smolik petr@smoliku.cz
+ * Advisor: Pavel Pisa
+ * Project Responsible: Zdenek Hanzalek
* --------------------------------------------------------------------
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
- *
+ *
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
- *
- */
+ *
+ */
#include <stdio.h>
#include <stdlib.h>
#define exit return
#endif
-Boolean quite=ORTE_FALSE;
-int regfail=0;
+Boolean quite = ORTE_FALSE;
+int regfail = 0;
//event system
void
-onRegFail(void *param) {
+onRegFail(void *param)
+{
printf("registration to a manager failed\n");
- regfail=1;
+ regfail = 1;
}
static void
-recvCallBack(const ORTERecvInfo *info,void *vinstance, void *recvCallBackParam) {
- uint32_t *instance=(uint32_t*)vinstance;
-
+recvCallBack(const ORTERecvInfo *info, void *vinstance, void *recvCallBackParam)
+{
+ uint32_t *instance = (uint32_t *)vinstance;
+
switch (info->status) {
case NEW_DATA:
if (!quite)
- printf("received fresh issue %"PRIu32"\n",*instance);
+ printf("received fresh issue %" PRIu32 "\n", *instance);
break;
case DEADLINE:
printf("deadline occurred\n");
}
static void
-sendCallBack(const ORTESendInfo *info,void *vinstance, void *sendCallBackParam) {
- uint32_t *instance=(uint32_t*)vinstance;
-
+sendCallBack(const ORTESendInfo *info, void *vinstance, void *sendCallBackParam)
+{
+ uint32_t *instance = (uint32_t *)vinstance;
+
switch (info->status) {
case NEED_DATA:
(*instance)++;
if (!quite)
- printf("sent issue %"PRIu32"\n",*instance);
+ printf("sent issue %" PRIu32 "\n", *instance);
break;
case CQL: //criticalQueueLevel
break;
}
}
-static void usage(void) {
+static void
+usage(void)
+{
printf("usage: orteping <parameters> \n");
printf(" -d, --domain <domain> working application domain\n");
printf(" -p, --publisher create publisher Ping,PingData\n");
printf(" -E, --expiration <s> expiration time of application\n");
printf(" -m, --minimumSeparation <s> minimumSeparation between two issues\n");
printf(" -I, --metaMulticast <IPAdd> use multicast IPAddr for metatraffic comm.\n");
- printf(" -i, --dataMulticast <IPAdd> use multicast IPAddr for userdata comm.\n");
+ printf(" -i, --dataMulticast <IPAdd> use multicast IPAddr for userdata comm.\n");
printf(" -t, --timetolive <number> time-to-live for multicast packets\n");
printf(" -v, --verbosity <level> set verbosity level SECTION, up to LEVEL:...\n");
printf(" examples: ORTEManager -v 51.7:32.5 sections 51 and 32\n");
printf(" -h, --help this usage screen\n");
}
-int main(int argc,char *argv[]) {
+int
+main(int argc, char *argv[])
+{
#if defined HAVE_GETOPT_LONG || defined HAVE_GETOPT_LONG_ORTE
static struct option long_opts[] = {
- { "domain",1,0, 'd' },
- { "publisher",0,0, 'p' },
- { "strength",1,0, 'S' },
- { "subscriber",0,0, 's' },
- { "refresh",1,0, 'R' },
- { "purge",1,0, 'P' },
- { "expiration",1,0, 'E' },
- { "minimumSeparation",1,0, 'm' },
- { "metaMulticast",1,0, 'I' },
- { "dataMulticast",1,0, 'i' },
- { "timetolive",1,0, 't' },
- { "delay",1,0, 'D' },
- { "verbosity",1,0, 'v' },
- { "quiet",0,0, 'q' },
- { "logfile",1,0, 'l' },
- { "version",0,0, 'V' },
+ { "domain", 1, 0, 'd' },
+ { "publisher", 0, 0, 'p' },
+ { "strength", 1, 0, 'S' },
+ { "subscriber", 0, 0, 's' },
+ { "refresh", 1, 0, 'R' },
+ { "purge", 1, 0, 'P' },
+ { "expiration", 1, 0, 'E' },
+ { "minimumSeparation", 1, 0, 'm' },
+ { "metaMulticast", 1, 0, 'I' },
+ { "dataMulticast", 1, 0, 'i' },
+ { "timetolive", 1, 0, 't' },
+ { "delay", 1, 0, 'D' },
+ { "verbosity", 1, 0, 'v' },
+ { "quiet", 0, 0, 'q' },
+ { "logfile", 1, 0, 'l' },
+ { "version", 0, 0, 'V' },
{ "help", 0, 0, 'h' },
{ 0, 0, 0, 0}
};
#endif
ORTEDomain *d;
- ORTEDomainProp dp;
- ORTEPublication *p=NULL;
- ORTESubscription *s=NULL;
- int opt,domain=ORTE_DEFAULT_DOMAIN;
- int32_t strength=1;
- int32_t instanceSend=0,instanceRecv=0;
- NtpTime persistence,deadline,minimumSeparation,delay;
- Boolean havePublisher=ORTE_FALSE;
- Boolean haveSubscriber=ORTE_FALSE;
- IPAddress smIPAddress=IPADDRESS_INVALID;
+ ORTEDomainProp dp;
+ ORTEPublication *p = NULL;
+ ORTESubscription *s = NULL;
+ int opt, domain = ORTE_DEFAULT_DOMAIN;
+ int32_t strength = 1;
+ int32_t instanceSend = 0, instanceRecv = 0;
+ NtpTime persistence, deadline, minimumSeparation, delay;
+ Boolean havePublisher = ORTE_FALSE;
+ Boolean haveSubscriber = ORTE_FALSE;
+ IPAddress smIPAddress = IPADDRESS_INVALID;
ORTEDomainAppEvents events;
-
+
ORTEInit();
ORTEDomainPropDefaultGet(&dp);
- NTPTIME_BUILD(minimumSeparation,0);
- NTPTIME_BUILD(delay,1); //1s
+ NTPTIME_BUILD(minimumSeparation, 0);
+ NTPTIME_BUILD(delay, 1); //1s
#if defined HAVE_GETOPT_LONG || defined HAVE_GETOPT_LONG_ORTE
- while ((opt = getopt_long(argc, argv, "m:S:d:v:R:E:P:l:I:i:t:D:Vhpsq",&long_opts[0], NULL)) != EOF) {
+ while ((opt = getopt_long(argc, argv, "m:S:d:v:R:E:P:l:I:i:t:D:Vhpsq", &long_opts[0], NULL)) != EOF) {
#else
while ((opt = getopt(argc, argv, "m:S:d:v:R:E:P:l:I:i:t:D:Vhpsq")) != EOF) {
#endif
switch (opt) {
case 'S':
- strength=strtol(optarg,NULL,0);
- break;
+ strength = strtol(optarg, NULL, 0);
+ break;
case 'd':
- domain=strtol(optarg,NULL,0);
- break;
+ domain = strtol(optarg, NULL, 0);
+ break;
case 'p':
- havePublisher=ORTE_TRUE;
- break;
+ havePublisher = ORTE_TRUE;
+ break;
case 's':
- haveSubscriber=ORTE_TRUE;
- break;
+ haveSubscriber = ORTE_TRUE;
+ break;
case 'v':
- ORTEVerbositySetOptions(optarg);
- break;
+ ORTEVerbositySetOptions(optarg);
+ break;
case 'R':
- NtpTimeAssembFromMs(dp.baseProp.refreshPeriod,strtol(optarg,NULL,0),0);
- break;
+ NtpTimeAssembFromMs(dp.baseProp.refreshPeriod, strtol(optarg, NULL, 0), 0);
+ break;
case 'P':
- NtpTimeAssembFromMs(dp.baseProp.purgeTime,strtol(optarg,NULL,0),0);
- break;
+ NtpTimeAssembFromMs(dp.baseProp.purgeTime, strtol(optarg, NULL, 0), 0);
+ break;
case 'E':
- NtpTimeAssembFromMs(dp.baseProp.expirationTime,strtol(optarg,NULL,0),0);
- break;
+ NtpTimeAssembFromMs(dp.baseProp.expirationTime, strtol(optarg, NULL, 0), 0);
+ break;
case 'm':
- NtpTimeAssembFromMs(minimumSeparation,strtol(optarg,NULL,0),0);
- break;
+ NtpTimeAssembFromMs(minimumSeparation, strtol(optarg, NULL, 0), 0);
+ break;
case 'D':
- NtpTimeAssembFromMs(delay,strtol(optarg,NULL,0)/1000,strtol(optarg,NULL,0)%1000);
- break;
+ NtpTimeAssembFromMs(delay, strtol(optarg, NULL, 0)/1000, strtol(optarg, NULL, 0)%1000);
+ break;
case 'I':
- dp.multicast.enabled=ORTE_TRUE;
- dp.multicast.ipAddress=StringToIPAddress(optarg);
- break;
+ dp.multicast.enabled = ORTE_TRUE;
+ dp.multicast.ipAddress = StringToIPAddress(optarg);
+ break;
case 'i':
- dp.multicast.enabled=ORTE_TRUE;
- smIPAddress=StringToIPAddress(optarg);
- break;
+ dp.multicast.enabled = ORTE_TRUE;
+ smIPAddress = StringToIPAddress(optarg);
+ break;
case 't':
- dp.multicast.ttl=strtol(optarg,NULL,0);
- break;
+ dp.multicast.ttl = strtol(optarg, NULL, 0);
+ break;
case 'l':
- ORTEVerbositySetLogFile(optarg);
+ ORTEVerbositySetLogFile(optarg);
case 'q':
- quite=ORTE_TRUE;
- break;
+ quite = ORTE_TRUE;
+ break;
case 'V':
- printf("Ocera Real-Time Ethernet (%s).\n",dp.version);
- exit(0);
- break;
+ printf("Ocera Real-Time Ethernet (%s).\n", dp.version);
+ exit(0);
+ break;
case 'h':
default:
- usage();
- exit(opt == 'h' ? 0 : 1);
+ usage();
+ exit(opt == 'h' ? 0 : 1);
}
}
//initiate event system
ORTEDomainInitEvents(&events);
- events.onRegFail=onRegFail;
+ events.onRegFail = onRegFail;
- //Create application
- d=ORTEDomainAppCreate(domain,&dp,&events,ORTE_FALSE);
+ //Create application
+ d = ORTEDomainAppCreate(domain, &dp, &events, ORTE_FALSE);
//Register ser./deser. rutines with maximal size 4 Bytes
- ORTETypeRegisterAdd(d,"PingData",NULL,NULL,NULL,4);
+ ORTETypeRegisterAdd(d, "PingData", NULL, NULL, NULL, 4);
//Create publisher
if (havePublisher) {
- NTPTIME_BUILD(persistence,5);
- p=ORTEPublicationCreate(
- d,
- "Ping",
- "PingData",
- &instanceSend,
- &persistence,
- strength,
- sendCallBack,
- NULL,
- &delay);
- if (p == NULL) {
- printf("ORTEPublicationCreate failed\n");
- exit(1);
- }
+ NTPTIME_BUILD(persistence, 5);
+ p = ORTEPublicationCreate(
+ d,
+ "Ping",
+ "PingData",
+ &instanceSend,
+ &persistence,
+ strength,
+ sendCallBack,
+ NULL,
+ &delay);
+ if (p == NULL) {
+ printf("ORTEPublicationCreate failed\n");
+ exit(1);
+ }
}
if (haveSubscriber) {
- NTPTIME_BUILD(deadline,3);
- s=ORTESubscriptionCreate(
- d,
- IMMEDIATE,
- BEST_EFFORTS,
- "Ping",
- "PingData",
- &instanceRecv,
- &deadline,
- &minimumSeparation,
- recvCallBack,
- NULL,
- smIPAddress);
- if (s == NULL) {
- printf("ORTESubscriptionCreate failed\n");
- exit(1);
- }
+ NTPTIME_BUILD(deadline, 3);
+ s = ORTESubscriptionCreate(
+ d,
+ IMMEDIATE,
+ BEST_EFFORTS,
+ "Ping",
+ "PingData",
+ &instanceRecv,
+ &deadline,
+ &minimumSeparation,
+ recvCallBack,
+ NULL,
+ smIPAddress);
+ if (s == NULL) {
+ printf("ORTESubscriptionCreate failed\n");
+ exit(1);
+ }
}
//never ending loop
- while (!regfail)
+ while (!regfail)
ORTESleepMs(1000);
exit(0);
}
-
projects / orte.git / blobdiff