From f5f83be4fcb0e90a09317437ff30e90312e1cf54 Mon Sep 17 00:00:00 2001 From: Masood Malekghassemi Date: Thu, 19 Feb 2015 17:28:51 -0800 Subject: [PATCH] Replaces the generated code in src/python/interop/interop with more recently generated code. --- src/python/interop/interop/empty_pb2.py | 2 + src/python/interop/interop/messages_pb2.py | 2 + src/python/interop/interop/test_pb2.py | 117 +++++++++++++++++++++ 3 files changed, 121 insertions(+) diff --git a/src/python/interop/interop/empty_pb2.py b/src/python/interop/interop/empty_pb2.py index 753341c7daf..732a358a369 100644 --- a/src/python/interop/interop/empty_pb2.py +++ b/src/python/interop/interop/empty_pb2.py @@ -57,4 +57,6 @@ Empty = _reflection.GeneratedProtocolMessageType('Empty', (_message.Message,), d _sym_db.RegisterMessage(Empty) +from grpc.framework.face import demonstration as _face_testing +from grpc.framework.face import interfaces as _face_interfaces # @@protoc_insertion_point(module_scope) diff --git a/src/python/interop/interop/messages_pb2.py b/src/python/interop/interop/messages_pb2.py index 79270cdf129..d449a991404 100644 --- a/src/python/interop/interop/messages_pb2.py +++ b/src/python/interop/interop/messages_pb2.py @@ -441,4 +441,6 @@ StreamingOutputCallResponse = _reflection.GeneratedProtocolMessageType('Streamin _sym_db.RegisterMessage(StreamingOutputCallResponse) +from grpc.framework.face import demonstration as _face_testing +from grpc.framework.face import interfaces as _face_interfaces # @@protoc_insertion_point(module_scope) diff --git a/src/python/interop/interop/test_pb2.py b/src/python/interop/interop/test_pb2.py index 12414531598..e86094611b1 100644 --- a/src/python/interop/interop/test_pb2.py +++ b/src/python/interop/interop/test_pb2.py @@ -29,4 +29,121 @@ _sym_db.RegisterFileDescriptor(DESCRIPTOR) +from grpc.framework.face import demonstration as _face_testing +from grpc.framework.face import interfaces as _face_interfaces +class TestServiceService(object): + """""" + def __init__(self): + pass +class TestServiceServicer(object): + """""" + def EmptyCall(self, arg): + raise NotImplementedError() + def UnaryCall(self, arg): + raise NotImplementedError() + def StreamingOutputCall(self, arg): + raise NotImplementedError() + def StreamingInputCall(self, arg): + raise NotImplementedError() + def FullDuplexCall(self, arg): + raise NotImplementedError() + def HalfDuplexCall(self, arg): + raise NotImplementedError() +class TestServiceStub(object): + """""" + def EmptyCall(self, arg): + raise NotImplementedError() + EmptyCall.async = None + def UnaryCall(self, arg): + raise NotImplementedError() + UnaryCall.async = None + def StreamingOutputCall(self, arg): + raise NotImplementedError() + StreamingOutputCall.async = None + def StreamingInputCall(self, arg): + raise NotImplementedError() + StreamingInputCall.async = None + def FullDuplexCall(self, arg): + raise NotImplementedError() + FullDuplexCall.async = None + def HalfDuplexCall(self, arg): + raise NotImplementedError() + HalfDuplexCall.async = None +class _TestServiceStub(TestServiceStub): + def __init__(self, face_stub, default_timeout): + self._face_stub = face_stub + self._default_timeout = default_timeout + stub_self = self + class EmptyCall(object): + def __call__(self, arg): + return stub_self._face_stub.blocking_value_in_value_out("EmptyCall", arg, stub_self._default_timeout) + def async(self, arg): + return stub_self._face_stub.future_value_in_value_out("EmptyCall", arg, stub_self._default_timeout) + self.EmptyCall = EmptyCall() + class UnaryCall(object): + def __call__(self, arg): + return stub_self._face_stub.blocking_value_in_value_out("UnaryCall", arg, stub_self._default_timeout) + def async(self, arg): + return stub_self._face_stub.future_value_in_value_out("UnaryCall", arg, stub_self._default_timeout) + self.UnaryCall = UnaryCall() + class StreamingOutputCall(object): + def __call__(self, arg): + return stub_self._face_stub.inline_value_in_stream_out("StreamingOutputCall", arg, stub_self._default_timeout) + def async(self, arg): + return stub_self._face_stub.inline_value_in_stream_out("StreamingOutputCall", arg, stub_self._default_timeout) + self.StreamingOutputCall = StreamingOutputCall() + class StreamingInputCall(object): + def __call__(self, arg): + return stub_self._face_stub.blocking_stream_in_value_out("StreamingInputCall", arg, stub_self._default_timeout) + def async(self, arg): + return stub_self._face_stub.future_stream_in_value_out("StreamingInputCall", arg, stub_self._default_timeout) + self.StreamingInputCall = StreamingInputCall() + class FullDuplexCall(object): + def __call__(self, arg): + return stub_self._face_stub.inline_stream_in_stream_out("FullDuplexCall", arg, stub_self._default_timeout) + def async(self, arg): + return stub_self._face_stub.inline_stream_in_stream_out("FullDuplexCall", arg, stub_self._default_timeout) + self.FullDuplexCall = FullDuplexCall() + class HalfDuplexCall(object): + def __call__(self, arg): + return stub_self._face_stub.inline_stream_in_stream_out("HalfDuplexCall", arg, stub_self._default_timeout) + def async(self, arg): + return stub_self._face_stub.inline_stream_in_stream_out("HalfDuplexCall", arg, stub_self._default_timeout) + self.HalfDuplexCall = HalfDuplexCall() +def mock_TestService(servicer, default_timeout): + value_in_value_out = {} + value_in_stream_out = {} + stream_in_value_out = {} + stream_in_stream_out = {} + class EmptyCall(_face_interfaces.InlineValueInValueOutMethod): + def service(self, request, context): + return servicer.EmptyCall(request) + value_in_value_out['EmptyCall'] = EmptyCall() + class UnaryCall(_face_interfaces.InlineValueInValueOutMethod): + def service(self, request, context): + return servicer.UnaryCall(request) + value_in_value_out['UnaryCall'] = UnaryCall() + class StreamingOutputCall(_face_interfaces.InlineValueInStreamOutMethod): + def service(self, request, context): + return servicer.StreamingOutputCall(request) + value_in_stream_out['StreamingOutputCall'] = StreamingOutputCall() + class StreamingInputCall(_face_interfaces.InlineStreamInValueOutMethod): + def service(self, request, context): + return servicer.StreamingInputCall(request) + stream_in_value_out['StreamingInputCall'] = StreamingInputCall() + class FullDuplexCall(_face_interfaces.InlineStreamInStreamOutMethod): + def service(self, request, context): + return servicer.FullDuplexCall(request) + stream_in_stream_out['FullDuplexCall'] = FullDuplexCall() + class HalfDuplexCall(_face_interfaces.InlineStreamInStreamOutMethod): + def service(self, request, context): + return servicer.HalfDuplexCall(request) + stream_in_stream_out['HalfDuplexCall'] = HalfDuplexCall() + face_linked_pair = _face_testing.server_and_stub(default_timeout,inline_value_in_value_out_methods=value_in_value_out,inline_value_in_stream_out_methods=value_in_stream_out,inline_stream_in_value_out_methods=stream_in_value_out,inline_stream_in_stream_out_methods=stream_in_stream_out) + class LinkedPair(object): + def __init__(self, server, stub): + self.server = server + self.stub = stub + stub = _TestServiceStub(face_linked_pair.stub, default_timeout) + return LinkedPair(None, stub) # @@protoc_insertion_point(module_scope)