Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 42 for files (0.26 sec)

  1. cmd/erasure-common.go

    }
    
    // readMultipleFiles Reads raw data from all specified files from all disks.
    func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) {
    	resps := make([]chan ReadMultipleResp, len(disks))
    	for i := range resps {
    		resps[i] = make(chan ReadMultipleResp, len(req.Files))
    	}
    	g := errgroup.WithNErrs(len(disks))
    	// Read files in parallel across disks.
    	for index := range disks {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  2. internal/s3select/json/reader_test.go

    			}
    			if err != io.EOF {
    				t.Fatalf("Reading failed with %s, %s", err, file.Name())
    			}
    		})
    	}
    }
    
    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)
    			}
    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)
  3. internal/disk/stat_netbsd.go

    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail)
    	info = Info{
    		Total:  uint64(s.Frsize) * (uint64(s.Blocks) - reservedBlocks),
    		Free:   uint64(s.Frsize) * uint64(s.Bavail),
    		Files:  uint64(s.Files),
    		Ffree:  uint64(s.Ffree),
    		FSType: string(s.Fstypename[:]),
    	}
    	if info.Free > info.Total {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  4. internal/disk/stat_openbsd.go

    	}
    	reservedBlocks := uint64(s.F_bfree) - uint64(s.F_bavail)
    	info = Info{
    		Total:  uint64(s.F_bsize) * (uint64(s.F_blocks) - reservedBlocks),
    		Free:   uint64(s.F_bsize) * uint64(s.F_bavail),
    		Files:  uint64(s.F_files),
    		Ffree:  uint64(s.F_ffree),
    		FSType: getFSType(s.F_fstypename[:]),
    	}
    	if info.Free > info.Total {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  5. cmd/storage-errors.go

    // errFileNotFound - cannot find the file.
    var errFileNotFound = StorageErr("file not found")
    
    // errFileNotFound - cannot find requested file version.
    var errFileVersionNotFound = StorageErr("file version not found")
    
    // errTooManyOpenFiles - too many open files.
    var errTooManyOpenFiles = StorageErr("too many open files, please increase 'ulimit -n'")
    
    // errFileNameTooLong - given file name is too long than supported length.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  6. internal/disk/stat_linux.go

    		iostats.DiscardTicks = stats[14]
    	}
    	return
    }
    
    func readStat(fileName string) (stats []uint64, err error) {
    	file, err := os.Open(fileName)
    	if err != nil {
    		return nil, err
    	}
    	defer file.Close()
    
    	s, err := bufio.NewReader(file).ReadString('\n')
    	if err != nil && !errors.Is(err, io.EOF) {
    		return nil, err
    	}
    	statLine := strings.TrimSpace(s)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  7. cmd/untar.go

    		header, err := tarReader.Next()
    		switch {
    
    		// if no more files are found return
    		case err == io.EOF:
    			wg.Wait()
    			return asyncErr
    
    		// return any other error
    		case err != nil:
    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    			return fmt.Errorf("tar file error: %w%s", err, extra)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  8. internal/disk/stat_bsd.go

    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    		Total:  uint64(s.Bsize) * (s.Blocks - reservedBlocks),
    		Free:   uint64(s.Bsize) * s.Bavail,
    		Files:  s.Files,
    		Ffree:  s.Ffree,
    		FSType: getFSType(s.Fstypename[:]),
    	}
    	if info.Free > info.Total {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  9. docs/debugging/hash-set/main.go

    	for i := 1; i <= cardinality; i++ {
    		nums[i-1] = 1 + ((start + i) % cardinality)
    	}
    	return nums
    }
    
    var (
    	file, object, deploymentID, prefix string
    	setCount, shards                   int
    	verbose                            bool
    )
    
    func main() {
    	flag.StringVar(&file, "file", "", "Read all objects from file, newline separated")
    	flag.StringVar(&prefix, "prefix", "", "Add prefix to all objects")
    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. internal/config/constants.go

    	EnvRootUser     = "MINIO_ROOT_USER"
    	EnvRootPassword = "MINIO_ROOT_PASSWORD"
    
    	// Legacy files
    	EnvAccessKeyFile = "MINIO_ACCESS_KEY_FILE"
    	EnvSecretKeyFile = "MINIO_SECRET_KEY_FILE"
    
    	// Current files
    	EnvRootUserFile     = "MINIO_ROOT_USER_FILE"
    	EnvRootPasswordFile = "MINIO_ROOT_PASSWORD_FILE"
    
    	// Set all config environment variables from 'config.env'
    	// if necessary. Overrides all previous settings and also
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jan 01 16:36:33 GMT 2024
    - 3.4K bytes
    - Viewed (3)
Back to top