Method process_deadlines

dds/DCPS/WriteDataContainer.cpp:1653–1708

}

void
WriteDataContainer::process_deadlines(const MonotonicTimePoint& now)
{
  // Lock the DataWriterImpl.
  ACE_GUARD (ACE_Recursive_Thread_Mutex, dwi_guard, deadline_status_lock_);
  // Lock ourselves.
  ACE_GUARD (ACE_Recursive_Thread_Mutex, wdc_guard, lock_);

  if (deadline_map_.empty()) {
    return;
  }

  bool notify = false;

  for (DeadlineMapType::iterator pos = deadline_map_.begin(), limit = deadline_map_.end();
       pos != limit && pos->first < now; pos = deadline_map_.begin()) {

    PublicationInstance_rch instance = pos->second;
    deadline_map_.erase(pos);

    ++deadline_status_.total_count;
    deadline_status_.total_count_change = deadline_status_.total_count - deadline_last_total_count_;
    deadline_status_.last_instance_handle = instance->instance_handle_;

    writer_->set_status_changed_flag(DDS::OFFERED_DEADLINE_MISSED_STATUS, true);
    notify = true;

    DDS::DataWriterListener_var listener = writer_->listener_for(DDS::OFFERED_DEADLINE_MISSED_STATUS);

    if (listener) {
      // Copy before releasing the lock.
      const DDS::OfferedDeadlineMissedStatus status = deadline_status_;

      // Release the lock during the upcall.
      ACE_Reverse_Lock<ACE_Recursive_Thread_Mutex> deadline_reverse_status_lock(deadline_status_lock_);
      ACE_GUARD(ACE_Reverse_Lock<ACE_Recursive_Thread_Mutex>, rev_dwi_guard, deadline_reverse_status_lock);

      // @todo Will this operation ever throw?  If so we may want to
      //       catch all exceptions, and act accordingly.
      listener->on_offered_deadline_missed(writer_, status);

      // We need to update the last total count value to our current total
      // so that the next time we will calculate the correct total_count_change;
      deadline_last_total_count_ = deadline_status_.total_count;
    }

    instance->deadline_ += deadline_period_;
    deadline_map_.insert(std::make_pair(instance->deadline_, instance));
  }

  if (notify) {
    writer_->notify_status_condition();
  }

  deadline_task_->schedule(deadline_map_.begin()->first - now);
}

void