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

Method SkipHandle

phxqueue/consumer/consumer.cpp:873–876  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

871}
872
873bool Consumer::SkipHandle(const comm::proto::ConsumerContext &cc, const comm::proto::QItem &item) {
874 if (!(item.sub_ids() & (1ULL << (cc.sub_id() - 1)))) return true;
875 return false;
876}
877
878comm::RetCode Consumer::Handle(const comm::proto::ConsumerContext &cc,
879 comm::proto::QItem &item, comm::HandleResult &handle_result) {

Callers 1

UpdateConsumeStatMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected