41 void MaybeEchoDeadline(ServerContext* context, const EchoRequest* request,  in MaybeEchoDeadline()  argument
43   if (request->has_param() && request->param().echo_deadline()) {  in MaybeEchoDeadline()
74 Status TestServiceImpl::Echo(ServerContext* context, const EchoRequest* request,  in Echo()  argument
77   if (request->has_param() && request->param().server_sleep_us() > 0) {  in Echo()
80                      gpr_time_from_micros(request->param().server_sleep_us(),  in Echo()
84   if (request->has_param() && request->param().server_die()) {  in Echo()
88   if (request->has_param() && request->param().has_expected_error()) {  in Echo()
89     const auto& error = request->param().expected_error();  in Echo()
104   response->set_message(request->message());  in Echo()
105   MaybeEchoDeadline(context, request, response);  in Echo()
109   if (request->has_param() && request->param().client_cancel_after_us()) {  in Echo()
117           gpr_time_from_micros(request->param().client_cancel_after_us(),  in Echo()
121   } else if (request->has_param() &&  in Echo()
122              request->param().server_cancel_after_us()) {  in Echo()
125         gpr_time_from_micros(request->param().server_cancel_after_us(),  in Echo()
128   } else if (!request->has_param() ||  in Echo()
129              !request->param().skip_cancelled_check()) {  in Echo()
133   if (request->has_param() && request->param().echo_metadata()) {  in Echo()
143     if (request->param().debug_info().stack_entries_size() ||  in Echo()
144         !request->param().debug_info().detail().empty()) {  in Echo()
146           request->param().debug_info().SerializeAsString();  in Echo()
151   if (request->has_param() &&  in Echo()
152       (request->param().expected_client_identity().length() > 0 ||  in Echo()
153        request->param().check_auth_context())) {  in Echo()
155                            request->param().expected_transport_security_type(),  in Echo()
156                            request->param().expected_client_identity());  in Echo()
158   if (request->has_param() && request->param().response_message_length() > 0) {  in Echo()
160         grpc::string(request->param().response_message_length(), '\0'));  in Echo()
162   if (request->has_param() && request->param().echo_peer()) {  in Echo()
184   EchoRequest request;  in RequestStream()  local
199   while (reader->Read(&request)) {  in RequestStream()
200     response->mutable_message()->append(request.message());  in RequestStream()
221                                        const EchoRequest* request,  in ResponseStream()  argument
254     response.set_message(request->message() + grpc::to_string(i));  in ResponseStream()
290   EchoRequest request;  in BidiStream()  local
310   while (stream->Read(&request)) {  in BidiStream()
312     gpr_log(GPR_INFO, "recv msg %s", request.message().c_str());  in BidiStream()
313     response.set_message(request.message());  in BidiStream()