Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for isOffline (0.04 sec)

  1. cmd/bucket-targets.go

    	lastOnline      time.Time
    	lastHCAt        time.Time
    	offlineDuration time.Duration
    	latency         latencyStat
    }
    
    // isOffline returns current liveness result of remote target. Add endpoint to
    // healthCheck map if missing and default to online status
    func (sys *BucketTargetSys) isOffline(ep *url.URL) bool {
    	sys.hMutex.RLock()
    	defer sys.hMutex.RUnlock()
    	if h, ok := sys.hc[ep.Host]; ok {
    		return !h.Online
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    		rinfo.ReplicationStatus = rinfo.PrevReplicationStatus
    		return
    	}
    	if dobj.VersionID != "" && rinfo.VersionPurgeStatus == replication.VersionPurgeComplete {
    		return
    	}
    	if globalBucketTargetSys.isOffline(tgt.EndpointURL()) {
    		replLogOnceIf(ctx, fmt.Errorf("remote target is offline for bucket:%s arn:%s", dobj.Bucket, tgt.ARN), "replication-target-offline-delete-"+tgt.ARN)
    		sendEvent(eventArgs{
    			BucketName: dobj.Bucket,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    		errMap[depID] = errs[i]
    		if errs[i] != nil && minio.IsNetworkOrHostDown(errs[i], true) {
    			ep := c.state.Peers[depID].Endpoint
    			epURL, _ := url.Parse(ep)
    			if !globalBucketTargetSys.isOffline(epURL) {
    				globalBucketTargetSys.markOffline(epURL)
    			}
    		}
    	}
    	return c.newConcErr(errMap, actionName)
    }
    
    func (c *SiteReplicationSys) annotateErr(annotation string, err error) error {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
Back to top