Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for wait (0.13 sec)

  1. cmd/bucket-replication.go

    			defer wg.Done()
    			tgtInfo := replicateDeleteToTarget(ctx, dobj, tgt)
    
    			mu.Lock()
    			rinfos.Targets = append(rinfos.Targets, tgtInfo)
    			mu.Unlock()
    		}(tgtClnt)
    	}
    	wg.Wait()
    
    	replicationStatus = rinfos.ReplicationStatus()
    	prevStatus := dobj.DeleteMarkerReplicationStatus()
    
    	if dobj.VersionID != "" {
    		prevStatus = replication.StatusType(dobj.VersionPurgeStatus())
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  2. cmd/site-replication.go

    				nil,
    			)
    			resultsMu.Lock()
    			results.NodeResults = append(results.NodeResults, result)
    			resultsMu.Unlock()
    			return
    		}()
    	}
    	wg.Wait()
    	return
    }
    
    // GetClusterInfo - returns site replication information.
    func (c *SiteReplicationSys) GetClusterInfo(ctx context.Context) (info madmin.SiteReplicationInfo, err error) {
    	c.RLock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
Back to top