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

Method Wait

phxqueue/comm/notifierpool.cpp:76–83  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

74}
75
76void Notifier::Wait(comm::RetCode &retcode) {
77 int iretcode;
78 while (!comm::utils::CoRead(impl_->fds[0], reinterpret_cast<char*>(&iretcode), sizeof(int))) {
79 QLErr("CoRead fail");
80 poll(nullptr, 0, 100);
81 }
82 retcode = static_cast<comm::RetCode>(iretcode);
83}
84
85//////////////////////////
86

Callers 1

mainFunction · 0.45

Calls 1

CoReadFunction · 0.85

Tested by 1

mainFunction · 0.36