Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for lseek (0.07 sec)

  1. src/internal/poll/sendfile_windows.go

    	o := &fd.wop
    	o.handle = src
    
    	// TODO(brainman): skip calling syscall.Seek if OS allows it
    	curpos, err := syscall.Seek(o.handle, 0, io.SeekCurrent)
    	if err != nil {
    		return 0, err
    	}
    
    	if n <= 0 { // We don't know the size of the file so infer it.
    		// Find the number of bytes offset from curpos until the end of the file.
    		n, err = syscall.Seek(o.handle, -curpos, io.SeekEnd)
    		if err != nil {
    			return
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  2. src/internal/poll/fd_wasip1.go

    	// a bit brittle but cannot be addressed without a large change of the
    	// algorithm in the os.(*File).readdir method.
    	return n - len(b), nil
    }
    
    // Seek wraps syscall.Seek.
    func (fd *FD) Seek(offset int64, whence int) (int64, error) {
    	if err := fd.incref(); err != nil {
    		return 0, err
    	}
    	defer fd.decref()
    	// syscall.Filetype is a uint8 but we store it as a uint32 in SysFile in
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 20:14:02 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. src/net/sendfile_unix_alt.go

    	// of the file -- if you pass it offset 0, it starts from
    	// offset 0. There's no way to tell it "start from current
    	// position", so we have to manage that explicitly.
    	pos, err := f.Seek(0, io.SeekCurrent)
    	if err != nil {
    		return 0, err, false
    	}
    
    	sc, err := f.SyscallConn()
    	if err != nil {
    		return 0, nil, false
    	}
    
    	var werr error
    	err = sc.Read(func(fd uintptr) bool {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  4. docs/en/docs/reference/uploadfile.md

        options:
            members:
                - file
                - filename
                - size
                - headers
                - content_type
                - read
                - write
                - seek
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 472 bytes
    - Viewed (0)
  5. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/filelock/LockInfoAccess.java

        public LockInfo readLockInfo(RandomAccessFile lockFileAccess) throws IOException {
            if (lockFileAccess.length() <= infoRegionPos) {
                return new LockInfo();
            } else {
                lockFileAccess.seek(infoRegionPos);
    
                DataInputStream inputStream = new DataInputStream(new BufferedInputStream(new RandomAccessFileInputStream(lockFileAccess)));
                byte protocolVersion = inputStream.readByte();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  6. src/internal/coverage/encodecounter/encode.go

    }
    
    func (cfw *CoverageDataWriter) patchSegmentHeader(ws *slicewriter.WriteSeeker) error {
    	// record position
    	off, err := ws.Seek(0, io.SeekCurrent)
    	if err != nil {
    		return fmt.Errorf("error seeking in patchSegmentHeader: %v", err)
    	}
    	// seek back to start so that we can update the segment header
    	if _, err := ws.Seek(0, io.SeekStart); err != nil {
    		return fmt.Errorf("error seeking in patchSegmentHeader: %v", err)
    	}
    	if cfw.debug {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  7. platforms/core-runtime/files/src/main/java/org/gradle/internal/file/RandomAccessFileInputStream.java

        private final RandomAccessFile file;
    
        public RandomAccessFileInputStream(RandomAccessFile file) {
            this.file = file;
        }
    
        @Override
        public long skip(long n) throws IOException {
            file.seek(file.getFilePointer() + n);
            return n;
        }
    
        @Override
        public int read(byte[] bytes) throws IOException {
            return file.read(bytes);
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  8. pkg/util/tail/tail.go

    	defer f.Close()
    	fi, err := f.Stat()
    	if err != nil {
    		return nil, false, err
    	}
    	size := fi.Size()
    	if size == 0 {
    		return nil, false, nil
    	}
    	if size < max {
    		max = size
    	}
    	offset, err := f.Seek(-max, io.SeekEnd)
    	if err != nil {
    		return nil, false, err
    	}
    	data, err := io.ReadAll(f)
    	return data, offset > 0, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 13:13:22 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  9. pkg/proxy/util/nfacct/nfacct_linux.go

    //	}
    func decode(msg []byte, strict bool) (*Counter, error) {
    	counter := &Counter{}
    	reader := bytes.NewReader(msg)
    	// skip the first 4 bytes (netfilter generic message).
    	if _, err := reader.Seek(nl.SizeofNfgenmsg, io.SeekCurrent); err != nil {
    		return nil, err
    	}
    
    	// attrsProcessed tracks the number of processed attributes.
    	var attrsProcessed int
    
    	// length and type of netlink attribute.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 06:47:50 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/ByteInput.java

        }
    
        /**
         * Starts reading from the given offset.
         */
        public DataInputStream start(long offset) throws IOException {
            file.seek(offset);
            bufferedInputStream.clear();
            countingInputStream = new CountingInputStream(bufferedInputStream);
            return new DataInputStream(countingInputStream);
        }
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top