| 294 | } |
| 295 | |
| 296 | void EchoProcessHuluRequest(brpc::InputMessageBase* msg_base) { |
| 297 | brpc::DestroyingPtr<brpc::policy::MostCommonMessage> msg( |
| 298 | static_cast<brpc::policy::MostCommonMessage*>(msg_base)); |
| 299 | butil::IOBuf buf; |
| 300 | buf.append(msg->meta); |
| 301 | buf.append(msg->payload); |
| 302 | ASSERT_EQ(0, msg->socket()->Write(&buf)); |
| 303 | } |
| 304 | |
| 305 | class MyConnect : public brpc::AppConnect { |
| 306 | public: |