tr := NewReader(&buf)

	entries, err := fsys.ReadDir(".")
	if err != nil {
		t.Fatal(err)
	}

	var curfname string
	for _, entry := range entries {
		curfname = entry.Name()
		if entry.IsDir() {
			curfname += "/"
			continue
		}
		hdr, err := tr.Next()
		if err == io.EOF {
			break // End of archive
		}
		if err != nil {
			t.Fatal(err)

func (c *SiteReplicationSys) PeerJoinReq(ctx context.Context, arg madmin.SRPeerJoinReq) error {
	var ourName string
	for d, p := range arg.Peers {
		if d == globalDeploymentID() {
			ourName = p.Name
			break
		}
	}
	if ourName == "" {
		return errSRSelfNotFound
	}

	sa, _, err := globalIAMSys.GetServiceAccount(ctx, arg.SvcAcctAccessKey)