- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,013 for _Gwaiting (0.17 sec)
-
src/runtime/internal/wasitest/nonblock_test.go
// the FIFOs in their original order and spawns a goroutine for each that reads // from the FIFO and writes the result to stderr. If I/O was blocking, all // goroutines would be blocked waiting for one read call to return, and the // output order wouldn't match. type fifo struct { file *os.File path string } func TestNonblock(t *testing.T) { if target != "wasip1/wasm" { t.Skip() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 29 15:35:27 UTC 2023 - 2.4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/Instants.groovy
logger.log "waiting for instant '$name' ..." lock.wait(waitMillis) } if (timePoints.containsKey(name)) { return } throw new IllegalStateException("Timeout waiting for instant '$name' to be defined by another thread.") } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.7K bytes - Viewed (0) -
cmd/typed-errors.go
// error returned by disks which are to be initialized are waiting for the // first server to initialize them in distributed set to initialize them. var errNotFirstDisk = errors.New("Not first drive") // error returned by first disk waiting to initialize other servers. var errFirstDiskWait = errors.New("Waiting on other drives") // error returned for a negative actual size.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 28 17:14:16 UTC 2024 - 5.8K bytes - Viewed (0) -
src/net/http/transport.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ContinuousBuildToolingApiSpecification.groovy
static String getWaitingMessage(GradleVersion targetVersion) { return usesNativeWatchers(targetVersion) ? "Waiting for changes to input files..." : "Waiting for changes to input files of tasks..." } static boolean usesNativeWatchers(GradleVersion targetVersion) { return targetVersion.baseVersion >= GradleVersion.version("7.5") }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 9.1K bytes - Viewed (0) -
pkg/kubelet/runonce.go
return fmt.Errorf("timeout error: pod %q containers not running after %d retries", format.Pod(pod), runOnceMaxRetries) } // TODO(proppy): health checking would be better than waiting + checking the state at the next iteration. klog.InfoS("Pod's containers synced, waiting", "pod", klog.KObj(pod), "duration", delay) time.Sleep(delay) retry++ delay *= runOnceRetryDelayBackoff } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client_test.go
newEvent(v1.EventTypeWarning, "Unable to mount volumes for pod \"recycler-for-podRecyclerFailure_default(3c9809e5-347c-11e6-a79b-3c970e965218)\": timeout expired waiting for volumes to attach/mount"), newEvent(v1.EventTypeWarning, "Error syncing pod, skipping: timeout expired waiting for volumes to attach/mount for pod \"default\"/\"recycler-for-podRecyclerFailure\". list of unattached/unmounted"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 8.5K bytes - Viewed (0) -
src/cmd/go/internal/robustio/robustio_darwin.go
// license that can be found in the LICENSE file. package robustio import ( "errors" "syscall" ) const errFileNotFound = syscall.ENOENT // isEphemeralError returns true if err may be resolved by waiting. func isEphemeralError(err error) bool { var errno syscall.Errno if errors.As(err, &errno) { return errno == errFileNotFound } return false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 26 15:28:04 UTC 2019 - 466 bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// to a map of currently waiting pods and return status with "Wait" code. // Pod will remain waiting pod for the minimum duration returned by the Permit plugins. RunPermitPlugins(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status // WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/util/goroutinemap/goroutinemap_test.go
waitDoneCh := make(chan interface{}, 1) go func() { grm.Wait() waitDoneCh <- true }() // Assert err := waitChannelWithTimeout(waitDoneCh, testTimeout) if err != nil { t.Errorf("Error waiting for GoRoutineMap.Wait: %v", err) } } func Test_NewGoRoutineMap_Positive_WaitEmptyWithExpBackoff(t *testing.T) { // Test than Wait() on empty GoRoutineMap always succeeds without blocking // Arrange
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 11 14:09:48 UTC 2017 - 14.9K bytes - Viewed (0)