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

Method Notify

phxqueue/comm/notifierpool.cpp:68–74  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

66}
67
68void Notifier::Notify(const comm::RetCode retcode) {
69 int iretcode = as_integer(retcode);
70 while (!comm::utils::CoWrite(impl_->fds[1], reinterpret_cast<char*>(&iretcode), sizeof(int))) {
71 QLErr("CoWrite fail");
72 poll(nullptr, 0, 100);
73 }
74}
75
76void Notifier::Wait(comm::RetCode &retcode) {
77 int iretcode;

Callers 1

mainFunction · 0.45

Calls 2

as_integerFunction · 0.85
CoWriteFunction · 0.85

Tested by 1

mainFunction · 0.36