Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for Fd (0.01 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/http/dial_linux.go

    		c.Control(func(fdPtr uintptr) {
    			// 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 custom socket send/recv buffers.
    			if opts.SendBufSize > 0 {
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_SNDBUF, opts.SendBufSize)
    			}
    
    			if opts.RecvBufSize > 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jul 23 10:53:03 GMT 2024
    - 5K bytes
    - Click Count (0)
  2. src/cmd/asm/internal/lex/lex.go

    	}
    }
    
    // NewLexer returns a lexer for the named file and the given link context.
    func NewLexer(name string) TokenReader {
    	input := NewInput(name)
    	fd, err := os.Open(name)
    	if err != nil {
    		log.Fatalf("%s\n", err)
    	}
    	input.Push(NewTokenizer(name, fd, fd))
    	return input
    }
    
    // The other files in this directory each contain an implementation of TokenReader.
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Aug 29 18:31:05 GMT 2023
    - 4.1K bytes
    - Click Count (0)
  3. internal/disk/directio_unix.go

    	return directio.OpenFile(filePath, flag, perm)
    }
    
    // DisableDirectIO - disables directio mode.
    func DisableDirectIO(f *os.File) error {
    	fd := f.Fd()
    	flag, err := unix.FcntlInt(fd, unix.F_GETFL, 0)
    	if err != nil {
    		return err
    	}
    	flag &= ^(syscall.O_DIRECT)
    	_, err = unix.FcntlInt(fd, unix.F_SETFL, flag)
    	return err
    }
    
    // AlignedBlock - pass through to directio implementation.
    func AlignedBlock(blockSize int) []byte {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Jun 17 14:31:36 GMT 2023
    - 1.6K bytes
    - Click Count (0)
  4. internal/disk/directio_darwin.go

    	return directio.OpenFile(filePath, flag, perm)
    }
    
    // DisableDirectIO - disables directio mode.
    func DisableDirectIO(f *os.File) error {
    	fd := f.Fd()
    	_, err := unix.FcntlInt(fd, unix.F_NOCACHE, 0)
    	return err
    }
    
    // AlignedBlock - pass through to directio implementation.
    func AlignedBlock(blockSize int) []byte {
    	return directio.AlignedBlock(blockSize)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Jun 17 14:31:36 GMT 2023
    - 1.4K bytes
    - Click Count (0)
  5. src/main/java/jcifs/SmbPipeHandle.java

        /**
         * Tests whether this file descriptor is open and valid.
         *
         * @return whether the FD is open and valid
         */
        boolean isOpen();
    
        /**
         * Tests whether this file descriptor was previously open but has become invalid.
         *
         * @return whether the FD was previously open but became invalid
         */
        boolean isStale();
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  6. internal/lock/lock.go

    // Package lock - implements filesystem locking wrappers around an
    // open file descriptor.
    package lock
    
    import (
    	"errors"
    	"os"
    	"sync"
    )
    
    // ErrAlreadyLocked is returned if the underlying fd is already locked.
    var ErrAlreadyLocked = errors.New("file already locked")
    
    // RLockedFile represents a read locked file, implements a special
    // closer which only closes the associated *os.File when the ref count.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.5K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb/SmbPipeInputStream.java

         */
        @Override
        public int available() throws IOException {
            try (SmbFileHandleImpl fd = this.handle.ensureOpen(); SmbTreeHandleImpl th = fd.getTree()) {
                if (th.isSMB2()) {
                    final Smb2IoctlRequest req = new Smb2IoctlRequest(th.getConfig(), Smb2IoctlRequest.FSCTL_PIPE_PEEK, fd.getFileId());
                    req.setMaxOutputResponse(16);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  8. cmd/service.go

    Harshavardhana <******@****.***> 1709103734 -0800
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Click Count (0)
  9. internal/logger/logrotate.go

    Taran Pelkey <******@****.***> 1743296162 -0400
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  10. internal/disk/fdatasync_linux.go

    // do not require all metadata to be synchronized with the disk.
    func Fdatasync(f *os.File) error {
    	return syscall.Fdatasync(int(f.Fd()))
    }
    
    // FadviseDontNeed invalidates page-cache
    func FadviseDontNeed(f *os.File) error {
    	return unix.Fadvise(int(f.Fd()), 0, 0, unix.FADV_DONTNEED)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Sep 29 23:40:28 GMT 2021
    - 1.8K bytes
    - Click Count (0)
Back to Top