Index

Package: DDS.DataReader_Impl

Description

package DDS.DataReader_Impl is
(c) Copyright, Real-Time Innovations, $Date:: 2012-02-16 #$ All rights reserved. No duplications, whole or partial, manual or electronic, may be made without express written permission. Any such copies, or revisions thereof, must display this notice unaltered. This code contains trade secrets of Real-Time Innovations, Inc.

Classes

Ref 

type Ref is new DDS.Domain_Entity_Impl.Ref and DDS.DataReader.Ref with private;

Ancestors:

Immediate Children:

Primitive operations:

Call_ListnerT (Inherited)
Call_ListnerT
Call_ListnerT (Inherited)
Create_Querycondition (Inherited)
Create_Querycondition
Create_Querycondition (Inherited)
Create_Readcondition (Inherited)
Create_Readcondition
Create_Readcondition (Inherited)
Delete_Contained_Entities (Inherited)
Delete_Contained_Entities
Delete_Contained_Entities (Inherited)
Delete_Readcondition (Inherited)
Delete_Readcondition
Delete_Readcondition (Inherited)
Get_Datareader_Cache_Status
Get_Datareader_Cache_Status (Inherited)
Get_Datareader_Protocol_Status
Get_Datareader_Protocol_Status (Inherited)
Get_Key_Value
Get_Listener (Inherited)
Get_Listener
Get_Listener (Inherited)
Get_Liveliness_Changed_Status
Get_Liveliness_Changed_Status (Inherited)
Get_Matched_Publication_Data (Inherited)
Get_Matched_Publication_Data
Get_Matched_Publication_Data (Inherited)
Get_Matched_Publication_Datareader_Protocol_Status (Inherited)
Get_Matched_Publication_Datareader_Protocol_Status
Get_Matched_Publication_Datareader_Protocol_Status (Inherited)
Get_Matched_Publications (Inherited)
Get_Matched_Publications
Get_Matched_Publications (Inherited)
Get_Qos (Inherited)
Get_Qos (Inherited)
Get_Requested_Deadline_Missed_Status (Inherited)
Get_Requested_Deadline_Missed_Status
Get_Requested_Incompatible_Qos_Status (Inherited)
Get_Requested_Incompatible_Qos_Status
Get_Requested_Incompatible_Qos_Status (Inherited)
Get_Sample_Lost_Status (Inherited)
Get_Sample_Lost_Status
Get_Sample_Lost_Status (Inherited)
Get_Sample_Rejected_Status (Inherited)
Get_Sample_Rejected_Status
Get_Sample_Rejected_Status (Inherited)
Get_Subscriber (Inherited)
Get_Subscriber (overriding Ref)
Get_Subscriber (Inherited)
Get_Subscription_Matched_Status (Inherited)
Get_Subscription_Matched_Status
Get_Subscription_Matched_Status (Inherited)
Get_Topicdescription (Inherited)
Get_Topicdescription
Get_Topicdescription (Inherited)
Is_Data_ConsistentI (Inherited)
Is_Data_ConsistentI
Is_Data_ConsistentI (Inherited)
Lookup_Instance
Read_Instance
Read_Next_Instance
Read_Next_Instance_W_Condition
Read_Next_Instance_W_Condition
Read_Next_Sample
Read_Or_Take_UntypedI
Read_Or_Take_UntypedI
Read_W_Condition
Read_W_Condition
Set_Listener (Inherited)
Set_Listener
Set_Listener (Inherited)
Set_Qos (Inherited)
Set_Qos (Inherited)
Set_Qos_With_Profile
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
Take_Instance
Take_Next_Instance
Take_Next_Instance_W_Condition
Take_Next_Instance_W_Condition
Take_Next_Sample
Take_W_Condition
Take_W_Condition
Wait_For_Historical_Data (Inherited)
Wait_For_Historical_Data
Wait_For_Historical_Data (Inherited)

Types

Ref_Access 

type Ref_Access is access all Ref'Class;

Subprograms & Entries

Create_Readcondition 

function Create_Readcondition 
(Self: not null access Ref;
Sample_States: in DDS.SampleStateMask;
View_States: in DDS.ViewStateMask;
Instance_States: in DDS.InstanceStateMask) return DDS.ReadCondition.Ref_Access;

Create_Querycondition 

function Create_Querycondition 
(Self: not null access Ref;
Sample_States: in DDS.SampleStateMask;
View_States: in DDS.ViewStateMask;
Instance_States: in DDS.InstanceStateMask;
Query_Expression: in DDS.String;
Query_Parameters: in DDS.String_Seq.Sequence) return DDS.QueryCondition.Ref_Access;

Delete_Readcondition 

procedure Delete_Readcondition 
(Self: not null access Ref;
A_Condition: access DDS.ReadCondition.Ref'Class);

Delete_Contained_Entities 

procedure  Delete_Contained_Entities 
(Self: not null access Ref);
Deletes all the entities that were created by means of the "create" operations on the DDS_DataReader. Deletes all contained DDS_ReadCondition and DDS_QueryCondition objects. Once DDS_DataReader_delete_contained_entities returns successfully, the application may delete the DDS_DataReader, knowing that it has no contained - DDS_ReadCondition and DDS_QueryCondition objects. rasies exception on error

Set_Qos 

procedure Set_Qos 
(Self: not null access Ref;
Qos: in DDS.DataReaderQoS);

Set_Qos_With_Profile 

procedure Set_Qos_With_Profile 
(Self: not null access Ref;
Library_Name: in String;
Profile_Name: in String);

Set_Qos_With_Profile 

procedure Set_Qos_With_Profile 
(Self: not null access Ref;
Library_Name: in Standard.String;
Profile_Name: in Standard.String);

Get_Qos 

procedure Get_Qos 
(Self: not null access Ref;
Qos: in out DDS.DataReaderQoS);

Set_Listener 

procedure Set_Listener 
(Self: not null access Ref;
A_Listener: in DDS.DataReaderListener.Ref_Access;
Mask: in DDS.StatusMask);

Get_Listener 

function Get_Listener 
(Self: not null access Ref) return DDS.DataReaderListener.Ref_Access;

Call_ListnerT 

procedure Call_ListnerT 
(Self: not null access Ref;
A_Listener: in DDS.DataReaderListener.Ref_Access;
Mask: in DDS.StatusMask);

Get_Topicdescription 

function Get_Topicdescription 
(Self: not null access Ref) return DDS.TopicDescription.Ref_Access;

Get_Subscriber 

function Get_Subscriber 
(Self: not null access Ref) return access DDS.Subscriber.Ref'Class;

Get_Sample_Rejected_Status 

procedure Get_Sample_Rejected_Status 
(Self: not null access Ref;
Status: in out DDS.SampleRejectedStatus);

Get_Liveliness_Changed_Status 

procedure Get_Liveliness_Changed_Status 
(Self: not null access Ref;
Status: in out DDS.LivelinessChangedStatus);

Get_Requested_Deadline_Missed_Status 

procedure Get_Requested_Deadline_Missed_Status 
(Self: not null access Ref;
Status: in out DDS.RequestedDeadlineMissedStatus);

Get_Requested_Incompatible_Qos_Status 

procedure Get_Requested_Incompatible_Qos_Status 
(Self: not null access Ref;
Status: in out DDS.RequestedIncompatibleQosStatus);

Get_Subscription_Matched_Status 

procedure Get_Subscription_Matched_Status 
(Self: not null access Ref;
Status: in out DDS.SubscriptionMatchedStatus);

Get_Sample_Lost_Status 

procedure Get_Sample_Lost_Status 
(Self: not null access Ref;
Status: in out DDS.SampleLostStatus);

Get_Datareader_Cache_Status 

procedure Get_Datareader_Cache_Status 
(Self: not null access Ref;
Status: in out DDS.DataReaderCacheStatus);

Get_Datareader_Protocol_Status 

procedure Get_Datareader_Protocol_Status 
(Self: not null access Ref;
Status: in out DDS.DataReaderProtocolStatus);

Get_Matched_Publication_Datareader_Protocol_Status 

procedure Get_Matched_Publication_Datareader_Protocol_Status 
(Self: not null access Ref;
Status: in out DDS.DataReaderProtocolStatus;
Publication_Handle: not null access DDS.InstanceHandle_T);

Wait_For_Historical_Data 

procedure Wait_For_Historical_Data 
(Self: not null access Ref;
Max_Wait: in DDS.Duration_T);

Get_Matched_Publications 

function Get_Matched_Publications 
(Self: not null access Ref) return DDS.InstanceHandle_Seq.Sequence;

Get_Matched_Publication_Data 

function Get_Matched_Publication_Data 
(Self: not null access Ref;
Publication_Handle: not null access DDS.InstanceHandle_T) return DDS.PublicationBuiltinTopicData;

Free 

procedure Free 
(This: in out Ref_Access);

CreateI 

function CreateI 
(Subscriber: not null DDS.Subscriber.Ref_Access;
Topic: not null access DDS.TopicDescription.Ref'Class;
Qos: in DDS.DataReaderQoS;
Listener: in DDS.DataReaderListener.Ref_Access;
Mask: in DDS.StatusMask) return DDS.DataReader.Ref_Access;

CreateI 

function CreateI 
(Subscriber: not null DDS.Subscriber.Ref_Access;
Topic: not null access DDS.TopicDescription.Ref'Class;
Library_Name: in DDS.String;
Profile_Name: in DDS.String;
Listener: in DDS.DataReaderListener.Ref_Access;
Mask: in DDS.StatusMask) return DDS.DataReader.Ref_Access;

Create_WrapperI 

function Create_WrapperI 
(Subscriber: not null DDS.Subscriber.Ref_Access;
C_DataReader: System.Address;
Topic: not null access DDS.Topic.Ref'Class) return Ref_Access;

Get_FacadeI 

function Get_FacadeI 
(C_DataReader: System.Address) return Ref_Access;

Read_Or_Take_UntypedI 

procedure Read_Or_Take_UntypedI 
(Self: not null access constant Ref;
Is_Loan: out DDS.Boolean;
Received_Data: System.Address;
Data_Count: out Natural;
Info_Seq: SampleInfo_Seq.Sequence_Access;
Data_Seq_Len: Long_Integer;
Data_Seq_Max_Len: Long_Integer;
Data_Seq_Has_Ownership: Long_Integer;
Data_Seq_Contiguous_Buffer_For_Copy: System.Address;
Data_Size: Integer;
Max_Samples: Long_Integer;
Sample_States: SampleStateMask;
View_States: ViewStateMask;
Instance_States: InstanceStateMask;
Take: DDS.Boolean);

Read_Or_Take_UntypedI 

function Read_Or_Take_UntypedI 
(Self: not null access constant Ref;
Is_Loan: access DDS.Boolean;
Received_Data: System.Address;
Data_Count: access Natural;
Info_Seq: SampleInfo_Seq.Sequence_Access;
Data_Seq_Len: Long_Integer;
Data_Seq_Max_Len: Long_Integer;
Data_Seq_Has_Ownership: Long_Integer;
Data_Seq_Contiguous_Buffer_For_Copy: System.Address;
Data_Size: Integer;
Max_Samples: Long_Integer;
Sample_States: SampleStateMask;
View_States: ViewStateMask;
Instance_States: InstanceStateMask;
Take: DDS.Boolean) return DDS_ReturnCode_t;

ReadI 

procedure ReadI 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Sample_States: in Standard.DDS.SampleStateMask := Standard.DDS.ANY_SAMPLE_STATE;
View_States: in Standard.DDS.ViewStateMask := Standard.DDS.ANY_VIEW_STATE;
Instance_States: in Standard.DDS.InstanceStateMask := Standard.DDS.ANY_INSTANCE_STATE);

TakeI 

procedure TakeI 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Sample_States: in Standard.DDS.SampleStateMask := Standard.DDS.ANY_SAMPLE_STATE;
View_States: in Standard.DDS.ViewStateMask := Standard.DDS.ANY_VIEW_STATE;
Instance_States: in Standard.DDS.InstanceStateMask := Standard.DDS.ANY_INSTANCE_STATE);

Read_W_Condition 

procedure Read_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Condition: access Standard.DDS.ReadCondition.Ref'Class);

Read_W_Condition 

function Read_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Condition: access Standard.DDS.ReadCondition.Ref'Class) return DDS_ReturnCode_t;

Take_W_Condition 

procedure Take_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Condition: access Standard.DDS.ReadCondition.Ref'Class);

Take_W_Condition 

function Take_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Condition: access Standard.DDS.ReadCondition.Ref'Class) return DDS_ReturnCode_t;

Read_Next_Sample 

procedure Read_Next_Sample 
(Self: not null access Ref;
Received_Data: System.Address;
Sample_Info: not null access Standard.DDS.SampleInfo);

Take_Next_Sample 

procedure Take_Next_Sample 
(Self: not null access Ref;
Received_Data: System.Address;
Sample_Info: not null access Standard.DDS.SampleInfo);

Read_Instance 

procedure Read_Instance 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
A_Handle: access constant Standard.DDS.InstanceHandle_T;
Sample_States: in Standard.DDS.SampleStateMask := Standard.DDS.ANY_SAMPLE_STATE;
View_States: in Standard.DDS.ViewStateMask := Standard.DDS.ANY_VIEW_STATE;
Instance_States: in Standard.DDS.InstanceStateMask := Standard.DDS.ANY_INSTANCE_STATE);

Take_Instance 

procedure Take_Instance 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
A_Handle: access constant Standard.DDS.InstanceHandle_T;
Sample_States: in Standard.DDS.SampleStateMask := Standard.DDS.ANY_SAMPLE_STATE;
View_States: in Standard.DDS.ViewStateMask := Standard.DDS.ANY_VIEW_STATE;
Instance_States: in Standard.DDS.InstanceStateMask := Standard.DDS.ANY_INSTANCE_STATE);

Read_Next_Instance 

procedure Read_Next_Instance 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Previous_Handle: access constant Standard.DDS.InstanceHandle_T;
Sample_States: in Standard.DDS.SampleStateMask := Standard.DDS.ANY_SAMPLE_STATE;
View_States: in Standard.DDS.ViewStateMask := Standard.DDS.ANY_VIEW_STATE;
Instance_States: in Standard.DDS.InstanceStateMask := Standard.DDS.ANY_INSTANCE_STATE);

Take_Next_Instance 

procedure Take_Next_Instance 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Previous_Handle: access constant Standard.DDS.InstanceHandle_T;
Sample_States: in Standard.DDS.SampleStateMask := Standard.DDS.ANY_SAMPLE_STATE;
View_States: in Standard.DDS.ViewStateMask := Standard.DDS.ANY_VIEW_STATE;
Instance_States: in Standard.DDS.InstanceStateMask := Standard.DDS.ANY_INSTANCE_STATE);

Read_Next_Instance_W_Condition 

procedure Read_Next_Instance_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Previous_Handle: access constant Standard.DDS.InstanceHandle_T;
Condition: Standard.DDS.ReadCondition.Ref_Access);

Read_Next_Instance_W_Condition 

function Read_Next_Instance_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Previous_Handle: access constant Standard.DDS.InstanceHandle_T;
Condition: Standard.DDS.ReadCondition.Ref_Access) return DDS_ReturnCode_t;

Take_Next_Instance_W_Condition 

procedure Take_Next_Instance_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Previous_Handle: access constant Standard.DDS.InstanceHandle_T;
Condition: Standard.DDS.ReadCondition.Ref_Access);

Take_Next_Instance_W_Condition 

function Take_Next_Instance_W_Condition 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence;
Max_Samples: in Standard.DDS.Long := Standard.DDS.LENGTH_UNLIMITED;
Previous_Handle: access constant Standard.DDS.InstanceHandle_T;
Condition: Standard.DDS.ReadCondition.Ref_Access) return DDS_ReturnCode_t;

Return_Loan 

procedure Return_Loan 
(Self: not null access Ref;
Received_Data: System.Address;
Info_Seq: not null access Standard.DDS.SampleInfo_Seq.Sequence);

Get_Key_Value 

procedure Get_Key_Value 
(Self: not null access Ref;
Key_Holder: System.Address;
Handle: access constant Standard.DDS.InstanceHandle_T);

Lookup_Instance 

function Lookup_Instance 
(Self: not null access Ref;
Key_Holder: System.Address) return Standard.DDS.InstanceHandle_T;

Is_Data_ConsistentI 

function Is_Data_ConsistentI 
(Self: not null access constant Ref;
Sample: System.Address;
Sample_Info: not null DDS.SampleInfo_Access;
MetpImpl: DDS.MetpTypeSupport.Unsupported'Class) return Standard.Boolean;

Finalize_Callback 

procedure Finalize_Callback 
(Arg1: System.Address;
Arg2: System.Address;
Arg3: access RTIDDS.Low_Level.ndds_reda_reda_worker_impl_h.REDAWorker);