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
Begin_Access (Inherited)
call_listener (Inherited)
call_listener
Copy_From_Topic_Qos
Copy_From_Topic_Qos (Inherited)
Create_DataReader
Create_DataReader (Inherited)
Create_DataReader_With_Profile
Create_DataReader_With_Profile
Create_DataReader_With_Profile (Inherited)
Create_DataReader_With_Profile (Inherited)
Delete_Contained_Entities
Delete_Contained_Entities (Inherited)
Delete_DataReader (Inherited)
Delete_DataReader
End_Access (Inherited)
Get_DataReaders
Get_DataReaders (Inherited)
Get_Default_DataReader_Qos (Inherited)
Get_Default_DataReader_Qos
Get_Default_Library
Get_Default_Library (Inherited)
Get_Default_Profile
Get_Default_Profile (Inherited)
Get_Default_Profile_Library (Inherited)
Get_Default_Profile_Library
Get_Listener
Get_Listener (Inherited)
Get_Participant (Inherited)
Get_Participant
Get_Qos (Inherited)
GetInterface
Lookup_DataReader
Lookup_DataReader (Inherited)
Notify_DataReaders (Inherited)
Notify_DataReaders
Set_Default_DataReader_Qos (Inherited)
Set_Default_DataReader_Qos
Set_Default_DataReader_Qos_With_Profile (Inherited)
Set_Default_DataReader_Qos_With_Profile (Inherited)
Set_Default_DataReader_Qos_With_Profile
Set_Default_DataReader_Qos_With_Profile
Set_Default_Library (Inherited)
Set_Default_Library
Set_Default_Profile (Inherited)
Set_Default_Profile
Set_Listener
Set_Listener (Inherited)
Set_Qos (Inherited)
Set_Qos_With_Profile
Set_Qos_With_Profile
Set_Qos_With_Profile (Inherited)
Set_Qos_With_Profile (Inherited)
SetInterface

Types

Ref_Access

type Ref_Access is access all Ref'Class;

DDS_Subscriber_Access

type DDS_Subscriber_Access is access all DDS_Subscriber with Storage_Size => 0;

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 not null 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: not null DDS_Subscriber_Access) return DDS.Subscriber_Impl.Ref_Access;

Get_FacadeI

function Get_FacadeI 
(C_Subscriber: not null DDS_Subscriber_Access) return Ref_Access;

Finalize_Callback

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

As_DDS_Entity_access

function As_DDS_Entity_access is new Ada.Unchecked_Conversion 
(DDS_Subscriber_Access, DDS.Entity_Impl.DDS_Entity_Access);

GetInterface

function GetInterface 
(Self: not null access Ref) return DDS_Subscriber_Access;

SetInterface

procedure SetInterface 
(Self: not null access Ref;
To: DDS_Subscriber_Access);

call_listener

procedure  call_listener 
(Self: not null access Ref;
mask: StatusMask);