- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 293 for attempt (0.15 sec)
-
internal/dsync/drwmutex.go
return locked } switch { case opts.RetryInterval < 0: return false case opts.RetryInterval > 0: time.Sleep(opts.RetryInterval) default: attempt++ time.Sleep(lockRetryBackOff(dm.rng, attempt)) } } } } func (dm *DRWMutex) startContinuousLockRefresh(lockLossCallback func(), id, source string, quorum int) { ctx, cancel := context.WithCancel(context.Background())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/AnyValue.kt
* limitations under the License. */ package okhttp3.tls.internal.der import okio.ByteString /** * A value whose type is not specified statically. Use this with [Adapters.any] which will attempt * to resolve a concrete type. */ internal data class AnyValue( var tagClass: Int, var tag: Long, var constructed: Boolean = false, var length: Long = -1L, val bytes: ByteString, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0) -
CHANGELOG.md
JVM artifact (`com.squareup.okhttp3:okhttp-jvm:3.x.x`) for Maven builds. This should work-around an issue where Maven doesn't interpret Gradle metadata. * Fix: Make another attempt at supporting Kotlin 1.5.31 at runtime. We were crashing on `DurationUnit` which was a typealias in 1.5.x. * Upgrade: [Okio 3.2.0][okio_3_2_0]. ## Version 5.0.0-alpha.9 _2022-06-16_
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) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* * Unfortunately, older HTTPS servers refuse to connect when such options are presented. Rather than * avoiding these options entirely, this class allows a connection to be attempted with modern * options and then retried without them should the attempt fail. * * ## Connection Reuse * * Each connection can carry a varying number of streams, depending on the underlying protocol being
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/MinimalIterable.java
* be clearly documented. * * <p>Note that although your APIs should be liberal in what they accept, your methods which * <i>return</i> iterables should make every attempt to return ones of the robust variety. * * <p>This testing utility is not thread-safe. * * @author Kevin Bourrillion */ @GwtCompatible
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
import okio.IOException /** * Listener for connection events. Extend this class to monitor the new connections and closes. * * All event methods must execute fast, without external locking, cannot throw exceptions, * attempt to mutate the event parameters, or be reentrant back into the client. * Any IO - writing to files or network should be done asynchronously. */ @ExperimentalOkHttpApi abstract class ConnectionListener { /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener.go
if err := os.Remove(path); err != nil && !os.IsNotExist(err) { // Anything other than "file not found" is an error. return nil, fmt.Errorf("failed to remove unix://%s: %v", path, err) } // Attempt to create the folder in case it doesn't exist if err := os.MkdirAll(filepath.Dir(path), 0o750); err != nil { // If we cannot create it, just warn here - we will fail later if there is a real error
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K bytes - Viewed (0) -
build-logic/integration-testing/src/main/kotlin/gradlebuild.test-fixtures.gradle.kts
val testFixturesApiElements by configurations // Required due to: https://github.com/gradle/gradle/issues/13278 testFixturesRuntimeElements.extendsFrom(testFixturesRuntimeOnly) // do not attempt to find projects when the plugin is applied just to generate accessors if (project.name != "gradle-kotlin-dsl-accessors" && project.name != "test" /* remove once wrapper is updated */) { dependencies {
Plain Text - Registered: Wed Mar 27 11:36:08 GMT 2024 - Last Modified: Mon Feb 12 13:19:06 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
if err != nil { t.Fatal(err) } lkClient := newlockRESTClient(endpoint) if lkClient.IsOnline() { t.Fatalf("unexpected result. connection was online") } // Attempt all calls. _, err = lkClient.RLock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") } _, err = lkClient.Lock(context.Background(), dsync.LockArgs{}) if err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2K bytes - Viewed (0) -
istioctl/cmd/sysexits.go
// https://www.tldp.org/LDP/abs/html/exitcodes.html#EXITCODESREF) and then some // used by convention (see sysexits). // // The intention here is to use 64-78 in a way that matches the attempt in // sysexits to signify some error running istioctl, and use 79-125 as custom // error codes for other info that we'd like to use to pass info on. const ( ExitUnknownError = 1 // for compatibility with existing exit code
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.9K bytes - Viewed (0)