MCPcopy Create free account
hub / github.com/apache/impala / ScheduledTaskScheduleAgain

Method ScheduledTaskScheduleAgain

be/src/kudu/rpc/reactor-test.cc:59–65  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

57 }
58
59 void ScheduledTaskScheduleAgain(const Status& /*status*/) {
60 auto* current = Thread::current_thread();
61 messenger_->ScheduleOnReactor(
62 [=](const Status& s) { this->ScheduledTaskCheckThread(s, current); },
63 MonoDelta::FromMilliseconds(0));
64 latch_.CountDown();
65 }
66
67 protected:
68 shared_ptr<Messenger> messenger_;

Callers 1

TEST_FFunction · 0.80

Calls 3

ScheduleOnReactorMethod · 0.80
CountDownMethod · 0.80

Tested by

no test coverage detected