- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 136 for lseek (0.08 sec)
-
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) -
docs/em/docs/tutorial/request-files.md
`UploadFile` โ๏ธ ๐ `async` ๐ฉโ๐ฌ. ๐ซ ๐ ๐ค ๐ ๐ ๐ฉโ๐ฌ ๐ (โ๏ธ ๐ `SpooledTemporaryFile`). * `write(data)`: โ `data` (`str` โ๏ธ `bytes`) ๐. * `read(size)`: โ `size` (`int`) ๐ข/๐ฆน ๐. * `seek(offset)`: ๐ถ ๐ข ๐ง `offset` (`int`) ๐. * ๐คถ โ., `await myfile.seek(0)` ๐ ๐ถ โถ๏ธ ๐. * ๐ โด๏ธ โ ๐ฅ ๐ ๐ `await myfile.read()` ๐ & โคด๏ธ ๐ช โ ๐ ๐. * `close()`: ๐ ๐. ๐ ๐ซ ๐ฉโ๐ฌ `async` ๐ฉโ๐ฌ, ๐ ๐ช "โ" ๐ซ.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Mar 13 19:02:19 UTC 2024 - 6.6K bytes - Viewed (0) -
src/internal/coverage/test/counter_test.go
} if len(allfuncs) != numSegments { t.Fatalf("expected %d got %d", numSegments, len(allfuncs)) } for sidx := 0; sidx < int(ns); sidx++ { if off, err := inf.Seek(0, io.SeekCurrent); err != nil { t.Fatalf("Seek failed: %v", err) } else { t.Logf("sidx=%d off=%d\n", sidx, off) } if sidx != 0 { if ok, err := cdr.BeginNextSegment(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 26 12:44:34 UTC 2023 - 6.2K bytes - Viewed (0) -
internal/ioutil/ioutil_test.go
if !errors.Is(err, io.ErrUnexpectedEOF) { t.Errorf("Expected io.ErrUnexpectedEOF, but got %v", err) } if written != 5 { t.Errorf("Expected written to be '5', but got %v", written) } f.Seek(0, io.SeekStart) r.Seek(0, io.SeekStart) written, err = CopyAligned(f, r, *bufp, r.Size(), f) if !errors.Is(err, nil) { t.Errorf("Expected nil, but got %v", err) } if written != r.Size() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/ByteOutput.java
} /** * Starts writing to the given offset. Can be beyond the current length of the file. */ public DataOutputStream start(long offset) throws IOException { file.seek(offset); bufferedOutputStream.clear(); countingOutputStream = new CountingOutputStream(bufferedOutputStream); return new DataOutputStream(countingOutputStream); } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 2.4K bytes - Viewed (0) -
src/os/exec_windows_test.go
} r, err := Open(name) if err != nil { t.Fatal(err) } defer r.Close() const n = 100 var execs [n]string // First create n executables. for i := 0; i < n; i++ { // Rewind r. if _, err := r.Seek(0, io.SeekStart); err != nil { t.Fatal(err) } name := filepath.Join(t.TempDir(), "test.exe") execs[i] = name w, err := Create(name) if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 26 15:13:24 UTC 2023 - 1.8K bytes - Viewed (0) -
src/cmd/internal/buildid/buildid.go
bad := func() (string, error) { return "", &fs.PathError{Op: "parse", Path: name, Err: errBuildIDMalformed} } off := int64(8) for { if _, err := f.Seek(off, io.SeekStart); err != nil { return "", err } // TODO(iant): Make a debug/ar package, and use it // here and in cmd/link. var hdr [60]byte if _, err := io.ReadFull(f, hdr[:]); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 28 21:52:53 UTC 2020 - 9K bytes - Viewed (0) -
src/debug/pe/symbol.go
if fh.PointerToSymbolTable == 0 { return nil, nil } if fh.NumberOfSymbols <= 0 { return nil, nil } _, err := r.Seek(int64(fh.PointerToSymbolTable), io.SeekStart) if err != nil { return nil, fmt.Errorf("fail to seek to symbol table: %v", err) } c := saferio.SliceCap[COFFSymbol](uint64(fh.NumberOfSymbols)) if c < 0 { return nil, errors.New("too many symbols; file may be corrupt")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:33:30 UTC 2023 - 6.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/streams/DefaultValueStore.java
} @Override public long skip(long count) throws IOException { int toSkip = (int) Math.min(count, remaining); if (toSkip > 0) { file.seek(file.getFilePointer() + toSkip); remaining -= toSkip; } return toSkip; } @Override public int read() throws IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 8K bytes - Viewed (0)