- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for Zhang (0.15 sec)
-
CHANGELOG.md
* Fix: Don't leak file handles when a cache disk write fails. * Fix: Don't hang when the public suffix database cannot be loaded. We had a bug where a failure reading the public suffix database would cause subsequent reads to hang when they should have crashed. * Fix: Avoid `InetAddress.getCanonicalHostName()` in MockWebServer. This avoids problems if the
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs // These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 sconfig.Producer.Retry.Max = 2 sconfig.Producer.Retry.Backoff = (10 * time.Second) sconfig.Producer.Return.Successes = true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
internal/event/target/kafka.go
config.Net.TLS.Config.ClientAuth = args.TLS.ClientAuth config.Net.TLS.Config.RootCAs = args.TLS.RootCAs // These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 config.Producer.Retry.Max = 2 config.Producer.Retry.Backoff = (1 * time.Second) config.Producer.Return.Successes = true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
assertThat(other.port).isNotEqualTo(server.port) other.shutdown() } @Test fun shutdownWhileBlockedDispatching() { // Enqueue a request that'll cause MockWebServer to hang on QueueDispatcher.dispatch(). val connection = server.url("/").toUrl().openConnection() as HttpURLConnection connection.readTimeout = 500 try { connection.responseCode fail<Unit>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.5K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
OkHttp 4.x Change Log ===================== ## Version 4.12.0 _2023-10-16_ * Fix: Don't hang taking headers for HTTP 103 responses. * Fix: Recover gracefully when a cache entry's certificate is corrupted. * Fix: Fail permanently when there's a failure loading the bundled public suffix database. This is the dataset that powers `HttpUrl.topPrivateDomain()`.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
misc/cgo/gmp/gmp.go
allocated by C. The most important consideration is not to constrain future implementations, so the rule is that Go code can hand a Go pointer to C code but must separately arrange for Go to hang on to a reference to the pointer until C is done with it. */ package gmp /* #cgo LDFLAGS: -lgmp #include <gmp.h> #include <stdlib.h> // gmp 5.0.0+ changed the type of the 3rd argument to mp_bitcnt_t,
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 9.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
fail<Any>() } catch (expected: ConnectException) { } } @Test fun shutdownWhileBlockedDispatching() { // Enqueue a request that'll cause MockWebServer to hang on QueueDispatcher.dispatch(). val connection = server.url("/").toUrl().openConnection() as HttpURLConnection connection.setReadTimeout(500) try { connection.getResponseCode() fail<Any>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 21.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
} } } } /** * Call the non-timed {@link Future#get()} in a way that allows us to abort if it's expected to * hang forever. More precisely, if it's expected to return, we simply call it[*], but if it's * expected to hang (because one of the input futures that we know makes it up isn't done yet), * then we call it in a separate thread (using pseudoTimedGet). The result is that we wait as long
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
// Checks the health of collective ops peers. Explicit health check is needed in // multi worker collective ops to detect failures in the cluster. If a peer is // down, collective ops may hang. TF_CAPI_EXPORT extern void TFE_CollectiveOpsCheckPeerHealth( TFE_Context* ctx, const char* task, int64_t timeout_in_ms, TF_Status* status); // Information about the shape of a Tensor and its type.
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 21:07:00 GMT 2023 - 15.1K bytes - Viewed (0) -
cmd/storage-datatypes.go
// - on xl.meta (array of versions) on disk to check for version disparity // - on rewrite dataDir on disk that must be additionally purged // only after as a 2-phase call, allowing the older dataDir to // hang-around in-case we need some form of recovery. type RenameDataResp struct { Sign []byte OldDataDir string // contains '<uuid>', it is designed to be passed as value to Delete(bucket, pathJoin(object, dataDir)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0)