- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of about 10,000 for Gone (0.09 sec)
-
src/net/writev_test.go
if err != nil { t.Fatal(err) } defer c1.Close() c2 := <-ch if c2 == nil { t.Fatal("no server side connection") } c2.Close() // 1 GB of data should be enough to notice the connection is gone. // Just a few bytes is not enough. // Arrange to reuse the same 1 MB buffer so that we don't allocate much. buf := make([]byte, 1<<20) buffers := make(Buffers, 1<<10) for i := range buffers { buffers[i] = buf
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 5K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/split_merged_operands.cc
#include "tensorflow/compiler/mlir/lite/utils/stateful_ops_utils.h" // Background info: // Currently the model taken to MLIRConverter is frozen (all the variables have // been converted to constants, all the assign ops are gone, etc.). However, // TFLite has these variable tensors semantics. So the variable mapping from TF // to TFLite is actually broken here, we sort of hard-code the variable tensors
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Apr 24 20:30:06 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/erasure-healing.go
if isAllNotFound(errs) { err := errFileNotFound if versionID != "" { err = errFileVersionNotFound } // Nothing to do, file is already gone. return er.defaultHealResult(FileInfo{}, storageDisks, storageEndpoints, errs, bucket, object, versionID), err } readQuorum, _, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
pilot/pkg/networking/core/match/match.go
// that fallback may be an empty map, so we re-queue onMatch in case it still needs fixing onMatch.OnMatch = fallback.OnMatch return []*matcher.Matcher_OnMatch{onMatch} // the inner mapper is gone } // envoy will nack this eventually log.Warnf("empty mapper %v with no fallback", innerMapper.Matcher) return innerMapper.allOnMatches() } func (m Mapper) allOnMatches() []*matcher.Matcher_OnMatch {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
defer eventBroadcaster.Shutdown() if !cache.WaitForNamedCacheSync("resource_claim", ctx.Done(), ec.podSynced, ec.podSchedulingSynced, ec.claimsSynced, ec.templatesSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ec.runWorker, time.Second) } <-ctx.Done() } func (ec *Controller) runWorker(ctx context.Context) { for ec.processNextWorkItem(ctx) { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/apis/rbac/helpers_test.go
// install RBAC types _ "k8s.io/kubernetes/pkg/apis/rbac/install" ) // TestHelpersRoundTrip confirms that the rbac.New* helper functions produce RBAC objects that match objects // that have gone through conversion and defaulting. This is required because these helper functions are // used to create the bootstrap RBAC policy which is used during reconciliation. If they produced objects
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 9.2K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
<-ctx.Done() } func (c *Controller) runLeaseWorker(ctx context.Context) { for c.processNextLease(ctx) { } } func (c *Controller) processNextLease(ctx context.Context) bool { key, quit := c.leaseQueue.Get() if quit { return false } defer c.leaseQueue.Done(key) err := c.processDeletedLease(ctx, key) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go
case err == ObjectCountNotFoundErr: // there are multiple scenarios in which we can see this error: // a. the type is truly unknown, a typo on the caller's part. // b. the count has gone stale for too long and the pruner // has removed the type from the cache. // c. the type is an aggregated resource that is served by a // different apiserver (thus its object count is not updated)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 7K bytes - Viewed (0) -
pkg/controller/certificates/cleaner/cleaner.go
defer logger.Info("Shutting down CSR cleaner controller") for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ccc.worker, pollingInterval) } <-ctx.Done() } // worker runs a thread that dequeues CSRs, handles them, and marks them done. func (ccc *CSRCleanerController) worker(ctx context.Context) { logger := klog.FromContext(ctx) csrs, err := ccc.csrLister.List(labels.Everything()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 03:26:08 UTC 2023 - 8K bytes - Viewed (0) -
hack/verify-e2e-test-ownership.sh
# This script verifies the following e2e test ownership policies # - tests MUST start with [sig-foo] # - tests SHOULD NOT have multiple [sig-foo] tags # TODO: these two can be dropped if KubeDescribe is gone from codebase # - tests MUST NOT have [k8s.io] in test names # - tests MUST NOT use KubeDescribe set -o errexit set -o nounset set -o pipefail # This will canonicalize the path
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 20 06:46:18 UTC 2022 - 7.3K bytes - Viewed (0)