Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for goAway (0.3 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        val pingFrame = peer.takeFrame()
        assertThat(pingFrame.type).isEqualTo(Http2.TYPE_PING)
        val goaway = peer.takeFrame()
        assertThat(goaway.type).isEqualTo(Http2.TYPE_GOAWAY)
        assertThat(goaway.streamId).isEqualTo(0)
        assertThat(goaway.errorCode).isEqualTo(ErrorCode.PROTOCOL_ERROR)
      }
    
      @Test fun close() {
        // Write the mocking script.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/SocketEffect.kt

      public class CloseSocket(
        public val closeSocket: Boolean = true,
        public val shutdownInput: Boolean = false,
        public val shutdownOutput: Boolean = false,
      ) : SocketEffect
    
      /**
       * On HTTP/2, send a [GOAWAY frame](https://tools.ietf.org/html/rfc7540#section-6.8) immediately
       * after the response and will close the connection when the client's socket is exhausted.
       *
       * On HTTP/1 this closes the socket.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

            lastGoodStreamId = this.lastGoodStreamId
          }
          // TODO: propagate exception message into debugData.
          // TODO: configure a timeout on the reader so that it doesn’t block forever.
          writer.goAway(lastGoodStreamId, statusCode, EMPTY_BYTE_ARRAY)
        }
      }
    
      /**
       * Closes this connection. This cancels all open streams and unanswered pings. It closes the
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        }
      }
    
      /**
       * This simulates a race condition where we receive a healthy HTTP/2 connection and just prior to
       * writing our request, we get a GOAWAY frame from the server.
       */
      @ParameterizedTest
      @ArgumentsSource(ProtocolParamProvider::class)
      fun connectionShutdownAfterHealthCheck(protocol: Protocol) {
        setUp(protocol)
        server.enqueue(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        )
        server.enqueue(
          MockResponse(body = "def"),
        )
    
        // Send a separate request which will trigger a GOAWAY frame on the healthy connection.
        val response = getResponse(newRequest("/"))
        assertContent("abc", response)
    
        // Ensure the GOAWAY frame has time to be read and processed.
        Thread.sleep(500)
        assertContent(
          "def",
          getResponse(
            Request(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.32.md

    - github.com/docker/go-events: [e31b211](https://github.com/docker/go-events/tree/e31b211)
    - github.com/go-ini/ini: [v1.67.0](https://github.com/go-ini/ini/tree/v1.67.0)
    - github.com/gobwas/glob: [v0.2.3](https://github.com/gobwas/glob/tree/v0.2.3)
    - github.com/goccy/go-json: [v0.10.2](https://github.com/goccy/go-json/tree/v0.10.2)
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 14:49:49 UTC 2025
    - 412.3K bytes
    - Viewed (0)
Back to top