// will try time.RFC3339Nano when parse http.TimeFormat failed
func ParseReplicationTS(str string) (time.Time, error) {
	tm, err := time.Parse(http.TimeFormat, str)
	if tm.IsZero() || err != nil {
		tm, err = time.Parse(time.RFC3339Nano, str)
	}
	return tm, err

		}

		// Replicate bucket policy if present.
		policyJSON, tm := meta.PolicyConfigJSON, meta.PolicyConfigUpdatedAt
		if len(policyJSON) > 0 {
			err = c.BucketMetaHook(ctx, madmin.SRBucketMeta{
				Type:      madmin.SRBucketMetaTypePolicy,
				Bucket:    bucket,
				Policy:    policyJSON,
				UpdatedAt: tm,
			})
			if err != nil {
				return errSRBucketMetaError(err)
			}
		}

	return m
}

func (m *Monitor) updateMeasurement(opts BucketOptions, bytes uint64) {
	m.mlock.Lock()
	defer m.mlock.Unlock()

	tm, ok := m.bucketsMeasurement[opts]
	if !ok {
		tm = &bucketMeasurement{}
	}
	tm.incrementBytes(bytes)
	m.bucketsMeasurement[opts] = tm
}

// SelectionFunction for buckets
type SelectionFunction func(bucket string) bool

// SelectBuckets will select all the buckets passed in.

			tm, err := time.Parse(time.RFC3339Nano, string(val))
			if err == nil {
				j.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+ReplicationTimestamp] = []byte(tm.UTC().Format(time.RFC3339Nano))
			}
		}
		if val, ok := j.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+ReplicaTimestamp]; ok {
			tm, err := time.Parse(time.RFC3339Nano, string(val))
			if err == nil {

	tgtStatuses := replicationStatusesMap(oi.ReplicationStatusInternal)
	purgeStatuses := versionPurgeStatusesMap(oi.VersionPurgeStatusInternal)
	tm, _ := time.Parse(time.RFC3339Nano, oi.UserDefined[ReservedMetadataPrefixLower+ReplicationTimestamp])
	rstate := oi.ReplicationState()
	rstate.ReplicateDecisionStr = dsc.String()
	asz, _ := oi.GetActualSize()

Welcome to


      ____              __
     / __/__  ___ _____/ /__
    _\ \/ _ \/ _ `/ __/  '_/
   /___/ .__/\_,_/_/ /_/\_\   version 2.1.0.2.6.0.0-598
      /_/

Using Scala version 2.11.8 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_112)
Type in expressions to have them evaluated.
Type :help for more information.

scala>
```

	}

	tgtStatuses := replicationStatusesMap(oi.ReplicationStatusInternal)
	purgeStatuses := versionPurgeStatusesMap(oi.VersionPurgeStatusInternal)
	existingObjResync := rcfg.Resync(GlobalContext, oi, dsc, tgtStatuses)
	tm, _ := time.Parse(time.RFC3339Nano, userDefined[ReservedMetadataPrefixLower+ReplicationTimestamp])
	rstate := oi.ReplicationState()
	rstate.ReplicateDecisionStr = dsc.String()
	asz, _ := oi.GetActualSize()

]evBqd ÂЫ+M¼7=òŽq\EñêAsTXKoÜæA]ing<ã>U„µŸ‡M{kXiTûn~CªDoQn¾¼}ßgd¨ãu„BpE¦?il ‰ ~[wln :ey2þå_e_sò&PyTE„Vñ7jº²)aïª1>kMV¨ßÏûTIª i~ ¢ lI÷¦r²Hgåb§,¿NsGF EÁûle7ßûz_c›oRûOxx7-w§ò4ñpªS]\K<û `{Ö 9Ng#, ;V¢y _xéæBpe >[oDŒw{Y óbD\[TÛ>Âkch.² ï^¾evÎniyqBåi`¼F_ÄqT{tm~Gª¼sñi¾˜~V|xs »•u]X–që·rywI¿ëkZai# wl{È«rKPïroJON_™}ûzew v\grm~G¬dÀ£ &ÚñÆrykAªÃ¯ 1 Õ¬tiN¾{ML^ñPBuv¢hkòAAãMEI2öΈ ¨ˆµzKph{~ñ`u¢ qò }J 1ÖW†ãTï¦xs}^²IU_ÜEJ²v Ö¢sã\T[ªve~mlñXuGpÜŒ}jFºeî· _c\]a¦’¾ uT@ã_X¼êõCÜíöÏõ çÿÅØ ùu èÏö÷ÏÃÒÛÐéÌtñæ\Egn<foûgin{ª>y`p²...