Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 67 for readFile (2.13 sec)

  1. cmd/bitrot-whole.go

    	tillOffset int64           // Affects the length of data requested in disk.ReadFile depending on Read()'s offset
    	buf        []byte          // Holds bit-rot verified data
    }
    
    func (b *wholeBitrotReader) ReadAt(buf []byte, offset int64) (n int, err error) {
    	if b.buf == nil {
    		b.buf = make([]byte, b.tillOffset-offset)
    		if _, err := b.disk.ReadFile(context.TODO(), b.volume, b.filePath, offset, b.buf, b.verifier); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  3. 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)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  4. internal/s3select/json/reader_test.go

    	}
    }
    
    func BenchmarkReader(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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 2.5K bytes
    - Viewed (0)
  5. docs/debugging/reorder-disks/main.go

    				result = append(result, localDisk{index: index, path: u.Path})
    			}
    		}
    	}
    
    	return result, nil
    }
    
    func getFormatJSON(path string) (format, error) {
    	formatJSON, err := os.ReadFile(filepath.Join(path, ".minio.sys/format.json"))
    	if err != nil {
    		return format{}, err
    	}
    	var f format
    	err = json.Unmarshal(formatJSON, &f)
    	if err != nil {
    		return format{}, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    	filled := make([]byte, size)
    	parityData := make(map[int]map[int][]byte)
    	fmt.Printf("Attempting to combine version %q.\n", out)
    	for _, file := range files {
    		b, err := os.ReadFile(file)
    		if err != nil {
    			return err
    		}
    		meta, err := os.ReadFile(file + ".json")
    		if err != nil {
    			return err
    		}
    		type erasureInfo struct {
    			V2Obj *struct {
    				EcDist  []int
    				EcIndex int
    				EcM     int
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  7. cmd/xl-storage-disk-id-check.go

    		return nil, err
    	}
    	defer done(&err)
    
    	return p.storage.ListDir(ctx, origvolume, volume, dirPath, count)
    }
    
    // Legacy API - does not have any deadlines
    func (p *xlStorageDiskIDCheck) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadFile, volume, path)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  9. docs/debugging/hash-set/main.go

    	}
    
    	if setCount == 0 {
    		log.Fatalln("set count cannot be zero")
    	}
    
    	id := uuid.MustParse(deploymentID)
    
    	if file != "" {
    		distrib := make([][]string, setCount)
    		b, err := os.ReadFile(file)
    		if err != nil {
    			log.Fatalln(err)
    		}
    		b = bytes.ReplaceAll(b, []byte("\r"), []byte{})
    		sc := bufio.NewScanner(bytes.NewBuffer(b))
    		for sc.Scan() {
    			object = strings.TrimSpace(sc.Text())
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.7K bytes
    - Viewed (0)
  10. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top