RTI TCP Transport Version 7.2.0

[$(NDDSHOME)/example/C/helloWorldTCP/HelloWorld_subscriber.c]

/* HelloWorld_subscriber.c
A subscription example
This file is derived from code automatically generated by the rtiddsgen
command:
rtiddsgen -language C -example <arch> HelloWorld.idl
Example subscription of type HelloWorld automatically generated by
'rtiddsgen'. To test them, follow these steps:
(1) Compile this file and the example publication.
(2) Start the subscription on the same domain used for RTI Connext with the command
objs/<arch>/HelloWorld_subscriber <domain_id> <sample_count>
(3) Start the publication on the same domain used for RTI Connext with the command
objs/<arch>/HelloWorld_publisher <domain_id> <sample_count>
(4) [Optional] Specify the list of discovery initial peers and
multicast receive addresses via an environment variable or a file
(in the current working directory) called NDDS_DISCOVERY_PEERS.
You can run any number of publishers and subscribers programs, and can
add and remove them dynamically from the domain.
Example:
To run the example application on domain <domain_id>:
On UNIX systems:
objs/<arch>/HelloWorld_publisher <arguments>
objs/<arch>/HelloWorld_subscriber <arguments>
On Windows systems:
objs<arch>\HelloWorld_publisher <arguments>
objs<arch>\HelloWorld_subscriber <arguments>
Use the option '--help' to print a list of all
the accepted command-line options.
modification history
------------ -------
*/
#include <stdio.h>
#include <stdlib.h>
#include "ndds/ndds_c.h"
#include "HelloWorld.h"
#include "HelloWorldSupport.h"
#include "HelloCommon.h"
void HelloWorldListener_on_requested_deadline_missed(
void* listener_data,
DDS_DataReader* reader,
const struct DDS_RequestedDeadlineMissedStatus *status)
{
}
void HelloWorldListener_on_requested_incompatible_qos(
void* listener_data,
DDS_DataReader* reader,
const struct DDS_RequestedIncompatibleQosStatus *status)
{
}
void HelloWorldListener_on_sample_rejected(
void* listener_data,
DDS_DataReader* reader,
const struct DDS_SampleRejectedStatus *status)
{
}
void HelloWorldListener_on_liveliness_changed(
void* listener_data,
DDS_DataReader* reader,
const struct DDS_LivelinessChangedStatus *status)
{
}
void HelloWorldListener_on_sample_lost(
void* listener_data,
DDS_DataReader* reader,
const struct DDS_SampleLostStatus *status)
{
}
void HelloWorldListener_on_subscription_matched(
void* listener_data,
DDS_DataReader* reader,
const struct DDS_SubscriptionMatchedStatus *status)
{
}
void HelloWorldListener_on_data_available(
void* listener_data,
DDS_DataReader* reader)
{
HelloWorldDataReader *HelloWorld_reader = NULL;
struct HelloWorldSeq data_seq = DDS_SEQUENCE_INITIALIZER;
int i;
HelloWorld_reader = HelloWorldDataReader_narrow(reader);
if (HelloWorld_reader == NULL) {
fprintf(stderr, "DataReader narrow error\n");
return;
}
retcode = HelloWorldDataReader_take(
HelloWorld_reader,
&data_seq, &info_seq, DDS_LENGTH_UNLIMITED,
if (retcode == DDS_RETCODE_NO_DATA) {
return;
} else if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "take error %d\n", retcode);
return;
}
for (i = 0; i < HelloWorldSeq_get_length(&data_seq); ++i) {
if (DDS_SampleInfoSeq_get_reference(&info_seq, i)->valid_data) {
HelloWorldTypeSupport_print_data(
HelloWorldSeq_get_reference(&data_seq, i));
fflush(stdout);
}
}
retcode = HelloWorldDataReader_return_loan(
HelloWorld_reader,
&data_seq, &info_seq);
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "return loan error %d\n", retcode);
}
}
/* Delete all entities */
static int subscriber_shutdown(
DDS_DomainParticipant *participant)
{
int status = 0;
if (participant != NULL) {
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "delete_contained_entities error %d\n", retcode);
status = -1;
}
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "delete_participant error %d\n", retcode);
status = -1;
}
}
/* RTI Connext provides the finalize_instance() method on
domain participant factory for users who want to release memory used
by the participant factory. Uncomment the following block of code for
clean destruction of the singleton. */
/*
retcode = DDS_DomainParticipantFactory_finalize_instance();
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "finalize_instance error %d\n", retcode);
status = -1;
}
*/
return status;
}
static int subscriber_main(const struct CmdLineArgs * const args)
{
DDS_DomainParticipant *participant = NULL;
DDS_Subscriber *subscriber = NULL;
DDS_Topic *topic = NULL;
struct DDS_DataReaderListener reader_listener =
DDS_DataReader *reader = NULL;
const char *type_name = NULL;
int count = 0;
struct DDS_Duration_t poll_period = {4,0};
struct DDS_DomainParticipantQos domain_participant_qos =
int result = -1;
&domain_participant_qos);
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "get_default_participant_qos error\n");
goto done;
}
/* Now we configure the TCP transport */
retcode = configureTcpTransport(args, &domain_participant_qos);
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "assert_property error\n");
goto done;
}
args->domain_id,
&domain_participant_qos,
NULL /* listener */,
if (participant == NULL) {
fprintf(stderr, "create_participant error\n");
goto done;
}
/*
* To customize subscriber QoS, use
* the configuration file USER_QOS_PROFILES.xml
*/
participant,
NULL /* listener */,
if (subscriber == NULL) {
fprintf(stderr, "create_subscriber error\n");
goto done;
}
/* Register the type before creating the topic */
type_name = HelloWorldTypeSupport_get_type_name();
retcode = HelloWorldTypeSupport_register_type(participant, type_name);
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr, "register_type error %d\n", retcode);
goto done;
}
/*
* To customize topic QoS, use
* the configuration file USER_QOS_PROFILES.xml
*/
participant,
"Example HelloWorld",
type_name,
NULL /* listener */,
if (topic == NULL) {
fprintf(stderr, "create_topic error\n");
goto done;
}
/* Set up a data reader listener */
reader_listener.on_requested_deadline_missed =
HelloWorldListener_on_requested_deadline_missed;
HelloWorldListener_on_requested_incompatible_qos;
reader_listener.on_sample_rejected =
HelloWorldListener_on_sample_rejected;
reader_listener.on_liveliness_changed =
HelloWorldListener_on_liveliness_changed;
reader_listener.on_sample_lost =
HelloWorldListener_on_sample_lost;
reader_listener.on_subscription_matched =
HelloWorldListener_on_subscription_matched;
reader_listener.on_data_available =
HelloWorldListener_on_data_available;
/*
* To customize data reader QoS, use
* the configuration file USER_QOS_PROFILES.xml
*/
subscriber,
&reader_listener,
if (reader == NULL) {
fprintf(stderr, "create_datareader error\n");
goto done;
}
/* Main loop */
for (count=0; (args->sample_count == 0) || (count < args->sample_count); ++count) {
printf("HelloWorld subscriber sleeping for %d sec...\n",
poll_period.sec);
fflush(stdout);
NDDS_Utility_sleep(&poll_period);
}
result = 0;
done:
/* Cleanup any resource allocated with Domain Participant QoS */
retcode = DDS_DomainParticipantQos_finalize(&domain_participant_qos);
if (retcode != DDS_RETCODE_OK) {
fprintf(stderr,
"DDS_DomainParticipantQos_finalize error %d\n",
retcode);
result = -1;
}
/* Cleanup and delete delete all entities */
if (subscriber_shutdown(participant) != 0) {
fprintf(stderr, "subscriber_shutdown error\n");
result = -1;
}
return result;
}
int main(int argc, const char **argv)
{
struct CmdLineArgs args;
if (!parseCmdline(&args, argc, argv)) {
return 1;
}
if (args.verbose > 1) {
/*
NDDS_Config_Logger_set_verbosity_by_category(
NDDS_Config_Logger_get_instance(),
NDDS_CONFIG_LOG_CATEGORY_COMMUNICATION,
NDDS_CONFIG_LOG_VERBOSITY_STATUS_ALL);
*/
}
return subscriber_main(&args);
}
#define DDS_TheParticipantFactory
DDS_ReturnCode_t DDS_DomainParticipantFactory_delete_participant(DDS_DomainParticipantFactory *self, DDS_DomainParticipant *a_participant)
DDS_DomainParticipant * DDS_DomainParticipantFactory_create_participant(DDS_DomainParticipantFactory *self, DDS_DomainId_t domainId, const struct DDS_DomainParticipantQos *qos, const struct DDS_DomainParticipantListener *listener, DDS_StatusMask mask)
DDS_ReturnCode_t DDS_DomainParticipantFactory_get_default_participant_qos(DDS_DomainParticipantFactory *self, struct DDS_DomainParticipantQos *qos)
struct DDS_DomainParticipantImpl DDS_DomainParticipant
#define DDS_DomainParticipantQos_INITIALIZER
const struct DDS_SubscriberQos DDS_SUBSCRIBER_QOS_DEFAULT
const struct DDS_TopicQos DDS_TOPIC_QOS_DEFAULT
DDS_ReturnCode_t DDS_DomainParticipantQos_finalize(struct DDS_DomainParticipantQos *self)
DDS_Subscriber * DDS_DomainParticipant_create_subscriber(DDS_DomainParticipant *self, const struct DDS_SubscriberQos *qos, const struct DDS_SubscriberListener *listener, DDS_StatusMask mask)
DDS_Topic * DDS_DomainParticipant_create_topic(DDS_DomainParticipant *self, const char *topic_name, const char *type_name, const struct DDS_TopicQos *qos, const struct DDS_TopicListener *listener, DDS_StatusMask mask)
DDS_ReturnCode_t DDS_DomainParticipant_delete_contained_entities(DDS_DomainParticipant *self)
const DDS_InstanceStateMask DDS_ANY_INSTANCE_STATE
NDDS_Config_Logger * NDDS_Config_Logger_get_instance(void)
void NDDS_Config_Logger_set_verbosity(NDDS_Config_Logger *self, NDDS_Config_LogVerbosity verbosity)
NDDS_CONFIG_LOG_VERBOSITY_STATUS_ALL
struct DDS_DataReaderImpl DDS_DataReader
#define DDS_DataReaderListener_INITIALIZER
const DDS_Long DDS_LENGTH_UNLIMITED
DDS_ReturnCode_t
DDS_RETCODE_OK
DDS_RETCODE_NO_DATA
const DDS_SampleStateMask DDS_ANY_SAMPLE_STATE
#define DDS_SEQUENCE_INITIALIZER
#define DDS_STATUS_MASK_NONE
#define DDS_STATUS_MASK_ALL
const struct DDS_DataReaderQos DDS_DATAREADER_QOS_DEFAULT
DDS_DataReader * DDS_Subscriber_create_datareader(DDS_Subscriber *self, DDS_TopicDescription *topic, const struct DDS_DataReaderQos *qos, const struct DDS_DataReaderListener *listener, DDS_StatusMask mask)
struct DDS_SubscriberImpl DDS_Subscriber
DDS_TopicDescription * DDS_Topic_as_topicdescription(DDS_Topic *topic)
struct DDS_TopicWrapperI DDS_Topic
const DDS_ViewStateMask DDS_ANY_VIEW_STATE
void NDDS_Utility_sleep(const struct DDS_Duration_t *durationIn)
DDS_DataReaderListener_RequestedIncompatibleQosCallback on_requested_incompatible_qos
DDS_DataReaderListener_SampleRejectedCallback on_sample_rejected
DDS_DataReaderListener_SampleLostCallback on_sample_lost
DDS_DataReaderListener_DataAvailableCallback on_data_available
DDS_DataReaderListener_LivelinessChangedCallback on_liveliness_changed
DDS_DataReaderListener_SubscriptionMatchedCallback on_subscription_matched
DDS_DataReaderListener_RequestedDeadlineMissedCallback on_requested_deadline_missed