"format": "time_series",
          "interval": "",
          "intervalFactor": 2,
          "legendFormat": "Internode Bytes Received [{{server}}]",
          "metric": "minio_http_requests_duration_seconds_count",
          "range": true,
          "refId": "A",
          "step": 4
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"

™xÍ«ù*k­ÈN «£ùn´X*g?NÞ gÆÈà«C \:B¯ C ù€z‡âO¤`~f KùüÒò‹l]¦ð5 „$ » ŒÕðA E ï ¢wô”L8aÜ t‰ŸŽÁ*¥Ð~ K›½púÑ |ÍVp¢ãUuç‡'lÝ£Ä(æ4Ç ° REø¼£xjá UÀ¼œ:… Ûš ˆOì}h?™ŽÜÐ¥é× ©R ’-ê É!U³ ©°X††¡.©ŒÐkŒ9†PÍB2 Ðn >²ú¬bæmHœ@¿oÏ « !ì X3=ÀÓºˆ. Ô‰ c3> ‹È~ ‹Pô ¯Ö¯tã >pZë˜{,5eä²x»2oUT®Ìô~ág™ Ú³sÜÉ×Þ³ñ6…q f‘Å &%øŒ ët™Ú)©ÄÌ wœ d”Ö(5êìázyBtí ’aYS±×jX_óÊM[&`®üÊÄécdÝ Ûà<”†¾— ±8”! ¿gVÙ· $0ƒÔ ©ÝW F[£C 7U#!z YñMƒå=y„ @*Ç ¢Ÿ× "êðÍÜ oÏÿâø/ ‰Á ¤Á{è ‘$aÃÕµO{1 ¨Û®5æ7J(hÔ ´JŽ„DŒÏ»_¦›&HÒþƒZ7Èk| § énaÁ™ È,µÕkø ŒV×# ̬U OÔW~ QãËàYwã ó °æ{P s%Ö|o=0{...

	Key      []byte
	KmsCtx   kms.Context
	Checksum *hash.Checksum
	MD5Hex   string
}

// fanOutPutObject takes an input source reader and fans out multiple PUT operations
// based on the incoming fan-out request, a context cancellation by the caller
// would ensure all fan-out operations are canceled.

sitea_out=$(cat /tmp/sitea_dirs.txt)
siteb_out=$(cat /tmp/siteb_dirs.txt)

if [ $sitea_count -ne 0 ]; then
	echo "BUG: expected no 'directory objects' left after deletion: ${sitea_out}"
	exit 1
fi

if [ $siteb_count -ne 0 ]; then
	echo "BUG: expected no 'directory objects' left after deletion: ${siteb_out}"
	exit 1
fi

	for _, format := range formats {
		if format == nil {
			continue
		}
		formatCountMap[format.Drives()]++
	}

	maxDrives := 0
	maxCount := 0
	for drives, count := range formatCountMap {
		if count > maxCount {
			maxCount = count
			maxDrives = drives
		}
	}

	if maxDrives == 0 {
		return nil, errErasureReadQuorum
	}

	if maxCount < len(formats)/2 {
		return nil, errErasureReadQuorum

import "context"

const (
	healthDrivesOfflineCount = "drives_offline_count"
	healthDrivesOnlineCount  = "drives_online_count"
	healthDrivesCount        = "drives_count"
)

var (
	healthDrivesOfflineCountMD = NewGaugeMD(healthDrivesOfflineCount,
		"Count of offline drives in the cluster")
	healthDrivesOnlineCountMD = NewGaugeMD(healthDrivesOnlineCount,
		"Count of online drives in the cluster")

	LastMinute  ReplicationLastMinute
	// Error counts
	ErrCounts map[string]int `json:"errCounts"` // Count of credential errors
}

func (rt *RTimedMetrics) String() string {
	s := rt.toMetric()
	return fmt.Sprintf("Errors in LastMinute: %v, LastHour: %v, SinceUptime: %v", s.LastMinute.Count, s.LastHour.Count, s.Totals.Count)
}

func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats {
	if rt == nil {

func (s *storageRESTServer) ListDirHandler(ctx context.Context, params *grid.MSS, out chan<- *ListDirResult) *grid.RemoteErr {
	if !s.checkID(params.Get(storageRESTDiskID)) {
		return grid.NewRemoteErr(errDiskNotFound)
	}
	volume := params.Get(storageRESTVolume)
	dirPath := params.Get(storageRESTDirPath)
	origvolume := params.Get(storageRESTOrigVolume)
	count, err := strconv.Atoi(params.Get(storageRESTCount))
	if err != nil {

	flag.IntVar(&setCount, "set-count", 0, "Total set count")
	flag.IntVar(&shards, "shards", 0, "Total shards count")
	flag.BoolVar(&verbose, "v", false, "Display all objects")

	flag.Parse()

	if deploymentID == "" {
		log.Fatalln("deployment ID is mandatory")
	}

	if setCount == 0 {
		log.Fatalln("set count cannot be zero")
	}

	id := uuid.MustParse(deploymentID)

	nameTmp := direntNamePool.Get().(*[]byte)
	defer direntNamePool.Put(nameTmp)
	tmp := *nameTmp

	boff := 0 // starting read position in buf
	nbuf := 0 // end valid data in buf

	count := opts.count

	for count != 0 {
		if boff >= nbuf {
			boff = 0
			stop := globalOSMetrics.time(osMetricReadDirent)
			nbuf, err = syscall.ReadDirent(fd, buf)
			stop()
			if err != nil {
				if isSysErrNotDir(err) {