Lines Matching full:vars
39 typedef std::map<grpc::string, grpc::string> VARS; typedef
50 grpc_generator::Printer *printer, VARS &vars) { in GenerateImports() argument
51 vars["filename"] = file->filename(); in GenerateImports()
52 printer->Print(vars, in GenerateImports()
55 printer->Print(vars, "//source: $filename$.fbs\n\n"); in GenerateImports()
56 printer->Print(vars, "package $Package$;\n\n"); in GenerateImports()
57 vars["Package"] = vars["Package"] + "."; in GenerateImports()
115 static inline string JavaClassName(VARS &vars, const string &name) { in JavaClassName() argument
117 return vars["Package"] + name; in JavaClassName()
253 static void GrpcWriteDocCommentBody(Printer *printer, VARS &vars, in GrpcWriteDocCommentBody() argument
263 vars["line"] = lines[i]; in GrpcWriteDocCommentBody()
265 printer->Print(vars, " * $line$\n"); in GrpcWriteDocCommentBody()
267 printer->Print(vars, " *$line$\n"); in GrpcWriteDocCommentBody()
275 static void GrpcWriteDocComment(Printer *printer, VARS &vars, in GrpcWriteDocComment() argument
279 GrpcWriteDocCommentBody(printer, vars, lines, false); in GrpcWriteDocComment()
283 static void GrpcWriteServiceDocComment(Printer *printer, VARS &vars, in GrpcWriteServiceDocComment() argument
287 GrpcWriteDocCommentBody(printer, vars, lines, true); in GrpcWriteServiceDocComment()
291 static void GrpcWriteMethodDocComment(Printer *printer, VARS &vars, in GrpcWriteMethodDocComment() argument
295 GrpcWriteDocCommentBody(printer, vars, lines, true); in GrpcWriteMethodDocComment()
300 // "extr_type_name" vars
301 static void PrintTypeExtractor(Printer *p, VARS &vars) { in PrintTypeExtractor() argument
302 p->Print(vars, in PrintTypeExtractor()
323 static void PrintMethodFields(Printer *p, VARS &vars, in PrintMethodFields() argument
326 vars["service_name"] = service->name(); in PrintMethodFields()
336 vars["arg_in_id"] = to_string(2L * i); // trying to make msvc 10 happy in PrintMethodFields()
337 vars["arg_out_id"] = to_string(2L * i + 1); in PrintMethodFields()
338 vars["method_name"] = method->name(); in PrintMethodFields()
339 vars["input_type_name"] = method->get_input_type_name(); in PrintMethodFields()
340 vars["output_type_name"] = method->get_output_type_name(); in PrintMethodFields()
341 vars["input_type"] = JavaClassName(vars, method->get_input_type_name()); in PrintMethodFields()
342 vars["output_type"] = JavaClassName(vars, method->get_output_type_name()); in PrintMethodFields()
343 vars["method_field_name"] = MethodPropertiesFieldName(method.get()); in PrintMethodFields()
344 vars["method_new_field_name"] = MethodPropertiesGetterName(method.get()); in PrintMethodFields()
345 vars["method_method_name"] = MethodPropertiesGetterName(method.get()); in PrintMethodFields()
352 vars["method_type"] = "BIDI_STREAMING"; in PrintMethodFields()
354 vars["method_type"] = "CLIENT_STREAMING"; in PrintMethodFields()
358 vars["method_type"] = "SERVER_STREAMING"; in PrintMethodFields()
360 vars["method_type"] = "UNARY"; in PrintMethodFields()
365 vars, in PrintMethodFields()
376 if (encounteredTypes.insert(vars["input_type_name"]).second) { in PrintMethodFields()
377 vars["extr_type"] = vars["input_type"]; in PrintMethodFields()
378 vars["extr_type_name"] = vars["input_type_name"]; in PrintMethodFields()
379 PrintTypeExtractor(p, vars); in PrintMethodFields()
382 if (encounteredTypes.insert(vars["output_type_name"]).second) { in PrintMethodFields()
383 vars["extr_type"] = vars["output_type"]; in PrintMethodFields()
384 vars["extr_type_name"] = vars["output_type_name"]; in PrintMethodFields()
385 PrintTypeExtractor(p, vars); in PrintMethodFields()
389 vars, in PrintMethodFields()
416 // vars["proto_method_descriptor_supplier"] = service->name() + in PrintMethodFields()
418 p->Print(vars, " .setSchemaDescriptor(null)\n"); in PrintMethodFields()
422 p->Print(vars, " .build();\n"); in PrintMethodFields()
423 p->Print(vars, in PrintMethodFields()
446 static void PrintBindServiceMethodBody(Printer *p, VARS &vars,
450 static void PrintStub(Printer *p, VARS &vars, const ServiceDescriptor *service, in PrintStub() argument
453 vars["service_name"] = service_name; in PrintStub()
454 vars["abstract_name"] = service_name + "ImplBase"; in PrintStub()
492 vars["stub_name"] = stub_name; in PrintStub()
493 vars["client_name"] = client_name; in PrintStub()
496 if (!interface) { GrpcWriteServiceDocComment(p, vars, service); } in PrintStub()
498 p->Print(vars, in PrintStub()
502 p->Print(vars, in PrintStub()
510 p->Print(vars, "private $stub_name$($Channel$ channel) {\n"); in PrintStub()
515 p->Print(vars, in PrintStub()
522 p->Print(vars, in PrintStub()
527 p->Print(vars, "return new $stub_name$(channel, callOptions);\n"); in PrintStub()
535 vars["input_type"] = JavaClassName(vars, method->get_input_type_name()); in PrintStub()
536 vars["output_type"] = JavaClassName(vars, method->get_output_type_name()); in PrintStub()
537 vars["lower_method_name"] = LowerMethodName(&*method); in PrintStub()
538 vars["method_method_name"] = MethodPropertiesGetterName(&*method); in PrintStub()
558 if (!interface) { GrpcWriteMethodDocComment(p, vars, &*method); } in PrintStub()
566 p->Print(vars, in PrintStub()
571 p->Print(vars, in PrintStub()
578 p->Print(vars, in PrintStub()
583 p->Print(vars, in PrintStub()
593 p->Print(vars, in PrintStub()
613 p->Print(vars, in PrintStub()
618 p->Print(vars, in PrintStub()
631 vars["calls_method"] = "blockingServerStreamingCall"; in PrintStub()
632 vars["params"] = "request"; in PrintStub()
634 vars["calls_method"] = "blockingUnaryCall"; in PrintStub()
635 vars["params"] = "request"; in PrintStub()
637 p->Print(vars, in PrintStub()
645 vars["calls_method"] = "asyncBidiStreamingCall"; in PrintStub()
646 vars["params"] = "responseObserver"; in PrintStub()
648 vars["calls_method"] = "asyncServerStreamingCall"; in PrintStub()
649 vars["params"] = "request, responseObserver"; in PrintStub()
653 vars["calls_method"] = "asyncClientStreamingCall"; in PrintStub()
654 vars["params"] = "responseObserver"; in PrintStub()
656 vars["calls_method"] = "asyncUnaryCall"; in PrintStub()
657 vars["params"] = "request, responseObserver"; in PrintStub()
660 vars["last_line_prefix"] = client_streaming ? "return " : ""; in PrintStub()
661 p->Print(vars, in PrintStub()
671 vars["calls_method"] = "futureUnaryCall"; in PrintStub()
672 p->Print(vars, in PrintStub()
686 vars, in PrintStub()
688 vars["instance"] = "this"; in PrintStub()
689 PrintBindServiceMethodBody(p, vars, service); in PrintStub()
705 static void PrintMethodHandlerClass(Printer *p, VARS &vars, in PrintMethodHandlerClass() argument
717 vars["method_id"] = to_string(i); in PrintMethodHandlerClass()
718 vars["method_id_name"] = MethodIdFieldName(&*method); in PrintMethodHandlerClass()
719 p->Print(vars, in PrintMethodHandlerClass()
723 vars["service_name"] = service->name() + "ImplBase"; in PrintMethodHandlerClass()
724 p->Print(vars, in PrintMethodHandlerClass()
738 p->Print(vars, in PrintMethodHandlerClass()
750 vars["method_id_name"] = MethodIdFieldName(&*method); in PrintMethodHandlerClass()
751 vars["lower_method_name"] = LowerMethodName(&*method); in PrintMethodHandlerClass()
752 vars["input_type"] = JavaClassName(vars, method->get_input_type_name()); in PrintMethodHandlerClass()
753 vars["output_type"] = JavaClassName(vars, method->get_output_type_name()); in PrintMethodHandlerClass()
754 p->Print(vars, in PrintMethodHandlerClass()
770 p->Print(vars, in PrintMethodHandlerClass()
782 vars["method_id_name"] = MethodIdFieldName(&*method); in PrintMethodHandlerClass()
783 vars["lower_method_name"] = LowerMethodName(&*method); in PrintMethodHandlerClass()
784 vars["input_type"] = JavaClassName(vars, method->get_input_type_name()); in PrintMethodHandlerClass()
785 vars["output_type"] = JavaClassName(vars, method->get_output_type_name()); in PrintMethodHandlerClass()
787 vars, in PrintMethodHandlerClass()
806 static void PrintGetServiceDescriptorMethod(Printer *p, VARS &vars, in PrintGetServiceDescriptorMethod() argument
808 vars["service_name"] = service->name(); in PrintGetServiceDescriptorMethod()
809 // vars["proto_base_descriptor_supplier"] = service->name() + in PrintGetServiceDescriptorMethod()
810 // "BaseDescriptorSupplier"; vars["proto_file_descriptor_supplier"] = in PrintGetServiceDescriptorMethod()
812 // vars["proto_method_descriptor_supplier"] = service->name() + in PrintGetServiceDescriptorMethod()
813 // "MethodDescriptorSupplier"; vars["proto_class_name"] = in PrintGetServiceDescriptorMethod()
816 // vars, in PrintGetServiceDescriptorMethod()
858 vars, in PrintGetServiceDescriptorMethod()
861 p->Print(vars, in PrintGetServiceDescriptorMethod()
864 p->Print(vars, "$ServiceDescriptor$ result = serviceDescriptor;\n"); in PrintGetServiceDescriptorMethod()
867 p->Print(vars, "synchronized ($service_class_name$.class) {\n"); in PrintGetServiceDescriptorMethod()
873 p->Print(vars, in PrintGetServiceDescriptorMethod()
878 p->Print(vars, "\n.setSchemaDescriptor(null)"); in PrintGetServiceDescriptorMethod()
881 vars["method_method_name"] = MethodPropertiesGetterName(&*method); in PrintGetServiceDescriptorMethod()
882 p->Print(vars, "\n.addMethod($method_method_name$())"); in PrintGetServiceDescriptorMethod()
899 static void PrintBindServiceMethodBody(Printer *p, VARS &vars, in PrintBindServiceMethodBody() argument
901 vars["service_name"] = service->name(); in PrintBindServiceMethodBody()
903 p->Print(vars, in PrintBindServiceMethodBody()
910 vars["lower_method_name"] = LowerMethodName(&*method); in PrintBindServiceMethodBody()
911 vars["method_method_name"] = MethodPropertiesGetterName(&*method); in PrintBindServiceMethodBody()
912 vars["input_type"] = JavaClassName(vars, method->get_input_type_name()); in PrintBindServiceMethodBody()
913 vars["output_type"] = JavaClassName(vars, method->get_output_type_name()); in PrintBindServiceMethodBody()
914 vars["method_id_name"] = MethodIdFieldName(&*method); in PrintBindServiceMethodBody()
921 vars["calls_method"] = "asyncBidiStreamingCall"; in PrintBindServiceMethodBody()
923 vars["calls_method"] = "asyncClientStreamingCall"; in PrintBindServiceMethodBody()
927 vars["calls_method"] = "asyncServerStreamingCall"; in PrintBindServiceMethodBody()
929 vars["calls_method"] = "asyncUnaryCall"; in PrintBindServiceMethodBody()
932 p->Print(vars, ".addMethod(\n"); in PrintBindServiceMethodBody()
934 p->Print(vars, in PrintBindServiceMethodBody()
938 p->Print(vars, in PrintBindServiceMethodBody()
952 static void PrintService(Printer *p, VARS &vars, in PrintService() argument
955 vars["service_name"] = service->name(); in PrintService()
956 vars["service_class_name"] = ServiceClassName(service->name()); in PrintService()
957 vars["grpc_version"] = ""; in PrintService()
960 vars["grpc_version"] = " (version " XSTR(GRPC_VERSION) ")"; in PrintService()
967 GrpcWriteServiceDocComment(p, vars, service); in PrintService()
968 p->Print(vars, in PrintService()
974 p->Print(vars, "private $service_class_name$() {}\n\n"); in PrintService()
976 p->Print(vars, in PrintService()
980 PrintMethodFields(p, vars, service); in PrintService()
985 p, vars, in PrintService()
987 p->Print(vars, in PrintService()
990 p->Print(vars, "return new $service_name$Stub(channel);\n"); in PrintService()
997 p, vars, in PrintService()
1000 p->Print(vars, in PrintService()
1004 p->Print(vars, "return new $service_name$BlockingStub(channel);\n"); in PrintService()
1011 p, vars, in PrintService()
1014 p->Print(vars, in PrintService()
1018 p->Print(vars, "return new $service_name$FutureStub(channel);\n"); in PrintService()
1022 PrintStub(p, vars, service, ABSTRACT_CLASS); in PrintService()
1023 PrintStub(p, vars, service, ASYNC_CLIENT_IMPL); in PrintService()
1024 PrintStub(p, vars, service, BLOCKING_CLIENT_IMPL); in PrintService()
1025 PrintStub(p, vars, service, FUTURE_CLIENT_IMPL); in PrintService()
1027 PrintMethodHandlerClass(p, vars, service); in PrintService()
1028 PrintGetServiceDescriptorMethod(p, vars, service); in PrintService()
1067 grpc_generator::Printer *printer, VARS &vars, in GenerateService() argument
1071 vars["String"] = "java.lang.String"; in GenerateService()
1072 vars["Deprecated"] = "java.lang.Deprecated"; in GenerateService()
1073 vars["Override"] = "java.lang.Override"; in GenerateService()
1074 vars["Channel"] = "io.grpc.Channel"; in GenerateService()
1075 vars["CallOptions"] = "io.grpc.CallOptions"; in GenerateService()
1076 vars["MethodType"] = "io.grpc.MethodDescriptor.MethodType"; in GenerateService()
1077 vars["ServerMethodDefinition"] = "io.grpc.ServerMethodDefinition"; in GenerateService()
1078 vars["BindableService"] = "io.grpc.BindableService"; in GenerateService()
1079 vars["ServerServiceDefinition"] = "io.grpc.ServerServiceDefinition"; in GenerateService()
1080 vars["ServiceDescriptor"] = "io.grpc.ServiceDescriptor"; in GenerateService()
1081 vars["ProtoFileDescriptorSupplier"] = in GenerateService()
1083 vars["ProtoServiceDescriptorSupplier"] = in GenerateService()
1085 vars["ProtoMethodDescriptorSupplier"] = in GenerateService()
1087 vars["AbstractStub"] = "io.grpc.stub.AbstractStub"; in GenerateService()
1088 vars["MethodDescriptor"] = "io.grpc.MethodDescriptor"; in GenerateService()
1089 vars["NanoUtils"] = "io.grpc.protobuf.nano.NanoUtils"; in GenerateService()
1090 vars["StreamObserver"] = "io.grpc.stub.StreamObserver"; in GenerateService()
1091 vars["Iterator"] = "java.util.Iterator"; in GenerateService()
1092 vars["Generated"] = "javax.annotation.Generated"; in GenerateService()
1093 vars["ListenableFuture"] = in GenerateService()
1095 vars["ExperimentalApi"] = "io.grpc.ExperimentalApi"; in GenerateService()
1099 PrintService(printer, vars, service, disable_version); in GenerateService()
1108 VARS vars; in GenerateServiceSource() local
1109 vars["flatc_version"] = grpc::string( in GenerateServiceSource()
1113 vars["file_name"] = file->filename(); in GenerateServiceSource()
1116 vars["Package"] = parameters->package_name; // ServiceJavaPackage(service); in GenerateServiceSource()
1118 GenerateImports(file, &*printer, vars); in GenerateServiceSource()
1119 GenerateService(service, &*printer, vars, false); in GenerateServiceSource()