- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for waiters (0.27 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} /** Performs a GAS operation on the {@link #waiters} field. */ @Override Waiter gasWaiters(AbstractFuture<?> future, Waiter update) { while (true) { Waiter waiter = future.waiters; if (update == waiter) { return waiter; } if (casWaiters(future, waiter, update)) { return waiter; } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** Non-volatile write of the thread to the {@link Waiter#thread} field. */ abstract void putThread(Waiter waiter, Thread newValue); /** Non-volatile write of the waiter to the {@link Waiter#next} field. */ abstract void putNext(Waiter waiter, @CheckForNull Waiter newValue); /** Performs a CAS operation on the {@link #waiters} field. */ abstract boolean casWaiters(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
cmd/erasure-object.go
inlineBuffers[i] = bytes.NewBuffer(buf[:0]) defer grid.PutByteBuffer(buf) writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize()) } } n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum) closeBitrotWriters(writers) if erasureErr != nil { return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// is already pending deletion. Prevent the pod from being a creation observation. jm.deletePod(logger, pod, false) return } // If it has a ControllerRef, that's all that matters. if controllerRef := metav1.GetControllerOf(pod); controllerRef != nil { job := jm.resolveControllerRef(pod.Namespace, controllerRef) if job == nil { return } jobKey, err := controller.KeyFunc(job)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
hack/local-up-cluster.sh
kube::util::create_client_certkey "${CONTROLPLANE_SUDO}" "${CERT_DIR}" request-header-ca auth-proxy system:auth-proxy # TODO remove masters and add rolebinding kube::util::create_client_certkey "${CONTROLPLANE_SUDO}" "${CERT_DIR}" 'client-ca' kube-aggregator system:kube-aggregator system:masters
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 25 02:33:52 UTC 2024 - 53.3K bytes - Viewed (0) -
src/net/http/request.go
// come from an attacker (more likely to be a constant in // code). // Wrap the writer in a bufio Writer if it's not already buffered. // Don't always call NewWriter, as that forces a bytes.Buffer // and other small bufio Writers to have a minimum 4k buffer // size. var bw *bufio.Writer if _, ok := w.(io.ByteWriter); !ok { bw = bufio.NewWriter(w) w = bw }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
) // recordContainerEvent should be used by the runtime manager for all container related events. // it has sanity checks to ensure that we do not write events that can abuse our masters. // in particular, it ensures that a containerID never appears in an event message as that // is prone to causing a lot of distinct events that do not count well.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
src/cmd/dist/test.go
// cmd.Stdout and cmd.Stderr in order to keep the underlying // interleaving of writes, but then it would see even partial writes // interleaved, which would corrupt the JSON. So, we only process // cmd.Stdout. This has another consequence though: if stdout==stderr, // we have to serialize Writes in case the Writer is not concurrent // safe. If we were just passing stdout/stderr through to exec, it would
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 16:01:35 UTC 2024 - 50K bytes - Viewed (0) -
src/testing/testing.go
func (f matchStringOnly) StartCPUProfile(w io.Writer) error { return errMain } func (f matchStringOnly) StopCPUProfile() {} func (f matchStringOnly) WriteProfileTo(string, io.Writer, int) error { return errMain } func (f matchStringOnly) ImportPath() string { return "" } func (f matchStringOnly) StartTestLog(io.Writer) {}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
src/cmd/go/go_test.go
tg.run("install", "p1") tg.wantNotStale("p1", "", "./testgo list claims p1 is stale, incorrectly, before any changes") // Changing mtime of runtime/internal/sys/sys.go // should have no effect: only the content matters. // In fact this should be true even outside a release branch. sys := tg.path("goroot/src/runtime/internal/sys/sys.go") tg.sleep() restore := addVar(sys, 0) restore()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 81.1K bytes - Viewed (0)