Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 72 for readFile (0.48 sec)

  1. internal/s3select/json/preader_test.go

    	}
    }
    
    func BenchmarkPReader(b *testing.B) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		b.Fatal(err)
    	}
    	for _, file := range files {
    		b.Run(file.Name(), func(b *testing.B) {
    			f, err := os.ReadFile(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				b.Fatal(err)
    			}
    			b.SetBytes(int64(len(f)))
    			b.ReportAllocs()
    			b.ResetTimer()
    			var record sql.Record
    			for i := 0; i < b.N; i++ {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 2.5K bytes
    - Viewed (0)
  2. cmd/storage-rest-common.go

    	storageRESTMethodWriteAll       = "/writeall"
    	storageRESTMethodReadVersion    = "/readversion"
    	storageRESTMethodReadXL         = "/readxl"
    	storageRESTMethodReadAll        = "/readall"
    	storageRESTMethodReadFile       = "/readfile"
    	storageRESTMethodReadFileStream = "/readfilestream"
    	storageRESTMethodListDir        = "/listdir"
    	storageRESTMethodDeleteVersions = "/deleteverions"
    	storageRESTMethodRenameFile     = "/renamefile"
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 12 21:00:20 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_test.go

    		if dataDir != tc.expectedDataDir {
    			t.Fatalf("Expected %s but got %s", tc.expectedDataDir, dataDir)
    		}
    		count++
    	}
    }
    
    func Benchmark_mergeXLV2Versions(b *testing.B) {
    	data, err := os.ReadFile("testdata/xl.meta-v1.2.zst")
    	if err != nil {
    		b.Fatal(err)
    	}
    	dec, _ := zstd.NewReader(nil)
    	data, err = dec.DecodeAll(data, nil)
    	if err != nil {
    		b.Fatal(err)
    	}
    
    	var xl xlMetaV2
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  4. 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  5. cmd/storage-interface.go

    	// File operations.
    	ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) ([]string, error)
    	ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error)
    	AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  6. internal/config/certs.go

    // decrypted using the ENV_VAR: MINIO_CERT_PASSWD.
    func LoadX509KeyPair(certFile, keyFile string) (tls.Certificate, error) {
    	certPEMBlock, err := os.ReadFile(certFile)
    	if err != nil {
    		return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the public key: %s", err)
    	}
    	keyPEMBlock, err := os.ReadFile(keyFile)
    	if err != nil {
    		return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the private key: %s", err)
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  7. internal/ioutil/read_file.go

    	_, err = io.ReadFull(f, dst)
    	return dst, st, err
    }
    
    // ReadFile reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    //
    // passes NOATIME flag for reads on Unix systems to avoid atime updates.
    func ReadFile(name string) ([]byte, error) {
    	// Don't wrap with un-needed buffer.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader_amd64_test.go

    	Fatal(args ...interface{})
    }
    
    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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  9. 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)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  10. cmd/xl-storage_test.go

    		}
    	}
    
    	{
    		buf := make([]byte, 5)
    		// Test for negative offset.
    		if _, err = xlStorage.ReadFile(context.Background(), volume, "myobject", -1, buf, v); err == nil {
    			t.Fatalf("expected: error, got: <nil>")
    		}
    	}
    
    	for l := 0; l < 2; l++ {
    		// Following block validates all ReadFile test cases.
    		for i, testCase := range testCases {
    			var n int64
    			// Common read buffer.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top