- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for lseek (0.07 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) -
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) -
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) -
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) -
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) -
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) -
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)