Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getPeerForUpload (0.06 sec)

  1. cmd/generic-handlers.go

    		if bucket != "" && object != "" && uploadID != "" {
    			deplID, err := getDeplIDFromUpload(uploadID)
    			if err != nil {
    				h.ServeHTTP(w, r)
    				return
    			}
    			remote, self := globalSiteReplicationSys.getPeerForUpload(deplID)
    			if self {
    				h.ServeHTTP(w, r)
    				return
    			}
    			r.URL.Scheme = remote.EndpointURL.Scheme
    			r.URL.Host = remote.EndpointURL.Host
    			// Make sure we remove any existing headers before
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  2. cmd/site-replication.go

    }
    
    type srPeerInfo struct {
    	madmin.PeerInfo
    	EndpointURL *url.URL
    }
    
    // getPeerForUpload returns the site replication peer handling this upload. Defaults to local cluster otherwise
    func (c *SiteReplicationSys) getPeerForUpload(deplID string) (pi srPeerInfo, local bool) {
    	ci, _ := c.GetClusterInfo(GlobalContext)
    	if !ci.Enabled {
    		return pi, true
    	}
    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