MCPcopy Create free account
hub / github.com/apache/incubator-pegasus / fetch_current_handler

Method fetch_current_handler

src/runtime/task/task.h:504–504  ·  view source on GitHub ↗

rpc_response_task is a special kind of task, because we support the semantic of distributed service in sending rpc request, for example: "querying meta-server and send message to proper replica-server based on gpid". in order to support this, we need to replace the original rpc response callback to another one: 1. which can proecss the distributed service semantics, AND 2. which won't call the or

Source from the content-addressed store, hash-verified

502 // TODO(sunweijie): totally elimite this feature
503 //
504 void fetch_current_handler(rpc_response_handler &cb) { cb = std::move(_cb); }
505 void replace_callback(rpc_response_handler &&cb)
506 {
507 task_state cur_state = state();

Callers 1

call_taskMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected