- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 345 for Window (0.22 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* `server_max_window_bits`, and `server_no_context_takeover`. * * Typically this will look like one of the following: * * ``` * Sec-WebSocket-Extensions: permessage-deflate * Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits="15" * Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits=15
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
return if (bit and set != 0) values[HEADER_TABLE_SIZE] else -1 } val initialWindowSize: Int get() { val bit = 1 shl INITIAL_WINDOW_SIZE return if (bit and set != 0) values[INITIAL_WINDOW_SIZE] else DEFAULT_INITIAL_WINDOW_SIZE } fun clear() { set = 0 values.fill(0) } operator fun set( id: Int, value: Int, ): Settings {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketExtensionsTest.kt
assertThat(parse("permessage-deflate; client_max_window_bits=8")).isEqualTo( WebSocketExtensions(perMessageDeflate = true, clientMaxWindowBits = 8), ) assertThat(parse("permessage-deflate; client_max_window_bits=\"8\"")).isEqualTo( WebSocketExtensions(perMessageDeflate = true, clientMaxWindowBits = 8), ) assertThat(parse("permessage-deflate; client_max_window_bits=15")).isEqualTo(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/SettingsTest.kt
Settings.DEFAULT_INITIAL_WINDOW_SIZE, ) settings[Settings.INITIAL_WINDOW_SIZE] = 108 assertThat(settings.initialWindowSize).isEqualTo(108) } @Test fun merge() { val a = Settings() a[Settings.HEADER_TABLE_SIZE] = 10000 a[Settings.MAX_HEADER_LIST_SIZE] = 20000 a[Settings.INITIAL_WINDOW_SIZE] = 30000 val b = Settings()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
out1.write(ByteArray(Settings.DEFAULT_INITIAL_WINDOW_SIZE)) out1.flush() // Check that we've filled the window for both the stream and also the connection. assertThat(connection.writeBytesTotal) .isEqualTo(Settings.DEFAULT_INITIAL_WINDOW_SIZE.toLong()) assertThat(connection.writeBytesMaximum) .isEqualTo(Settings.DEFAULT_INITIAL_WINDOW_SIZE.toLong()) assertThat(stream1.writeBytesTotal)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
internal/bucket/bandwidth/measurement.go
type bucketMeasurement struct { lock sync.Mutex bytesSinceLastWindow uint64 // Total bytes since last window was processed startTime time.Time // Start time for window expMovingAvg float64 // Previously calculate sliding window } // newBucketMeasurement creates a new instance of the measurement with the initial start time.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt
/** * Notification that the receiving stream flow control window has changed. * [WindowCounter] generally carries the client view of total and acked bytes. */ fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter, bufferSize: Long, ) /** * Notification that the receiving connection flow control window has changed.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
) } /** * Returns a human-readable representation of a `WINDOW_UPDATE` frame. This frame includes the * window size increment instead of flags. */ fun frameLogWindowUpdate( inbound: Boolean, streamId: Int, length: Int, windowSizeIncrement: Long, ): String { val formattedType = formattedType(TYPE_WINDOW_UPDATE) val direction = if (inbound) "<<" else ">>" return format(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
// We defer throwing the exception until now so that we can refill the connection // flow-control window. This is necessary because we don't transmit window updates until // the application reads the data. If we throw this prior to updating the connection // flow-control window, we risk having it go to 0 preventing the server from sending data. throw errorExceptionToDeliver!! }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1)