- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for Ling (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
payload2: Int, ) { try { writer.ping(reply, payload1, payload2) } catch (e: IOException) { failConnection(e) } } /** For testing: sends a ping and waits for a pong. */ @Throws(InterruptedException::class) fun writePingAndAwaitPong() { writePing() awaitPong() } /** For testing: sends a ping to be awaited with [awaitPong]. */
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/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.advanceUntil(ns(500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1000L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. } @Test
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
length: Int, flags: Int, streamId: Int, ) { if (length != 8) throw IOException("TYPE_PING length != 8: $length") if (streamId != 0) throw IOException("TYPE_PING streamId != 0") val payload1 = source.readInt() val payload2 = source.readInt() val ack = flags and FLAG_ACK != 0 handler.ping(ack, payload1, payload2) } @Throws(IOException::class) private fun readGoAway(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
sink.writeInt(settings[i]) } sink.flush() } } /** * Send a connection-level ping to the peer. `ack` indicates this is a reply. The data in * `payload1` and `payload2` opaque binary, and there are no rules on the content. */ @Throws(IOException::class) fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { this.withLock {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if resp.IsError() { return fmt.Errorf("Create index err: %v", res) } return nil } return nil } func (c *esClientV7) ping(ctx context.Context, _ ElasticsearchArgs) (bool, error) { resp, err := c.Ping( c.Ping.WithContext(ctx), ) if err != nil { return false, store.ErrNotConnected } xhttp.DrainBody(resp.Body) return !resp.IsError(), nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
import okhttp3.internal.ws.WebSocketProtocol.OPCODE_CONTINUATION import okhttp3.internal.ws.WebSocketProtocol.OPCODE_CONTROL_CLOSE import okhttp3.internal.ws.WebSocketProtocol.OPCODE_CONTROL_PING import okhttp3.internal.ws.WebSocketProtocol.OPCODE_CONTROL_PONG import okhttp3.internal.ws.WebSocketProtocol.OPCODE_FLAG_CONTROL import okhttp3.internal.ws.WebSocketProtocol.OPCODE_TEXT
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
awaitingPong = true } if (failedPing != -1) { failWebSocket( e = SocketTimeoutException( "sent ping but didn't receive pong within " + "${pingIntervalMillis}ms (after ${failedPing - 1} successful ping/pongs)", ), isWriter = true, ) return } try { writer.writePing(ByteString.EMPTY)
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) -
gorm.go
ConnPool: db.ConnPool, Context: context.Background(), Clauses: map[string]clause.Clause{}, } if err == nil && !config.DisableAutomaticPing { if pinger, ok := db.ConnPool.(interface{ Ping() error }); ok { err = pinger.Ping() } } if err != nil { config.Logger.Error(context.Background(), "failed to initialize database, got error %v", err) } return } // Session create new db session
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sun Aug 20 11:46:56 GMT 2023 - 11.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
val settings1 = Settings() settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams peer.sendFrame().settings(settings1) peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 0) peer.acceptFrame() // PING peer.play() // Play it back. val connection = Http2Connection.Builder(true, TaskRunner.INSTANCE) .socket(peer.openSocket())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
internal/event/target/postgresql.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0)