| 53 | } |
| 54 | |
| 55 | void SporadicTask::cancel() |
| 56 | { |
| 57 | { |
| 58 | ACE_Guard<ACE_Thread_Mutex> guard(mutex_); |
| 59 | if (!desired_scheduled_) { |
| 60 | return; |
| 61 | } |
| 62 | |
| 63 | desired_scheduled_ = false; |
| 64 | } |
| 65 | |
| 66 | const ReactorTask_rch reactor_task = reactor_task_.lock(); |
| 67 | if (reactor_task) { |
| 68 | reactor_task->execute_or_enqueue(sporadic_command_); |
| 69 | } else if (log_level >= LogLevel::Error) { |
| 70 | ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: SporadicTask::cancel: " |
| 71 | "failed to receive ReactorTask handle\n")); |
| 72 | } |
| 73 | } |
| 74 | |
| 75 | void SporadicTask::update_schedule(ReactorWrapper& reactor_wrapper) |
| 76 | { |
no test coverage detected