Lines Matching defs:connection
67 connection(peer, HTTP_2);
87 FramedConnection connection = connection(peer, HTTP_2);
88 Ping ping = connection.ping();
96 assertEquals(0x4f4b6f6b, pingFrame.payload2); // connection.ping() sets this.
115 FramedConnection connection = connection(peer, HTTP_2);
118 assertEquals(65535, connection.peerSettings.getInitialWindowSize(-1));
130 // This stream was created *after* the connection settings were adjusted.
131 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
133 assertEquals(3368, connection.peerSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE));
134 assertEquals(1684, connection.bytesLeftInWriteWindow); // initial wasn't affected.
144 FramedConnection connection = sendHttp2SettingsAndCheckForAck(client, settings);
147 assertEquals(0, connection.peerSettings.getHeaderTableSize());
148 Http2.Reader frameReader = (Http2.Reader) connection.readerRunnable.frameReader;
158 FramedConnection connection = sendHttp2SettingsAndCheckForAck(client, settings);
161 assertFalse(connection.peerSettings.getEnablePush(true));
169 FramedConnection connection = sendHttp2SettingsAndCheckForAck(true, settings);
172 assertEquals(newMaxFrameSize, connection.peerSettings.getMaxFrameSize(-1));
173 assertEquals(newMaxFrameSize, connection.frameWriter.maxDataLength());
189 FramedConnection connection = connection(peer, HTTP_2);
190 FramedStream stream1 = connection.newStream(headerEntries("a", "android"), true, true);
191 FramedStream stream2 = connection.newStream(headerEntries("b", "banana"), true, true);
192 connection.ping().roundTripTime(); // Ensure the GO_AWAY that resets stream2 has been received.
206 connection.newStream(headerEntries("c", "cola"), true, true);
213 assertEquals(1, connection.openStreamCount());
242 peer.acceptFrame(); // connection WINDOW UPDATE
249 FramedConnection connection = connection(peer, HTTP_2);
250 connection.okHttpSettings.set(Settings.INITIAL_WINDOW_SIZE, 0, windowSize);
251 FramedStream stream = connection.newStream(headerEntries("b", "banana"), false, true);
270 assertTrue(windowUpdateStreamIds.contains(0)); // connection
289 FramedConnection connection = connection(peer, HTTP_2);
290 FramedStream client = connection.newStream(headerEntries("b", "banana"), false, true);
309 FramedConnection connection = connection(peer, HTTP_2);
310 FramedStream client = connection.newStream(headerEntries("b", "banana"), true, true);
336 FramedConnection connection = connection(peer, HTTP_2);
337 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
374 FramedConnection connection = connectionBuilder(peer, HTTP_2)
376 FramedStream client = connection.newStream(headerEntries("b", "banana"), false, true);
397 FramedConnection connection = connectionBuilder(peer, HTTP_2).build();
398 connection.newStream(headerEntries("b", "banana"), false, true);
446 FramedConnection connection = new FramedConnection.Builder(true)
453 connection.newStream(headerEntries("a", longString), false, true);
458 connection.newStream(headerEntries("b", longString), false, true);
474 FramedConnection connection = connection(peer, HTTP_2);
482 connection.ping().roundTripTime(); // Ensure that settings have been applied before returning.
483 return connection;
486 private FramedConnection connection(MockSpdyPeer peer, Variant variant) throws IOException {
