Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,159 for Store2 (0.12 sec)

  1. pkg/kubelet/util/manager/watch_based_manager.go

    	store := &objectCache{
    		listObject:    listObject,
    		watchObject:   watchObject,
    		newObject:     newObject,
    		isImmutable:   isImmutable,
    		groupResource: groupResource,
    		clock:         clock,
    		maxIdleTime:   maxIdleTime,
    		items:         make(map[objectKey]*objectCacheItem),
    	}
    
    	go wait.Until(store.startRecycleIdleWatch, time.Minute, stopCh)
    	go store.shutdownWhenStopped(stopCh)
    	return store
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. src/runtime/profbuf.go

    		// We need to set overflowTime if we're incrementing b.overflow from 0.
    		if uint32(overflow) == 0 {
    			// Store overflowTime first so it's always available when overflow != 0.
    			b.overflowTime.Store(uint64(now))
    			b.overflow.Store((((overflow >> 32) + 1) << 32) + 1)
    			break
    		}
    		// Otherwise we're racing to increment against reader
    		// who wants to set b.overflow to 0.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. pilot/pkg/model/typed_xds_cache.go

    	}
    	cache.store = newLru(cache.onEvict)
    	return cache
    }
    
    type evictKeyConfigs[K comparable] struct {
    	key              K
    	dependentConfigs []ConfigHash
    }
    
    type lruCache[K comparable] struct {
    	enableAssertions bool
    	store            simplelru.LRUCache[K, cacheValue]
    	// token stores the latest token of the store, used to prevent stale data overwrite.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 05:26:03 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/constants/constants.go

    	KubeadmConfigConfigMap = "kubeadm-config"
    
    	// ClusterConfigurationConfigMapKey specifies in what ConfigMap key the cluster configuration should be stored
    	ClusterConfigurationConfigMapKey = "ClusterConfiguration"
    
    	// KubeProxyConfigMap specifies in what ConfigMap in the kube-system namespace the kube-proxy configuration should be stored
    	KubeProxyConfigMap = "kube-proxy"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 03:36:35 UTC 2024
    - 32.4K bytes
    - Viewed (0)
  5. src/compress/flate/huffman_bit_writer.go

    	// Always use dynamic Huffman or Store
    	var numCodegens int
    
    	// Generate codegen and codegenFrequencies, which indicates how to encode
    	// the literalEncoding and the offsetEncoding.
    	w.generateCodegen(numLiterals, numOffsets, w.literalEncoding, huffOffset)
    	w.codegenEncoding.generate(w.codegenFreq[:], 7)
    	size, numCodegens := w.dynamicSize(w.literalEncoding, huffOffset, 0)
    
    	// Store bytes, if we don't get a reasonable improvement.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 29 22:59:14 UTC 2022
    - 18.4K bytes
    - Viewed (0)
  6. src/cmd/internal/obj/s390x/a.out.go

    	ALARL
    	ALA
    	ALAY
    
    	// interlocked load and op
    	ALAA
    	ALAAG
    	ALAAL
    	ALAALG
    	ALAN
    	ALANG
    	ALAX
    	ALAXG
    	ALAO
    	ALAOG
    
    	// load/store multiple
    	ALMY
    	ALMG
    	ASTMY
    	ASTMG
    
    	// store clock
    	ASTCK
    	ASTCKC
    	ASTCKE
    	ASTCKF
    
    	// macros
    	ACLEAR
    
    	// crypto
    	AKM
    	AKMC
    	AKLMD
    	AKIMD
    	AKDSA
    	AKMA
    	AKMCTR
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 05 16:41:03 UTC 2023
    - 12.4K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/ssa/deadstore.go

    			}
    		}
    	}
    
    	// Eliminate stores to unread autos.
    	for _, store := range stores {
    		n, _ := store.Aux.(*ir.Name)
    		if seen.Has(n) {
    			continue
    		}
    
    		// replace store with OpCopy
    		store.SetArgs1(store.MemoryArg())
    		store.Aux = nil
    		store.AuxInt = 0
    		store.Op = OpCopy
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 25 20:07:26 UTC 2024
    - 11K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go

    }
    
    // testPropagateStore helps propagates store with objects, automates key generation, and returns
    // keys and stored objects.
    func testPropagateStore(ctx context.Context, t *testing.T, store storage.Interface, obj *example.Pod) (string, *example.Pod) {
    	// Setup store with a key and grab the output for returning.
    	key := computePodKey(obj)
    
    	// Setup store with the specified key and grab the output for returning.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 22 07:26:55 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  9. src/runtime/sys_linux_arm64.s

    	SVC
    
    finish:
    	MOVD	0(RSP), R3	// sec
    	MOVD	8(RSP), R5	// nsec
    
    	MOVD	R20, RSP	// restore SP
    	// Restore vdsoPC, vdsoSP
    	// We don't worry about being signaled between the two stores.
    	// If we are not in a signal handler, we'll restore vdsoSP to 0,
    	// and no one will care about vdsoPC. If we are in a signal handler,
    	// we cannot receive another signal.
    	MOVD	16(RSP), R1
    	MOVD	R1, m_vdsoSP(R21)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 24 18:53:44 UTC 2023
    - 16.7K bytes
    - Viewed (0)
  10. src/internal/concurrent/hashtriemap.go

    	if oldEntry == nil {
    		// Easy case: create a new entry and store it.
    		slot.Store(&newEntry.node)
    	} else {
    		// We possibly need to expand the entry already there into one or more new nodes.
    		//
    		// Publish the node last, which will make both oldEntry and newEntry visible. We
    		// don't want readers to be able to observe that oldEntry isn't in the tree.
    		slot.Store(ht.expand(oldEntry, newEntry, hash, hashShift, i))
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 16:01:55 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top