X-Git-Url: https://rtime.felk.cvut.cz/gitweb/orte.git/blobdiff_plain/e80a6f5e0540d9e10ee957240e6f5b3faaa54021..44b53e7b789fa481a19db83e52cb3f15f0d90e85:/orte/examples/reliable/r_subscriber_besteffort.c diff --git a/orte/examples/reliable/r_subscriber_besteffort.c b/orte/examples/reliable/r_subscriber_besteffort.c index 8ebafb8..63832df 100644 --- a/orte/examples/reliable/r_subscriber_besteffort.c +++ b/orte/examples/reliable/r_subscriber_besteffort.c @@ -1,33 +1,33 @@ /* - * $Id: subscriberbesteffort.c,v 0.0.0.1 2003/12/27 + * $Id: subscriberbesteffort.c,v 0.0.0.1 2003/12/27 * * DEBUG: section Subscriber BestEffort * - * ------------------------------------------------------------------- - * 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 #ifdef __RTL__ @@ -44,12 +44,13 @@ static ORTEDomain *d; static char instance2Recv[64]; static void -recvCallBack(const ORTERecvInfo *info,void *vinstance, void *recvCallBackParam) { - char *instance=(char*)vinstance; - +recvCallBack(const ORTERecvInfo *info, void *vinstance, void *recvCallBackParam) +{ + char *instance = (char *)vinstance; + switch (info->status) { case NEW_DATA: - printf("%s\n",instance); + printf("%s\n", instance); break; case DEADLINE: printf("deadline occurred\n"); @@ -58,51 +59,53 @@ recvCallBack(const ORTERecvInfo *info,void *vinstance, void *recvCallBackParam) } -int -main(int argc, char *args[]) { +int +main(int argc, char *args[]) +{ ORTESubscription *s; - NtpTime deadline,minimumSeparation; + NtpTime deadline, minimumSeparation; ORTEInit(); //ORTEVerbositySetOptions("ALL,10"); - d=ORTEDomainAppCreate(ORTE_DEFAULT_DOMAIN,NULL,NULL,ORTE_FALSE); - ORTETypeRegisterAdd(d,"HelloMsg",NULL,NULL,NULL,sizeof(instance2Recv)); - NTPTIME_BUILD(deadline,3); - NTPTIME_BUILD(minimumSeparation,0); - s=ORTESubscriptionCreate( - d, - IMMEDIATE, - BEST_EFFORTS, - "Reliable HelloMsg", - "HelloMsg", - &instance2Recv, - &deadline, - &minimumSeparation, - recvCallBack, - NULL, - IPADDRESS_INVALID); + d = ORTEDomainAppCreate(ORTE_DEFAULT_DOMAIN, NULL, NULL, ORTE_FALSE); + ORTETypeRegisterAdd(d, "HelloMsg", NULL, NULL, NULL, sizeof(instance2Recv)); + NTPTIME_BUILD(deadline, 3); + NTPTIME_BUILD(minimumSeparation, 0); + s = ORTESubscriptionCreate( + d, + IMMEDIATE, + BEST_EFFORTS, + "Reliable HelloMsg", + "HelloMsg", + &instance2Recv, + &deadline, + &minimumSeparation, + recvCallBack, + NULL, + IPADDRESS_INVALID); if (s == NULL) { printf("ORTESubscriptionCreate failed\n"); return 1; } #ifndef CONFIG_ORTE_RT - while (1) + while (1) ORTESleepMs(1000); #endif return 0; } #ifdef CONFIG_ORTE_RT -void -hello_init(void) { - main(0,NULL); +void +hello_init(void) +{ + main(0, NULL); } -void -hello_exit(void) { +void +hello_exit(void) +{ ORTEDomainAppDestroy(d); } MODULE_LICENSE("GPL"); module_init(hello_init); module_exit(hello_exit); #endif -