| 245 | } |
| 246 | |
| 247 | void |
| 248 | WriterInfo::start_liveliness_timer() |
| 249 | { |
| 250 | ACE_Guard<ACE_Thread_Mutex> guard(mutex_); |
| 251 | last_liveliness_activity_time_ = MonotonicTimePoint::now(); |
| 252 | if (reader_liveliness_lease_duration_is_finite_) { |
| 253 | liveliness_check_task_->schedule(reader_liveliness_lease_duration_); |
| 254 | } |
| 255 | } |
| 256 | |
| 257 | void |
| 258 | WriterInfo::check_liveliness(const MonotonicTimePoint& now) |
no test coverage detected