Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 46 for Fd (0.02 sec)

  1. internal/lock/lock_windows.go

    	fd, err := syscall.CreateFile(pathp, access, shareflag, nil, createflag, accessAttr, 0)
    	if err != nil {
    		return nil, err
    	}
    
    	return os.NewFile(uintptr(fd), path), nil
    }
    
    func lockFile(fd syscall.Handle, flags uint32) error {
    	// https://msdn.microsoft.com/en-us/library/windows/desktop/aa365203(v=vs.85).aspx
    	if fd == syscall.InvalidHandle {
    		return nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. 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
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  3. 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() ) {
                    Smb2IoctlRequest req = new Smb2IoctlRequest(th.getConfig(), Smb2IoctlRequest.FSCTL_PIPE_PEEK, fd.getFileId());
                    req.setMaxOutputResponse(16);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 07:12:23 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  4. 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.
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  5. src/main/java/jcifs/SmbPipeHandle.java

         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
        void close () throws CIFSException;
    
    
        /**
         * @return whether the FD is open and valid
         */
        boolean isOpen ();
    
    
        /**
         * @return whether the FD was previously open but became invalid
         */
        boolean isStale ();
    
    
        /**
         * @param type
         * @return unwrapped instance
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.8K bytes
    - Viewed (0)
  6. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  7. 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)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  8. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbFileInputStream.java

            }
            // ensure file is open
            try ( SmbFileHandleImpl fd = ensureOpen();
                  SmbTreeHandleImpl th = fd.getTree() ) {
    
                /*
                 * Read AndX Request / Response
                 */
    
                if ( log.isTraceEnabled() ) {
                    log.trace("read: fid=" + fd + ",off=" + off + ",len=" + len);
                }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 08:55:14 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/netns_other.go

    func NetnsSet(n NetnsFd) error {
    	return errors.New("not implemented")
    }
    
    func OpenNetns(nspath string) (NetnsCloser, error) {
    	return nil, errors.New("not implemented")
    }
    
    // inspired by netns.Do() but with an existing fd.
    func NetnsDo(fdable NetnsFd, toRun func() error) error {
    	return errors.New("not implemented")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Mar 14 09:32:25 UTC 2024
    - 1K bytes
    - Viewed (0)
Back to top