|
|
|
@ -280,12 +280,14 @@ class ChannelzServicerTest(unittest.TestCase): |
|
|
|
|
self.assertEqual(gtc_resp.channel[i].data.calls_failed, |
|
|
|
|
gsc_resp.subchannel.data.calls_failed) |
|
|
|
|
|
|
|
|
|
@unittest.skip('Due to server destruction logic issue #17258') |
|
|
|
|
def test_server_basic(self): |
|
|
|
|
self._pairs = _generate_channel_server_pairs(1) |
|
|
|
|
resp = self._channelz_stub.GetServers( |
|
|
|
|
channelz_pb2.GetServersRequest(start_server_id=0)) |
|
|
|
|
self.assertEqual(len(resp.server), 1) |
|
|
|
|
|
|
|
|
|
@unittest.skip('Due to server destruction logic issue #17258') |
|
|
|
|
def test_get_one_server(self): |
|
|
|
|
self._pairs = _generate_channel_server_pairs(1) |
|
|
|
|
gss_resp = self._channelz_stub.GetServers( |
|
|
|
@ -297,6 +299,7 @@ class ChannelzServicerTest(unittest.TestCase): |
|
|
|
|
self.assertEqual(gss_resp.server[0].ref.server_id, |
|
|
|
|
gs_resp.server.ref.server_id) |
|
|
|
|
|
|
|
|
|
@unittest.skip('Due to server destruction logic issue #17258') |
|
|
|
|
def test_server_call(self): |
|
|
|
|
self._pairs = _generate_channel_server_pairs(1) |
|
|
|
|
k_success = 23 |
|
|
|
@ -391,6 +394,7 @@ class ChannelzServicerTest(unittest.TestCase): |
|
|
|
|
self.assertEqual(gs_resp.socket.data.messages_received, |
|
|
|
|
test_constants.STREAM_LENGTH) |
|
|
|
|
|
|
|
|
|
@unittest.skip('Due to server destruction logic issue #17258') |
|
|
|
|
def test_server_sockets(self): |
|
|
|
|
self._pairs = _generate_channel_server_pairs(1) |
|
|
|
|
self._send_successful_unary_unary(0) |
|
|
|
@ -409,6 +413,7 @@ class ChannelzServicerTest(unittest.TestCase): |
|
|
|
|
# If the RPC call failed, it will raise a grpc.RpcError |
|
|
|
|
# So, if there is no exception raised, considered pass |
|
|
|
|
|
|
|
|
|
@unittest.skip('Due to server destruction logic issue #17258') |
|
|
|
|
def test_server_listen_sockets(self): |
|
|
|
|
self._pairs = _generate_channel_server_pairs(1) |
|
|
|
|
|
|
|
|
|