- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for CH (0.12 sec)
-
cmd/bucket-replication.go
} return } var ch, healCh chan<- ReplicationWorkerOperation switch ri.OpType { case replication.HealReplicationType, replication.ExistingObjectReplicationType: ch = p.mrfReplicaCh healCh = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size) default: ch = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size) } if ch == nil && healCh == nil { return } select {
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) -
cmd/testdata/undeleteable-object.tgz
¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ ŠªPartASizes‘Ñ Š¤SizeÑ Š¥MTimeÓ É žÕô §MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ 481841022d5df9056cb9¬content-type¸application/octet-stream¡v Φ“í ¤nullÄ4þãšh2ÙQTÑÞ´’· Ú ø@-•)kë [Šå Íp" Â¥Cache ˆ¢ch ¢sz ¢os multisitea/data/disterasure/xl5/.minio.sys/buckets/bucket/.usage-cache.bin/xl.meta XL2 Æ } Ä$•Ä Ó É ž³í Ä -˜•K Å Qƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ï/b‘ ·C¾—ÕÌx3Áà ¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Viewed (0) -
cmd/data-usage-cache.go
} // Create a clone of the entry. func (e dataUsageEntry) clone() dataUsageEntry { // We operate on a copy from the receiver. if e.Children != nil { ch := make(dataUsageHashMap, len(e.Children)) for k, v := range e.Children { ch[k] = v } e.Children = ch } if e.ReplicationStats != nil { // Clone ReplicationStats e.ReplicationStats = e.ReplicationStats.clone() } if e.AllTierStats != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
internal/grid/grid.go
// The context both allows returning errors on writes and to ensure that // this isn't abandoned if the channel is no longer being read from. func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer { return &writerWrapper{ch: ch, ctx: ctx} } // bytesOrLength returns small (<=100b) byte slices as string, otherwise length. func bytesOrLength(b []byte) string { if len(b) > 100 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/notification.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/iam-object-store.go
ch := make(chan itemOrErr) go func() { defer xioutil.SafeClose(ch) // Allocate new results channel to receive ObjectInfo. objInfoCh := make(chan ObjectInfo) if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil { select { case ch <- itemOrErr{Err: err}: case <-ctx.Done(): } return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/metrics-v3-types.go
} // Describe - implements prometheus.Collector interface. func (mg *MetricsGroup) Describe(ch chan<- *prometheus.Desc) { for _, desc := range mg.Descriptors { ch <- desc.toPromDesc(mg.CollectorPath.metricPrefix(), mg.ExtraLabels) } } // Collect - implements prometheus.Collector interface. func (mg *MetricsGroup) Collect(ch chan<- prometheus.Metric) { metricValues := newMetricValues(mg.descriptorMap) var err error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:05:22 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
vers[i], vers[j] = vers[j], vers[i] }) var entries []chan metaCacheEntry for _, v := range vers { v.cached = nil ch := make(chan metaCacheEntry, 1) ch <- v close(ch) entries = append(entries, ch) } out := make(chan metaCacheEntry, 1) err := mergeEntryChannels(context.Background(), entries, out, 1) if err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
cmd/admin-handlers.go
<-ctx.Done() globalNotificationSys.ServiceFreeze(ctx, false) }() keepAliveTicker := time.NewTicker(500 * time.Millisecond) defer keepAliveTicker.Stop() enc := json.NewEncoder(w) ch := objectSpeedTest(ctx, speedTestOpts{ objectSize: size, concurrencyStart: concurrent, duration: duration, autotune: autotune, storageClass: storageClass,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2)