Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 79 for much (0.13 sec)

  1. cmd/namespace-lock_test.go

    		// Unlock the 1st lock; ref=1 after this line
    		nsLk.unlock("volume", "path", false)
    
    		// Taking another lockMapMutex here allows queuing up additional lockers. This should
    		// not be required but makes reproduction much easier.
    		nsLk.lockMapMutex.Lock()
    
    		// lk3 blocks.
    		lk3ch := make(chan bool)
    		go func() {
    			lk3ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0)
    		}()
    
    		// lk4, blocks.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 3.1K bytes
    - Viewed (0)
  2. internal/config/cache/cache.go

    	if c.Endpoint == "" {
    		// Endpoint not set, make this a no-op
    		return nil, nil
    	}
    
    	buf, err := r.MarshalMsg(nil)
    	if err != nil {
    		return nil, err
    	}
    
    	// We do not want Gets to take so much time, anything
    	// beyond 250ms we should cut it, remote cache is too
    	// busy already.
    	ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond)
    	defer cancel()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader.go

    		}
    	}
    	// Read until next line.
    	in, err := r.buf.ReadBytes('\n')
    	dst = append(dst, in...)
    	return dst, err
    }
    
    // csvSplitSize is the size of each block.
    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  4. cmd/signature-v4-utils.go

    		// some broken clients set empty-sha256
    		// with > 0 content-length in the body,
    		// we should skip such clients and allow
    		// blindly such insecure clients only if
    		// S3 strict compatibility is disabled.
    
    		// We return true only in situations when
    		// deployment has asked MinIO to allow for
    		// such broken clients and content-length > 0.
    		return r.ContentLength > 0 && !globalServerCtxt.StrictS3Compat
    	}
    	return false
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  5. docs/throttle/README.md

    If you have traditional spinning (hdd) drives, some applications with high concurrency might require MinIO cluster to be tuned such that to avoid random I/O on the drives. The way to convert high concurrent I/O into a sequential I/O is by reducing the number of concurrent operations allowed per cluster. This allows MinIO cluster to be operationally resilient to such workloads, while also making sure the drives are at optimal efficiency and responsive.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  6. docs/hotfixes.md

        heal legacy objects when versioning is enabled after upgrade (#13671)
    ```
    
    - A security fix must be backported if a customer is affected by it, we have a mechanism in SUBNET to send out notifications to affected customers in such situations, this is a mandatory requirement.
    
    ```
    commit 99bf4d0c429f04dbd013ba98840d07b759ae1702 (tag: RELEASE.2019-06-15T23-07-18Z)
    Author: Harshavardhana <******@****.***>
    Date:   Sat Jun 15 11:27:17 2019 -0700
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  7. cmd/is-dir-empty_linux.go

    package cmd
    
    import (
    	"syscall"
    )
    
    // Returns true if no error and there is no object or prefix inside this directory
    func isDirEmpty(dirname string, legacy bool) bool {
    	if legacy {
    		// On filesystems such as btrfs, nfs this is not true, so fallback
    		// to performing readdir() instead.
    		entries, err := readDirN(dirname, 1)
    		if err != nil {
    			return false
    		}
    		return len(entries) == 0
    	}
    	var stat syscall.Stat_t
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 15:17:08 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  8. internal/lock/lock_nix.go

    		}
    	}
    
    	return &LockedFile{File: f}, nil
    }
    
    // TryLockedOpenFile - tries a new write lock, functionality
    // it is similar to LockedOpenFile with with syscall.LOCK_EX
    // mode but along with syscall.LOCK_NB such that the function
    // doesn't wait forever but instead returns if it cannot
    // acquire a write lock.
    func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 2.8K bytes
    - Viewed (0)
  9. internal/disk/stat_linux.go

    	info.Major = unix.Major(devID)
    	info.Minor = unix.Minor(devID)
    
    	// Check for overflows.
    	// https://github.com/minio/minio/issues/8035
    	// XFS can show wrong values at times error out
    	// in such scenarios.
    	if info.Free > info.Total {
    		return info, fmt.Errorf("detected free space (%d) > total drive space (%d), fs corruption at (%s). please run 'fsck'", info.Free, info.Total, path)
    	}
    	info.Used = info.Total - info.Free
    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)
  10. internal/mountinfo/mountinfo_linux.go

    	}
    	var crossMounts mountInfos
    	for _, mount := range mts {
    		// Add a separator to indicate that this is a proper mount-point.
    		// This is to avoid a situation where prefix is '/tmp/fsmount'
    		// and mount path is /tmp/fs. In such a scenario we need to check for
    		// `/tmp/fs/` to be a common prefix amount other mounts.
    		mpath := strings.TrimSuffix(mount.Path, "/") + "/"
    		ppath := strings.TrimSuffix(path, "/") + "/"
    		if strings.HasPrefix(mpath, ppath) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.7K bytes
    - Viewed (0)
Back to top