Home	Sort by relevance Sort by last modified time

Full Search Definition Symbol File Path History   | | Help

    Searched refs:_base_server (Results 1 - 7 of 7) sorted by null

/external/grpc-grpc/test/http2_test/
test_ping.py	26 self._base_server = http2_base_server.H2ProtocolBaseServer() 27 self._base_server._handlers['RequestReceived'] = self.on_request_received 28 self._base_server._handlers['DataReceived'] = self.on_data_received 29 self._base_server._handlers['ConnectionLost'] = self.on_connection_lost 32 return self._base_server 35 self._base_server.default_ping() 36 self._base_server.on_request_received_default(event) 37 self._base_server.default_ping() 40 self._base_server.on_data_received_default(event) 41 sr = self._base_server.parse_received_data(event.stream_id     [all...]
test_rst_after_data.py	24 self._base_server = http2_base_server.H2ProtocolBaseServer() 25 self._base_server._handlers['DataReceived'] = self.on_data_received 26 self._base_server._handlers['SendDone'] = self.on_send_done 29 return self._base_server 32 self._base_server.on_data_received_default(event) 33 sr = self._base_server.parse_received_data(event.stream_id) 35 response_data = self._base_server.default_response_data(sr.response_size) 37 self._base_server.setup_send(response_data, event.stream_id) 41 self._base_server.send_reset_stream() 42 self._base_server._stream_status[stream_id] = Fals     [all...]
test_rst_during_data.py	24 self._base_server = http2_base_server.H2ProtocolBaseServer() 25 self._base_server._handlers['DataReceived'] = self.on_data_received 26 self._base_server._handlers['SendDone'] = self.on_send_done 29 return self._base_server 32 self._base_server.on_data_received_default(event) 33 sr = self._base_server.parse_received_data(event.stream_id) 35 response_data = self._base_server.default_response_data(sr.response_size) 39 self._base_server.setup_send(truncated_response_data, event.stream_id) 42 self._base_server.send_reset_stream() 43 self._base_server._stream_status[stream_id] = Fals     [all...]
test_rst_after_header.py	23 self._base_server = http2_base_server.H2ProtocolBaseServer() 24 self._base_server._handlers['RequestReceived'] = self.on_request_received 27 return self._base_server 31 self._base_server.on_request_received_default(event) 33 self._base_server.send_reset_stream()
test_max_streams.py	26 self._base_server = http2_base_server.H2ProtocolBaseServer() 27 self._base_server._handlers['DataReceived'] = self.on_data_received 28 self._base_server._handlers['ConnectionMade'] = self.on_connection_made 31 return self._base_server 35 self._base_server._conn.initiate_connection() 36 self._base_server._conn.update_settings( 38 self._base_server.transport.setTcpNoDelay(True) 39 self._base_server.transport.write(self._base_server._conn.data_to_send()) 42 self._base_server.on_data_received_default(event     [all...]
test_goaway.py	28 self._base_server = http2_base_server.H2ProtocolBaseServer() 29 self._base_server._handlers['RequestReceived'] = self.on_request_received 30 self._base_server._handlers['DataReceived'] = self.on_data_received 31 self._base_server._handlers['SendDone'] = self.on_send_done 32 self._base_server._handlers['ConnectionLost'] = self.on_connection_lost 37 return self._base_server 43 self._base_server.on_connection_lost(reason) 46 self._base_server.on_send_done_default(stream_id) 48 self._base_server._conn.close_connection(error_code=0, additional_data=None, last_stream_id=stream_id) 49 self._base_server._stream_status[stream_id] = Fals     [all...]
test_data_frame_padding.py	31 self._base_server = http2_base_server.H2ProtocolBaseServer() 32 self._base_server._handlers['DataReceived'] = self.on_data_received 33 self._base_server._handlers['WindowUpdated'] = self.on_window_update 34 self._base_server._handlers['RequestReceived'] = self.on_request_received 48 return self._base_server 52 self._base_server.on_data_received_default(event) 55 sr = self._base_server.parse_received_data(event.stream_id) 59 response_data = self._base_server.default_response_data(sr.response_size) 66 self._base_server.setup_send(response_data , event.stream_id, pad_length=self._pad_length, read_chunk_size=self._read_chunk_size) 69 self._base_server.on_request_received_default(event     [all...]

Completed in 98 milliseconds