Lines Matching +full:out +full:- +full:file
6 * you may not use this file except in compliance with the License.
9 * http://www.apache.org/licenses/LICENSE-2.0
68 // // destructor called at end of scope, un-indenting my_py_printer
73 printer_->Indent(); in IndentScope()
76 ~IndentScope() { printer_->Outdent(); } in ~IndentScope()
83 const grpc_generator::File* file) in PrivateGenerator() argument
84 : config(config), file(file) {} in PrivateGenerator()
87 grpc_generator::Printer* out) { in PrintAllComments() argument
95 out->Print("# missing associated documentation comment in .proto file\n"); in PrintAllComments()
96 out->Print("pass\n"); in PrintAllComments()
99 out->Print("\"\"\""); in PrintAllComments()
102 size_t start_pos = it->find_first_not_of(' '); in PrintAllComments()
104 out->PrintRaw(it->c_str() + start_pos); in PrintAllComments()
106 out->Print("\n"); in PrintAllComments()
108 out->Print("\"\"\"\n"); in PrintAllComments()
112 grpc_generator::Printer* out) { in PrintBetaServicer() argument
114 service_dict["Service"] = service->name(); in PrintBetaServicer()
115 out->Print("\n\n"); in PrintBetaServicer()
116 out->Print(service_dict, "class Beta$Service$Servicer(object):\n"); in PrintBetaServicer()
118 IndentScope raii_class_indent(out); in PrintBetaServicer()
119 out->Print( in PrintBetaServicer()
122 "file not marked beta) for all further purposes. This class was " in PrintBetaServicer()
126 StringVector service_comments = service->GetAllComments(); in PrintBetaServicer()
127 PrintAllComments(service_comments, out); in PrintBetaServicer()
128 for (int i = 0; i < service->method_count(); ++i) { in PrintBetaServicer()
129 auto method = service->method(i); in PrintBetaServicer()
131 method->ClientStreaming() ? "request_iterator" : "request"; in PrintBetaServicer()
133 method_dict["Method"] = method->name(); in PrintBetaServicer()
135 out->Print(method_dict, "def $Method$(self, $ArgName$, context):\n"); in PrintBetaServicer()
137 IndentScope raii_method_indent(out); in PrintBetaServicer()
138 StringVector method_comments = method->GetAllComments(); in PrintBetaServicer()
139 PrintAllComments(method_comments, out); in PrintBetaServicer()
140 out->Print("context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)\n"); in PrintBetaServicer()
148 grpc_generator::Printer* out) { in PrintBetaStub() argument
150 service_dict["Service"] = service->name(); in PrintBetaStub()
151 out->Print("\n\n"); in PrintBetaStub()
152 out->Print(service_dict, "class Beta$Service$Stub(object):\n"); in PrintBetaStub()
154 IndentScope raii_class_indent(out); in PrintBetaStub()
155 out->Print( in PrintBetaStub()
158 "file not marked beta) for all further purposes. This class was " in PrintBetaStub()
162 StringVector service_comments = service->GetAllComments(); in PrintBetaStub()
163 PrintAllComments(service_comments, out); in PrintBetaStub()
164 for (int i = 0; i < service->method_count(); ++i) { in PrintBetaStub()
165 auto method = service->method(i); in PrintBetaStub()
167 method->ClientStreaming() ? "request_iterator" : "request"; in PrintBetaStub()
169 method_dict["Method"] = method->name(); in PrintBetaStub()
171 out->Print(method_dict, in PrintBetaStub()
175 IndentScope raii_method_indent(out); in PrintBetaStub()
176 StringVector method_comments = method->GetAllComments(); in PrintBetaStub()
177 PrintAllComments(method_comments, out); in PrintBetaStub()
178 out->Print("raise NotImplementedError()\n"); in PrintBetaStub()
180 if (!method->ServerStreaming()) { in PrintBetaStub()
181 out->Print(method_dict, "$Method$.future = None\n"); in PrintBetaStub()
190 const grpc_generator::Service* service, grpc_generator::Printer* out) { in PrintBetaServerFactory() argument
192 service_dict["Service"] = service->name(); in PrintBetaServerFactory()
193 out->Print("\n\n"); in PrintBetaServerFactory()
194 out->Print(service_dict, in PrintBetaServerFactory()
198 IndentScope raii_create_server_indent(out); in PrintBetaServerFactory()
199 out->Print( in PrintBetaServerFactory()
202 "file not marked beta) for all further purposes. This function was\n" in PrintBetaServerFactory()
208 for (int i = 0; i < service->method_count(); ++i) { in PrintBetaServerFactory()
209 auto method = service->method(i); in PrintBetaServerFactory()
211 grpc::string(method->ClientStreaming() ? "stream_" : "unary_") + in PrintBetaServerFactory()
212 grpc::string(method->ServerStreaming() ? "stream_" : "unary_") + in PrintBetaServerFactory()
215 if (!method->get_module_and_message_path_input( in PrintBetaServerFactory()
221 if (!method->get_module_and_message_path_output( in PrintBetaServerFactory()
227 make_pair(method->name(), method_implementation_constructor)); in PrintBetaServerFactory()
229 make_pair(method->name(), input_message_module_and_class)); in PrintBetaServerFactory()
231 make_pair(method->name(), output_message_module_and_class)); in PrintBetaServerFactory()
235 out->Print("request_deserializers = {\n"); in PrintBetaServerFactory()
241 method_dict["MethodName"] = name_and_input_module_class_pair->first; in PrintBetaServerFactory()
243 name_and_input_module_class_pair->second; in PrintBetaServerFactory()
244 IndentScope raii_indent(out); in PrintBetaServerFactory()
245 out->Print(method_dict, in PrintBetaServerFactory()
249 out->Print("}\n"); in PrintBetaServerFactory()
250 out->Print("response_serializers = {\n"); in PrintBetaServerFactory()
256 method_dict["MethodName"] = name_and_output_module_class_pair->first; in PrintBetaServerFactory()
258 name_and_output_module_class_pair->second; in PrintBetaServerFactory()
259 IndentScope raii_indent(out); in PrintBetaServerFactory()
260 out->Print(method_dict, in PrintBetaServerFactory()
264 out->Print("}\n"); in PrintBetaServerFactory()
265 out->Print("method_implementations = {\n"); in PrintBetaServerFactory()
271 method_dict["Method"] = name_and_implementation_constructor->first; in PrintBetaServerFactory()
272 method_dict["Constructor"] = name_and_implementation_constructor->second; in PrintBetaServerFactory()
273 IndentScope raii_descriptions_indent(out); in PrintBetaServerFactory()
275 name_and_implementation_constructor->first; in PrintBetaServerFactory()
276 out->Print(method_dict, in PrintBetaServerFactory()
280 out->Print("}\n"); in PrintBetaServerFactory()
281 out->Print( in PrintBetaServerFactory()
288 out->Print( in PrintBetaServerFactory()
297 const grpc_generator::Service* service, grpc_generator::Printer* out) { in PrintBetaStubFactory() argument
299 dict["Service"] = service->name(); in PrintBetaStubFactory()
300 out->Print("\n\n"); in PrintBetaStubFactory()
301 out->Print(dict, in PrintBetaStubFactory()
305 IndentScope raii_create_server_indent(out); in PrintBetaStubFactory()
306 out->Print( in PrintBetaStubFactory()
309 "file not marked beta) for all further purposes. This function was\n" in PrintBetaStubFactory()
315 for (int i = 0; i < service->method_count(); ++i) { in PrintBetaStubFactory()
316 auto method = service->method(i); in PrintBetaStubFactory()
318 grpc::string(method->ClientStreaming() ? "STREAM" : "UNARY") + "_" + in PrintBetaStubFactory()
319 grpc::string(method->ServerStreaming() ? "STREAM" : "UNARY"); in PrintBetaStubFactory()
321 if (!method->get_module_and_message_path_input( in PrintBetaStubFactory()
327 if (!method->get_module_and_message_path_output( in PrintBetaStubFactory()
333 make_pair(method->name(), method_cardinality)); in PrintBetaStubFactory()
335 make_pair(method->name(), input_message_module_and_class)); in PrintBetaStubFactory()
337 make_pair(method->name(), output_message_module_and_class)); in PrintBetaStubFactory()
341 out->Print("request_serializers = {\n"); in PrintBetaStubFactory()
347 method_dict["MethodName"] = name_and_input_module_class_pair->first; in PrintBetaStubFactory()
349 name_and_input_module_class_pair->second; in PrintBetaStubFactory()
350 IndentScope raii_indent(out); in PrintBetaStubFactory()
351 out->Print(method_dict, in PrintBetaStubFactory()
355 out->Print("}\n"); in PrintBetaStubFactory()
356 out->Print("response_deserializers = {\n"); in PrintBetaStubFactory()
362 method_dict["MethodName"] = name_and_output_module_class_pair->first; in PrintBetaStubFactory()
364 name_and_output_module_class_pair->second; in PrintBetaStubFactory()
365 IndentScope raii_indent(out); in PrintBetaStubFactory()
366 out->Print(method_dict, in PrintBetaStubFactory()
370 out->Print("}\n"); in PrintBetaStubFactory()
371 out->Print("cardinalities = {\n"); in PrintBetaStubFactory()
376 method_dict["Method"] = name_and_cardinality->first; in PrintBetaStubFactory()
377 method_dict["Cardinality"] = name_and_cardinality->second; in PrintBetaStubFactory()
378 IndentScope raii_descriptions_indent(out); in PrintBetaStubFactory()
379 out->Print(method_dict, in PrintBetaStubFactory()
382 out->Print("}\n"); in PrintBetaStubFactory()
383 out->Print( in PrintBetaStubFactory()
389 out->Print(method_dict, in PrintBetaStubFactory()
399 const grpc_generator::Service* service, grpc_generator::Printer* out) { in PrintStub() argument
401 dict["Service"] = service->name(); in PrintStub()
402 out->Print("\n\n"); in PrintStub()
403 out->Print(dict, "class $Service$Stub(object):\n"); in PrintStub()
405 IndentScope raii_class_indent(out); in PrintStub()
406 StringVector service_comments = service->GetAllComments(); in PrintStub()
407 PrintAllComments(service_comments, out); in PrintStub()
408 out->Print("\n"); in PrintStub()
409 out->Print("def __init__(self, channel):\n"); in PrintStub()
411 IndentScope raii_init_indent(out); in PrintStub()
412 out->Print("\"\"\"Constructor.\n"); in PrintStub()
413 out->Print("\n"); in PrintStub()
414 out->Print("Args:\n"); in PrintStub()
416 IndentScope raii_args_indent(out); in PrintStub()
417 out->Print("channel: A grpc.Channel.\n"); in PrintStub()
419 out->Print("\"\"\"\n"); in PrintStub()
420 for (int i = 0; i < service->method_count(); ++i) { in PrintStub()
421 auto method = service->method(i); in PrintStub()
423 grpc::string(method->ClientStreaming() ? "stream" : "unary") + "_" + in PrintStub()
424 grpc::string(method->ServerStreaming() ? "stream" : "unary"); in PrintStub()
426 if (!method->get_module_and_message_path_input( in PrintStub()
432 if (!method->get_module_and_message_path_output( in PrintStub()
438 method_dict["Method"] = method->name(); in PrintStub()
440 out->Print(method_dict, in PrintStub()
447 IndentScope raii_first_attribute_indent(out); in PrintStub()
448 IndentScope raii_second_attribute_indent(out); in PrintStub()
449 out->Print(method_dict, "'/$PackageQualifiedService$/$Method$',\n"); in PrintStub()
450 out->Print(method_dict, in PrintStub()
453 out->Print( in PrintStub()
456 out->Print(")\n"); in PrintStub()
465 grpc_generator::Printer* out) { in PrintServicer() argument
467 service_dict["Service"] = service->name(); in PrintServicer()
468 out->Print("\n\n"); in PrintServicer()
469 out->Print(service_dict, "class $Service$Servicer(object):\n"); in PrintServicer()
471 IndentScope raii_class_indent(out); in PrintServicer()
472 StringVector service_comments = service->GetAllComments(); in PrintServicer()
473 PrintAllComments(service_comments, out); in PrintServicer()
474 for (int i = 0; i < service->method_count(); ++i) { in PrintServicer()
475 auto method = service->method(i); in PrintServicer()
477 method->ClientStreaming() ? "request_iterator" : "request"; in PrintServicer()
479 method_dict["Method"] = method->name(); in PrintServicer()
481 out->Print("\n"); in PrintServicer()
482 out->Print(method_dict, "def $Method$(self, $ArgName$, context):\n"); in PrintServicer()
484 IndentScope raii_method_indent(out); in PrintServicer()
485 StringVector method_comments = method->GetAllComments(); in PrintServicer()
486 PrintAllComments(method_comments, out); in PrintServicer()
487 out->Print("context.set_code(grpc.StatusCode.UNIMPLEMENTED)\n"); in PrintServicer()
488 out->Print("context.set_details('Method not implemented!')\n"); in PrintServicer()
489 out->Print("raise NotImplementedError('Method not implemented!')\n"); in PrintServicer()
498 const grpc_generator::Service* service, grpc_generator::Printer* out) { in PrintAddServicerToServer() argument
500 service_dict["Service"] = service->name(); in PrintAddServicerToServer()
501 out->Print("\n\n"); in PrintAddServicerToServer()
502 out->Print(service_dict, in PrintAddServicerToServer()
505 IndentScope raii_class_indent(out); in PrintAddServicerToServer()
506 out->Print("rpc_method_handlers = {\n"); in PrintAddServicerToServer()
508 IndentScope raii_dict_first_indent(out); in PrintAddServicerToServer()
509 IndentScope raii_dict_second_indent(out); in PrintAddServicerToServer()
510 for (int i = 0; i < service->method_count(); ++i) { in PrintAddServicerToServer()
511 auto method = service->method(i); in PrintAddServicerToServer()
513 grpc::string(method->ClientStreaming() ? "stream" : "unary") + "_" + in PrintAddServicerToServer()
514 grpc::string(method->ServerStreaming() ? "stream" : "unary") + in PrintAddServicerToServer()
517 if (!method->get_module_and_message_path_input( in PrintAddServicerToServer()
523 if (!method->get_module_and_message_path_output( in PrintAddServicerToServer()
529 method_dict["Method"] = method->name(); in PrintAddServicerToServer()
533 out->Print(method_dict, in PrintAddServicerToServer()
536 IndentScope raii_call_first_indent(out); in PrintAddServicerToServer()
537 IndentScope raii_call_second_indent(out); in PrintAddServicerToServer()
538 out->Print(method_dict, "servicer.$Method$,\n"); in PrintAddServicerToServer()
539 out->Print( in PrintAddServicerToServer()
542 out->Print( in PrintAddServicerToServer()
547 out->Print("),\n"); in PrintAddServicerToServer()
552 out->Print("}\n"); in PrintAddServicerToServer()
553 out->Print("generic_handler = grpc.method_handlers_generic_handler(\n"); in PrintAddServicerToServer()
555 IndentScope raii_call_first_indent(out); in PrintAddServicerToServer()
556 IndentScope raii_call_second_indent(out); in PrintAddServicerToServer()
557 out->Print(method_dict, in PrintAddServicerToServer()
560 out->Print("server.add_generic_rpc_handlers((generic_handler,))\n"); in PrintAddServicerToServer()
565 bool PrivateGenerator::PrintBetaPreamble(grpc_generator::Printer* out) { in PrintBetaPreamble() argument
568 out->Print(var, in PrintBetaPreamble()
570 out->Print(var, "from $Package$ import interfaces as beta_interfaces\n"); in PrintBetaPreamble()
571 out->Print("from grpc.framework.common import cardinality\n"); in PrintBetaPreamble()
572 out->Print( in PrintBetaPreamble()
578 bool PrivateGenerator::PrintPreamble(grpc_generator::Printer* out) { in PrintPreamble() argument
581 out->Print(var, "import $Package$\n"); in PrintPreamble()
583 out->Print("\n"); in PrintPreamble()
585 for (int i = 0; i < file->service_count(); ++i) { in PrintPreamble()
586 auto service = file->service(i); in PrintPreamble()
587 for (int j = 0; j < service->method_count(); ++j) { in PrintPreamble()
588 auto method = service.get()->method(j); in PrintPreamble()
590 grpc::string input_type_file_name = method->get_input_type_name(); in PrintPreamble()
598 grpc::string output_type_file_name = method->get_output_type_name(); in PrintPreamble()
620 out->Print(var, "$ImportStatement$ as $ModuleAlias$\n"); in PrintPreamble()
626 bool PrivateGenerator::PrintGAServices(grpc_generator::Printer* out) { in PrintGAServices() argument
627 grpc::string package = file->package(); in PrintGAServices()
631 for (int i = 0; i < file->service_count(); ++i) { in PrintGAServices()
632 auto service = file->service(i); in PrintGAServices()
633 grpc::string package_qualified_service_name = package + service->name(); in PrintGAServices()
634 if (!(PrintStub(package_qualified_service_name, service.get(), out) && in PrintGAServices()
635 PrintServicer(service.get(), out) && in PrintGAServices()
637 service.get(), out))) { in PrintGAServices()
644 bool PrivateGenerator::PrintBetaServices(grpc_generator::Printer* out) { in PrintBetaServices() argument
645 grpc::string package = file->package(); in PrintBetaServices()
649 for (int i = 0; i < file->service_count(); ++i) { in PrintBetaServices()
650 auto service = file->service(i); in PrintBetaServices()
651 grpc::string package_qualified_service_name = package + service->name(); in PrintBetaServices()
652 if (!(PrintBetaServicer(service.get(), out) && in PrintBetaServices()
653 PrintBetaStub(service.get(), out) && in PrintBetaServices()
655 out) && in PrintBetaServices()
657 out))) { in PrintBetaServices()
668 auto out = file->CreatePrinter(&output); in GetGrpcServices() local
670 out->Print( in GetGrpcServices()
673 if (!PrintPreamble(out.get())) { in GetGrpcServices()
676 if (!PrintGAServices(out.get())) { in GetGrpcServices()
680 out->Print("try:\n"); in GetGrpcServices()
682 IndentScope raii_dict_try_indent(out.get()); in GetGrpcServices()
683 out->Print( in GetGrpcServices()
686 if (!PrintPreamble(out.get())) { in GetGrpcServices()
689 if (!PrintBetaPreamble(out.get())) { in GetGrpcServices()
692 if (!PrintGAServices(out.get())) { in GetGrpcServices()
695 if (!PrintBetaServices(out.get())) { in GetGrpcServices()
699 out->Print("except ImportError:\n"); in GetGrpcServices()
701 IndentScope raii_dict_except_indent(out.get()); in GetGrpcServices()
702 out->Print("pass"); in GetGrpcServices()
729 output.reset(context->Open(file_name)); in GenerateGrpc()
732 output.reset(context->OpenForInsert(file_name, "module_scope")); in GenerateGrpc()
740 coded_output->WriteRaw(grpc_code.data(), grpc_code.size()); in GenerateGrpc()
747 bool PythonGrpcGenerator::Generate(const FileDescriptor* file, in Generate() argument
751 // Get output file name. in Generate()
755 if (file->name().size() > static_cast<size_t>(proto_suffix_length) && in Generate()
756 file->name().find_last_of(".proto") == file->name().size() - 1) { in Generate()
758 file->name().substr(0, file->name().size() - proto_suffix_length); in Generate()
759 std::replace(base.begin(), base.end(), '-', '_'); in Generate()
763 *error = "Invalid proto file name. Proto file must end with .proto"; in Generate()
766 generator_file_name = file->name(); in Generate()
768 ProtoBufFile pbfile(file); in Generate()