| 70 | #define REGISTER_MSG(Msg) REGISTER_FACTORY(ExtMsg, Msg, opcode) |
| 71 | |
| 72 | struct ExtMsgQuery : ExtMsg, FastAllocated<ExtMsgQuery> { |
| 73 | enum { opcode = 2004 }; |
| 74 | |
| 75 | ExtMsgHeader* header; |
| 76 | int32_t flags; |
| 77 | Namespace ns; |
| 78 | int32_t numberToSkip; |
| 79 | int32_t numberToReturn; |
| 80 | bson::BSONObj query; |
| 81 | bson::BSONObj returnFieldSelector; |
| 82 | bool isCmd; |
| 83 | |
| 84 | std::string toString() override; |
| 85 | Future<Void> run(Reference<ExtConnection>) override; |
| 86 | |
| 87 | std::string getDBName(); |
| 88 | |
| 89 | private: |
| 90 | ExtMsgQuery(ExtMsgHeader*, const uint8_t*); |
| 91 | friend struct ExtMsg::Factory<ExtMsgQuery>; |
| 92 | }; |
| 93 | |
| 94 | struct ExtMsgReply : ExtMsg, FastAllocated<ExtMsgReply> { |
| 95 | enum { opcode = 1 }; |
nothing calls this directly
no outgoing calls
no test coverage detected