Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 62 for gids (0.05 sec)

  1. pkg/kubelet/cm/cgroup_manager_linux.go

    	}
    
    	return nil
    }
    
    // Scans through all subsystems to find pids associated with specified cgroup.
    func (m *cgroupManagerImpl) Pids(name CgroupName) []int {
    	// we need the driver specific name
    	cgroupFsName := m.Name(name)
    
    	// Get a list of processes that we need to kill
    	pidsToKill := sets.New[int]()
    	var pids []int
    	for _, val := range m.subsystems.MountPoints {
    		dir := path.Join(val, cgroupFsName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 26.5K bytes
    - Viewed (0)
  2. pkg/registry/batch/cronjob/strategy_test.go

    	if len(errs) == 0 {
    		t.Errorf("Expected a validation error")
    	}
    
    	// Make sure we correctly implement the interface.
    	// Otherwise a typo could silently change the default.
    	var gcds rest.GarbageCollectionDeleteStrategy = Strategy
    	if got, want := gcds.DefaultGarbageCollectionPolicy(genericapirequest.NewContext()), rest.DeleteDependents; got != want {
    		t.Errorf("DefaultGarbageCollectionPolicy() = %#v, want %#v", got, want)
    	}
    
    	var (
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 14:34:53 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/pod_container_manager_linux.go

    func (m *podContainerManagerImpl) tryKillingCgroupProcesses(podCgroup CgroupName) error {
    	pidsToKill := m.cgroupManager.Pids(podCgroup)
    	// No pids charged to the terminated pod cgroup return
    	if len(pidsToKill) == 0 {
    		return nil
    	}
    
    	var errlist []error
    	// os.Kill often errors out,
    	// We try killing all the pids multiple times
    	removed := map[int]bool{}
    	for i := 0; i < 5; i++ {
    		if i != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 16:38:36 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  4. src/os/user/lookup_windows.go

    	var sids []string
    	for _, entry := range entries {
    		if entry.Name == nil {
    			continue
    		}
    		sid, err := lookupGroupName(windows.UTF16PtrToString(entry.Name))
    		if err != nil {
    			return nil, err
    		}
    		sids = append(sids, sid)
    	}
    	return sids, nil
    }
    
    func newUser(uid, gid, dir, username, domain string) (*User, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 12 16:42:41 UTC 2023
    - 11.8K bytes
    - Viewed (0)
  5. misc/wasm/wasm_exec.js

    			this._ids = new Map([ // mapping from JS values to reference ids
    				[0, 1],
    				[null, 2],
    				[true, 3],
    				[false, 4],
    				[globalThis, 5],
    				[this, 6],
    			]);
    			this._idPool = [];   // unused ids that have been garbage collected
    			this.exited = false; // whether the Go program has exited
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 22 17:47:47 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  6. cmd/local-locker.go

    				lris, ok := l.lockMap[resource]
    				if !ok {
    					continue
    				}
    				// Collect uids, so we don't mutate while we delete
    				uids := make([]string, 0, len(lris))
    				for _, lri := range lris {
    					uids = append(uids, lri.UID)
    				}
    
    				// Delete collected uids:
    				for _, uid := range uids {
    					lris, ok := l.lockMap[resource]
    					if !ok {
    						// Just to be safe, delete uuids.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. src/runtime/runtime-gdb.py

    	def invoke(self, arg, _from_tty):
    		goid_str, cmd = arg.split(None, 1)
    		goids = []
    
    		if goid_str == 'all':
    			for ptr in SliceValue(gdb.parse_and_eval("'runtime.allgs'")):
    				goids.append(int(ptr['goid']))
    		else:
    			goids = [int(gdb.parse_and_eval(goid_str))]
    
    		for goid in goids:
    			self.invoke_per_goid(goid, cmd)
    
    	def invoke_per_goid(self, goid, cmd):
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 10 12:59:20 UTC 2023
    - 15.4K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/PdfExtractor.java

                } else {
                    final List<PDNameTreeNode<PDComplexFileSpecification>> kids = efTree.getKids();
                    if (kids == null) {
                        return;
                    }
                    for (final PDNameTreeNode<PDComplexFileSpecification> node : kids) {
                        processEmbeddedDocNames(node.getNames(), writer);
                    }
                }
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  9. cmd/local-locker_test.go

    					if len(l.lockUID) == locks*readers {
    						t.Fatalf("objects uids all remain, unlikely")
    					}
    					if len(l.lockMap) == 0 {
    						t.Fatalf("objects all deleted, 0 remains")
    					}
    					if len(l.lockUID) == 0 {
    						t.Fatalf("objects uids all deleted, 0 remains")
    					}
    
    					start = time.Now()
    					l.expireOldLocks(-time.Minute)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 11.8K bytes
    - Viewed (0)
  10. src/crypto/x509/parser.go

    			return nil, errors.New("x509: invalid certificate policies")
    		}
    		oid, ok := newOIDFromDER(OIDBytes)
    		if !ok {
    			return nil, errors.New("x509: invalid certificate policies")
    		}
    		oids = append(oids, oid)
    	}
    	return oids, nil
    }
    
    // isValidIPMask reports whether mask consists of zero or more 1 bits, followed by zero bits.
    func isValidIPMask(mask []byte) bool {
    	seenZero := false
    
    	for _, b := range mask {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:00:16 UTC 2024
    - 38.5K bytes
    - Viewed (0)
Back to top