Add service definition to sync server

pull/17350/head
Hope Casey-Allen 6 years ago
parent 470ea17843
commit 4a6e165328
  1. 2
      test/cpp/end2end/client_callback_end2end_test.cc
  2. 20
      test/cpp/end2end/test_service_impl.cc
  3. 4
      test/cpp/end2end/test_service_impl.h

@ -219,8 +219,8 @@ TEST_P(ClientCallbackEnd2endTest, SendClientInitialMetadata) {
gpr_log(GPR_ERROR, s.error_message().c_str());
gpr_log(GPR_ERROR, s.error_details().c_str());
GPR_ASSERT(s.ok());
std::lock_guard<std::mutex> l(mu);
done = true;
cv.notify_one();
});

@ -181,17 +181,16 @@ Status TestServiceImpl::Echo(ServerContext* context, const EchoRequest* request,
return Status::OK;
}
void CallbackTestServiceImpl::CheckClientInitialMetadata(
Status TestServiceImpl::CheckClientInitialMetadata(
ServerContext* context, const SimpleRequest* request,
SimpleResponse* response,
experimental::ServerCallbackRpcController* controller) {
SimpleResponse* response) {
EXPECT_EQ(MetadataMatchCount(context->client_metadata(),
kCheckClientInitialMetadataKey,
kCheckClientInitialMetadataVal),
1);
EXPECT_EQ(1u,
context->client_metadata().count(kCheckClientInitialMetadataKey));
controller->Finish(Status::OK);
return Status::OK;
}
void CallbackTestServiceImpl::Echo(
@ -212,6 +211,19 @@ void CallbackTestServiceImpl::Echo(
}
}
void CallbackTestServiceImpl::CheckClientInitialMetadata(
ServerContext* context, const SimpleRequest* request,
SimpleResponse* response,
experimental::ServerCallbackRpcController* controller) {
EXPECT_EQ(MetadataMatchCount(context->client_metadata(),
kCheckClientInitialMetadataKey,
kCheckClientInitialMetadataVal),
1);
EXPECT_EQ(1u,
context->client_metadata().count(kCheckClientInitialMetadataKey));
controller->Finish(Status::OK);
}
void CallbackTestServiceImpl::EchoNonDelayed(
ServerContext* context, const EchoRequest* request, EchoResponse* response,
experimental::ServerCallbackRpcController* controller) {

@ -55,6 +55,10 @@ class TestServiceImpl : public ::grpc::testing::EchoTestService::Service {
Status Echo(ServerContext* context, const EchoRequest* request,
EchoResponse* response) override;
Status CheckClientInitialMetadata(
ServerContext* context, const SimpleRequest* request,
SimpleResponse* response) override;
// Unimplemented is left unimplemented to test the returned error.
Status RequestStream(ServerContext* context,

Loading…
Cancel
Save