- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Sait (0.15 sec)
-
istioctl/pkg/waypoint/waypoint.go
Example: ` # Apply a waypoint to the current namespace istioctl x waypoint apply # Apply a waypoint to a specific namespace and wait for it to be ready istioctl x waypoint apply --namespace default --wait`, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClientWithRevision(revision) if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:40 GMT 2024 - 15K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
readBytes.update(acknowledged = unacknowledgedBytesRead) } } else if (!finished && errorExceptionToDeliver == null) { // Nothing to do. Wait until that changes then try again. waitForIo() tryAgain = true } } finally { if (doReadTimeout) { readTimeout.exitAndThrowIfTimedOut()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
cmd/endpoint.go
endpoints[i].IsLocal = isLocal epsResolved++ if !foundLocal { foundLocal = isLocal } } } // Wait for the tick, if the there exist a local endpoint in discovery. // Non docker/kubernetes environment we do not need to wait. if !foundLocal && orchestrated { <-keepAliveTicker.C } } } // On Kubernetes/Docker setups DNS resolves inappropriately sometimes
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/GradleBuildConfigurationDefaults.kt
fun applyDefaultDependencies(model: CIBuildModel, buildType: BuildType, dependsOnQuickFeedbackLinux: Boolean) { if (dependsOnQuickFeedbackLinux) { // wait for quick feedback phase to finish successfully buildType.dependencies { dependsOn(RelativeId(stageTriggerId(model, StageName.QUICK_FEEDBACK_LINUX_ONLY))) } }
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 7.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// // Certain operations (like SYN_STREAM) need to synchronize on both the frameWriter (to do // blocking I/O) and this (to create streams). Such operations must synchronize on 'this' last. // This ensures that we never wait for a blocking operation while holding 'this'. /** True if this peer initiated the connection. */ internal val client: Boolean = builder.client /** User code to run in response to incoming streams or settings. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
cmd/bucket-replication.go
defer wg.Done() tgtInfo := replicateDeleteToTarget(ctx, dobj, tgt) mu.Lock() rinfos.Targets = append(rinfos.Targets, tgtInfo) mu.Unlock() }(tgtClnt) } wg.Wait() replicationStatus = rinfos.ReplicationStatus() prevStatus := dobj.DeleteMarkerReplicationStatus() if dobj.VersionID != "" { prevStatus = replication.StatusType(dobj.VersionPurgeStatus())
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 112K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
if (remainingNanos < SPIN_THRESHOLD_NANOS) { // Remove the waiter, one way or another we are done parking this thread. removeWaiter(node); break long_wait_loop; // jump down to the busy wait loop } } } oldHead = waiters; // re-read and loop. } while (oldHead != Waiter.TOMBSTONE); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
cmd/admin-handlers.go
if ok { continue } client := client ng.Go(ctx, func() error { return client.CommitBinary(ctx) }, idx, *client.host) } for _, nerr := range ng.Wait() { if nerr.Err != nil { prs, ok := peerResults[nerr.Host.String()] if ok { prs.Err = nerr.Err.Error() peerResults[nerr.Host.String()] = prs } else {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/config-current.go
Description: "manage namespace scanning for usage calculation, lifecycle, healing and more", }, config.HelpKV{ Key: config.BatchSubSys, Description: "manage batch job workers and wait times", }, config.HelpKV{ Key: config.CompressionSubSys, Description: "enable server side compression of objects", }, config.HelpKV{ Key: config.IdentityOpenIDSubSys,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 30.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
import okhttp3.internal.concurrent.TaskFaker import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.connection.Locks.withLock import okhttp3.internal.notifyAll import okhttp3.internal.wait import okio.AsyncTimeout import okio.Buffer import okio.BufferedSource import okio.Source import okio.buffer import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Assertions.assertArrayEquals
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)