Inheritance diagram for OpenDDS::Security::AccessControlBuiltInImpl::RevokePermissionsTask:

[legend]

Collaboration diagram for OpenDDS::Security::AccessControlBuiltInImpl::RevokePermissionsTask:

[legend]

Public Member Functions
	RevokePermissionsTask (const DCPS::TimeSource &time_source, DCPS::ReactorInterceptor_rch interceptor, AccessControlBuiltInImpl &impl)

virtual	~RevokePermissionsTask ()

void	insert (DDS::Security::PermissionsHandle pm_handle, const time_t &expiration)

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

Public Member Functions inherited from OpenDDS::DCPS::SporadicTask
	SporadicTask (const TimeSource &time_source, RcHandle< ReactorInterceptor > interceptor)

virtual	~SporadicTask ()

void	schedule (const TimeDuration &delay)

void	cancel ()

Public Member Functions inherited from OpenDDS::DCPS::RcEventHandler
	RcEventHandler ()

ACE_Event_Handler::Reference_Count	add_reference ()

ACE_Event_Handler::Reference_Count	remove_reference ()

Public Member Functions inherited from ACE_Event_Handler
virtual	~ACE_Event_Handler (void)

virtual ACE_HANDLE	get_handle (void) const

virtual void	set_handle (ACE_HANDLE)

virtual int	priority (void) const

virtual void	priority (int priority)

virtual int	handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_exit (ACE_Process *)

virtual int	handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)

virtual int	handle_signal (int signum, siginfo_t =0, ucontext_t =0)

virtual int	resume_handler (void)

virtual int	handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual int	handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual void	reactor (ACE_Reactor *reactor)

virtual ACE_Reactor *	reactor (void) const

virtual ACE_Reactor_Timer_Interface *	reactor_timer_interface (void) const

Reference_Counting_Policy &	reference_counting_policy (void)

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Private Member Functions
typedef	OPENDDS_MAP (DDS::Security::PermissionsHandle, time_t) HandleToExpiration

typedef	OPENDDS_MULTIMAP (time_t, DDS::Security::PermissionsHandle) ExpirationToHandle

virtual void	execute (const DCPS::MonotonicTimePoint &now)

Private Attributes
AccessControlBuiltInImpl &	impl_

ACE_Thread_Mutex	lock_

HandleToExpiration	handle_to_expiration_

ExpirationToHandle	expiration_to_handle_

Additional Inherited Members
Public Types inherited from ACE_Event_Handler
typedef long	Reference_Count

Static Public Member Functions inherited from ACE_Event_Handler
static ACE_THR_FUNC_RETURN	read_adapter (void *event_handler)

static int	register_stdin_handler (ACE_Event_Handler eh, ACE_Reactor reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)

static int	remove_stdin_handler (ACE_Reactor reactor, ACE_Thread_Manager thr_mgr)

Public Attributes inherited from ACE_Event_Handler
	LO_PRIORITY

	HI_PRIORITY

	NULL_MASK

	READ_MASK

	WRITE_MASK

	EXCEPT_MASK

	ACCEPT_MASK

	CONNECT_MASK

	TIMER_MASK

	QOS_MASK

	GROUP_QOS_MASK

	SIGNAL_MASK

	ALL_EVENTS_MASK

	RWE_MASK

	DONT_CALL

	ACE_EVENT_HANDLER_NOT_RESUMED

	ACE_REACTOR_RESUMES_HANDLER

	ACE_APPLICATION_RESUMES_HANDLER

Protected Types inherited from ACE_Event_Handler
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_Count >	Atomic_Reference_Count

Protected Member Functions inherited from OpenDDS::DCPS::SporadicTask
long	get_timer_id ()

Protected Member Functions inherited from ACE_Event_Handler
	ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Protected Attributes inherited from ACE_Event_Handler
Atomic_Reference_Count	reference_count_

Detailed Description

Definition at line 261 of file AccessControlBuiltInImpl.h.

Constructor & Destructor Documentation

◆ RevokePermissionsTask()

OpenDDS::Security::AccessControlBuiltInImpl::RevokePermissionsTask::RevokePermissionsTask	(	const DCPS::TimeSource &	time_source,
		DCPS::ReactorInterceptor_rch	interceptor,
		AccessControlBuiltInImpl &	impl
	)

Definition at line 1546 of file AccessControlBuiltInImpl.cpp.

   : SporadicTask(time_source, interceptor)
   , impl_(impl)
 { }

◆ ~RevokePermissionsTask()

OpenDDS::Security::AccessControlBuiltInImpl::RevokePermissionsTask::~RevokePermissionsTask ( )

virtual

Definition at line 1553 of file AccessControlBuiltInImpl.cpp.

References ACE_DEBUG, ACE_TEXT(), expiration_to_handle_, handle_to_expiration_, LM_DEBUG, and OpenDDS::DCPS::security_debug.

 {
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("AccessControlBuiltInImpl::RevokePermissionsTask::~RevokePermissionsTask %@ handle_to_expiration_ %B expiration_to_handle_ %B\n"),
                this,
                handle_to_expiration_.size(),
                expiration_to_handle_.size()));
   }
 }

Member Function Documentation

◆ erase()

void OpenDDS::Security::AccessControlBuiltInImpl::RevokePermissionsTask::erase ( DDS::Security::PermissionsHandle pm_handle )

Definition at line 1615 of file AccessControlBuiltInImpl.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), expiration_to_handle_, handle_to_expiration_, LM_DEBUG, lock_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::Security::AccessControlBuiltInImpl::return_permissions_handle().

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, lock_);
 
   HandleToExpiration::iterator iter = handle_to_expiration_.find(pm_handle);
   if (iter == handle_to_expiration_.end()) {
     return;
   }
 
   const time_t expiration = iter->second;
 
   std::pair<ExpirationToHandle::iterator, ExpirationToHandle::iterator> er =
     expiration_to_handle_.equal_range(expiration);
   while (er.first != er.second) {
     if (er.first->second == pm_handle) {
       expiration_to_handle_.erase(er.first++);
       if (DCPS::security_debug.bookkeeping) {
         ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                    ACE_TEXT("AccessControlBuiltInImpl::RevokePermissionsTask::erase expiration_to_handle_ (total %B)\n"),
                    expiration_to_handle_.size()));
       }
     } else {
       ++er.first;
     }
   }
 
   handle_to_expiration_.erase(pm_handle);
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("AccessControlBuiltInImpl::RevokePermissionsTask::execute handle_to_expiration_ (total %B)\n"),
                handle_to_expiration_.size()));
   }
 }

◆ execute()

void OpenDDS::Security::AccessControlBuiltInImpl::RevokePermissionsTask::execute ( const DCPS::MonotonicTimePoint & now )

privatevirtual

Implements OpenDDS::DCPS::SporadicTask.

Definition at line 1650 of file AccessControlBuiltInImpl.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, expiration_to_handle_, gmtime(), handle_to_expiration_, impl_, OpenDDS::Security::AccessControlBuiltInImpl::listener_ptr_, LM_DEBUG, LM_ERROR, OpenDDS::Security::AccessControlBuiltInImpl::local_ac_perms_, lock_, mktime(), OpenDDS::DCPS::SporadicTask::schedule(), OpenDDS::DCPS::security_debug, and time().

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, lock_);
 
   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);
 
   for (ExpirationToHandle::iterator pos = expiration_to_handle_.begin(), limit = expiration_to_handle_.end();
          pos != limit && pos->first < cur_utc_time;) {
     const ::DDS::Security::PermissionsHandle pm_handle = pos->second;
     ACPermsMap::iterator iter = impl_.local_ac_perms_.find(pm_handle);
     if (iter == impl_.local_ac_perms_.end()) {
       ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) AccessControlBuiltInImpl::Revoke_Permissions_Timer::execute: ")
                  ACE_TEXT("pm_handle %d not found!\n"), pm_handle));
     }
     impl_.local_ac_perms_.erase(iter);
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("AccessControlBuiltInImpl::RevokePermissionsTask::execute local_ac_perms_ (total %B)\n"),
                  impl_.local_ac_perms_.size()));
     }
 
     // If a listener exists, call on_revoke_permissions
     if (impl_.listener_ptr_ && !impl_.listener_ptr_->on_revoke_permissions(&impl_, pm_handle)) {
       ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) AccessControlBuiltInImpl::Revoke_Permissions_Timer::execute: ")
                  ACE_TEXT("on_revoke_permissions failed for pm_handle %d!\n"), pm_handle));
     }
 
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) AccessControlBuiltInImpl::Revoke_Permissions_Timer::execute: Completed...\n")));
     }
 
     handle_to_expiration_.erase(pm_handle);
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("AccessControlBuiltInImpl::RevokePermissionsTask::execute handle_to_expiration_ (total %B)\n"),
                  handle_to_expiration_.size()));
     }
 
     expiration_to_handle_.erase(pos++);
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("AccessControlBuiltInImpl::RevokePermissionsTask::execute expiration_to_handle_ (total %B)\n"),
                  expiration_to_handle_.size()));
     }
   }
 
   if (!expiration_to_handle_.empty()) {
     const TimeDuration duration = std::min(TimeDuration(expiration_to_handle_.begin()->first - cur_utc_time), MAX_DURATION);
     schedule(duration);
   }
 }

◆ insert()

void OpenDDS::Security::AccessControlBuiltInImpl::RevokePermissionsTask::insert	(	DDS::Security::PermissionsHandle	pm_handle,
		const time_t &	expiration
	)

Definition at line 1572 of file AccessControlBuiltInImpl.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::SporadicTask::cancel(), expiration_to_handle_, gmtime(), handle_to_expiration_, LM_DEBUG, lock_, mktime(), OpenDDS::DCPS::SporadicTask::schedule(), OpenDDS::DCPS::security_debug, and time().

Referenced by OpenDDS::Security::AccessControlBuiltInImpl::check_create_datareader(), OpenDDS::Security::AccessControlBuiltInImpl::check_create_datawriter(), OpenDDS::Security::AccessControlBuiltInImpl::check_remote_datareader(), and OpenDDS::Security::AccessControlBuiltInImpl::check_remote_datawriter().

 {
   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::RevokePermissionsTask::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::RevokePermissionsTask::insert expiration_to_handle_ (total %B)\n"),
                expiration_to_handle_.size()));
   }
 
   if (!empty_before && pos == expiration_to_handle_.begin()) {
     cancel();
   }
 
   if (pos == expiration_to_handle_.begin()) {
     schedule(duration);
   }
 }