Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 143 for Ustat (0.05 sec)

  1. cmd/xl-storage-format-v1.go

    type xlMetaV1Object struct {
    	Version string   `json:"version"` // Version of the current `xl.meta`.
    	Format  string   `json:"format"`  // Format of the current `xl.meta`.
    	Stat    StatInfo `json:"stat"`    // Stat of the current object `xl.meta`.
    	// Erasure coded info for the current object `xl.meta`.
    	Erasure ErasureInfo `json:"erasure"`
    	// MinIO release tag for current object `xl.meta`.
    	Minio struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	if err != nil {
    		return stat, toStorageErr(err)
    	}
    	rd := msgpNewReader(respReader)
    	defer readMsgpReaderPoolPut(rd)
    
    	for {
    		var st StatInfo
    		err = st.DecodeMsg(rd)
    		if err != nil {
    			if errors.Is(err, io.EOF) {
    				err = nil
    			}
    			break
    		}
    
    		stat = append(stat, st)
    	}
    
    	return stat, toStorageErr(err)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. cmd/ftp-server-driver.go

    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(ftpTrace(s, startTime, source, strings.Join(paths, " "), err, sz))
    	}
    }
    
    // Stat implements ftpDriver
    func (driver *ftpDriver) Stat(ctx *ftp.Context, objPath string) (fi os.FileInfo, err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    	if objPath == SlashSeparator {
    		return &minioFileInfo{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  4. internal/disk/disk_unix.go

    func SameDisk(disk1, disk2 string) (bool, error) {
    	st1 := syscall.Stat_t{}
    	st2 := syscall.Stat_t{}
    
    	if err := syscall.Stat(disk1, &st1); err != nil {
    		return false, err
    	}
    
    	if err := syscall.Stat(disk2, &st2); err != nil {
    		return false, err
    	}
    
    	return st1.Dev == st2.Dev, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 1.2K bytes
    - Viewed (0)
  5. internal/config/lambda/event/targetlist.go

    import (
    	"fmt"
    	"net/http"
    	"strings"
    	"sync"
    )
    
    // Target - lambda target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Send(Event) (*http.Response, error)
    	Stat() TargetStat
    	Close() error
    }
    
    // TargetStats is a collection of stats for multiple targets.
    type TargetStats struct {
    	TargetStats map[string]TargetStat
    }
    
    // TargetStat is the stats of a single target.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  6. internal/kms/kms.go

    	stat := make(map[string]madmin.ItemState, len(c.endpoints))
    	resp, err := c.client.Version(ctx, &kms.VersionRequest{})
    
    	for _, r := range resp {
    		stat[r.Host] = madmin.ItemOnline
    	}
    	for _, e := range kms.UnwrapHostErrors(err) {
    		stat[e.Host] = madmin.ItemOffline
    	}
    	return stat, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    					Value:          stat.Failed.LastMinute.Count,
    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    					Description:    getRepFailedBytesLastHourMD(clusterMetricNamespace),
    					Value:          float64(stat.Failed.LastHour.Bytes),
    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  8. docs/bucket/replication/test_del_marker_proxying.sh

    	if [ $loop_count -eq 1000 ]; then
    		break
    	fi
    	echo "Hello World" | ./mc pipe sitea/bucket/obj$loop_count
    	./mc rm sitea/bucket/obj$loop_count
    	RESULT=$({ ./mc stat --no-list sitea/bucket/obj$loop_count; } 2>&1)
    	if [[ ${RESULT} != *"Object does not exist"* ]]; then
    		echo "BUG: stat should fail. succeeded."
    		exit_1
    	fi
    	loop_count=$((loop_count + 1))
    done
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. buildscripts/resolve-right-versions.sh

    	pid=$!
    	disown $pid
    	sleep 5
    
    	if ! ps -p ${pid} 1>&2 >/dev/null; then
    		echo "server1 log:"
    		cat "${WORK_DIR}/server1.log"
    		echo "FAILED"
    		purge "$WORK_DIR"
    		exit 1
    	fi
    
    	"${WORK_DIR}/mc" stat minio/bucket/testobj
    
    	pkill minio
    	sleep 3
    }
    
    function main() {
    	start_port=$(shuf -i 10000-65000 -n 1)
    
    	start_minio_5drive ${start_port}
    }
    
    function purge() {
    	rm -rf "$1"
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 16 14:51:33 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  10. internal/mountinfo/mountinfo_linux.go

    )
    
    // IsLikelyMountPoint determines if a directory is a mountpoint.
    func IsLikelyMountPoint(path string) bool {
    	s1, err := os.Lstat(path)
    	if err != nil {
    		return false
    	}
    
    	// A symlink can never be a mount point
    	if s1.Mode()&os.ModeSymlink != 0 {
    		return false
    	}
    
    	s2, err := os.Lstat(filepath.Dir(strings.TrimSuffix(path, "/")))
    	if err != nil {
    		return false
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.7K bytes
    - Viewed (0)
Back to top