- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 438 for ahead (0.04 sec)
-
cni/pkg/repair/netns.go
// /var/run/netns/<name>. However, this pattern is not ubiquitous. Some platforms bind mount to other places. As we run // in a pod, we cannot just access any arbitrary file they happen to bind mount in, as we don't know ahead of time where // it might be. // // Instead, we rely directly on the procfs. // This rules out two possible methods: // * use crictl to inspect the pod; this returns the bind-mounted network namespace file.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 04:07:10 UTC 2024 - 4.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
// readers, and one writer. Each reader can Acquire(1) to obtain a read // lock. The writer can Acquire(N) to obtain a write lock, excluding all // of the readers. If we allow the readers to jump ahead in the queue, // the writer will starve — there is always one token available for every // reader. break } s.cur += w.n s.waiters.Remove(next) close(w.ready) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
* Returns true if the response headers and status indicate that this response has a (possibly * 0-length) body. See RFC 7231. */ fun Response.promisesBody(): Boolean { // HEAD requests never yield a body regardless of the response headers. if (request.method == "HEAD") { return false } val responseCode = code if ((responseCode < HTTP_CONTINUE || responseCode >= 200) && responseCode != HTTP_NO_CONTENT &&
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.2K bytes - Viewed (0) -
src/internal/coverage/cfile/apis.go
// running ClearCounters. for _, c := range cl { sd := unsafe.Slice((*atomic.Uint32)(unsafe.Pointer(c.Counters)), int(c.Len)) for i := 0; i < len(sd); i++ { // Skip ahead until the next non-zero value. sdi := sd[i].Load() if sdi == 0 { continue } // We found a function that was executed; clear its counters. nCtrs := sdi for j := 0; j < int(nCtrs); j++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:57:47 UTC 2024 - 5.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/runtime_fallback/runtime_fallback_executor.cc
} // Deallocate arguments. for (auto* argument : exec_arguments) argument->DropRef(); return ret_values; } // Run TFRT fallback initialization function to instantiate all fallback // kernels ahead of executing the compute function. void RuntimeFallbackExecutor::RunTfrtInitializer() { const Function* func = bef_file_->GetFunction("_tfrt_fallback_init"); CHECK(func) << "TFRT initialization function was not found";
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 08 00:18:59 UTC 2024 - 9.1K bytes - Viewed (0) -
doc/go_mem.html
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
src/encoding/json/decode.go
d.opcode = stateEndValue(&d.scan, data[i]) } else { d.opcode = scanEnd } d.off = i + 1 } // value consumes a JSON value from d.data[d.off-1:], decoding into v, and // reads the following byte ahead. If v is invalid, the value is discarded. // The first byte of the value has been read already. func (d *decodeState) value(v reflect.Value) error { switch d.opcode { default: panic(phasePanicMsg)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 35.3K bytes - Viewed (0) -
pkg/controller/cronjob/utils_test.go
if schedule == nil { t.Errorf("expected 1 start times, got nil") } else if !schedule.Equal(T2) { t.Errorf("expected: %v, got: %v", T2, schedule) } } { // Case 6: now is way way ahead of last start time, and there is no deadline. cj.ObjectMeta.CreationTimestamp = metav1.Time{Time: T1.Add(-2 * time.Hour)} cj.Status.LastScheduleTime = &metav1.Time{Time: T1.Add(-1 * time.Hour)}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 22.8K bytes - Viewed (0) -
CONTRIBUTING.md
sufficient description, if applicable unit tests are added, if it is a reasonable contribution (meaning it is not a single liner cosmetic PR). **2. Valid?** - If the PR passes all the quality checks then we go ahead and assign a reviewer. - If the PR didn't meet the validation criteria, we request for additional changes to be made to PR to pass quality checks and send it back or on a rare occasion we may reject it.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 21 11:45:51 UTC 2024 - 15.6K bytes - Viewed (0) -
src/internal/coverage/cfile/testsupport.go
tot := uint64(0) totExec := uint64(0) for _, c := range cl { sd := unsafe.Slice((*atomic.Uint32)(unsafe.Pointer(c.Counters)), c.Len) tot += uint64(len(sd)) for i := 0; i < len(sd); i++ { // Skip ahead until the next non-zero value. if sd[i].Load() == 0 { continue } // We found a function that was executed. nCtrs := sd[i+coverage.NumCtrsOffset].Load() cst := i + coverage.FirstCtrOffset
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:57:47 UTC 2024 - 8.7K bytes - Viewed (0)