MCPcopy Create free account
hub / github.com/alibaba/PhotonLibOS / serve_request

Method serve_request

rpc/rpc.cpp:287–295  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

285 return 0;
286 }
287 int serve_request()
288 {
289 sk->m_serving_count++;
290 ResponseSender sender(this, &Context::response_sender);
291 int ret = func(&request, sender, stream);
292 sk->m_serving_count--;
293 sk->m_cond_served.notify_all();
294 return ret;
295 }
296 int response_sender(iovector* resp)
297 {
298 assert(w_lock);

Callers 1

async_serveMethod · 0.80

Calls 2

funcFunction · 0.50
notify_allMethod · 0.45

Tested by

no test coverage detected