Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for files (0.13 sec)

  1. docs/debugging/xl-meta/main.go

    		}
    		if len(files) > 1 || strings.HasSuffix(files[0], ".zip") {
    			ndjson = true
    		}
    
    		toPrint := make([]string, 0, 16)
    		for _, file := range files {
    			var r io.Reader
    			var sz int64
    			switch file {
    			case "-":
    				r = os.Stdin
    			default:
    				f, err := os.Open(file)
    				if err != nil {
    					return err
    				}
    				if st, err := f.Stat(); err == nil {
    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)
  2. cmd/storage-datatypes.go

    	}
    	return fi
    }
    
    // ReadMultipleReq contains information of multiple files to read from disk.
    type ReadMultipleReq struct {
    	Bucket       string   // Bucket. Can be empty if multiple buckets.
    	Prefix       string   // Shared prefix of all files. Can be empty. Will be joined to filename without modification.
    	Files        []string // Individual files to read.
    	MaxSize      int64    // Return error if size is exceed.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  3. cmd/erasure-metadata.go

    	g := errgroup.WithNErrs(len(disks))
    
    	// Start writing `xl.meta` to all disks in parallel.
    	for index := range disks {
    		index := index
    		g.Go(func() error {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			// Pick one FileInfo for a disk at index.
    			fi := files[index]
    			fi.Erasure.Index = index + 1
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  4. cmd/common-main.go

    	}
    	defer root.Close()
    
    	files, err := root.Readdir(-1)
    	if err != nil {
    		return nil, nil, false, err
    	}
    	for _, file := range files {
    		// Ignore all
    		// - regular files
    		// - "CAs" directory
    		// - any directory which starts with ".."
    		if file.Mode().IsRegular() || file.Name() == "CAs" || strings.HasPrefix(file.Name(), "..") {
    			continue
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  5. cmd/storage-rest-client.go

    	}()
    	mr := msgp.NewReader(pr)
    	defer readMsgpReaderPoolPut(mr)
    	for {
    		var file ReadMultipleResp
    		if err := file.DecodeMsg(mr); err != nil {
    			if errors.Is(err, io.EOF) {
    				err = nil
    			}
    			pr.CloseWithError(err)
    			return toStorageErr(err)
    		}
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		case resp <- file:
    		}
    	}
    }
    
    // CleanAbandonedData will read metadata of the object on disk
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	if err != nil {
    		return nil, err
    	}
    	defer done(&err)
    
    	return p.storage.StatInfoFile(ctx, volume, path, glob)
    }
    
    // ReadMultiple will read multiple files and send each files as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context will return an error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  7. cmd/update.go

    // IsDocker - returns if the environment minio is running in docker or
    // not. The check is a simple file existence check.
    //
    // https://github.com/moby/moby/blob/master/daemon/initlayer/setup_unix.go
    // https://github.com/containers/podman/blob/master/libpod/runtime.go
    //
    //	"/.dockerenv":        "file",
    //	"/run/.containerenv": "file",
    func IsDocker() bool {
    	var err error
    	for _, envfile := range []string{
    		"/.dockerenv",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    	done(err)
    	if err != nil {
    		return
    	}
    	for _, si := range stats {
    		msgp.Encode(w, &si)
    	}
    }
    
    // ReadMultiple returns multiple files
    func (s *storageRESTServer) ReadMultiple(w http.ResponseWriter, r *http.Request) {
    	if !s.IsValid(w, r) {
    		return
    	}
    	rw := streamHTTPResponse(w)
    	defer func() {
    		if r := recover(); r != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  9. cmd/sftp-server-driver.go

    		return nil, err
    	}
    
    	switch r.Method {
    	case "List":
    		var files []os.FileInfo
    
    		bucket, prefix := path2BucketObject(r.Filepath)
    		if bucket == "" {
    			buckets, err := clnt.ListBuckets(r.Context())
    			if err != nil {
    				return nil, err
    			}
    
    			for _, bucket := range buckets {
    				files = append(files, &minioFileInfo{
    					p:     bucket.Name,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  10. cmd/erasure-multipart.go

    			continue
    		}
    
    		break
    	}
    
    	g := errgroup.WithNErrs(len(req.Files)).WithConcurrency(32)
    
    	partsInfo := make([]ObjectPartInfo, len(req.Files))
    	for i, file := range req.Files {
    		file := file
    		partN := i + start
    		i := i
    
    		g.Go(func() error {
    			buf, err := disk.ReadAll(ctx, minioMetaMultipartBucket, pathJoin(partPath, file))
    			if err != nil {
    				return err
    			}
    
    			var pfi FileInfo
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
Back to top