diff options
author | Craig Tiller <ctiller@google.com> | 2015-08-17 14:59:51 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-08-17 14:59:51 -0700 |
commit | 629c6f534f292163986abce5dd3d97e9846171d3 (patch) | |
tree | e9fbb4c8ce6e911c45c6cb0956e50d803f80d803 /src | |
parent | 8f7bff7d48129e577f972815afcc9f32c78d258b (diff) |
Re-add accidentally deleted code
Diffstat (limited to 'src')
-rw-r--r-- | src/cpp/server/server.cc | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/cpp/server/server.cc b/src/cpp/server/server.cc index dbe60e50de..dfc2b303bc 100644 --- a/src/cpp/server/server.cc +++ b/src/cpp/server/server.cc @@ -333,6 +333,15 @@ bool Server::Start(ServerCompletionQueue** cqs, size_t num_cqs) { new UnimplementedAsyncRequest(this, cqs[i]); } } + // Start processing rpcs. + if (!sync_methods_->empty()) { + for (auto m = sync_methods_->begin(); m != sync_methods_->end(); m++) { + m->SetupRequest(); + m->Request(server_, cq_.cq()); + } + + ScheduleCallback(); + } return true; } |