| 164 | } |
| 165 | |
| 166 | void ProcessMessage(void (*process)(brpc::InputMessageBase*), |
| 167 | brpc::InputMessageBase* msg, bool set_eof) { |
| 168 | if (msg->_socket == NULL) { |
| 169 | _socket->ReAddress(&msg->_socket); |
| 170 | } |
| 171 | msg->_arg = &_server; |
| 172 | _socket->PostponeEOF(); |
| 173 | if (set_eof) { |
| 174 | _socket->SetEOF(); |
| 175 | } |
| 176 | (*process)(msg); |
| 177 | } |
| 178 | |
| 179 | brpc::policy::HttpContext* MakePostRequestMessage(const std::string& path) { |
| 180 | brpc::policy::HttpContext* msg = new brpc::policy::HttpContext(false); |
nothing calls this directly
no test coverage detected