Method liveliness_lost_task

dds/DCPS/DataWriterImpl.cpp:2505–2542

}

void
DataWriterImpl::liveliness_lost_task(const MonotonicTimePoint& now)
{
  ThreadStatusManager::Event ev(TheServiceParticipant->get_thread_status_manager());

  ACE_Guard<ACE_Recursive_Thread_Mutex> guard(lock_);

  const TimeDuration elapsed = now - last_liveliness_activity_time_;

  if (elapsed < liveliness_lost_interval_) {
    // Reschedule.
    liveliness_lost_task_->schedule(liveliness_lost_interval_ - elapsed);
    return;
  }

  const bool notify = !liveliness_lost_;
  liveliness_lost_task_->schedule(liveliness_lost_interval_);
  liveliness_lost_ = true;

  if (notify) {
    ++liveliness_lost_status_.total_count;
    ++liveliness_lost_status_.total_count_change;

    set_status_changed_flag(DDS::LIVELINESS_LOST_STATUS, true);
    notify_status_condition();

    DDS::DataWriterListener_var listener = listener_for(DDS::LIVELINESS_LOST_STATUS);

    if (!CORBA::is_nil(listener.in())) {
      {
        ACE_Reverse_Lock<ACE_Recursive_Thread_Mutex> rev_lock(lock_);
        ACE_Guard<ACE_Reverse_Lock<ACE_Recursive_Thread_Mutex> > rev_guard(rev_lock);
        listener->on_liveliness_lost(this, liveliness_lost_status_);
      }
      liveliness_lost_status_.total_count_change = 0;
    }
  }
}

bool
DataWriterImpl::send_liveliness(const MonotonicTimePoint& now)