Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for halen (0.13 sec)

  1. callbacks.go

    				} else if curIdx < sortedIdx {
    					return fmt.Errorf("conflicting callback %s with before %s", c.name, c.after)
    				}
    			} else if idx := getRIndex(names, c.after); idx != -1 {
    				// if after callback exists but haven't sorted
    				// set after callback's before callback to current callback
    				after := cs[idx]
    
    				if after.before == "" {
    					after.before = c.name
    				}
    
    				if err := sortCallback(after); err != nil {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Mar 26 03:33:36 GMT 2024
    - 8.6K bytes
    - Viewed (1)
  2. cni/pkg/nodeagent/podcgroupns.go

    }
    
    func (p *PodNetnsProcFinder) FindNetnsForPods(pods map[types.UID]*corev1.Pod) (PodToNetns, error) {
    	/*
    		for each process, find its netns inode,
    		if we already seen the inode, skip it
    		if we haven't seen the inode, check the process cgroup and see if we
    		can extract a pod uid from it.
    		if we can, open the netns, and save a map of uid->netns-fd
    	*/
    
    	podUIDNetns := make(PodToNetns)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex.go

    				(*locks)[lockID] = ""
    			}
    		}(lockID)
    	}
    	wg.Wait()
    
    	// Return true if releaseAll was successful, otherwise we return 'false'
    	// to indicate we haven't sufficiently unlocked lockers to avoid deadlocks.
    	//
    	// Caller may use this as an indication to call again.
    	return !checkFailedUnlocks(*locks, tolerance)
    }
    
    // Unlock unlocks the write lock.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    	// agreed is called if all disks agreed.
    	agreed func(entry metaCacheEntry)
    
    	// partial will be called when there is disagreement between disks.
    	// if disk did not return any result, but also haven't errored
    	// the entry will be empty and errs will
    	partial func(entries metaCacheEntries, errs []error)
    
    	// finished will be called when all streams have finished and
    	// more than one disk returned an error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
Back to top