- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 61 for START (0.18 sec)
-
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* captured by any of the steps in the pipeline are closed. * </ol> * * <h3>Starting a pipeline</h3> * * Start a {@code ClosingFuture} pipeline {@linkplain #submit(ClosingCallable, Executor) from a * callable block} that may capture objects for later closing. To start a pipeline from a {@link * ListenableFuture} that doesn't create resources that should be closed later, you can use {@link
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
cluster/gce/util.sh
--project "${PROJECT}" \ --region "${REGION}" -q > /dev/null; then # successful operation - wait until it's visible start="$(date +%s)" while true; do now="$(date +%s)" # Timeout set to 15 minutes if [[ $((now - start)) -gt 900 ]]; then echo "Timeout while waiting for master IP visibility" exit 2 fi
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
cmd/object-handlers.go
} // For providing ranged content start, rangeLen, err := rs.GetOffsetLength(ci.Size) if err != nil { start, rangeLen = 0, ci.Size } // Set content length. w.Header().Set(xhttp.ContentLength, strconv.FormatInt(rangeLen, 10)) if rs != nil { contentRange := fmt.Sprintf("bytes %d-%d/%d", start, start+rangeLen-1, ci.Size)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
case images.ErrImagePullBackOff.Error(): return kubecontainer.ContainerID{}, fmt.Errorf("container %q in pod %q is waiting to start: trying and failing to pull image", containerName, podName) default: return kubecontainer.ContainerID{}, fmt.Errorf("container %q in pod %q is waiting to start: %v", containerName, podName, reason) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
const cgoLdflag = "//go:cgo_ldflag" idx := bytes.Index(src, []byte(cgoLdflag)) for idx >= 0 { // We are looking at //go:cgo_ldflag. // Find start of line. start := bytes.LastIndex(src[:idx], []byte("\n")) if start == -1 { start = 0 } // Find end of line. end := bytes.Index(src[idx:], []byte("\n")) if end == -1 { end = len(src) } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/flatbuffer_export.cc
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:41:49 UTC 2024 - 164.5K bytes - Viewed (0) -
src/crypto/x509/verify_test.go
} leaf, _, err := generateCert("Leaf", false, parent, parentKey) if err != nil { t.Fatal(err) } start := time.Now() _, err = leaf.Verify(VerifyOptions{ Roots: roots, Intermediates: intermediates, }) t.Logf("verification took %v", time.Since(start)) if err == nil || !strings.Contains(err.Error(), "signature check attempts limit") {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 110.2K bytes - Viewed (0) -
pkg/apis/apps/validation/validation_test.go
}, }, { name: "invalid ordinals.start", set: mkStatefulSet(&validPodTemplate, tweakReplicas(3), tweakOrdinalsStart(-2), ), errs: field.ErrorList{ field.Invalid(field.NewPath("spec", "ordinals.start"), nil, ""), }, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 111.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/ir/tfl_ops.cc
namespace { // Compute the length of a range (1-D) tensor given `start`, `limit`, `delta`. // Template parameter `FloatOrInt` must be standard C integer or floating-point // types. template <typename FloatOrInt> int GetLengthOfRange(FloatOrInt start, FloatOrInt limit, FloatOrInt delta) { // Refer to the implementation in // tensorflow/lite/kernels/range.cc.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 09:41:17 UTC 2024 - 169.2K bytes - Viewed (0) -
src/net/http/transport_test.go
ts := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {})).ts var mu sync.Mutex var start, done bool trace := &httptrace.ClientTrace{ TLSHandshakeStart: func() { mu.Lock() defer mu.Unlock() start = true }, TLSHandshakeDone: func(s tls.ConnectionState, err error) { mu.Lock() defer mu.Unlock() done = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0)