extern "C" {
#endif
-#if defined(HAVE_CONFIG_H) || defined(OMK_FOR_USER) || defined(OMK_FOR_KERNEL)
- #include "orte/orte_config.h"
-#elif defined _MSC_VER
+#if defined _MSC_VER
#include "orte/ew_types.h"
+#elif defined(HAVE_CONFIG_H) || defined(OMK_FOR_USER) || defined(OMK_FOR_KERNEL)
+ #include "orte/orte_config.h"
#else
#error ""
#error "You don't have file 'orte/orte_config.h'."
#ifndef RTPS_ENDIAN_H
#define RTPS_ENDIAN_H 1
-#include "orte/orte_config.h"
-
#define FLAG_BIG_ENDIAN 0
#define FLAG_LITTLE_ENDIAN 1
for(i=0;i<appParams->metatrafficMulticastIPAddressCount;i++) {
des.sin_family=AF_INET;
des.sin_addr.s_addr = htonl(appParams->metatrafficMulticastIPAddressList[i]);
- des.sin_port = htons(object->multicastPort);
+ des.sin_port = htons((uint16_t)object->multicastPort);
if (d->taskSend.mb.cdrCodecDirect) {
sock_sendto (&d->taskSend.sock,
d->taskSend.mb.cdrCodecDirect->buffer,
} else {
port=appParams->userdataUnicastPort;
}
- des.sin_port = htons(port);
+ des.sin_port = htons((uint16_t)port);
if (d->taskSend.mb.cdrCodecDirect) {
sock_sendto (&d->taskSend.sock,
d->taskSend.mb.cdrCodecDirect->buffer,
/* receiving multicast port (metatraffic) */
Domain2PortMulticastMetatraffic(d->domain,mport);
- sock_bind(&d->taskRecvMulticastMetatraffic.sock,mport);
+ sock_bind(&d->taskRecvMulticastMetatraffic.sock,(uint16_t)mport);
debug(30,2) ("ORTEDomainCreate: bind on port(RecvMulticastMetatraffic): %u\n",
d->taskRecvMulticastMetatraffic.sock.port);
}
/* receiving multicast port (userdata) */
Domain2PortMulticastUserdata(d->domain,mport);
- sock_bind(&d->taskRecvMulticastUserdata.sock,mport);
+ sock_bind(&d->taskRecvMulticastUserdata.sock,(uint16_t)mport);
debug(30,2) ("ORTEDomainCreate: bind on port(RecvMulticastUserdata): %u\n",
d->taskRecvMulticastUserdata.sock.port);
}
ORTERecvInfo info;
ORTESubsProp *sp;
ObjectEntryOID *objectEntryOID;\r
- int max_size;
+ unsigned int max_size;
if (cstRemoteWriter==NULL) return;
objectEntryOID=cstRemoteWriter->cstReader->objectEntryOID;
cdrCodec->data_endian=FLAG_BIG_ENDIAN;
/* Host Id */
- CDR_put_ulong(cdrCodec,
- *(CORBA_unsigned_long*)&hid);
+ CDR_get_ulong(cdrCodec,
+ (CORBA_unsigned_long*)&hid);
/* App Id */
- CDR_put_ulong(cdrCodec,
- *(CORBA_unsigned_long*)&aid);
+ CDR_get_ulong(cdrCodec,
+ (CORBA_unsigned_long*)&aid);
cdrCodec->data_endian=data_endian;
CDR_put_octet(cdrCodec,flags);
/* length */
- CDR_put_ushort(cdrCodec,length);
+ CDR_put_ushort(cdrCodec,(CORBA_unsigned_short)length);
data_endian=cdrCodec->data_endian;
cdrCodec->data_endian=FLAG_BIG_ENDIAN;
/* length */
cdrCodec->wptr=swptr+2;
- CDR_put_ushort(cdrCodec,len-4);
+ CDR_put_ushort(cdrCodec,(CORBA_unsigned_short)(len-4));
cdrCodec->wptr=swptr+len;
LIB_CFLAGS= $(CFLAGS) -LD
INCLUDE= -I$(MSCDIR)\include -I..\..\include -I..\..\include\win32
ORTELIB_OBJS= \
- "..\ul_gavlprim.obj" \
- "..\conv.obj" \
- "..\debug.obj" \
- "..\event.obj" \
- "..\fnmatch.obj" \
- "..\htimerNtp.obj" \
- "..\objectEntry.obj" \
- "..\objectEntryTimer.obj" \
- "..\objectUtils.obj" \
- "..\ORTEAppRecvMetatrafficThread.obj" \
- "..\ORTEAppRecvUserdataThread.obj" \
- "..\ORTEAppSendThread.obj" \
- "..\ORTEDomain.obj" \
- "..\ORTEDomainApp.obj" \
- "..\ORTEDomainMgr.obj" \
- "..\ORTEInit.obj" \
- "..\ORTEMisc.obj" \
- "..\ORTEPattern.obj" \
- "..\ORTEPublication.obj" \
- "..\ORTEPublicationTimer.obj" \
- "..\ORTESubscription.obj" \
- "..\ORTEThreadUtils.obj" \
- "..\ORTETypeRegister.obj" \
- "..\ORTEVerbosity.obj" \
- "..\parameter.obj" \
- "..\RTPSAck.obj" \
- "..\RTPSCSTReader.obj" \
- "..\RTPSCSTReaderProc.obj" \
- "..\RTPSCSTReaderTimer.obj" \
- "..\RTPSCSTWriter.obj" \
- "..\RTPSCSTWriterTimer.obj" \
- "..\RTPSGap.obj" \
- "..\RTPSHeader.obj" \
- "..\RTPSHeardBeat.obj" \
- "..\RTPSInfoDST.obj" \
- "..\RTPSInfoREPLY.obj" \
- "..\RTPSInfoSRC.obj" \
- "..\RTPSInfoTS.obj" \
- "..\RTPSIssue.obj" \
- "..\RTPSPad.obj" \
- "..\RTPSUtils.obj" \
- "..\RTPSVar.obj" \
- "..\sock.obj" \
- "..\ul_gavl.obj"
+ "..\cdr.c" \
+ "..\conv.c" \
+ "..\debug.c" \
+ "..\event.c" \
+ "..\fnmatch.c" \
+ "..\htimerNtp.c" \
+ "..\objectEntry.c" \
+ "..\objectEntryTimer.c" \
+ "..\objectUtils.c" \
+ "..\ORTEAppRecvThread.c" \
+ "..\ORTEAppSendThread.c" \
+ "..\ORTEDomainApp.c" \
+ "..\ORTEPublication.c" \
+ "..\ORTEPublicationTimer.c" \
+ "..\ORTESubscription.c" \
+ "..\ORTEDomain.c" \
+ "..\ORTEDomainMgr.c" \
+ "..\ORTEInit.c" \
+ "..\ORTEThreadUtils.c" \
+ "..\ORTETypeRegister.c" \
+ "..\ORTEVerbosity.c" \
+ "..\ORTEPattern.c" \
+ "..\ORTEMisc.c" \
+ "..\parameter.c" \
+ "..\RTPSAck.c" \
+ "..\RTPSCSTReader.c" \
+ "..\RTPSCSTReaderTimer.c" \
+ "..\RTPSCSTReaderProc.c" \
+ "..\RTPSCSTWriter.c" \
+ "..\RTPSCSTWriterTimer.c" \
+ "..\RTPSGap.c" \
+ "..\RTPSHeader.c" \
+ "..\RTPSHeardBeat.c" \
+ "..\RTPSInfoDST.c" \
+ "..\RTPSInfoREPLY.c" \
+ "..\RTPSInfoSRC.c" \
+ "..\RTPSInfoTS.c" \
+ "..\RTPSPad.c" \
+ "..\RTPSUtils.c" \
+ "..\RTPSVar.c" \
+ "..\RTPSIssue.c" \
+ "..\sock.c" \
+ "..\ul_gavl.c" \
+ "..\ul_gavlprim.c"
CC= $(MSCDIR)\bin\cl
LINK= $(MSCDIR)\bin\link
# PROP Default_Filter "cpp;c;cxx;rc;def;r;odl;idl;hpj;bat"\r
# Begin Source File\r
\r
+SOURCE=..\cdr.c\r
+# End Source File\r
+# Begin Source File\r
+\r
SOURCE=..\conv.c\r
# End Source File\r
# Begin Source File\r
# End Source File\r
# Begin Source File\r
\r
-SOURCE=..\ORTEAppRecvMetatrafficThread.c\r
-# End Source File\r
-# Begin Source File\r
-\r
-SOURCE=..\ORTEAppRecvUserdataThread.c\r
+SOURCE=..\ORTEAppRecvThread.c\r
# End Source File\r
# Begin Source File\r
\r
}
len+=4; //data size
cdrCodec->wptr-=2; //new alignments value
- if (CDR_put_ushort(cdrCodec,len)==CORBA_FALSE) return -1;
+ if (CDR_put_ushort(cdrCodec,(CORBA_unsigned_short)len)==CORBA_FALSE) return -1;
if (ps->parameterLength>MAX_PARAMETER_LOCAL_LENGTH) {
if (CDR_put_string(cdrCodec,(char*)ps->parameter)==
return 0;
}
int managerStart(void) {
- ORTEDomainStart(d,ORTE_TRUE,ORTE_FALSE,ORTE_TRUE);
+ ORTEDomainStart(d,ORTE_TRUE,ORTE_FALSE,ORTE_FALSE,ORTE_FALSE,ORTE_TRUE);
return 0;
}
int managerStop(void) {
daemonInit();
#endif
- ORTEDomainStart(d,ORTE_TRUE,ORTE_FALSE,ORTE_FALSE,ORTE_FALSE,ORTE_FALSE);
-/* #ifndef CONFIG_ORTE_UNIX
- d->taskSend.terminate=ORTE_FALSE;
- ORTEAppSendThread(d);
- #endif*/
- ORTEDomainStart(d,ORTE_FALSE,ORTE_FALSE,ORTE_FALSE,ORTE_FALSE,ORTE_TRUE);
+ ORTEDomainStart(d,ORTE_TRUE,ORTE_FALSE,ORTE_FALSE,ORTE_FALSE,ORTE_TRUE);
+ #ifndef CONFIG_ORTE_UNIX
+ while(1) ORTESleepMs(1000);
+ #endif
#ifdef CONFIG_ORTE_UNIX
waitForEndingCommand();
# without OCERA framework
if [ ! -e Makefile.rules-ocera ] ; then
-# cp Makefile.rules Makefile.rules-ocera
+ cp Makefile.rules Makefile.rules-ocera
fi
if [ -e OCERA_TOP_DIR ] ; then