#include <stdio.h>
#include <stdlib.h>
#ifdef RTI_VX653
#include <vThreadsData.h>
#endif
#include "HelloWorld.h"
#include "HelloWorldSupport.h"
#include "ndds/ndds_cpp.h"
public:
};
void HelloWorldListener::on_data_available(
DDSDataReader* reader)
{
HelloWorldDataReader *HelloWorld_reader = NULL;
HelloWorldSeq data_seq;
int i;
HelloWorld_reader = HelloWorldDataReader::narrow(reader);
if (HelloWorld_reader == NULL) {
printf("DataReader narrow error\n");
return;
}
retcode = HelloWorld_reader->take(
return;
printf("take error %d\n", retcode);
return;
}
for (i = 0; i < data_seq.length(); ++i) {
if (info_seq[i].valid_data) {
HelloWorldTypeSupport::print_data(&data_seq[i]);
}
}
retcode = HelloWorld_reader->return_loan(data_seq, info_seq);
printf("return loan error %d\n", retcode);
}
}
static int subscriber_shutdown(
{
int status = 0;
if (participant != NULL) {
printf("delete_contained_entities error %d\n", retcode);
status = -1;
}
printf("delete_participant error %d\n", retcode);
status = -1;
}
}
return status;
}
extern "C" int subscriber_main(int domainId, int sample_count)
{
HelloWorldListener *reader_listener = NULL;
const char *type_name = NULL;
int count = 0;
int status = 0;
if (participant == NULL) {
printf("create_participant error\n");
subscriber_shutdown(participant);
return -1;
}
if (subscriber == NULL) {
printf("create_subscriber error\n");
subscriber_shutdown(participant);
return -1;
}
type_name = HelloWorldTypeSupport::get_type_name();
retcode = HelloWorldTypeSupport::register_type(
participant, type_name);
printf("register_type error %d\n", retcode);
subscriber_shutdown(participant);
return -1;
}
"Example HelloWorld",
if (topic == NULL) {
printf("create_topic error\n");
subscriber_shutdown(participant);
return -1;
}
reader_listener = new HelloWorldListener();
if (reader == NULL) {
printf("create_datareader error\n");
subscriber_shutdown(participant);
delete reader_listener;
return -1;
}
for (count=0; (sample_count == 0) || (count < sample_count); ++count) {
printf("HelloWorld subscriber sleeping for %d sec...\n",
}
status = subscriber_shutdown(participant);
delete reader_listener;
return status;
}
#if defined(RTI_WINCE)
int wmain(int argc, wchar_t** argv)
{
int domainId = 0;
int sample_count = 0;
if (argc >= 2) {
domainId = _wtoi(argv[1]);
}
if (argc >= 3) {
sample_count = _wtoi(argv[2]);
}
return subscriber_main(domainId, sample_count);
}
#elif !(defined(RTI_VXWORKS) && !defined(__RTP__)) && !defined(RTI_PSOS)
int main(int argc, char *argv[])
{
int domainId = 0;
int sample_count = 0;
if (argc >= 2) {
domainId = atoi(argv[1]);
}
if (argc >= 3) {
sample_count = atoi(argv[2]);
}
return subscriber_main(domainId, sample_count);
}
#endif
#ifdef RTI_VX653
const unsigned char* __ctype = *(__ctypePtrGet());
extern "C" void usrAppInit ()
{
#ifdef USER_APPL_INIT
USER_APPL_INIT;
#endif
taskSpawn("sub", RTI_OSAPI_THREAD_PRIORITY_NORMAL, 0x8, 0x150000, (FUNCPTR)subscriber_main, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
}
#endif