Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Lively (0.19 sec)

  1. cni/pkg/repair/netns.go

    	// We want the pause container, as the istio-validation one may exit before we are done.
    	// We do this by detecting the longest running process. We could look at `cmdline`, but is likely more reliable to weird platforms.
    	for _, p := range procs {
    		ns := getPidNamespace(p.PID)
    		fd, err := unix.Open(ns, unix.O_RDONLY, 0)
    		if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Dec 20 22:14:13 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  2. cmd/update-notifier.go

    	if globalServerCtxt.JSON {
    		return fmt.Sprintf("You are running an older version of MinIO released %s, update: %s", newerThan, downloadURL)
    	}
    
    	// Return the nicely colored and formatted update message.
    	return colorizeUpdateMessage(downloadURL, newerThan)
    }
    
    // colorizeUpdateMessage - inspired from Yeoman project npm package https://github.com/yeoman/update-notifier
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  3. operator/cmd/mesh/operator-init.go

    	kubeClient, client, err := kubeClients(cliClient, l)
    	if err != nil {
    		l.LogAndFatal(err)
    	}
    	if oiArgs.common.revision == "default" {
    		oiArgs.common.revision = ""
    	}
    	// Error here likely indicates Deployment is missing. If some other K8s error, we will hit it again later.
    	already, _ := isControllerInstalled(kubeClient.Kube(), oiArgs.common.operatorNamespace, oiArgs.common.revision)
    	if already {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  4. internal/handlers/forwarder.go

    	}
    
    	return f
    }
    
    type bufPool struct {
    	sz   int
    	pool sync.Pool
    }
    
    func (b *bufPool) Put(buf []byte) {
    	if cap(buf) < b.sz || cap(buf) > b.sz*2 {
    		// Buffer too small or will likely leak memory after being expanded.
    		// Drop it.
    		return
    	}
    	b.pool.Put(&buf)
    }
    
    func (b *bufPool) Get() []byte {
    	bufp := b.pool.Get().(*[]byte)
    	return (*bufp)[:b.sz]
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 07 05:42:10 GMT 2023
    - 5.6K bytes
    - Viewed (0)
  5. cmd/metacache.go

    	// metacacheSharePrefix controls whether prefixes on dirty paths are always shared.
    	// This will make `test/a` and `test/b` share listings if they are concurrent.
    	// Enabling this will make cache sharing more likely and cause less IO,
    	// but may cause additional latency to some calls.
    	metacacheSharePrefix = false
    )
    
    //go:generate msgp -file $GOFILE -unexported
    
    // metacache contains a tracked cache entry.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
  6. src/arena/arena.go

    the CPU cost of the garbage collector is incurred less frequently.
    
    This functionality in this package is mostly captured in the Arena type.
    Arenas allocate large chunks of memory for Go values, so they're likely to
    be inefficient for allocating only small amounts of small Go values. They're
    best used in bulk, on the order of MiB of memory allocated on each use.
    
    Note that by allowing for this limited form of manual memory allocation
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Oct 12 20:23:36 GMT 2022
    - 4.3K bytes
    - Viewed (0)
Back to top