| 333 | } |
| 334 | |
| 335 | uint64_t EventCenter::create_time_event(uint64_t microseconds, EventCallbackRef ctxt) |
| 336 | { |
| 337 | ceph_assert(in_thread()); |
| 338 | uint64_t id = time_event_next_id++; |
| 339 | |
| 340 | ldout(cct, 30) << __func__ << " id=" << id << " trigger after " << microseconds << "us"<< dendl; |
| 341 | EventCenter::TimeEvent event; |
| 342 | clock_type::time_point expire = clock_type::now() + std::chrono::microseconds(microseconds); |
| 343 | event.id = id; |
| 344 | event.time_cb = ctxt; |
| 345 | std::multimap<clock_type::time_point, TimeEvent>::value_type s_val(expire, event); |
| 346 | auto it = time_events.insert(std::move(s_val)); |
| 347 | event_map[id] = it; |
| 348 | |
| 349 | return id; |
| 350 | } |
| 351 | |
| 352 | void EventCenter::delete_time_event(uint64_t id) |
| 353 | { |
no test coverage detected