| 127 | } |
| 128 | |
| 129 | brpc::policy::MostCommonMessage* MakeRequestMessage( |
| 130 | brpc::mongo_head_t* head) { |
| 131 | head->message_length = sizeof(head) + EXP_REQUEST.length(); |
| 132 | head->op_code = brpc::MONGO_OPCODE_REPLY; |
| 133 | brpc::policy::MostCommonMessage* msg = |
| 134 | brpc::policy::MostCommonMessage::Get(); |
| 135 | msg->meta.append(&head, sizeof(head)); |
| 136 | msg->payload.append(EXP_REQUEST); |
| 137 | return msg; |
| 138 | } |
| 139 | |
| 140 | void CheckEmptyResponse() { |
| 141 | int bytes_in_pipe = 0; |