Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 132 for inro (0.14 sec)

  1. cmd/data-usage_test.go

    	}
    	t.Log("serialized size:", buf.Len(), "bytes")
    	var got dataUsageCache
    	err = got.deserialize(&buf)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if got.Info.LastUpdate.IsZero() {
    		t.Error("lastupdate not set")
    	}
    
    	if !want.Info.LastUpdate.Equal(got.Info.LastUpdate) {
    		t.Fatalf("deserialize LastUpdate mismatch\nwant: %+v\ngot:  %+v", want, got)
    	}
    	if len(want.Cache) != len(got.Cache) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		storageLogOnceIf(ctx, err, "get-object-file-info-manually-modified")
    		return fi, nil, nil, toObjectErr(err, bucket, object, opts.VersionID)
    	}
    
    	filterOnlineDisksInplace(fi, onlineMeta, onlineDisks)
    	for i := range onlineMeta {
    		// verify metadata is valid, it has similar erasure info
    		// as well as common modtime, if modtime is not possible
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. cmd/iam.go

    				continue
    			}
    
    			ldapUsername, ok := jwtClaims.Lookup(ldapUserN)
    			if !ok {
    				// skip this cred - we dont have the
    				// username info needed
    				continue
    			}
    
    			// Collect each new cred.ParentUser into parentUsers
    			parentUsers = append(parentUsers, cred.ParentUser)
    
    			// Update the ldapUsernameMap
    			parentUserToLDAPUsernameMap[cred.ParentUser] = ldapUsername
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  4. cmd/xl-storage-disk-id-check.go

    		info.Metrics.TotalErrorsTimeout = p.totalErrsTimeout.Load()
    		info.Metrics.TotalErrorsAvailability = p.totalErrsAvailability.Load()
    		if p.health.isFaulty() {
    			// if disk is already faulty return faulty for 'mc admin info' output and prometheus alerts.
    			return info, errFaultyDisk
    		}
    		return info, nil
    	}
    
    	defer func() {
    		if opts.Metrics {
    			info.Metrics = p.getMetrics()
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. cmd/data-usage-cache_gen.go

    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "Info":
    			err = z.Info.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Info")
    				return
    			}
    		case "Cache":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Cache")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 100.8K bytes
    - Viewed (0)
  6. cmd/signals.go

    			exit(stopProcess())
    		case osSignal := <-globalOSSignalCh:
    			logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String()))
    			daemon.SdNotify(false, daemon.SdNotifyStopping)
    			exit(stopProcess())
    		case signal := <-globalServiceSignalCh:
    			switch signal {
    			case serviceRestart:
    				logger.Info("Restarting on service signal")
    				daemon.SdNotify(false, daemon.SdNotifyReloading)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  7. internal/logger/console.go

    }
    
    // Error :
    func Error(msg string, data ...interface{}) {
    	if DisableErrorLog {
    		return
    	}
    	consoleLog(errorm, msg, data...)
    }
    
    // Info :
    func Info(msg string, data ...interface{}) {
    	if DisableErrorLog {
    		return
    	}
    	consoleLog(info, msg, data...)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-rebalance.go

    	poolStats := r.PoolStats[poolIdx]
    	if poolStats.Info.Status == rebalCompleted {
    		return true
    	}
    
    	pfi := float64(poolStats.InitFreeSpace+poolStats.Bytes) / float64(poolStats.InitCapacity)
    	// Mark pool rebalance as done if within 5% from PercentFreeGoal.
    	if diff := math.Abs(pfi - r.PercentFreeGoal); diff <= 0.05 {
    		r.PoolStats[poolIdx].Info.Status = rebalCompleted
    		r.PoolStats[poolIdx].Info.EndTime = time.Now()
    		return true
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  9. cmd/globals.go

    	globalTCPOptions        xhttp.TCPOptions
    	globalHTTPServerErrorCh = make(chan error)
    	globalOSSignalCh        = make(chan os.Signal, 1)
    
    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    	// global Listen system to send S3 API events to registered listeners
    	globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  10. cmd/naughty-disk_test.go

    	if err := d.calcError(); err != nil {
    		return info, err
    	}
    	return d.disk.NSScanner(ctx, cache, updates, scanMode, weSleep)
    }
    
    func (d *naughtyDisk) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return info, err
    	}
    	return d.disk.DiskInfo(ctx, opts)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
Back to top