OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg > Class Template Reference

#include <FaceTSS.h>

Inheritance diagram for OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >:

Collaboration diagram for OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >:

Public Types
typedef DCPS::DDSTraits< Msg >::DataReaderType	DataReader

Public Member Functions
	DDSTypedAdapter (FaceReceiver &rcvr)
	~DDSTypedAdapter ()
virtual FACE::RETURN_CODE_TYPE	messages_waiting (FACE::WAITING_RANGE_TYPE &num_waiting)
Public Member Functions inherited from OpenDDS::FaceTSS::Entities::FaceReceiver
	FaceReceiver ()
virtual	~FaceReceiver ()
Public Member Functions inherited from OpenDDS::FaceTSS::Entities::DDSAdapter
	DDSAdapter ()

Additional Inherited Members
Public Attributes inherited from OpenDDS::FaceTSS::Entities::FaceReceiver
DDS::DataReader_var	dr
FACE::TS::MessageHeader	last_msg_header
FACE::TRANSACTION_ID_TYPE	last_msg_tid
FACE::SYSTEM_TIME_TYPE	sum_recvd_msgs_latency
FACE::LongLong	total_msgs_recvd
Public Attributes inherited from OpenDDS::FaceTSS::Entities::DDSAdapter
FACE::VALIDITY_TYPE	status_valid

Detailed Description

template<typename Msg>
class OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >

Definition at line 57 of file FaceTSS.h.

Member Typedef Documentation

DataReader

template<typename Msg>

typedef DCPS::DDSTraits<Msg>::DataReaderType OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >::DataReader

Definition at line 62 of file FaceTSS.h.

Constructor & Destructor Documentation

DDSTypedAdapter()

template<typename Msg >

OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >::DDSTypedAdapter

(

FaceReceiver &

rcvr

)

Definition at line 95 of file FaceTSS.h.

References OpenDDS::FaceTSS::Entities::FaceReceiver::dr, OpenDDS::FaceTSS::Entities::FaceReceiver::last_msg_header, OpenDDS::FaceTSS::Entities::FaceReceiver::last_msg_tid, OpenDDS::FaceTSS::Entities::FaceReceiver::sum_recvd_msgs_latency, and OpenDDS::FaceTSS::Entities::FaceReceiver::total_msgs_recvd.

  : FaceReceiver()
{
  dr = rcvr.dr;
  last_msg_header = rcvr.last_msg_header;
  last_msg_tid = rcvr.last_msg_tid;
  sum_recvd_msgs_latency = rcvr.sum_recvd_msgs_latency;
  total_msgs_recvd = rcvr.total_msgs_recvd;
}

~DDSTypedAdapter()

template<typename Msg >

OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >::~DDSTypedAdapter

(

)

Definition at line 106 of file FaceTSS.h.

{
}

Member Function Documentation

messages_waiting()

template<typename Msg >

FACE::RETURN_CODE_TYPE OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >::messages_waiting ( FACE::WAITING_RANGE_TYPE &  num_waiting )

virtual

Reimplemented from OpenDDS::FaceTSS::Entities::FaceReceiver.

Definition at line 111 of file FaceTSS.h.

References DDS::ALIVE_INSTANCE_STATE, DDS::ANY_SAMPLE_STATE, DDS::ANY_VIEW_STATE, OpenDDS::FaceTSS::Entities::FaceReceiver::dr, DDS::LENGTH_UNLIMITED, DDS::RETCODE_NO_DATA, and DDS::RETCODE_OK.

{
  const typename DataReader::_var_type typedReader =
    DataReader::_narrow(dr);
  if (!typedReader) {
    return FACE::INVALID_PARAM;
  }
  const DDS::ReadCondition_var rc =
      typedReader->create_readcondition(DDS::ANY_SAMPLE_STATE,
                                DDS::ANY_VIEW_STATE,
                                DDS::ALIVE_INSTANCE_STATE);

  DDS::ReturnCode_t ret;
  typename DCPS::DDSTraits<Msg>::MessageSequenceType seq;
  DDS::SampleInfoSeq sinfo;
  FACE::WAITING_RANGE_TYPE valid_waiting = 0;
  ret = typedReader->read_w_condition(seq, sinfo, DDS::LENGTH_UNLIMITED, rc);
  if (ret == DDS::RETCODE_OK) {
    for (CORBA::ULong i = 0; i < seq.length(); ++i) {
      if (sinfo[i].valid_data) {
        ++valid_waiting;
      }
    }
    num_waiting = valid_waiting;
    return FACE::RC_NO_ERROR;
  } else if (ret == DDS::RETCODE_NO_DATA) {
    num_waiting = 0;
    return FACE::RC_NO_ERROR;
  }
  return FACE::NOT_AVAILABLE;
}

---

The documentation for this class was generated from the following file:

• FaceTSS.h