MCPcopy Create free account
hub / github.com/Tencent/phxqueue / Wait

Method Wait

phxqueue/producer/batchhelper.cpp:59–68  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

57}
58
59comm::RetCode Task::Wait() {
60 if (nullptr == notifier_) return comm::RetCode::RET_ERR_NOTIFIER_MISS;
61
62 comm::RetCode retcode = comm::RetCode::RET_OK;
63 notifier_->Wait(retcode);
64
65 comm::NotifierPool::GetInstance()->Put(notifier_);
66
67 return retcode;
68}
69
70void Task::Notify(comm::RetCode retcode) {
71 if (nullptr == notifier_) return;

Callers 1

BatchRawAddMethod · 0.45

Calls 1

PutMethod · 0.45

Tested by

no test coverage detected