InstanceState.inl

Go to the documentation of this file.

/*
 *
 *
 * Distributed under the OpenDDS License.
 * See: http://www.opendds.org/license.html
 */

#include "ReceivedDataElementList.h"
#include "ace/OS_NS_sys_time.h"

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL

ACE_INLINE
OpenDDS::DCPS::WeakRcHandle<OpenDDS::DCPS::DataReaderImpl>
OpenDDS::DCPS::InstanceState::data_reader() const
{
  return reader_;
}

ACE_INLINE
void
OpenDDS::DCPS::InstanceState::accessed()
{
  ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, lock_);
  //
  // Manage the view state due to data access here.
  //
  if (view_state_ & DDS::ANY_VIEW_STATE) {
    const bool updated = (view_state_ != DDS::NOT_NEW_VIEW_STATE);
    view_state_ = DDS::NOT_NEW_VIEW_STATE;
    if (updated) {
      state_updated();
    }
  }
}

ACE_INLINE
DDS::InstanceStateKind
OpenDDS::DCPS::InstanceState::instance_state() const
{
  return instance_state_;
}

ACE_INLINE
DDS::ViewStateKind
OpenDDS::DCPS::InstanceState::view_state() const
{
  return view_state_;
}

ACE_INLINE
bool OpenDDS::DCPS::InstanceState::match(DDS::ViewStateMask view, DDS::InstanceStateMask inst) const
{
  return (view_state_ & view) && (instance_state_ & inst);
}

ACE_INLINE
size_t OpenDDS::DCPS::InstanceState::disposed_generation_count() const
{
  return disposed_generation_count_;
}

ACE_INLINE
size_t OpenDDS::DCPS::InstanceState::no_writers_generation_count() const
{
  return no_writers_generation_count_;
}

ACE_INLINE
void
OpenDDS::DCPS::InstanceState::data_was_received(const GUID_t& writer_id)
{
  ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, lock_);
  cancel_release();

  //
  // Update the view state here, since only sample data received affects
  // this state value.  Then manage the data sample only transitions
  // here.  Let the lively() method manage the other transitions.
  //
  writers_.insert(writer_id);

  const CORBA::ULong old_view_state = view_state_;
  const CORBA::ULong old_instance_state = instance_state_;

  switch (view_state_) {
  case DDS::NEW_VIEW_STATE:
    break;

  case DDS::NOT_NEW_VIEW_STATE:
    if (instance_state_ & DDS::NOT_ALIVE_INSTANCE_STATE) {
      view_state_ = DDS::NEW_VIEW_STATE;
    }
    break;

  default:
    view_state_ = DDS::NEW_VIEW_STATE;
    break;
  }

  switch (instance_state_) {
  case DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE:
    ++disposed_generation_count_;
    break;

  case DDS::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE:
    ++no_writers_generation_count_;
    break;

  default:
    break;
  }

  instance_state_ = DDS::ALIVE_INSTANCE_STATE;

  if (view_state_ != old_view_state || instance_state_ != old_instance_state) {
    state_updated();
  }
}

ACE_INLINE
void
OpenDDS::DCPS::InstanceState::lively(const GUID_t& writer_id)
{
  ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, lock_);

  //
  // Manage transisitions in the instance state that do not require a
  // data sample, but merely the notion of liveliness.
  //
  writers_.insert(writer_id);

  if (instance_state_ == DDS::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE) {
    cancel_release(); // cancel unregister

    ++no_writers_generation_count_;
    const bool updated = (instance_state_ != DDS::ALIVE_INSTANCE_STATE);
    instance_state_ = DDS::ALIVE_INSTANCE_STATE;
    if (updated) {
      state_updated();
    }
  }
}

ACE_INLINE
bool
OpenDDS::DCPS::InstanceState::empty(bool value)
{
  //
  // Manage the instance state due to the DataReader becoming empty
  // here.
  //
  if ((empty_ = value) && release_pending_) {
    return release_if_empty();
  } else {
    return false;
  }
}


ACE_INLINE
bool
OpenDDS::DCPS::InstanceState::is_last (const GUID_t& pub)
{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, lock_, false);

  return writers_.size() == 1 && *writers_.begin() == pub;
}

ACE_INLINE
bool
OpenDDS::DCPS::InstanceState::no_writer () const
{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, lock_, true);

  return writers_.empty();
}

ACE_INLINE
const char* OpenDDS::DCPS::InstanceState::instance_state_string() const
{
  return instance_state_string(instance_state_);
}

OPENDDS_END_VERSIONED_NAMESPACE_DECL