MCPcopy Create free account
hub / github.com/apache/brpc / ProcessMessage

Method ProcessMessage

test/brpc_http_rpc_protocol_unittest.cpp:166–177  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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);

Callers

nothing calls this directly

Calls 3

ReAddressMethod · 0.80
PostponeEOFMethod · 0.80
SetEOFMethod · 0.80

Tested by

no test coverage detected