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

#include <FaceTSS.h>

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

[legend]

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

[legend]

List of all members.

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)

---

Detailed Description

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

Definition at line 58 of file FaceTSS.h.

---

Member Typedef Documentation

template<typename Msg>

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

Definition at line 63 of file FaceTSS.h.

---

Constructor & Destructor Documentation

template<typename Msg >

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

(

FaceReceiver &

rcvr

)

[inline]

Definition at line 96 of file FaceTSS.h.

  : 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;
}

template<typename Msg >

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

(

)

[inline]

Definition at line 107 of file FaceTSS.h.

{
}

---

Member Function Documentation

template<typename Msg >

FACE::RETURN_CODE_TYPE OpenDDS::FaceTSS::Entities::DDSTypedAdapter< Msg >::messages_waiting

(

FACE::WAITING_RANGE_TYPE &

num_waiting

)

[inline, virtual]

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

Definition at line 112 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