- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 454 for wait4 (0.04 sec)
-
src/cmd/vendor/golang.org/x/sys/unix/mkerrors.sh
#include <sys/stat.h> #include <sys/un.h> #include <sys/sockio.h> #include <sys/sys_domain.h> #include <sys/sysctl.h> #include <sys/mman.h> #include <sys/mount.h> #include <sys/utsname.h> #include <sys/wait.h> #include <sys/xattr.h> #include <sys/vsock.h> #include <net/bpf.h> #include <net/if.h> #include <net/if_types.h> #include <net/route.h> #include <netinet/in.h> #include <netinet/ip.h> #include <termios.h>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 20.2K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/annotations.go
trace.WithRegion(ctx, "region1", func() { trace.Log(ctx, "key0", "0123456789abcdef") // EvUserLog("task0", "key0", "0....f") }) // EvUserRegionEnd("region0", end) }) }() wg.Wait() preExistingRegion.End() postExistingRegion := trace.StartRegion(bgctx, "post-existing region") // End of traced execution. trace.Stop() postExistingRegion.End()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.4K bytes - Viewed (0) -
cmd/erasure-common.go
// // - Do not consume disks which are being healed // // - Future: skip busy disks return } mu.Lock() newDisks = append(newDisks, disks[i]) mu.Unlock() }() } wg.Wait() return newDisks } func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) { disks := er.getOnlineDisks() // Based on the random shuffling return back randomized disks.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
build/lib/release.sh
kube::release::package_client_tarballs & kube::release::package_kube_manifests_tarball & kube::util::wait-for-jobs || { kube::log::error "previous tarball phase failed"; return 1; } # _node and _server tarballs depend on _src tarball kube::release::package_node_tarballs & kube::release::package_server_tarballs & kube::util::wait-for-jobs || { kube::log::error "previous tarball phase failed"; return 1; }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 16:43:08 UTC 2024 - 21.7K bytes - Viewed (0) -
pkg/kubelet/images/image_gc_manager.go
} func (im *realImageGCManager) Start() { ctx := context.Background() go wait.Until(func() { _, err := im.detectImages(ctx, time.Now()) if err != nil { klog.InfoS("Failed to monitor images", "err", err) } }, 5*time.Minute, wait.NeverStop) // Start a goroutine periodically updates image cache. go wait.Until(func() { images, err := im.runtime.ListImages(ctx) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" utilerrors "k8s.io/apimachinery/pkg/util/errors" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" clientset "k8s.io/client-go/kubernetes" nodeutil "k8s.io/component-helpers/node/util" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/util" ) const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
Example: ` # Apply a waypoint to the current namespace istioctl waypoint apply # Apply a waypoint to a specific namespace and wait for it to be ready istioctl waypoint apply --namespace default --wait`, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClientWithRevision(revision) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0) -
cluster/gce/upgrade.sh
# so wait once we hit that many nodes. This isn't ideal, since one might take much # longer than the others, but it should help. process_count_left=$((process_count_left - 1)) if [[ process_count_left -eq 0 || "${instance}" == "${instances[-1]}" ]]; then # Wait for each of the parallel node upgrades to finish. for pid in "${pids[@]}"; do
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 25.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
(build.standardOutput =~ "Pinged owner at port ${socket.localPort}").count } def waitCloseAndFinish(GradleHandle build) { Thread.sleep(10 * 1000) //wait 10 seconds, in which the build should only wait for the lock to become available receivingLock.close() build.waitForFinish() } def replaceSocketReceiver(Runnable reactOnRequest) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
src/sync/mutex.go
// the ownership. New arriving goroutines have an advantage -- they are // already running on CPU and there can be lots of them, so a woken up // waiter has good chances of losing. In such case it is queued at front // of the wait queue. If a waiter fails to acquire the mutex for more than 1ms, // it switches mutex to the starvation mode. // // In starvation mode ownership of the mutex is directly handed off from
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0)