Index

Package: DDS.Subscriber_Impl

Description

package DDS.Subscriber_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.Subscriber.Ref with private;

Ancestors:

Primitive operations:

Begin_Access (overriding Begin_Access)
Copy_From_Topic_Qos (overriding Copy_From_Topic_Qos)
Create_DataReader (overriding Create_DataReader)
Create_DataReader_With_Profile (overriding Create_DataReader_With_Profile)
Create_DataReader_With_Profile (overriding Create_DataReader_With_Profile)
Delete_Contained_Entities (overriding Delete_Contained_Entities)
Delete_DataReader (overriding Delete_DataReader)
Enable (Inherited)
End_Access (overriding End_Access)
Get_DataReaders (overriding Get_DataReaders)
Get_Default_DataReader_Qos (overriding Get_Default_DataReader_Qos)
Get_Default_Library (overriding Get_Default_Library)
Get_Default_Profile (overriding Get_Default_Profile)
Get_Default_Profile_Library (overriding Get_Default_Profile_Library)
Get_Entity_Kind (Inherited)
Get_Instance_Handle (Inherited)
Get_Listener (overriding Get_Listener)
Get_Participant (overriding Get_Participant)
Get_Qos (overriding Get_Qos)
Get_Status_Changes (Inherited)
Get_StatusCondition (Inherited)
Lookup_DataReader (overriding Lookup_DataReader)
Notify_DataReaders (overriding Notify_DataReaders)
Set_Default_DataReader_Qos (overriding Set_Default_DataReader_Qos)
Set_Default_DataReader_Qos_With_Profile (overriding Set_Default_DataReader_Qos_With_Profile)
Set_Default_DataReader_Qos_With_Profile (overriding Set_Default_DataReader_Qos_With_Profile)
Set_Default_Library (overriding Set_Default_Library)
Set_Default_Profile (overriding Set_Default_Profile)
Set_Listener (overriding Set_Listener)
Set_Qos (overriding Set_Qos)
Set_Qos_With_Profile (overriding Set_Qos_With_Profile)
Set_Qos_With_Profile (overriding Set_Qos_With_Profile)

Types

Ref_Access 

type Ref_Access is access all Ref'Class;

Subprograms & Entries

Create_DataReader 

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

Create_DataReader_With_Profile 

function Create_DataReader_With_Profile 
(Self: not null access Ref;
Topic: not null access DDS.TopicDescription.Ref'Class;
Library_Name: in DDS.String;
profile_name: in DDS.String;
A_Listener: in DDS.DataReaderListener.Ref_Access := null;
Mask: in DDS.StatusMask := STATUS_MASK_NONE) return DDS.DataReader.Ref_Access;

Create_DataReader_With_Profile 

function Create_DataReader_With_Profile 
(Self: not null access Ref;
Topic: not null access DDS.TopicDescription.Ref'Class;
Library_Name: in Standard.String;
profile_name: in Standard.String;
A_Listener: in DDS.DataReaderListener.Ref_Access := null;
Mask: in DDS.StatusMask := STATUS_MASK_NONE) return DDS.DataReader.Ref_Access;

Delete_DataReader 

procedure Delete_DataReader 
(Self: not null access Ref;
A_DataReader: in out DDS.DataReader.Ref_Access);

Delete_Contained_Entities 

procedure Delete_Contained_Entities 
(Self: not null access Ref);

Lookup_DataReader 

function Lookup_DataReader 
(Self: not null access Ref;
Topic_Name: in DDS.String) return DDS.DataReader.Ref_Access;

Get_DataReaders 

procedure Get_DataReaders 
(Self: not null access Ref;
Readers: not null access DDS.DataReaderSeq.Sequence;
Sample_States: in DDS.SampleStateKind;
View_States: in DDS.ViewStateKind;
Instance_States: in DDS.InstanceStateKind);

Notify_DataReaders 

procedure Notify_DataReaders 
(Self: not null access Ref);

Set_Qos 

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

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.SubscriberQos);

Set_Listener 

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

Get_Listener 

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

Begin_Access 

procedure Begin_Access 
(Self: not null access Ref);

End_Access 

procedure End_Access 
(Self: not null access Ref);

Get_Participant 

function Get_Participant 
(Self: not null access Ref) return access DDS.DomainParticipant.Ref'Class;

Set_Default_DataReader_Qos 

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

Set_Default_DataReader_Qos_With_Profile 

procedure Set_Default_DataReader_Qos_With_Profile 
(Self: not null access Ref;
libName: DDS.String;
profName: DDS.String);

Set_Default_DataReader_Qos_With_Profile 

procedure Set_Default_DataReader_Qos_With_Profile 
(Self: not null access Ref;
libName: Standard.String;
profName: Standard.String);

Get_Default_DataReader_Qos 

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

Copy_From_Topic_Qos 

procedure Copy_From_Topic_Qos 
(Self: not null access Ref;
A_DataReader_Qos: in out DDS.DataReaderQoS;
A_Topic_Qos: in DDS.TopicQos);

Set_Default_Profile 

procedure Set_Default_Profile 
(Self: not null access Ref;
library_name: DDS.String;
profile_name: DDS.String);

Set_Default_Library 

procedure Set_Default_Library 
(Self: not null access Ref;
library_name: DDS.String);

Get_Default_Library 

function Get_Default_Library 
(Self: not null access Ref) return DDS.String;

Get_Default_Profile 

function Get_Default_Profile 
(Self: not null access Ref) return DDS.String;

Get_Default_Profile_Library 

function Get_Default_Profile_Library 
(Self: not null access Ref) return DDS.String;

Free 

procedure Free 
(This: in out Ref_Access);

CreateI 

function CreateI 
(Participant: in DDS.DomainParticipant.Ref_Access;
Qos: in DDS.SubscriberQos;
A_Listener: in DDS.SubscriberListener.Ref_Access;
Mask: in DDS.StatusMask) return DDS.Subscriber.Ref_Access;

Create_WrapperI 

function Create_WrapperI 
(C_Subscriber: System.Address) return DDS.Subscriber_Impl.Ref_Access;

Get_FacadeI 

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

Finalize_Callback 

procedure Finalize_Callback 
(arg1: System.Address;
arg2: System.Address;
arg3: access RTIDDS.Low_Level.reda.worker_impl_h.REDAWorker);