commit
ef6938477b
199 changed files with 3376 additions and 868 deletions
@ -0,0 +1,194 @@ |
|||||||
|
Negative HTTP/2 Interop Test Case Descriptions |
||||||
|
======================================= |
||||||
|
|
||||||
|
Client and server use |
||||||
|
[test.proto](../src/proto/grpc/testing/test.proto). |
||||||
|
|
||||||
|
Server |
||||||
|
------ |
||||||
|
The code for the custom http2 server can be found |
||||||
|
[here](https://github.com/grpc/grpc/tree/master/test/http2_test). |
||||||
|
It is responsible for handling requests and sending responses, and also for |
||||||
|
fulfilling the behavior of each particular test case. |
||||||
|
|
||||||
|
Server should accept these arguments: |
||||||
|
* --port=PORT |
||||||
|
* The port the server will run on. For example, "8080" |
||||||
|
* --test_case=TESTCASE |
||||||
|
* The name of the test case to execute. For example, "goaway" |
||||||
|
|
||||||
|
Client |
||||||
|
------ |
||||||
|
|
||||||
|
Clients implement test cases that test certain functionality. Each client is |
||||||
|
provided the test case it is expected to run as a command-line parameter. Names |
||||||
|
should be lowercase and without spaces. |
||||||
|
|
||||||
|
Clients should accept these arguments: |
||||||
|
* --server_host=HOSTNAME |
||||||
|
* The server host to connect to. For example, "localhost" or "127.0.0.1" |
||||||
|
* --server_port=PORT |
||||||
|
* The server port to connect to. For example, "8080" |
||||||
|
* --test_case=TESTCASE |
||||||
|
* The name of the test case to execute. For example, "goaway" |
||||||
|
|
||||||
|
Note |
||||||
|
----- |
||||||
|
|
||||||
|
Note that the server and client must be invoked with the same test case or else |
||||||
|
the test will be meaningless. For convenience, we provide a shell script wrapper |
||||||
|
that invokes both server and client at the same time, with the same test_case. |
||||||
|
This is the preferred way to run these tests. |
||||||
|
|
||||||
|
## Test Cases |
||||||
|
|
||||||
|
### goaway |
||||||
|
|
||||||
|
This test verifies that the client correctly responds to a goaway sent by the |
||||||
|
server. The client should handle the goaway by switching to a new stream without |
||||||
|
the user application having to do a thing. |
||||||
|
|
||||||
|
Client Procedure: |
||||||
|
1. Client sends two UnaryCall requests with: |
||||||
|
|
||||||
|
``` |
||||||
|
{ |
||||||
|
response_size: 314159 |
||||||
|
payload:{ |
||||||
|
body: 271828 bytes of zeros |
||||||
|
} |
||||||
|
} |
||||||
|
``` |
||||||
|
|
||||||
|
Client asserts: |
||||||
|
* Call was successful. |
||||||
|
* Response payload body is 314159 bytes in size. |
||||||
|
|
||||||
|
Server Procedure: |
||||||
|
1. Server sends a GOAWAY after receiving the first UnaryCall. |
||||||
|
|
||||||
|
Server asserts: |
||||||
|
* The second UnaryCall has a different stream_id than the first one. |
||||||
|
|
||||||
|
### rst_after_header |
||||||
|
|
||||||
|
This test verifies that the client fails correctly when the server sends a |
||||||
|
RST_STREAM immediately after sending headers to the client. |
||||||
|
|
||||||
|
Procedure: |
||||||
|
1. Client sends UnaryCall with: |
||||||
|
|
||||||
|
``` |
||||||
|
{ |
||||||
|
response_size: 314159 |
||||||
|
payload:{ |
||||||
|
body: 271828 bytes of zeros |
||||||
|
} |
||||||
|
} |
||||||
|
``` |
||||||
|
|
||||||
|
Client asserts: |
||||||
|
* Call was not successful. |
||||||
|
|
||||||
|
Server Procedure: |
||||||
|
1. Server sends a RST_STREAM with error code 0 after sending headers to the client. |
||||||
|
|
||||||
|
*At the moment the error code and message returned are not standardized throughout all |
||||||
|
languages. Those checks will be added once all client languages behave the same way. [#9142](https://github.com/grpc/grpc/issues/9142) is in flight.* |
||||||
|
|
||||||
|
### rst_during_data |
||||||
|
|
||||||
|
This test verifies that the client fails "correctly" when the server sends a |
||||||
|
RST_STREAM halfway through sending data to the client. |
||||||
|
|
||||||
|
Procedure: |
||||||
|
1. Client sends UnaryCall with: |
||||||
|
|
||||||
|
``` |
||||||
|
{ |
||||||
|
response_size: 314159 |
||||||
|
payload:{ |
||||||
|
body: 271828 bytes of zeros |
||||||
|
} |
||||||
|
} |
||||||
|
``` |
||||||
|
|
||||||
|
Client asserts: |
||||||
|
* Call was not successful. |
||||||
|
|
||||||
|
Server Procedure: |
||||||
|
1. Server sends a RST_STREAM with error code 0 after sending half of |
||||||
|
the requested data to the client. |
||||||
|
|
||||||
|
### rst_after_data |
||||||
|
|
||||||
|
This test verifies that the client fails "correctly" when the server sends a |
||||||
|
RST_STREAM after sending all of the data to the client. |
||||||
|
|
||||||
|
Procedure: |
||||||
|
1. Client sends UnaryCall with: |
||||||
|
|
||||||
|
``` |
||||||
|
{ |
||||||
|
response_size: 314159 |
||||||
|
payload:{ |
||||||
|
body: 271828 bytes of zeros |
||||||
|
} |
||||||
|
} |
||||||
|
``` |
||||||
|
|
||||||
|
Client asserts: |
||||||
|
* Call was not successful. |
||||||
|
|
||||||
|
Server Procedure: |
||||||
|
1. Server sends a RST_STREAM with error code 0 after sending all of the |
||||||
|
data to the client. |
||||||
|
|
||||||
|
*Certain client languages allow the data to be accessed even though a RST_STREAM |
||||||
|
was encountered. Once all client languages behave this way, checks will be added on |
||||||
|
the incoming data.* |
||||||
|
|
||||||
|
### ping |
||||||
|
|
||||||
|
This test verifies that the client correctly acknowledges all pings it gets from the |
||||||
|
server. |
||||||
|
|
||||||
|
Procedure: |
||||||
|
1. Client sends UnaryCall with: |
||||||
|
|
||||||
|
``` |
||||||
|
{ |
||||||
|
response_size: 314159 |
||||||
|
payload:{ |
||||||
|
body: 271828 bytes of zeros |
||||||
|
} |
||||||
|
} |
||||||
|
``` |
||||||
|
|
||||||
|
Client asserts: |
||||||
|
* call was successful. |
||||||
|
* response payload body is 314159 bytes in size. |
||||||
|
|
||||||
|
Server Procedure: |
||||||
|
1. Server tracks the number of outstanding pings (i.e. +1 when it sends a ping, and -1 |
||||||
|
when it receives an ack from the client). |
||||||
|
2. Server sends pings before and after sending headers, also before and after sending data. |
||||||
|
|
||||||
|
Server Asserts: |
||||||
|
* Number of outstanding pings is 0 when the connection is lost. |
||||||
|
|
||||||
|
### max_streams |
||||||
|
|
||||||
|
This test verifies that the client observes the MAX_CONCURRENT_STREAMS limit set by the server. |
||||||
|
|
||||||
|
Client Procedure: |
||||||
|
1. Client sends initial UnaryCall to allow the server to update its MAX_CONCURRENT_STREAMS settings. |
||||||
|
2. Client concurrently sends 10 UnaryCalls. |
||||||
|
|
||||||
|
Client Asserts: |
||||||
|
* All UnaryCalls were successful, and had the correct type and payload size. |
||||||
|
|
||||||
|
Server Procedure: |
||||||
|
1. Sets MAX_CONCURRENT_STREAMS to one after the connection is made. |
||||||
|
|
||||||
|
*The assertion that the MAX_CONCURRENT_STREAMS limit is upheld occurs in the http2 library we used.* |
@ -0,0 +1,153 @@ |
|||||||
|
# Copyright 2016, Google Inc. |
||||||
|
# All rights reserved. |
||||||
|
# |
||||||
|
# Redistribution and use in source and binary forms, with or without |
||||||
|
# modification, are permitted provided that the following conditions are |
||||||
|
# met: |
||||||
|
# |
||||||
|
# * Redistributions of source code must retain the above copyright |
||||||
|
# notice, this list of conditions and the following disclaimer. |
||||||
|
# * Redistributions in binary form must reproduce the above |
||||||
|
# copyright notice, this list of conditions and the following disclaimer |
||||||
|
# in the documentation and/or other materials provided with the |
||||||
|
# distribution. |
||||||
|
# * Neither the name of Google Inc. nor the names of its |
||||||
|
# contributors may be used to endorse or promote products derived from |
||||||
|
# this software without specific prior written permission. |
||||||
|
# |
||||||
|
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||||
|
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||||
|
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||||
|
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||||
|
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||||
|
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||||
|
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||||
|
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||||
|
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||||
|
|
||||||
|
"""The Python client used to test negative http2 conditions.""" |
||||||
|
|
||||||
|
import argparse |
||||||
|
|
||||||
|
import grpc |
||||||
|
from src.proto.grpc.testing import test_pb2 |
||||||
|
from src.proto.grpc.testing import messages_pb2 |
||||||
|
|
||||||
|
def _validate_payload_type_and_length(response, expected_type, expected_length): |
||||||
|
if response.payload.type is not expected_type: |
||||||
|
raise ValueError( |
||||||
|
'expected payload type %s, got %s' % |
||||||
|
(expected_type, type(response.payload.type))) |
||||||
|
elif len(response.payload.body) != expected_length: |
||||||
|
raise ValueError( |
||||||
|
'expected payload body size %d, got %d' % |
||||||
|
(expected_length, len(response.payload.body))) |
||||||
|
|
||||||
|
def _expect_status_code(call, expected_code): |
||||||
|
if call.code() != expected_code: |
||||||
|
raise ValueError( |
||||||
|
'expected code %s, got %s' % (expected_code, call.code())) |
||||||
|
|
||||||
|
def _expect_status_details(call, expected_details): |
||||||
|
if call.details() != expected_details: |
||||||
|
raise ValueError( |
||||||
|
'expected message %s, got %s' % (expected_details, call.details())) |
||||||
|
|
||||||
|
def _validate_status_code_and_details(call, expected_code, expected_details): |
||||||
|
_expect_status_code(call, expected_code) |
||||||
|
_expect_status_details(call, expected_details) |
||||||
|
|
||||||
|
# common requests |
||||||
|
_REQUEST_SIZE = 314159 |
||||||
|
_RESPONSE_SIZE = 271828 |
||||||
|
|
||||||
|
_SIMPLE_REQUEST = messages_pb2.SimpleRequest( |
||||||
|
response_type=messages_pb2.COMPRESSABLE, |
||||||
|
response_size=_RESPONSE_SIZE, |
||||||
|
payload=messages_pb2.Payload(body=b'\x00' * _REQUEST_SIZE)) |
||||||
|
|
||||||
|
def _goaway(stub): |
||||||
|
first_response = stub.UnaryCall(_SIMPLE_REQUEST) |
||||||
|
_validate_payload_type_and_length(first_response, |
||||||
|
messages_pb2.COMPRESSABLE, _RESPONSE_SIZE) |
||||||
|
second_response = stub.UnaryCall(_SIMPLE_REQUEST) |
||||||
|
_validate_payload_type_and_length(second_response, |
||||||
|
messages_pb2.COMPRESSABLE, _RESPONSE_SIZE) |
||||||
|
|
||||||
|
def _rst_after_header(stub): |
||||||
|
resp_future = stub.UnaryCall.future(_SIMPLE_REQUEST) |
||||||
|
_validate_status_code_and_details(resp_future, grpc.StatusCode.UNAVAILABLE, "") |
||||||
|
|
||||||
|
def _rst_during_data(stub): |
||||||
|
resp_future = stub.UnaryCall.future(_SIMPLE_REQUEST) |
||||||
|
_validate_status_code_and_details(resp_future, grpc.StatusCode.UNKNOWN, "") |
||||||
|
|
||||||
|
def _rst_after_data(stub): |
||||||
|
resp_future = stub.UnaryCall.future(_SIMPLE_REQUEST) |
||||||
|
_validate_payload_type_and_length(next(resp_future), |
||||||
|
messages_pb2.COMPRESSABLE, _RESPONSE_SIZE) |
||||||
|
_validate_status_code_and_details(resp_future, grpc.StatusCode.UNKNOWN, "") |
||||||
|
|
||||||
|
def _ping(stub): |
||||||
|
response = stub.UnaryCall(_SIMPLE_REQUEST) |
||||||
|
_validate_payload_type_and_length(response, |
||||||
|
messages_pb2.COMPRESSABLE, _RESPONSE_SIZE) |
||||||
|
|
||||||
|
def _max_streams(stub): |
||||||
|
# send one req to ensure server sets MAX_STREAMS |
||||||
|
response = stub.UnaryCall(_SIMPLE_REQUEST) |
||||||
|
_validate_payload_type_and_length(response, |
||||||
|
messages_pb2.COMPRESSABLE, _RESPONSE_SIZE) |
||||||
|
|
||||||
|
# give the streams a workout |
||||||
|
futures = [] |
||||||
|
for _ in range(15): |
||||||
|
futures.append(stub.UnaryCall.future(_SIMPLE_REQUEST)) |
||||||
|
for future in futures: |
||||||
|
_validate_payload_type_and_length(future.result(), |
||||||
|
messages_pb2.COMPRESSABLE, _RESPONSE_SIZE) |
||||||
|
|
||||||
|
def _run_test_case(test_case, stub): |
||||||
|
if test_case == 'goaway': |
||||||
|
_goaway(stub) |
||||||
|
elif test_case == 'rst_after_header': |
||||||
|
_rst_after_header(stub) |
||||||
|
elif test_case == 'rst_during_data': |
||||||
|
_rst_during_data(stub) |
||||||
|
elif test_case == 'rst_after_data': |
||||||
|
_rst_after_data(stub) |
||||||
|
elif test_case =='ping': |
||||||
|
_ping(stub) |
||||||
|
elif test_case == 'max_streams': |
||||||
|
_max_streams(stub) |
||||||
|
else: |
||||||
|
raise ValueError("Invalid test case: %s" % test_case) |
||||||
|
|
||||||
|
def _args(): |
||||||
|
parser = argparse.ArgumentParser() |
||||||
|
parser.add_argument( |
||||||
|
'--server_host', help='the host to which to connect', type=str, |
||||||
|
default="127.0.0.1") |
||||||
|
parser.add_argument( |
||||||
|
'--server_port', help='the port to which to connect', type=int, |
||||||
|
default="8080") |
||||||
|
parser.add_argument( |
||||||
|
'--test_case', help='the test case to execute', type=str, |
||||||
|
default="goaway") |
||||||
|
return parser.parse_args() |
||||||
|
|
||||||
|
def _stub(server_host, server_port): |
||||||
|
target = '{}:{}'.format(server_host, server_port) |
||||||
|
channel = grpc.insecure_channel(target) |
||||||
|
return test_pb2.TestServiceStub(channel) |
||||||
|
|
||||||
|
def main(): |
||||||
|
args = _args() |
||||||
|
stub = _stub(args.server_host, args.server_port) |
||||||
|
_run_test_case(args.test_case, stub) |
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__': |
||||||
|
main() |
@ -0,0 +1,175 @@ |
|||||||
|
# Copyright 2016, Google Inc. |
||||||
|
# All rights reserved. |
||||||
|
# |
||||||
|
# Redistribution and use in source and binary forms, with or without |
||||||
|
# modification, are permitted provided that the following conditions are |
||||||
|
# met: |
||||||
|
# |
||||||
|
# * Redistributions of source code must retain the above copyright |
||||||
|
# notice, this list of conditions and the following disclaimer. |
||||||
|
# * Redistributions in binary form must reproduce the above |
||||||
|
# copyright notice, this list of conditions and the following disclaimer |
||||||
|
# in the documentation and/or other materials provided with the |
||||||
|
# distribution. |
||||||
|
# * Neither the name of Google Inc. nor the names of its |
||||||
|
# contributors may be used to endorse or promote products derived from |
||||||
|
# this software without specific prior written permission. |
||||||
|
# |
||||||
|
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||||
|
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||||
|
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||||
|
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||||
|
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||||
|
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||||
|
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||||
|
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||||
|
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||||
|
|
||||||
|
"""Test of RPCs made against gRPC Python's application-layer API.""" |
||||||
|
|
||||||
|
import unittest |
||||||
|
|
||||||
|
import grpc |
||||||
|
|
||||||
|
from tests.unit.framework.common import test_constants |
||||||
|
|
||||||
|
_SERIALIZE_REQUEST = lambda bytestring: bytestring * 2 |
||||||
|
_DESERIALIZE_REQUEST = lambda bytestring: bytestring[len(bytestring) // 2:] |
||||||
|
_SERIALIZE_RESPONSE = lambda bytestring: bytestring * 3 |
||||||
|
_DESERIALIZE_RESPONSE = lambda bytestring: bytestring[:len(bytestring) // 3] |
||||||
|
|
||||||
|
_UNARY_UNARY = '/test/UnaryUnary' |
||||||
|
_UNARY_STREAM = '/test/UnaryStream' |
||||||
|
_STREAM_UNARY = '/test/StreamUnary' |
||||||
|
_STREAM_STREAM = '/test/StreamStream' |
||||||
|
|
||||||
|
|
||||||
|
def _unary_unary_multi_callable(channel): |
||||||
|
return channel.unary_unary(_UNARY_UNARY) |
||||||
|
|
||||||
|
|
||||||
|
def _unary_stream_multi_callable(channel): |
||||||
|
return channel.unary_stream( |
||||||
|
_UNARY_STREAM, |
||||||
|
request_serializer=_SERIALIZE_REQUEST, |
||||||
|
response_deserializer=_DESERIALIZE_RESPONSE) |
||||||
|
|
||||||
|
|
||||||
|
def _stream_unary_multi_callable(channel): |
||||||
|
return channel.stream_unary( |
||||||
|
_STREAM_UNARY, |
||||||
|
request_serializer=_SERIALIZE_REQUEST, |
||||||
|
response_deserializer=_DESERIALIZE_RESPONSE) |
||||||
|
|
||||||
|
|
||||||
|
def _stream_stream_multi_callable(channel): |
||||||
|
return channel.stream_stream(_STREAM_STREAM) |
||||||
|
|
||||||
|
|
||||||
|
class InvalidMetadataTest(unittest.TestCase): |
||||||
|
|
||||||
|
def setUp(self): |
||||||
|
self._channel = grpc.insecure_channel('localhost:8080') |
||||||
|
self._unary_unary = _unary_unary_multi_callable(self._channel) |
||||||
|
self._unary_stream = _unary_stream_multi_callable(self._channel) |
||||||
|
self._stream_unary = _stream_unary_multi_callable(self._channel) |
||||||
|
self._stream_stream = _stream_stream_multi_callable(self._channel) |
||||||
|
|
||||||
|
def testUnaryRequestBlockingUnaryResponse(self): |
||||||
|
request = b'\x07\x08' |
||||||
|
metadata = (('InVaLiD', 'UnaryRequestBlockingUnaryResponse'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
with self.assertRaises(ValueError) as exception_context: |
||||||
|
self._unary_unary(request, metadata=metadata) |
||||||
|
self.assertIn(expected_error_details, str(exception_context.exception)) |
||||||
|
|
||||||
|
def testUnaryRequestBlockingUnaryResponseWithCall(self): |
||||||
|
request = b'\x07\x08' |
||||||
|
metadata = (('InVaLiD', 'UnaryRequestBlockingUnaryResponseWithCall'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
with self.assertRaises(ValueError) as exception_context: |
||||||
|
self._unary_unary.with_call(request, metadata=metadata) |
||||||
|
self.assertIn(expected_error_details, str(exception_context.exception)) |
||||||
|
|
||||||
|
def testUnaryRequestFutureUnaryResponse(self): |
||||||
|
request = b'\x07\x08' |
||||||
|
metadata = (('InVaLiD', 'UnaryRequestFutureUnaryResponse'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
response_future = self._unary_unary.future(request, metadata=metadata) |
||||||
|
with self.assertRaises(grpc.RpcError) as exception_context: |
||||||
|
response_future.result() |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.details(), expected_error_details) |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.code(), grpc.StatusCode.INTERNAL) |
||||||
|
self.assertEqual(response_future.details(), expected_error_details) |
||||||
|
self.assertEqual(response_future.code(), grpc.StatusCode.INTERNAL) |
||||||
|
|
||||||
|
def testUnaryRequestStreamResponse(self): |
||||||
|
request = b'\x37\x58' |
||||||
|
metadata = (('InVaLiD', 'UnaryRequestStreamResponse'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
response_iterator = self._unary_stream(request, metadata=metadata) |
||||||
|
with self.assertRaises(grpc.RpcError) as exception_context: |
||||||
|
next(response_iterator) |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.details(), expected_error_details) |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.code(), grpc.StatusCode.INTERNAL) |
||||||
|
self.assertEqual(response_iterator.details(), expected_error_details) |
||||||
|
self.assertEqual(response_iterator.code(), grpc.StatusCode.INTERNAL) |
||||||
|
|
||||||
|
def testStreamRequestBlockingUnaryResponse(self): |
||||||
|
request_iterator = (b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH)) |
||||||
|
metadata = (('InVaLiD', 'StreamRequestBlockingUnaryResponse'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
with self.assertRaises(ValueError) as exception_context: |
||||||
|
self._stream_unary(request_iterator, metadata=metadata) |
||||||
|
self.assertIn(expected_error_details, str(exception_context.exception)) |
||||||
|
|
||||||
|
def testStreamRequestBlockingUnaryResponseWithCall(self): |
||||||
|
request_iterator = ( |
||||||
|
b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH)) |
||||||
|
metadata = (('InVaLiD', 'StreamRequestBlockingUnaryResponseWithCall'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
multi_callable = _stream_unary_multi_callable(self._channel) |
||||||
|
with self.assertRaises(ValueError) as exception_context: |
||||||
|
multi_callable.with_call(request_iterator, metadata=metadata) |
||||||
|
self.assertIn(expected_error_details, str(exception_context.exception)) |
||||||
|
|
||||||
|
def testStreamRequestFutureUnaryResponse(self): |
||||||
|
request_iterator = ( |
||||||
|
b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH)) |
||||||
|
metadata = (('InVaLiD', 'StreamRequestFutureUnaryResponse'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
response_future = self._stream_unary.future( |
||||||
|
request_iterator, metadata=metadata) |
||||||
|
with self.assertRaises(grpc.RpcError) as exception_context: |
||||||
|
response_future.result() |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.details(), expected_error_details) |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.code(), grpc.StatusCode.INTERNAL) |
||||||
|
self.assertEqual(response_future.details(), expected_error_details) |
||||||
|
self.assertEqual(response_future.code(), grpc.StatusCode.INTERNAL) |
||||||
|
|
||||||
|
def testStreamRequestStreamResponse(self): |
||||||
|
request_iterator = ( |
||||||
|
b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH)) |
||||||
|
metadata = (('InVaLiD', 'StreamRequestStreamResponse'),) |
||||||
|
expected_error_details = "metadata was invalid: %s" % metadata |
||||||
|
response_iterator = self._stream_stream(request_iterator, metadata=metadata) |
||||||
|
with self.assertRaises(grpc.RpcError) as exception_context: |
||||||
|
next(response_iterator) |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.details(), expected_error_details) |
||||||
|
self.assertEqual( |
||||||
|
exception_context.exception.code(), grpc.StatusCode.INTERNAL) |
||||||
|
self.assertEqual(response_iterator.details(), expected_error_details) |
||||||
|
self.assertEqual(response_iterator.code(), grpc.StatusCode.INTERNAL) |
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__': |
||||||
|
unittest.main(verbosity=2) |
@ -0,0 +1,64 @@ |
|||||||
|
# Copyright 2015, Google Inc. |
||||||
|
# All rights reserved. |
||||||
|
# |
||||||
|
# Redistribution and use in source and binary forms, with or without |
||||||
|
# modification, are permitted provided that the following conditions are |
||||||
|
# met: |
||||||
|
# |
||||||
|
# * Redistributions of source code must retain the above copyright |
||||||
|
# notice, this list of conditions and the following disclaimer. |
||||||
|
# * Redistributions in binary form must reproduce the above |
||||||
|
# copyright notice, this list of conditions and the following disclaimer |
||||||
|
# in the documentation and/or other materials provided with the |
||||||
|
# distribution. |
||||||
|
# * Neither the name of Google Inc. nor the names of its |
||||||
|
# contributors may be used to endorse or promote products derived from |
||||||
|
# this software without specific prior written permission. |
||||||
|
# |
||||||
|
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||||
|
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||||
|
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||||
|
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||||
|
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||||
|
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||||
|
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||||
|
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||||
|
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||||
|
|
||||||
|
require 'grpc' |
||||||
|
|
||||||
|
StatusCodes = GRPC::Core::StatusCodes |
||||||
|
|
||||||
|
describe StatusCodes do |
||||||
|
# convert upper snake-case to camel case. |
||||||
|
# e.g., DEADLINE_EXCEEDED -> DeadlineExceeded |
||||||
|
def upper_snake_to_camel(name) |
||||||
|
name.to_s.split('_').map(&:downcase).map(&:capitalize).join('') |
||||||
|
end |
||||||
|
|
||||||
|
StatusCodes.constants.each do |status_name| |
||||||
|
it 'there is a subclass of BadStatus corresponding to StatusCode: ' \ |
||||||
|
"#{status_name} that has code: #{StatusCodes.const_get(status_name)}" do |
||||||
|
camel_case = upper_snake_to_camel(status_name) |
||||||
|
error_class = GRPC.const_get(camel_case) |
||||||
|
# expect the error class to be a subclass of BadStatus |
||||||
|
expect(error_class < GRPC::BadStatus) |
||||||
|
|
||||||
|
error_object = error_class.new |
||||||
|
# check that the code matches the int value of the error's constant |
||||||
|
status_code = StatusCodes.const_get(status_name) |
||||||
|
expect(error_object.code).to eq(status_code) |
||||||
|
|
||||||
|
# check default parameters |
||||||
|
expect(error_object.details).to eq('unknown cause') |
||||||
|
expect(error_object.metadata).to eq({}) |
||||||
|
|
||||||
|
# check that the BadStatus factory for creates the correct |
||||||
|
# exception too |
||||||
|
from_factory = GRPC::BadStatus.new_status_exception(status_code) |
||||||
|
expect(from_factory.is_a?(error_class)).to be(true) |
||||||
|
end |
||||||
|
end |
||||||
|
end |
@ -0,0 +1,5 @@ |
|||||||
|
RUN apt-get update && apt-get -y install wget |
||||||
|
RUN echo deb http://llvm.org/apt/wily/ llvm-toolchain-wily-3.8 main >> /etc/apt/sources.list |
||||||
|
RUN echo deb-src http://llvm.org/apt/wily/ llvm-toolchain-wily-3.8 main >> /etc/apt/sources.list |
||||||
|
RUN wget -O - http://llvm.org/apt/llvm-snapshot.gpg.key| apt-key add - |
||||||
|
RUN apt-get update && apt-get -y install clang-format-3.8 |
@ -0,0 +1,37 @@ |
|||||||
|
%YAML 1.2 |
||||||
|
--- | |
||||||
|
# Copyright 2015, Google Inc. |
||||||
|
# All rights reserved. |
||||||
|
# |
||||||
|
# Redistribution and use in source and binary forms, with or without |
||||||
|
# modification, are permitted provided that the following conditions are |
||||||
|
# met: |
||||||
|
# |
||||||
|
# * Redistributions of source code must retain the above copyright |
||||||
|
# notice, this list of conditions and the following disclaimer. |
||||||
|
# * Redistributions in binary form must reproduce the above |
||||||
|
# copyright notice, this list of conditions and the following disclaimer |
||||||
|
# in the documentation and/or other materials provided with the |
||||||
|
# distribution. |
||||||
|
# * Neither the name of Google Inc. nor the names of its |
||||||
|
# contributors may be used to endorse or promote products derived from |
||||||
|
# this software without specific prior written permission. |
||||||
|
# |
||||||
|
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||||
|
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||||
|
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||||
|
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||||
|
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||||
|
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||||
|
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||||
|
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||||
|
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||||
|
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||||
|
|
||||||
|
FROM ubuntu:15.10 |
||||||
|
|
||||||
|
<%include file="../clang_format.include"/> |
||||||
|
ADD clang_format_all_the_things.sh / |
||||||
|
CMD ["echo 'Run with tools/distrib/clang_format_code.sh'"] |
||||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue