- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 265 for Vong (0.23 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
// At 0ms the server sends 3 unexpected pongs. The client accepts 'em and ignores em. server.webSocket!!.pong("pong 1".encodeUtf8()) client.processNextFrame() server.webSocket!!.pong("pong 2".encodeUtf8()) client.processNextFrame() taskFaker.runTasks() server.webSocket!!.pong("pong 3".encodeUtf8()) client.processNextFrame()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
src/main/resources/fess_indices/fess/id/stopwords.txt
bukannya cuma percuma dahulu dalam dan dapat dari daripada dekat demi demikian demikianlah sedemikian dengan depan di dia dialah dini diri dirinya terdiri dong dulu enggak enggaknya entah entahlah terhadap terhadapnya hal hampir hanya hanyalah harus haruslah harusnya seharusnya hendak hendaklah hendaknya
Plain Text - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Jul 19 06:31:02 GMT 2018 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private val pingIntervalMillis: Long, /** * For clients this is initially null, and will be assigned to the agreed-upon extensions. For * servers it should be the agreed-upon extensions immediately. */ private var extensions: WebSocketExtensions?, /** If compression is negotiated, outbound messages of this size and larger will be compressed. */ private var minimumDeflateSize: Long, private val webSocketCloseTimeout: Long,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* To differentiate the two cases we ping the server when a stream times out. If the overall * connection is fine the ping will receive a pong; otherwise it won't. * * The deadline to respond to this ping attempts to limit the cost of being wrong. If it is too * long, streams created while we await the pong will reuse broken connections and inevitably * fail. If it is too short, slow connections will be marked as failed and extra TCP and TLS
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
}, ) val INTEGER_AS_LONG = BasicDerAdapter( name = "INTEGER", tagClass = DerHeader.TAG_CLASS_UNIVERSAL, tag = 2L, codec = object : BasicDerAdapter.Codec<Long> { override fun decode(reader: DerReader): Long = reader.readLong() override fun encode( writer: DerWriter, value: Long, ) = writer.writeLong(value) },
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
} @Test fun clientTwoFrameHelloWithPongs() { data.write("010348656c".decodeHex()) // Hel data.write("8a00".decodeHex()) // Pong data.write("8a00".decodeHex()) // Pong data.write("8a00".decodeHex()) // Pong data.write("8a00".decodeHex()) // Pong data.write("80026c6f".decodeHex()) // lo clientReader.processNextFrame() callback.assertPong(EMPTY) callback.assertPong(EMPTY)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt
* > GeneralizedTime. */ internal val time: DerAdapter<Long> = object : DerAdapter<Long> { override fun matches(header: DerHeader): Boolean { return Adapters.UTC_TIME.matches(header) || Adapters.GENERALIZED_TIME.matches(header) } override fun fromDer(reader: DerReader): Long { val peekHeader = reader.peekHeader()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.6K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat( response.body.string(), ).isEqualTo("b") } // Calls succeed after the degraded pong timeout because the degraded pong was received. Thread.sleep(TimeUnit.NANOSECONDS.toMillis(Http2Connection.DEGRADED_PONG_TIMEOUT_NS.toLong())) val call3 = client.newCall(Request(server.url("/"))) call3.execute().use { response -> assertThat(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt
*/ internal class ThrottledSink( private val delegate: Sink, private val bytesPerPeriod: Long, private val periodDelayNanos: Long, ) : Sink by delegate { private var bytesWrittenSinceLastDelay = 0L override fun write( source: Buffer, byteCount: Long, ) { var bytesLeft = byteCount while (bytesLeft > 0) { if (bytesWrittenSinceLastDelay == bytesPerPeriod) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
} } return result } internal const val USER_AGENT: String = "okhttp/${CONST_VERSION}" internal fun checkOffsetAndCount( arrayLength: Long, offset: Long, count: Long, ) { if (offset or count < 0L || offset > arrayLength || arrayLength - offset < count) { throw ArrayIndexOutOfBoundsException("length=$arrayLength, offset=$offset, count=$offset") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11K bytes - Viewed (0)