Lines Matching refs:method
47 inline bool ClientOnlyStreaming(const grpc_generator::Method *method) {
48 return method->ClientStreaming() && !method->ServerStreaming();
51 inline bool ServerOnlyStreaming(const grpc_generator::Method *method) {
52 return !method->ClientStreaming() && method->ServerStreaming();
93 // Generates Server method signature source
94 void GenerateServerMethodSignature(const grpc_generator::Method *method, grpc_generator::Printer *printer,
96 vars["Method"] = exportName(method->name());
97 vars["Request"] = method->get_input_type_name();
98 vars["Response"] = (vars["CustomMethodIO"] == "") ? method->get_output_type_name() : vars["CustomMethodIO"];
99 if (method->NoStreaming()) {
100 printer->Print(vars, "$Method$($context$.Context, *$Request$) (*$Response$, error)");
101 } else if (ServerOnlyStreaming(method)) {
102 printer->Print(vars, "$Method$(*$Request$, $Service$_$Method$Server) error");
104 printer->Print(vars, "$Method$($Service$_$Method$Server) error");
108 void GenerateServerMethod(const grpc_generator::Method *method, grpc_generator::Printer *printer,
110 vars["Method"] = exportName(method->name());
111 vars["Request"] = method->get_input_type_name();
112 vars["Response"] = (vars["CustomMethodIO"] == "") ? method->get_output_type_name() : vars["CustomMethodIO"];
113 vars["FullMethodName"] = "/" + vars["Package"] + "." + vars["Service"] + "/" + vars["Method"];
114 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler";
115 if (method->NoStreaming()) {
120 printer->Print(vars, "if interceptor == nil { return srv.($Service$Server).$Method$(ctx, in) }\n");
129 printer->Print(vars, "return srv.($Service$Server).$Method$(ctx, req.(* $Request$))\n");
137 vars["StreamType"] = vars["ServiceUnexported"] + vars["Method"] + "Server";
140 if (ServerOnlyStreaming(method)) {
143 printer->Print(vars, "return srv.($Service$Server).$Method$(m, &$StreamType${stream})\n");
145 printer->Print(vars, "return srv.($Service$Server).$Method$(&$StreamType${stream})\n");
150 bool genSend = method->BidiStreaming() || ServerOnlyStreaming(method);
151 bool genRecv = method->BidiStreaming() || ClientOnlyStreaming(method);
152 bool genSendAndClose = ClientOnlyStreaming(method);
154 printer->Print(vars, "type $Service$_$Method$Server interface { \n");
201 // Generates Client method signature source
202 void GenerateClientMethodSignature(const grpc_generator::Method *method, grpc_generator::Printer *printer,
204 vars["Method"] = exportName(method->name());
205 vars["Request"] = ", in *" + ((vars["CustomMethodIO"] == "") ? method->get_input_type_name() : vars["CustomMethodIO"]);
206 if (ClientOnlyStreaming(method) || method->BidiStreaming()) {
209 vars["Response"] = "* " + method->get_output_type_name();
210 if (ClientOnlyStreaming(method) || method->BidiStreaming() || ServerOnlyStreaming(method)) {
211 vars["Response"] = vars["Service"] + "_" + vars["Method"] + "Client" ;
213 printer->Print(vars, "$Method$(ctx $context$.Context$Request$, \n\topts... $grpc$.CallOption) ($Response$, error)");
216 // Generates Client method source
217 void GenerateClientMethod(const grpc_generator::Method *method, grpc_generator::Printer *printer,
220 GenerateClientMethodSignature(method, printer, vars);
223 vars["Method"] = exportName(method->name());
224 vars["Request"] = (vars["CustomMethodIO"] == "") ? method->get_input_type_name() : vars["CustomMethodIO"];
225 vars["Response"] = method->get_output_type_name();
226 vars["FullMethodName"] = "/" + vars["Package"] + "." + vars["Service"] + "/" + vars["Method"];
227 if (method->NoStreaming()) {
236 vars["StreamType"] = vars["ServiceUnexported"] + vars["Method"] + "Client";
241 if (ServerOnlyStreaming(method)) {
249 bool genSend = method->BidiStreaming() || ClientOnlyStreaming(method);
250 bool genRecv = method->BidiStreaming() || ServerOnlyStreaming(method);
251 bool genCloseAndRecv = ClientOnlyStreaming(method);
254 printer->Print(vars, "type $Service$_$Method$Client interface {\n");
315 GenerateClientMethodSignature(service->method(i).get(), printer, vars);
339 auto method = service->method(i);
340 if (method->NoStreaming()) {
341 vars["MethodDesc"] = vars["ServiceDesc"] + ".Method[" + as_string(unary_methods) + "]";
347 GenerateClientMethod(method.get(), printer, vars);
355 GenerateServerMethodSignature(service->method(i).get(), printer, vars);
369 GenerateServerMethod(service->method(i).get(), printer, vars);
382 auto method = service->method(i);
383 vars["Method"] = method->name();
384 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler";
385 if (method->NoStreaming()) {
388 printer->Print(vars, "MethodName: \"$Method$\",\n");
399 auto method = service->method(i);
400 vars["Method"] = method->name();
401 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler";
402 if (!method->NoStreaming()) {
405 printer->Print(vars, "StreamName: \"$Method$\",\n");
407 if (ClientOnlyStreaming(method.get())) {
409 } else if (ServerOnlyStreaming(method.get())) {
