Method insert

dds/DCPS/security/AccessControlBuiltInImpl.cpp:1590–1631

}

void
AccessControlBuiltInImpl::RevokePermissions::insert(::DDS::Security::PermissionsHandle pm_handle,
                                                        const time_t& expiration)
{
  ACE_GUARD(ACE_Thread_Mutex, guard, lock_);

  if (handle_to_expiration_.count(pm_handle)) {
    return;
  }

  const time_t current_date_time = time(0);
  tm* current_time_tm = gmtime(&current_date_time);
  const time_t cur_utc_time = mktime(current_time_tm);
  const TimeDuration duration = std::min(TimeDuration(expiration - cur_utc_time), MAX_DURATION);

  const bool empty_before = expiration_to_handle_.empty();

  handle_to_expiration_[pm_handle] = expiration;

  if (DCPS::security_debug.bookkeeping) {
    ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
               ACE_TEXT("AccessControlBuiltInImpl::RevokePermissions::insert handle_to_expiration_ (total %B)\n"),
               handle_to_expiration_.size()));
  }

  ExpirationToHandle::const_iterator pos =
    expiration_to_handle_.insert(ExpirationToHandle::value_type(expiration, pm_handle));

  if (DCPS::security_debug.bookkeeping) {
    ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
               ACE_TEXT("AccessControlBuiltInImpl::RevokePermissions::insert expiration_to_handle_ (total %B)\n"),
               expiration_to_handle_.size()));
  }

  if (!empty_before && pos == expiration_to_handle_.begin()) {
    revokation_event_->cancel();
  }

  if (pos == expiration_to_handle_.begin()) {
    revokation_event_->schedule(duration);
  }
}

void
AccessControlBuiltInImpl::RevokePermissions::erase(::DDS::Security::PermissionsHandle pm_handle)