| 507 | } |
| 508 | |
| 509 | bool ReactorWrapper::open(ACE_Reactor* reactor) |
| 510 | { |
| 511 | reactor_ = reactor; |
| 512 | |
| 513 | #if OPENDDS_CONFIG_BOOTTIME_TIMERS |
| 514 | timer_fd_ = timerfd_create(CLOCK_BOOTTIME, TFD_CLOEXEC); |
| 515 | if (timer_fd_ == -1) { |
| 516 | if (log_level >= LogLevel::Notice) { |
| 517 | ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: ReactorWrapper::open: timerfd_create %m\n")); |
| 518 | } |
| 519 | return false; |
| 520 | } |
| 521 | |
| 522 | if (reactor_->register_handler(this, ACE_Event_Handler::READ_MASK) == -1) { |
| 523 | if (log_level >= LogLevel::Notice) { |
| 524 | ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: ReactorWrapper::open: register_handler %m\n")); |
| 525 | } |
| 526 | return false; |
| 527 | } |
| 528 | #endif |
| 529 | |
| 530 | return true; |
| 531 | } |
| 532 | |
| 533 | void ReactorWrapper::close() |
| 534 | { |
no test coverage detected