Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Fd (0.16 sec)

  1. cni/pkg/nodeagent/fakes_test.go

    type fakeNs struct {
    	closed *atomic.Bool
    	fd     uintptr
    	inode  uint64
    }
    
    func newFakeNs(fd uintptr) *fakeNs {
    	// the fake inode is the fd! magic.
    	return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: uint64(fd)}
    }
    
    func newFakeNsInode(fd uintptr, inode uint64) *fakeNs {
    	return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode}
    }
    
    // Fd returns the file descriptor
    func (f *fakeNs) Fd() uintptr {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  2. internal/http/dial_linux.go

    			// got socket file descriptor to set parameters.
    			fd := int(fdPtr)
    
    			_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_REUSEADDR, 1)
    
    			_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_REUSEPORT, 1)
    
    			{
    				// Enable big buffers
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_SNDBUF, opts.SendBufSize)
    
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_RCVBUF, opts.RecvBufSize)
    			}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 4.3K bytes
    - Viewed (3)
  3. cni/pkg/nodeagent/ztunnelserver.go

    	data, err := proto.Marshal(msg)
    	if err != nil {
    		return nil, err
    	}
    	return z.sendDataAndWaitForAck(data, fd)
    }
    
    func (z *ZtunnelConnection) sendDataAndWaitForAck(data []byte, fd *int) (*zdsapi.WorkloadResponse, error) {
    	var rights []byte
    	if fd != nil {
    		rights = unix.UnixRights(*fd)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/podcgroupns.go

    		return false
    	}
    	return true
    }
    
    func GetFd(f fs.File) (uintptr, error) {
    	if fdable, ok := f.(interface{ Fd() uintptr }); ok {
    		return fdable.Fd(), nil
    	}
    
    	return 0, fmt.Errorf("unable to get fd")
    }
    
    /// mostly copy pasted from spire below:
    
    // regexes listed here have to exclusively match a cgroup path
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/ztunnelserver_test.go

    	mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(1))
    
    	// we should get the fd to dev null. note that we can't assert the fd number
    	// as the kernel may have given us a different number that refers to the same file.
    	assert.Equal(t, len(fds), 1)
    	// in theory we should close the fd, but it's just a test..
    
    	assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Add).Add.Uid, uid)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  6. cmd/metacache-set.go

    			fdMu.Lock()
    			defer fdMu.Unlock()
    			if len(fds) == 0 {
    				return nil
    			}
    			fdsCopy := fds
    			for _, fd := range fdsCopy {
    				// Grab a fallback disk
    				fds = fds[1:]
    				if fd != nil && fd.IsOnline() {
    					return fd
    				}
    			}
    		}
    		// Either no more disks for fallback or
    		// not a storage error.
    		return nil
    	}
    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)
  7. internal/ioutil/ioutil.go

    				n, err = w.Write(buf[:len(buf)-remain])
    				if err != nil {
    					return written, err
    				}
    				nw = int64(n)
    			}
    
    			// Disable O_DIRECT on fd's on unaligned buffer
    			// perform an amortized Fdatasync(fd) on the fd at
    			// the end, this is performed by the caller before
    			// closing 'w'.
    			if err = disk.DisableDirectIO(file); err != nil {
    				return written, err
    			}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  8. internal/logger/logrotate.go

    	}
    
    	// close everything before we delete.
    	if err = gw.Close(); err != nil {
    		return err
    	}
    
    	if err = r.Close(); err != nil {
    		return err
    	}
    
    	// Attempt to remove after all fd's are closed.
    	return os.Remove(oldLgFile)
    }
    
    func (w *Writer) rotate() error {
    	if w.f != nil {
    		if err := w.closeCurrentFile(); err != nil {
    			return err
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  9. cmd/common-main.go

    	currentReleaseTime time.Time
    	orchestrated       = IsKubernetes() || IsDocker()
    )
    
    func init() {
    	if !term.IsTerminal(int(os.Stdout.Fd())) || !term.IsTerminal(int(os.Stderr.Fd())) {
    		color.TurnOff()
    	}
    	if env.Get("NO_COLOR", "") != "" || env.Get("TERM", "") == "dumb" {
    		color.TurnOff()
    	}
    
    	if runtime.GOOS == "windows" {
    		if mousetrap.StartedByExplorer() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  10. cmd/testdata/undeleteable-object.tgz

    §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ$CªPartASizes‘Ñ$C¤SizeÑ$C¥MTimeÓ É ¸Åñ€§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ d6566afb36d109141150¬content-type°application/json¡v ÎÅ ½¤ ¤nullÅ ,T_º¾ ÷²ŒÝ€ Ç7€{vO¸Ú¡£’3¹fd+Î>" ¾r_dn_search_filter","value":""},{"key":"group_search_filter","value":""},{"key":"group_search_base_dn","value":""},{"key":"tls_skip_verify","value":"off"},{"key":"server_insecure","value":"off"},{"key":"server_starttls","value":"off"},{"key":"...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 8.7M bytes
    - Viewed (0)
Back to top