Skip to content
Snippets Groups Projects
Commit 5b39f9a9 authored by vjpai's avatar vjpai
Browse files

refresh -> Reset

parent 6e2e64a8
No related branches found
No related tags found
No related merge requests found
...@@ -157,7 +157,7 @@ class AsyncQpsServerTest { ...@@ -157,7 +157,7 @@ class AsyncQpsServerTest {
// The tag is a pointer to an RPC context to invoke // The tag is a pointer to an RPC context to invoke
if (ctx->RunNextState() == false) { if (ctx->RunNextState() == false) {
// this RPC context is done, so refresh it // this RPC context is done, so refresh it
ctx->refresh(); ctx->Reset();
} }
} }
return; return;
...@@ -174,7 +174,7 @@ class AsyncQpsServerTest { ...@@ -174,7 +174,7 @@ class AsyncQpsServerTest {
ServerRpcContext() {} ServerRpcContext() {}
virtual ~ServerRpcContext(){}; virtual ~ServerRpcContext(){};
virtual bool RunNextState() = 0;// do next state, return false if all done virtual bool RunNextState() = 0;// do next state, return false if all done
virtual void refresh() = 0; // start this back at a clean state virtual void Reset() = 0; // start this back at a clean state
}; };
static void *tag(ServerRpcContext *func) { static void *tag(ServerRpcContext *func) {
return reinterpret_cast<void *>(func); return reinterpret_cast<void *>(func);
...@@ -201,7 +201,7 @@ class AsyncQpsServerTest { ...@@ -201,7 +201,7 @@ class AsyncQpsServerTest {
} }
~ServerRpcContextUnaryImpl() GRPC_OVERRIDE {} ~ServerRpcContextUnaryImpl() GRPC_OVERRIDE {}
bool RunNextState() GRPC_OVERRIDE { return (this->*next_state_)(); } bool RunNextState() GRPC_OVERRIDE { return (this->*next_state_)(); }
void refresh() GRPC_OVERRIDE { void Reset() GRPC_OVERRIDE {
srv_ctx_ = ServerContext(); srv_ctx_ = ServerContext();
req_ = RequestType(); req_ = RequestType();
response_writer_ = response_writer_ =
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment