#include <stdio.h>
#include <stdlib.h>
#include "ndds/ndds_cpp.h"
#include "HelloWorld.h"
#include "HelloWorldSupport.h"
static int publisher_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 publisher_main(int domainId, int sample_count)
{
HelloWorldDataWriter *HelloWorld_writer = NULL;
HelloWorld *instance = NULL;
const char *type_name = NULL;
int count = 0;
if (participant == NULL) {
printf("create_participant error\n");
publisher_shutdown(participant);
return -1;
}
if (publisher == NULL) {
printf("create_publisher error\n");
publisher_shutdown(participant);
return -1;
}
type_name = HelloWorldTypeSupport::get_type_name();
retcode = HelloWorldTypeSupport::register_type(
participant, type_name);
printf("register_type error %d\n", retcode);
publisher_shutdown(participant);
return -1;
}
"Example HelloWorld",
if (topic == NULL) {
printf("create_topic error\n");
publisher_shutdown(participant);
return -1;
}
if (writer == NULL) {
printf("create_datawriter error\n");
publisher_shutdown(participant);
return -1;
}
HelloWorld_writer = HelloWorldDataWriter::narrow(writer);
if (HelloWorld_writer == NULL) {
printf("DataWriter narrow error\n");
publisher_shutdown(participant);
return -1;
}
instance = HelloWorldTypeSupport::create_data();
if (instance == NULL) {
printf("HelloWorldTypeSupport::create_data error\n");
publisher_shutdown(participant);
return -1;
}
for (count=0; (sample_count == 0) || (count < sample_count); ++count) {
printf("Writing HelloWorld, count %d\n", count);
fflush(stdout);
sprintf(instance->msg, "Hello World! (%d)", count);
retcode = HelloWorld_writer->write(*instance, instance_handle);
printf("write error %d\n", retcode);
}
}
retcode = HelloWorldTypeSupport::delete_data(instance);
printf("HelloWorldTypeSupport::delete_data error %d\n", retcode);
}
return publisher_shutdown(participant);
}
#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 publisher_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 publisher_main(domainId, sample_count);
}
#endif