2 * $Id: m_subscriber.c,v 0.0.1.0 2005/01/03
4 * DEBUG: section m_subscriber
6 * -------------------------------------------------------------------
8 * Open Real-Time Ethernet
10 * Copyright (C) 2001-2006
11 * Department of Control Engineering FEE CTU Prague, Czech Republic
12 * http://dce.felk.cvut.cz
13 * http://www.ocera.org
15 * Author: Petr Smolik petr.smolik@wo.cz
17 * Project Responsible: Zdenek Hanzalek
18 * --------------------------------------------------------------------
20 * This program is free software; you can redistribute it and/or modify
21 * it under the terms of the GNU General Public License as published by
22 * the Free Software Foundation; either version 2 of the License, or
23 * (at your option) any later version.
25 * This program is distributed in the hope that it will be useful,
26 * but WITHOUT ANY WARRANTY; without even the implied warranty of
27 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
28 * GNU General Public License for more details.
35 #define main orte_schneider_subscriber_main
39 static ORTEDomain *d = NULL;
40 static char instance2Recv[64];
42 int maxDataSize(ORTEGetMaxSizeParam *gms, int num) {
47 recvCallBack(const ORTERecvInfo *info,void *vinstance, void *recvCallBackParam) {
48 char *instance=(char*)vinstance;
50 switch (info->status) {
52 printf("%s\n",instance);
55 printf("deadline occurred\n");
62 subscriberCreate(void *arg) {
64 NtpTime deadline,minimumSeparation;
66 ORTETypeRegisterAdd(d,"IDA_OCTETSTRING",NULL,NULL,maxDataSize,sizeof(instance2Recv));
67 NTPTIME_BUILD(deadline,10);
68 NTPTIME_BUILD(minimumSeparation,0);
69 s=ORTESubscriptionCreate(
80 // StringToIPAddress("225.0.0.2")
84 printf("ORTESubscriptionCreate failed\n");
90 main(int argc, char *args[]) {
94 ORTEDomainPropDefaultGet(&dp);
95 // dp.multicast.enabled=ORTE_TRUE;
96 // dp.multicast.ipAddress=StringToIPAddress("225.0.0.1");
97 ORTEVerbositySetOptions("ALL.5");
98 d=ORTEDomainAppCreate(1,&dp,NULL,ORTE_FALSE);
100 printf("ORTEDomainAppCreate failed!\n");
103 subscriberCreate(NULL);