- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for lseek (0.05 sec)
-
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) -
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) -
fastapi/datastructures.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 5.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)