OpenDDS  Snapshot(2023/04/28-20:55)
Public Member Functions | Private Member Functions | Private Attributes | List of all members
OpenDDS::DCPS::RegisterHandler Class Reference

#include <ReactorInterceptor.h>

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

Public Member Functions

 RegisterHandler (ACE_HANDLE io_handle, ACE_Event_Handler *event_handler, 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_Event_Handlerevent_handler_
 
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 83 of file ReactorInterceptor.h.

Constructor & Destructor Documentation

◆ RegisterHandler()

OpenDDS::DCPS::RegisterHandler::RegisterHandler ( ACE_HANDLE  io_handle,
ACE_Event_Handler event_handler,
ACE_Reactor_Mask  mask 
)
inline

Definition at line 85 of file ReactorInterceptor.h.

88  : io_handle_(io_handle)
89  , event_handler_(event_handler)
90  , mask_(mask)
91  {}
ACE_Event_Handler * event_handler_

Member Function Documentation

◆ execute()

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

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

Definition at line 122 of file ReactorInterceptor.cpp.

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

123 {
124  if (reactor()->register_handler(io_handle_, event_handler_, mask_) != 0) {
125  if (log_level >= LogLevel::Error) {
126  ACE_ERROR((LM_ERROR,
127  "(%P|%t) ERROR: RegisterHandler::execute: failed to register handler for socket %d\n",
128  io_handle_));
129  }
130  }
131 }
#define ACE_ERROR(X)
ACE_Event_Handler * event_handler_
OpenDDS_Dcps_Export LogLevel log_level

Member Data Documentation

◆ event_handler_

ACE_Event_Handler* OpenDDS::DCPS::RegisterHandler::event_handler_
private

Definition at line 95 of file ReactorInterceptor.h.

◆ io_handle_

ACE_HANDLE OpenDDS::DCPS::RegisterHandler::io_handle_
private

Definition at line 94 of file ReactorInterceptor.h.

◆ mask_

ACE_Reactor_Mask OpenDDS::DCPS::RegisterHandler::mask_
private

Definition at line 96 of file ReactorInterceptor.h.


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