CoreDX Data Distribution Service
The High Performance, Small Footprint DDS from Twin Oaks Computing, Inc
com.toc.coredx.dynamictype.DynamicDataWriter Class Reference

A DynamicDataWriter process data samples in DynamicData form. More...

Inheritance diagram for com.toc.coredx.dynamictype.DynamicDataWriter:
com.toc.coredx.DDS.DataWriter com.toc.coredx.DDS.DomainEntity com.toc.coredx.DDS.Entity

Public Member Functions

InstanceHandle_t register_instance (DynamicData instance_data)
 
InstanceHandle_t register_instance_w_timestamp (DynamicData instance_data, Time_t ts)
 
ReturnCode_t unregister_instance (DynamicData instance_data, InstanceHandle_t handle)
 
ReturnCode_t unregister_instance_w_timestamp (DynamicData instance_data, InstanceHandle_t handle, Time_t timestamp)
 
ReturnCode_t write (DynamicData instance_data, InstanceHandle_t handle)
 
ReturnCode_t write_w_timestamp (DynamicData instance_data, InstanceHandle_t handle, Time_t timestamp)
 
ReturnCode_t dispose (DynamicData instance_data, InstanceHandle_t handle)
 
ReturnCode_t dispose_w_timestamp (DynamicData instance_data, InstanceHandle_t handle, Time_t timestamp)
 
ReturnCode_t get_key_value (DynamicData key_holder, InstanceHandle_t handle)
 
InstanceHandle_t lookup_instance (DynamicData instance_data)
 
- Public Member Functions inherited from com.toc.coredx.DDS.DataWriter
ReturnCode_t enable ()
 
ReturnCode_t set_qos (DataWriterQos qos)
 
ReturnCode_t get_qos (DataWriterQos qos)
 
ReturnCode_t set_listener (DataWriterListener new_listener, long mask)
 
DataWriterListener get_listener ()
 
Topic get_topic ()
 
Publisher get_publisher ()
 
ReturnCode_t wait_for_acknowledgments (Duration_t max_wait)
 Block until this writer has received acknowledgements for all written data. More...
 
ReturnCode_t assert_liveliness ()
 
ReturnCode_t get_liveliness_lost_status (LivelinessLostStatus status)
 
ReturnCode_t get_offered_deadline_missed_status (OfferedDeadlineMissedStatus status)
 
ReturnCode_t get_offered_incompatible_qos_status (OfferedIncompatibleQosStatus status)
 
ReturnCode_t get_publication_matched_status (PublicationMatchedStatus status)
 
ReturnCode_t get_matched_subscriptions (InstanceHandleSeq subscription_handles)
 
ReturnCode_t get_matched_subscription_data (SubscriptionBuiltinTopicData subscription_data, InstanceHandle_t subscription_handle)
 
ReturnCode_t get_guid (GUID_t g)
 Access the GUID which uniquely identifies this writer.
 
- Public Member Functions inherited from com.toc.coredx.DDS.Entity
StatusCondition get_statuscondition ()
 
int get_status_changes ()
 
ReturnCode_t enable ()
 
InstanceHandle_t get_instance_handle ()
 

Detailed Description

A DynamicDataWriter process data samples in DynamicData form.

Member Function Documentation

◆ dispose()

ReturnCode_t com.toc.coredx.dynamictype.DynamicDataWriter.dispose ( DynamicData  instance_data,
InstanceHandle_t  handle 
)

Indicates that the instance no longer exists. If handle is not HANDLE_NIL, then handle must identify a valid instance that has been previously registered or written by this DataWriter. The current time is used as the source timstamp.

◆ dispose_w_timestamp()

ReturnCode_t com.toc.coredx.dynamictype.DynamicDataWriter.dispose_w_timestamp ( DynamicData  instance_data,
InstanceHandle_t  handle,
Time_t  timestamp 
)

Indicates that the instance no longer exists. If handle is not HANDLE_NIL, then handle must identify a valid instance that has been previously registered or written by this DataWriter. The source_timestamp is used as the source timstamp for the published message.

◆ get_key_value()

ReturnCode_t com.toc.coredx.dynamictype.DynamicDataWriter.get_key_value ( DynamicData  key_holder,
InstanceHandle_t  handle 
)

This routine will populate the data structure indicated by key_holder with the key infomation identified by handle.

◆ lookup_instance()

InstanceHandle_t com.toc.coredx.dynamictype.DynamicDataWriter.lookup_instance ( DynamicData  instance_data)

Returns the handle that identifies the data instance provided in instance_data. The 'key' field values of the data are associated with a unique handle.

◆ register_instance()

InstanceHandle_t com.toc.coredx.dynamictype.DynamicDataWriter.register_instance ( DynamicData  instance_data)

Declares the existance of an instance identified by the 'key fields' in instance_data. The handle that uniquely identifies the instance is returned. The current time is used as the source timestamp.

◆ register_instance_w_timestamp()

InstanceHandle_t com.toc.coredx.dynamictype.DynamicDataWriter.register_instance_w_timestamp ( DynamicData  instance_data,
Time_t  ts 
)

Declares the existance of an instance identified by the 'key fields' in instance_data. The handle that uniquely identifies the instance is returned. The source_timestamp is used as the source timestamp.

◆ unregister_instance()

ReturnCode_t com.toc.coredx.dynamictype.DynamicDataWriter.unregister_instance ( DynamicData  instance_data,
InstanceHandle_t  handle 
)

Indicates that the writer will no longer be providing updates the specified instance. If handle is not HANDLE_NIL, then handle must identify a valid instance that has been previously registered or written by this DataWriter. The current time is used as the source timstamp.

◆ unregister_instance_w_timestamp()

ReturnCode_t com.toc.coredx.dynamictype.DynamicDataWriter.unregister_instance_w_timestamp ( DynamicData  instance_data,
InstanceHandle_t  handle,
Time_t  timestamp 
)

Indicates that the writer will no longer be providing updates the specified instance. If handle is not HANDLE_NIL, then handle must identify a valid instance that has been previously registered or written by this DataWriter. The provided source_timestamp is used as the source timstamp.

◆ write()

ReturnCode_t com.toc.coredx.dynamictype.DynamicDataWriter.write ( DynamicData  instance_data,
InstanceHandle_t  handle 
)

Publishes the provided instance_data. If handle is HANDLE_NIL, then the handle is determined from the 'key fields' of instance_data.

The current time is used as the source timestamp for the published data.

This routine may block if RELIABILITY kind == RELIABLE, RESOURCE_LIMITS are not UNLIMITED, and the local resources are exhausted. The routine will block at most 'max_blocking_time' as configured in the RELIABLITY QoS. If the routine is still unable to handle the data, after blocking, then RETCODE_TIMEOUT is returned.

The routine may return RETCODE_OUT_OF_RESOURCES if it is determined that no amount of blocking will allow the data to be processed.

On success, RETCODE_OK is returned.

◆ write_w_timestamp()

ReturnCode_t com.toc.coredx.dynamictype.DynamicDataWriter.write_w_timestamp ( DynamicData  instance_data,
InstanceHandle_t  handle,
Time_t  timestamp 
)

Publishes the provided instance_data. If handle is HANDLE_NIL, then the handle is determined from the 'key fields' of instance_data.

The source_timestamp is used as the source timestamp for the published data.

This routine may block if RELIABILITY kind == RELIABLE, RESOURCE_LIMITS are not UNLIMITED, and the local resources are exhausted. The routine will block at most 'max_blocking_time' as configured in the RELIABLITY QoS. If the routine is still unable to handle the data, after blocking, then RETCODE_TIMEOUT is returned.

The routine may return RETCODE_OUT_OF_RESOURCES if it is determined that no amount of blocking will allow the data to be processed.

On success, RETCODE_OK is returned.


© 2009-2020 Twin Oaks Computing, Inc
Castle Rock, CO 80104
All rights reserved.