- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 18 for read_file (0.08 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs_src/generate_clients/tutorial004.js
import * as fs from 'fs' async function modifyOpenAPIFile(filePath) { try { const data = await fs.promises.readFile(filePath) const openapiContent = JSON.parse(data) const paths = openapiContent.paths for (const pathKey of Object.keys(paths)) { const pathData = paths[pathKey] for (const method of Object.keys(pathData)) { const operation = pathData[method] if (operation.tags && operation.tags.length > 0) {
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Thu Mar 14 11:40:05 GMT 2024 - 1K bytes - Click Count (0) -
cmd/naughty-disk_test.go
} return d.disk.ListDir(ctx, origvolume, volume, dirPath, count) } func (d *naughtyDisk) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) { if err := d.calcError(); err != nil { return 0, err } return d.disk.ReadFile(ctx, volume, path, offset, buf, verifier) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 10.1K bytes - Click Count (0) -
lib/time/mkzip.go
var zb bytes.Buffer zw := zip.NewWriter(&zb) seen := make(map[string]bool) err := filepath.WalkDir(".", func(path string, d fs.DirEntry, err error) error { if d.IsDir() { return nil } data, err := os.ReadFile(path) if err != nil { log.Fatal(err) } if strings.HasSuffix(path, ".zip") { log.Fatalf("unexpected file during walk: %s", path) } name := filepath.ToSlash(path)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Mar 04 17:32:07 GMT 2024 - 2.1K bytes - Click Count (0) -
src/archive/zip/writer_test.go
t.Fatalf("unexpected CreateHeader error: %v", err) } if err := w.Close(); err != nil { t.Fatalf("unexpected Close error: %v", err) } want, err := os.ReadFile("testdata/time-go.zip") if err != nil { t.Fatalf("unexpected ReadFile error: %v", err) } if got := buf.Bytes(); !bytes.Equal(got, want) { fmt.Printf("%x\n%x\n", got, want) t.Error("contents of time-go.zip differ") } }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Jan 28 04:20:09 GMT 2025 - 14.4K bytes - Click Count (0) -
cmd/xl-storage_test.go
} } { buf := make([]byte, 5) // Test for negative offset. if _, err = xlStorage.ReadFile(t.Context(), volume, "myobject", -1, buf, v); err == nil { t.Fatalf("expected: error, got: <nil>") } } for range 2 { // Following block validates all ReadFile test cases. for i, testCase := range testCases { var n int64 // Common read buffer.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 66K bytes - Click Count (0) -
internal/s3select/simdj/reader_amd64_test.go
type tester interface { Fatal(args ...any) } func loadCompressed(t tester, file string) (js []byte) { dec, err := zstd.NewReader(nil) if err != nil { t.Fatal(err) } defer dec.Close() js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst")) if err != nil { t.Fatal(err) } js, err = dec.DecodeAll(js, nil) if err != nil { t.Fatal(err) } return js } var testCases = []struct {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.9K bytes - Click Count (0) -
cmd/metacache-walk.go
meta.name = decodeDirObject(meta.name) return send(meta) } // Check legacy. if HasSuffix(entry, xlStorageFormatFileV1) && legacy { var meta metaCacheEntry meta.metadata, err = xioutil.ReadFile(pathJoinBuf(sb, volumeDir, current, entry)) diskHealthCheckOK(ctx, err) if err != nil { if !IsErrIgnored(err, io.EOF, io.ErrUnexpectedEOF) { internalLogIf(ctx, err) } continue
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon May 26 07:06:43 GMT 2025 - 12.6K bytes - Click Count (0) -
internal/store/queuestore.go
defer func(store *QueueStore[I]) { store.RUnlock() if err != nil && !os.IsNotExist(err) { // Upon error we remove the entry. store.Del(key) } }(store) raw, err = os.ReadFile(filepath.Join(store.directory, key.String())) if err != nil { return raw, err } if len(raw) == 0 { return raw, os.ErrNotExist } if key.Compress { raw, err = s2.Decode(nil, raw)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (0) -
cmd/xl-storage.go
// tries to verify whether the disk has bitrot. // // Additionally ReadFile also starts reading from an offset. ReadFile // semantics are same as io.ReadFull. func (s *xlStorage) ReadFile(ctx context.Context, volume string, path string, offset int64, buffer []byte, verifier *BitrotVerifier) (int64, error) { if offset < 0 { return 0, errInvalidArgument } volumeDir, err := s.getVolDir(volume) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
cmd/sftp-server.go
if sshPrivateKey == "" { logger.Fatal(fmt.Errorf("invalid arguments passed, private key file is mandatory for --sftp='ssh-private-key=path/to/id_ecdsa'"), "unable to start SFTP server") } privateBytes, err := os.ReadFile(sshPrivateKey) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed, private key file is not accessible: %v", err), "unable to start SFTP server") } private, err := ssh.ParsePrivateKey(privateBytes)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.5K bytes - Click Count (0)