Lines Matching refs:method
158 grpc_generator::Printer *printer, const grpc_generator::Method *method,
160 (*vars)["Method"] = method->name();
161 (*vars)["Request"] = method->input_type_name();
162 (*vars)["Response"] = method->output_type_name();
165 if (method->NoStreaming()) {
168 "virtual ::grpc::Status $Method$(::grpc::ClientContext* context, "
173 "Async$Method$(::grpc::ClientContext* context, "
180 "Async$Method$Raw(context, request, cq));\n");
183 } else if (method->ClientOnlyStreaming()) {
187 " $Method$("
193 "($Method$Raw(context, response));\n");
199 " Async$Method$(::grpc::ClientContext* context, $Response$* "
206 "Async$Method$Raw(context, response, cq, tag));\n");
209 } else if (method->ServerOnlyStreaming()) {
213 " $Method$(::grpc::ClientContext* context, const $Request$& request)"
219 "($Method$Raw(context, request));\n");
225 "Async$Method$("
232 "Async$Method$Raw(context, request, cq, tag));\n");
235 } else if (method->BidiStreaming()) {
239 "$Method$(::grpc::ClientContext* context) {\n");
245 "$Method$Raw(context));\n");
252 "Async$Method$(::grpc::ClientContext* context, "
259 "Async$Method$Raw(context, cq, tag));\n");
264 if (method->NoStreaming()) {
268 "Async$Method$Raw(::grpc::ClientContext* context, "
271 } else if (method->ClientOnlyStreaming()) {
275 " $Method$Raw("
279 " Async$Method$Raw(::grpc::ClientContext* context, "
282 } else if (method->ServerOnlyStreaming()) {
285 "virtual ::grpc::ClientReaderInterface< $Response$>* $Method$Raw("
290 "Async$Method$Raw("
293 } else if (method->BidiStreaming()) {
297 "$Method$Raw(::grpc::ClientContext* context) = 0;\n");
301 "Async$Method$Raw(::grpc::ClientContext* context, "
308 const grpc_generator::Method *method,
311 (*vars)["Method"] = method->name();
312 (*vars)["Request"] = method->input_type_name();
313 (*vars)["Response"] = method->output_type_name();
315 if (method->NoStreaming()) {
318 "::grpc::Status $Method$(::grpc::ClientContext* context, "
323 "Async$Method$(::grpc::ClientContext* context, "
330 "Async$Method$Raw(context, request, cq));\n");
333 } else if (method->ClientOnlyStreaming()) {
337 " $Method$("
342 "($Method$Raw(context, response));\n");
347 " Async$Method$(::grpc::ClientContext* context, "
354 "Async$Method$Raw(context, response, cq, tag));\n");
357 } else if (method->ServerOnlyStreaming()) {
361 " $Method$(::grpc::ClientContext* context, const $Request$& request)"
367 "($Method$Raw(context, request));\n");
373 "Async$Method$("
380 "Async$Method$Raw(context, request, cq, tag));\n");
383 } else if (method->BidiStreaming()) {
387 " $Method$(::grpc::ClientContext* context) {\n");
392 "$Method$Raw(context));\n");
398 "Async$Method$(::grpc::ClientContext* context, "
404 "Async$Method$Raw(context, cq, tag));\n");
409 if (method->NoStreaming()) {
412 "Async$Method$Raw(::grpc::ClientContext* context, "
415 } else if (method->ClientOnlyStreaming()) {
417 "::grpc::ClientWriter< $Request$>* $Method$Raw("
422 "::grpc::ClientAsyncWriter< $Request$>* Async$Method$Raw("
425 } else if (method->ServerOnlyStreaming()) {
427 "::grpc::ClientReader< $Response$>* $Method$Raw("
432 "::grpc::ClientAsyncReader< $Response$>* Async$Method$Raw("
435 } else if (method->BidiStreaming()) {
439 "$Method$Raw(::grpc::ClientContext* context) GRPC_OVERRIDE;\n");
443 "Async$Method$Raw(::grpc::ClientContext* context, "
449 void PrintHeaderClientMethodData(grpc_generator::Printer *printer, const grpc_generator::Method *method,
451 (*vars)["Method"] = method->name();
452 printer->Print(*vars, "const ::grpc::RpcMethod rpcmethod_$Method$_;\n");
455 void PrintHeaderServerMethodSync(grpc_generator::Printer *printer, const grpc_generator::Method *method,
457 (*vars)["Method"] = method->name();
458 (*vars)["Request"] = method->input_type_name();
459 (*vars)["Response"] = method->output_type_name();
460 if (method->NoStreaming()) {
462 "virtual ::grpc::Status $Method$("
465 } else if (method->ClientOnlyStreaming()) {
467 "virtual ::grpc::Status $Method$("
471 } else if (method->ServerOnlyStreaming()) {
473 "virtual ::grpc::Status $Method$("
476 } else if (method->BidiStreaming()) {
479 "virtual ::grpc::Status $Method$("
488 const grpc_generator::Method *method,
490 (*vars)["Method"] = method->name();
491 (*vars)["Request"] = method->input_type_name();
492 (*vars)["Response"] = method->output_type_name();
495 "class WithAsyncMethod_$Method$ : public BaseClass {\n");
502 "WithAsyncMethod_$Method$() {\n"
506 "~WithAsyncMethod_$Method$() GRPC_OVERRIDE {\n"
509 if (method->NoStreaming()) {
512 "// disable synchronous version of this method\n"
513 "::grpc::Status $Method$("
521 "void Request$Method$("
530 } else if (method->ClientOnlyStreaming()) {
533 "// disable synchronous version of this method\n"
534 "::grpc::Status $Method$("
543 "void Request$Method$("
552 } else if (method->ServerOnlyStreaming()) {
555 "// disable synchronous version of this method\n"
556 "::grpc::Status $Method$("
565 "void Request$Method$("
575 } else if (method->BidiStreaming()) {
578 "// disable synchronous version of this method\n"
579 "::grpc::Status $Method$("
588 "void Request$Method$("
604 const grpc_generator::Method *method,
606 (*vars)["Method"] = method->name();
607 (*vars)["Request"] = method->input_type_name();
608 (*vars)["Response"] = method->output_type_name();
611 "class WithGenericMethod_$Method$ : public BaseClass {\n");
618 "WithGenericMethod_$Method$() {\n"
622 "~WithGenericMethod_$Method$() GRPC_OVERRIDE {\n"
625 if (method->NoStreaming()) {
628 "// disable synchronous version of this method\n"
629 "::grpc::Status $Method$("
635 } else if (method->ClientOnlyStreaming()) {
638 "// disable synchronous version of this method\n"
639 "::grpc::Status $Method$("
646 } else if (method->ServerOnlyStreaming()) {
649 "// disable synchronous version of this method\n"
650 "::grpc::Status $Method$("
657 } else if (method->BidiStreaming()) {
660 "// disable synchronous version of this method\n"
661 "::grpc::Status $Method$("
690 PrintHeaderClientMethodInterfaces(printer, service->method(i).get(), vars, true);
696 PrintHeaderClientMethodInterfaces(printer, service->method(i).get(), vars, false);
706 PrintHeaderClientMethod(printer, service->method(i).get(), vars, true);
713 PrintHeaderClientMethod(printer, service->method(i).get(), vars, false);
716 PrintHeaderClientMethodData(printer, service->method(i).get(), vars);
735 PrintHeaderServerMethodSync(printer, service->method(i).get(), vars);
743 PrintHeaderServerMethodAsync(printer, service->method(i).get(), vars);
749 (*vars)["method_name"] = service->method(i).get()->name();
761 PrintHeaderServerMethodGeneric(printer, service->method(i).get(), vars);
776 // method names.
885 const grpc_generator::Method *method,
887 (*vars)["Method"] = method->name();
888 (*vars)["Request"] = method->input_type_name();
889 (*vars)["Response"] = method->output_type_name();
890 if (method->NoStreaming()) {
892 "::grpc::Status $ns$$Service$::Stub::$Method$("
897 "rpcmethod_$Method$_, "
903 "$ns$$Service$::Stub::Async$Method$Raw(::grpc::ClientContext* context, "
910 "rpcmethod_$Method$_, "
913 } else if (method->ClientOnlyStreaming()) {
916 "$ns$$Service$::Stub::$Method$Raw("
921 "rpcmethod_$Method$_, "
926 "$ns$$Service$::Stub::Async$Method$Raw("
932 "rpcmethod_$Method$_, "
935 } else if (method->ServerOnlyStreaming()) {
939 "$ns$$Service$::Stub::$Method$Raw("
944 "rpcmethod_$Method$_, "
949 "$ns$$Service$::Stub::Async$Method$Raw("
955 "rpcmethod_$Method$_, "
958 } else if (method->BidiStreaming()) {
962 "$ns$$Service$::Stub::$Method$Raw(::grpc::ClientContext* context) {\n");
967 "rpcmethod_$Method$_, "
973 "$ns$$Service$::Stub::Async$Method$Raw(::grpc::ClientContext* context, "
979 "rpcmethod_$Method$_, "
986 const grpc_generator::Method *method,
988 (*vars)["Method"] = method->name();
989 (*vars)["Request"] = method->input_type_name();
990 (*vars)["Response"] = method->output_type_name();
991 if (method->NoStreaming()) {
993 "::grpc::Status $ns$$Service$::Service::$Method$("
1003 } else if (method->ClientOnlyStreaming()) {
1005 "::grpc::Status $ns$$Service$::Service::$Method$("
1016 } else if (method->ServerOnlyStreaming()) {
1018 "::grpc::Status $ns$$Service$::Service::$Method$("
1029 } else if (method->BidiStreaming()) {
1031 "::grpc::Status $ns$$Service$::Service::$Method$("
1052 (*vars)["Method"] = service->method(i).get()->name();
1053 printer->Print(*vars, " \"/$Package$$Service$/$Method$\",\n");
1071 auto method = service->method(i);
1072 (*vars)["Method"] = method->name();
1074 if (method->NoStreaming()) {
1076 } else if (method->ClientOnlyStreaming()) {
1078 } else if (method->ServerOnlyStreaming()) {
1084 ", rpcmethod_$Method$_("
1095 PrintSourceClientMethod(printer, service->method(i).get(), vars);
1102 auto method = service->method(i);
1104 (*vars)["Method"] = method->name();
1105 (*vars)["Request"] = method->input_type_name();
1106 (*vars)["Response"] = method->output_type_name();
1107 if (method->NoStreaming()) {
1116 " std::mem_fn(&$ns$$Service$::Service::$Method$), this)));\n");
1117 } else if (method->ClientOnlyStreaming()) {
1125 " std::mem_fn(&$ns$$Service$::Service::$Method$), this)));\n");
1126 } else if (method->ServerOnlyStreaming()) {
1134 " std::mem_fn(&$ns$$Service$::Service::$Method$), this)));\n");
1135 } else if (method->BidiStreaming()) {
1143 " std::mem_fn(&$ns$$Service$::Service::$Method$), this)));\n");
1153 PrintSourceServerMethod(printer, service->method(i).get(), vars);
1165 // method names.
