Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for lseek (0.05 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. fastapi/datastructures.py

            To be awaitable, compatible with async, this is run in threadpool.
            """
            return await super().read(size)
    
        async def seek(
            self,
            offset: Annotated[
                int,
                Doc(
                    """
                    The position in bytes to seek to in the file.
                    """
                ),
            ],
        ) -> None:
            """
            Move to a position in the file.
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. src/internal/xcoff/ar.go

    	case AIAMAG:
    		return nil, fmt.Errorf("small AIX archive not supported")
    	default:
    		return nil, fmt.Errorf("unrecognised archive magic: 0x%x", magic)
    	}
    
    	var fhdr bigarFileHeader
    	if _, err := sr.Seek(0, io.SeekStart); err != nil {
    		return nil, err
    	}
    	if err := binary.Read(sr, binary.BigEndian, &fhdr); err != nil {
    		return nil, err
    	}
    
    	off, err := parseDecimalBytes(fhdr.Flfstmoff[:])
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 17:32:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. docs/de/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: Sat Mar 30 18:17:09 UTC 2024
    - 495 bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

          sinkBuffer.write(maskKey)
    
          if (length > 0) {
            val payloadStart = sinkBuffer.size
            sinkBuffer.write(payload)
    
            sinkBuffer.readAndWriteUnsafe(maskCursor!!)
            maskCursor.seek(payloadStart)
            toggleMask(maskCursor, maskKey)
            maskCursor.close()
          }
        } else {
          sinkBuffer.writeByte(b1)
          sinkBuffer.write(payload)
        }
    
        sink.flush()
      }
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top