- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 108 for pin1 (0.04 sec)
-
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)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K 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())
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jun 22 16:06:35 UTC 2024 - 12.8K bytes - Viewed (0) -
internal/event/target/mysql.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 11.6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/CertificatePinning.kt
if (!response.isSuccessful) throw IOException("Unexpected code $response") for (certificate in response.handshake!!.peerCertificates) { println(CertificatePinner.pin(certificate)) } } } } fun main() { CertificatePinning().run()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.4K bytes - Viewed (0) -
ci/official/requirements_updater/numpy1_requirements/requirements.in
ml_dtypes >= 0.4.0, < 0.5.0 # Install tensorboard, and keras # Note that here we want the latest version that matches TF major.minor version # Note that we must use nightly here as these are used in nightly jobs # For release jobs, we will pin these on the release branch keras-nightly ~= 3.0.0.dev tb-nightly ~= 2.18.0.a # Test dependencies grpcio >= 1.24.3, < 2.0 portpicker == 1.6.0 scipy == 1.11.3 requests >= 2.31.0 packaging==23.2 setuptools==70.0.0
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Fri Oct 11 22:42:53 UTC 2024 - 874 bytes - Viewed (0) -
internal/event/target/postgresql.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/CertificatePinning.java
if (!response.isSuccessful()) throw new IOException("Unexpected code " + response); for (Certificate certificate : response.handshake().peerCertificates()) { System.out.println(CertificatePinner.pin(certificate)); } } } public static void main(String... args) throws Exception { new CertificatePinning().run(); }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Dec 08 21:30:01 UTC 2019 - 1.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
} } @Test fun emptyPingCallsCallback() { data.write("8900".decodeHex()) // Empty ping clientReader.processNextFrame() callback.assertPing(EMPTY) } @Test fun pingCallsCallback() { data.write("890548656c6c6f".decodeHex()) // Ping with "Hello" clientReader.processNextFrame() callback.assertPing("Hello".encodeUtf8()) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 14.4K 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
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Oct 09 11:29:48 UTC 2024 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
final PingResponse pingResponse = searchEngineClient.ping(); writeJsonResponse(pingResponse.getStatus() == 0 ? HttpServletResponse.SC_OK : HttpServletResponse.SC_SERVICE_UNAVAILABLE, "\"data\":" + pingResponse.getMessage()); } catch (final Exception e) { if (logger.isDebugEnabled()) { logger.debug("Failed to process a ping request.", e); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 12 01:54:46 UTC 2024 - 50.3K bytes - Viewed (0)