| 578 | } |
| 579 | |
| 580 | bool Store::SkipGet(const comm::proto::QItem &item, const comm::proto::GetRequest &req) { |
| 581 | comm::RetCode ret; |
| 582 | |
| 583 | if (item.meta().topic_id() != req.topic_id()) { |
| 584 | QLErr("get item skip. item.topic %d req.topic %d", |
| 585 | item.meta().topic_id(), req.topic_id()); |
| 586 | return true; |
| 587 | } |
| 588 | |
| 589 | if (0 == ((1ULL << (req.sub_id() - 1)) & item.sub_ids())) { |
| 590 | return true; |
| 591 | } |
| 592 | |
| 593 | return false; |
| 594 | } |
| 595 | |
| 596 | bool Store::NeedDropMaster(const int paxos_group_id) { |
| 597 | return false; |