DDS

Class _TopicBuiltinTopicDataDataReaderTAOPeer

java.lang.Object

i2jrt.TAOObject

i2jrt.TAOLocalObject

DDS._TopicBuiltinTopicDataDataReaderTAOPeer

All Implemented Interfaces:

DataReader, DataReaderOperations, Entity, EntityOperations, TopicBuiltinTopicDataDataReader, TopicBuiltinTopicDataDataReaderOperations, DataReaderEx, DataReaderExOperations, org.omg.CORBA.Object

public class _TopicBuiltinTopicDataDataReaderTAOPeer
extends i2jrt.TAOLocalObject
implements TopicBuiltinTopicDataDataReader

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	_TopicBuiltinTopicDataDataReaderTAOPeer(long ptr)

Method Summary

Methods

Modifier and Type	Method and Description
QueryCondition	create_querycondition(int sample_states, int view_states, int instance_states, java.lang.String query_expression, java.lang.String[] query_parameters)
ReadCondition	create_readcondition(int sample_states, int view_states, int instance_states)
int	delete_contained_entities()
int	delete_readcondition(ReadCondition a_condition)
int	enable()
int	get_instance_handle()
int	get_key_value(TopicBuiltinTopicDataHolder key_holder, int handle)
void	get_latency_stats(LatencyStatisticsSeqHolder stats)
DataReaderListener	get_listener()
int	get_liveliness_changed_status(LivelinessChangedStatusHolder status)
int	get_matched_publication_data(PublicationBuiltinTopicDataHolder publication_data, int publication_handle)
int	get_matched_publications(InstanceHandleSeqHolder publication_handles)
int	get_qos(DataReaderQosHolder qos)
int	get_requested_deadline_missed_status(RequestedDeadlineMissedStatusHolder status)
int	get_requested_incompatible_qos_status(RequestedIncompatibleQosStatusHolder status)
int	get_sample_lost_status(SampleLostStatusHolder status)
int	get_sample_rejected_status(SampleRejectedStatusHolder status)
int	get_status_changes()
StatusCondition	get_statuscondition()
Subscriber	get_subscriber()
int	get_subscription_matched_status(SubscriptionMatchedStatusHolder status)
TopicDescription	get_topicdescription()
int	lookup_instance(TopicBuiltinTopicData instance_data)
int	read_instance_w_condition(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder sample_infos, int max_samples, int a_handle, ReadCondition a_condition)
int	read_instance(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
int	read_next_instance_w_condition(TopicBuiltinTopicDataSeqHolder data_values, SampleInfoSeqHolder sample_infos, int max_samples, int previous_handle, ReadCondition a_condition)
int	read_next_instance(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
int	read_next_sample(TopicBuiltinTopicDataHolder received_data, SampleInfoHolder sample_info)
int	read_w_condition(TopicBuiltinTopicDataSeqHolder data_values, SampleInfoSeqHolder sample_infos, int max_samples, ReadCondition a_condition)
int	read(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int sample_states, int view_states, int instance_states)
void	reset_latency_stats()
int	return_loan(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder info_seq)
int	set_listener(DataReaderListener a_listener, int mask)
int	set_qos(DataReaderQos qos)
boolean	statistics_enabled()
void	statistics_enabled(boolean statistics_enabled)
int	take_instance_w_condition(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder sample_infos, int max_samples, int a_handle, ReadCondition a_condition)
int	take_instance(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
int	take_next_instance_w_condition(TopicBuiltinTopicDataSeqHolder data_values, SampleInfoSeqHolder sample_infos, int max_samples, int previous_handle, ReadCondition a_condition)
int	take_next_instance(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
int	take_next_sample(TopicBuiltinTopicDataHolder received_data, SampleInfoHolder sample_info)
int	take_w_condition(TopicBuiltinTopicDataSeqHolder data_values, SampleInfoSeqHolder sample_infos, int max_samples, ReadCondition a_condition)
int	take(TopicBuiltinTopicDataSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int sample_states, int view_states, int instance_states)
int	wait_for_historical_data(Duration_t max_wait)

Methods inherited from class i2jrt.TAOLocalObject

_non_existent

Methods inherited from class i2jrt.TAOObject

_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_policy, _hash, _is_a, _is_equivalent, _release, _request, _set_policy_override, equals, finalize, hashCode

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.omg.CORBA.Object

_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_policy, _hash, _is_a, _is_equivalent, _non_existent, _release, _request, _set_policy_override

Constructor Detail

_TopicBuiltinTopicDataDataReaderTAOPeer

protected _TopicBuiltinTopicDataDataReaderTAOPeer(long ptr)

Method Detail

read

public int read(TopicBuiltinTopicDataSeqHolder received_data,
       SampleInfoSeqHolder info_seq,
       int max_samples,
       int sample_states,
       int view_states,
       int instance_states)

Specified by:

read in interface TopicBuiltinTopicDataDataReaderOperations

take

public int take(TopicBuiltinTopicDataSeqHolder received_data,
       SampleInfoSeqHolder info_seq,
       int max_samples,
       int sample_states,
       int view_states,
       int instance_states)

Specified by:

take in interface TopicBuiltinTopicDataDataReaderOperations

read_w_condition

public int read_w_condition(TopicBuiltinTopicDataSeqHolder data_values,
                   SampleInfoSeqHolder sample_infos,
                   int max_samples,
                   ReadCondition a_condition)

Specified by:

read_w_condition in interface TopicBuiltinTopicDataDataReaderOperations

take_w_condition

public int take_w_condition(TopicBuiltinTopicDataSeqHolder data_values,
                   SampleInfoSeqHolder sample_infos,
                   int max_samples,
                   ReadCondition a_condition)

Specified by:

take_w_condition in interface TopicBuiltinTopicDataDataReaderOperations

read_next_sample

public int read_next_sample(TopicBuiltinTopicDataHolder received_data,
                   SampleInfoHolder sample_info)

Specified by:

read_next_sample in interface TopicBuiltinTopicDataDataReaderOperations

take_next_sample

public int take_next_sample(TopicBuiltinTopicDataHolder received_data,
                   SampleInfoHolder sample_info)

Specified by:

take_next_sample in interface TopicBuiltinTopicDataDataReaderOperations

read_instance

public int read_instance(TopicBuiltinTopicDataSeqHolder received_data,
                SampleInfoSeqHolder info_seq,
                int max_samples,
                int a_handle,
                int sample_states,
                int view_states,
                int instance_states)

Specified by:

read_instance in interface TopicBuiltinTopicDataDataReaderOperations

take_instance

public int take_instance(TopicBuiltinTopicDataSeqHolder received_data,
                SampleInfoSeqHolder info_seq,
                int max_samples,
                int a_handle,
                int sample_states,
                int view_states,
                int instance_states)

Specified by:

take_instance in interface TopicBuiltinTopicDataDataReaderOperations

read_instance_w_condition

public int read_instance_w_condition(TopicBuiltinTopicDataSeqHolder received_data,
                            SampleInfoSeqHolder sample_infos,
                            int max_samples,
                            int a_handle,
                            ReadCondition a_condition)

Specified by:

read_instance_w_condition in interface TopicBuiltinTopicDataDataReaderOperations

take_instance_w_condition

public int take_instance_w_condition(TopicBuiltinTopicDataSeqHolder received_data,
                            SampleInfoSeqHolder sample_infos,
                            int max_samples,
                            int a_handle,
                            ReadCondition a_condition)

Specified by:

take_instance_w_condition in interface TopicBuiltinTopicDataDataReaderOperations

read_next_instance

public int read_next_instance(TopicBuiltinTopicDataSeqHolder received_data,
                     SampleInfoSeqHolder info_seq,
                     int max_samples,
                     int a_handle,
                     int sample_states,
                     int view_states,
                     int instance_states)

Specified by:

read_next_instance in interface TopicBuiltinTopicDataDataReaderOperations

take_next_instance

public int take_next_instance(TopicBuiltinTopicDataSeqHolder received_data,
                     SampleInfoSeqHolder info_seq,
                     int max_samples,
                     int a_handle,
                     int sample_states,
                     int view_states,
                     int instance_states)

Specified by:

take_next_instance in interface TopicBuiltinTopicDataDataReaderOperations

read_next_instance_w_condition

public int read_next_instance_w_condition(TopicBuiltinTopicDataSeqHolder data_values,
                                 SampleInfoSeqHolder sample_infos,
                                 int max_samples,
                                 int previous_handle,
                                 ReadCondition a_condition)

Specified by:

read_next_instance_w_condition in interface TopicBuiltinTopicDataDataReaderOperations

take_next_instance_w_condition

public int take_next_instance_w_condition(TopicBuiltinTopicDataSeqHolder data_values,
                                 SampleInfoSeqHolder sample_infos,
                                 int max_samples,
                                 int previous_handle,
                                 ReadCondition a_condition)

Specified by:

take_next_instance_w_condition in interface TopicBuiltinTopicDataDataReaderOperations

return_loan

public int return_loan(TopicBuiltinTopicDataSeqHolder received_data,
              SampleInfoSeqHolder info_seq)

Specified by:

return_loan in interface TopicBuiltinTopicDataDataReaderOperations

get_key_value

public int get_key_value(TopicBuiltinTopicDataHolder key_holder,
                int handle)

Specified by:

get_key_value in interface TopicBuiltinTopicDataDataReaderOperations

lookup_instance

public int lookup_instance(TopicBuiltinTopicData instance_data)

Specified by:

lookup_instance in interface TopicBuiltinTopicDataDataReaderOperations

get_latency_stats

public void get_latency_stats(LatencyStatisticsSeqHolder stats)

Specified by:

get_latency_stats in interface DataReaderExOperations

reset_latency_stats

public void reset_latency_stats()

Specified by:

reset_latency_stats in interface DataReaderExOperations

statistics_enabled

public boolean statistics_enabled()

Specified by:

statistics_enabled in interface DataReaderExOperations

statistics_enabled

public void statistics_enabled(boolean statistics_enabled)

Specified by:

statistics_enabled in interface DataReaderExOperations

create_readcondition

public ReadCondition create_readcondition(int sample_states,
                                 int view_states,
                                 int instance_states)

Specified by:

create_readcondition in interface DataReaderOperations

create_querycondition

public QueryCondition create_querycondition(int sample_states,
                                   int view_states,
                                   int instance_states,
                                   java.lang.String query_expression,
                                   java.lang.String[] query_parameters)

Specified by:

create_querycondition in interface DataReaderOperations

delete_readcondition

public int delete_readcondition(ReadCondition a_condition)

Specified by:

delete_readcondition in interface DataReaderOperations

delete_contained_entities

public int delete_contained_entities()

Specified by:

delete_contained_entities in interface DataReaderOperations

set_qos

public int set_qos(DataReaderQos qos)

Specified by:

set_qos in interface DataReaderOperations

get_qos

public int get_qos(DataReaderQosHolder qos)

Specified by:

get_qos in interface DataReaderOperations

set_listener

public int set_listener(DataReaderListener a_listener,
               int mask)

Specified by:

set_listener in interface DataReaderOperations

get_listener

public DataReaderListener get_listener()

Specified by:

get_listener in interface DataReaderOperations

get_topicdescription

public TopicDescription get_topicdescription()

Specified by:

get_topicdescription in interface DataReaderOperations

get_subscriber

public Subscriber get_subscriber()

Specified by:

get_subscriber in interface DataReaderOperations

get_sample_rejected_status

public int get_sample_rejected_status(SampleRejectedStatusHolder status)

Specified by:

get_sample_rejected_status in interface DataReaderOperations

get_liveliness_changed_status

public int get_liveliness_changed_status(LivelinessChangedStatusHolder status)

Specified by:

get_liveliness_changed_status in interface DataReaderOperations

get_requested_deadline_missed_status

public int get_requested_deadline_missed_status(RequestedDeadlineMissedStatusHolder status)

Specified by:

get_requested_deadline_missed_status in interface DataReaderOperations

get_requested_incompatible_qos_status

public int get_requested_incompatible_qos_status(RequestedIncompatibleQosStatusHolder status)

Specified by:

get_requested_incompatible_qos_status in interface DataReaderOperations

get_subscription_matched_status

public int get_subscription_matched_status(SubscriptionMatchedStatusHolder status)

Specified by:

get_subscription_matched_status in interface DataReaderOperations

get_sample_lost_status

public int get_sample_lost_status(SampleLostStatusHolder status)

Specified by:

get_sample_lost_status in interface DataReaderOperations

wait_for_historical_data

public int wait_for_historical_data(Duration_t max_wait)

Specified by:

wait_for_historical_data in interface DataReaderOperations

get_matched_publications

public int get_matched_publications(InstanceHandleSeqHolder publication_handles)

Specified by:

get_matched_publications in interface DataReaderOperations

get_matched_publication_data

public int get_matched_publication_data(PublicationBuiltinTopicDataHolder publication_data,
                               int publication_handle)

Specified by:

get_matched_publication_data in interface DataReaderOperations

enable

public int enable()

Specified by:

enable in interface EntityOperations

get_statuscondition

public StatusCondition get_statuscondition()

Specified by:

get_statuscondition in interface EntityOperations

get_status_changes

public int get_status_changes()

Specified by:

get_status_changes in interface EntityOperations

get_instance_handle

public int get_instance_handle()

Specified by:

get_instance_handle in interface EntityOperations