aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/http2_test/test_max_streams.py
diff options
context:
space:
mode:
authorGravatar Makarand Dharmapurikar <makarandd@google.com>2016-12-12 13:58:15 -0800
committerGravatar Makarand Dharmapurikar <makarandd@google.com>2016-12-12 13:58:15 -0800
commit8c57917f56bc7af695f2c92f8e5678160da4276e (patch)
treef20d42c8c4e23826a93075951c0ee4e044f9b879 /test/http2_test/test_max_streams.py
parenta16ea7f9b129d34edbdb867e720d4a2ea71e9a7f (diff)
fixed feedback from review
Diffstat (limited to 'test/http2_test/test_max_streams.py')
-rw-r--r--test/http2_test/test_max_streams.py9
1 files changed, 6 insertions, 3 deletions
diff --git a/test/http2_test/test_max_streams.py b/test/http2_test/test_max_streams.py
index deb26770c3..10a9da3deb 100644
--- a/test/http2_test/test_max_streams.py
+++ b/test/http2_test/test_max_streams.py
@@ -1,6 +1,7 @@
+import hyperframe.frame
import logging
+
import http2_base_server
-from hyperframe.frame import SettingsFrame
class TestcaseSettingsMaxStreams(object):
"""
@@ -18,7 +19,8 @@ class TestcaseSettingsMaxStreams(object):
def on_connection_made(self):
logging.info('Connection Made')
self._base_server._conn.initiate_connection()
- self._base_server._conn.update_settings({SettingsFrame.MAX_CONCURRENT_STREAMS: 1})
+ self._base_server._conn.update_settings(
+ {hyperframe.frame.SettingsFrame.MAX_CONCURRENT_STREAMS: 1})
self._base_server.transport.setTcpNoDelay(True)
self._base_server.transport.write(self._base_server._conn.data_to_send())
@@ -26,6 +28,7 @@ class TestcaseSettingsMaxStreams(object):
self._base_server.on_data_received_default(event)
sr = self._base_server.parse_received_data(event.stream_id)
if sr:
- logging.info('Creating response of size = %s'%sr.response_size)
+ logging.info('Creating response of size = %s' % sr.response_size)
response_data = self._base_server.default_response_data(sr.response_size)
self._base_server.setup_send(response_data, event.stream_id)
+ # TODO (makdharma): Add assertion to check number of live streams