OpenDDS  Snapshot(2023/04/07-19:43)
Public Member Functions | Private Member Functions | Private Attributes | List of all members
OpenDDS::DCPS::RemoveHandler Class Reference

#include <ReactorInterceptor.h>

Inheritance diagram for OpenDDS::DCPS::RemoveHandler:
Inheritance graph
[legend]
Collaboration diagram for OpenDDS::DCPS::RemoveHandler:
Collaboration graph
[legend]

Public Member Functions

 RemoveHandler (ACE_HANDLE io_handle, ACE_Reactor_Mask mask)
 
- Public Member Functions inherited from OpenDDS::DCPS::ReactorInterceptor::Command
 Command ()
 
virtual ~Command ()
 
- 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

void execute ()
 

Private Attributes

ACE_HANDLE io_handle_
 
ACE_Reactor_Mask mask_
 

Additional Inherited Members

- Protected Member Functions inherited from OpenDDS::DCPS::ReactorInterceptor::Command
const ACE_Reactorreactor () const
 
ACE_Reactorreactor ()
 
- Protected Member Functions inherited from OpenDDS::DCPS::RcObject
 RcObject ()
 

Detailed Description

Definition at line 101 of file ReactorInterceptor.h.

Constructor & Destructor Documentation

◆ RemoveHandler()

OpenDDS::DCPS::RemoveHandler::RemoveHandler ( ACE_HANDLE  io_handle,
ACE_Reactor_Mask  mask 
)
inline

Definition at line 103 of file ReactorInterceptor.h.

105  : io_handle_(io_handle)
106  , mask_(mask)
107  {}

Member Function Documentation

◆ execute()

void OpenDDS::DCPS::RemoveHandler::execute ( void  )
privatevirtual

Implements OpenDDS::DCPS::ReactorInterceptor::Command.

Definition at line 133 of file ReactorInterceptor.cpp.

References ACE_ERROR, OpenDDS::DCPS::LogLevel::Error, LM_ERROR, OpenDDS::DCPS::log_level, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and OpenDDS::DCPS::ReactorInterceptor::reactor().

134 {
135  if (reactor()->remove_handler(io_handle_, mask_) != 0) {
136  if (log_level >= LogLevel::Error) {
137  ACE_ERROR((LM_ERROR,
138  "(%P|%t) ERROR: UnregisterHandler::execute: failed to remove handler for socket %d\n",
139  io_handle_));
140  }
141  }
142 }
OpenDDS_Dcps_Export LogLevel log_level
#define ACE_ERROR(X)

Member Data Documentation

◆ io_handle_

ACE_HANDLE OpenDDS::DCPS::RemoveHandler::io_handle_
private

Definition at line 110 of file ReactorInterceptor.h.

◆ mask_

ACE_Reactor_Mask OpenDDS::DCPS::RemoveHandler::mask_
private

Definition at line 111 of file ReactorInterceptor.h.


The documentation for this class was generated from the following files: