- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 4,049 for cyan (0.19 sec)
-
guava-testlib/src/com/google/common/collect/testing/Platform.java
package com.google.common.collect.testing; import com.google.common.annotations.GwtCompatible; import java.util.Locale; /** * Methods factored out so that they can be emulated differently in GWT. * * <p>This class is emulated in GWT. * * @author Hayward Chan */ @GwtCompatible final class Platform { static <T> T[] clone(T[] array) { return array.clone(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Aug 04 01:39:13 GMT 2022 - 1.3K bytes - Viewed (0) -
cmd/background-heal-ops.go
opts madmin.HealOpts // Healing response will be sent here respCh chan healResult } // healResult represents a healing result with a possible error type healResult struct { result madmin.HealResultItem err error } // healRoutine receives heal tasks, to heal buckets, objects and format.json type healRoutine struct { tasks chan healTask workers int } func activeListeners() int {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/notification.go
} consolidatedReport.BucketStats[opts] = d } } return consolidatedReport } func (sys *NotificationSys) collectPeerMetrics(ctx context.Context, peerChannels []<-chan MetricV2, g *errgroup.Group) <-chan MetricV2 { ch := make(chan MetricV2) var wg sync.WaitGroup for index, err := range g.Wait() { if err != nil { if sys.peerClients[index] != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/batch-expire.go
case <-saverQuitCh: // persist in-memory state immediately to disk. batchLogIf(ctx, ri.updateAfter(ctx, api, 0, job)) return } } }() expireCh := make(chan []expireObjInfo, workerSize) expireDoneCh := make(chan struct{}) go func() { defer close(expireDoneCh) batchObjsForDelete(ctx, r, ri, job, api, wk, expireCh) }() var ( prevObj ObjectInfo
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
internal/ioutil/ioutil.go
// the function finishes executing, Run returns context.DeadlineExceeded to the caller. // channel so that the work function can attempt to exit gracefully. // Multiple calls to Run will run independently of each other. func (d *DeadlineWorker) Run(work func() error) error { c := make(chan ioret[struct{}], 1) t := time.NewTimer(d.timeout) go func() { c <- ioret[struct{}]{val: struct{}{}, err: work()} }()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
if m.GetRLock(ctx, "", "", time.Second) { clocked <- true <-cunlock m.RUnlock() cdone <- true } } // Borrowed from rwmutex_test.go func doTestParallelReaders(numReaders, gomaxprocs int) { runtime.GOMAXPROCS(gomaxprocs) m := NewLRWMutex() clocked := make(chan bool) cunlock := make(chan bool) cdone := make(chan bool)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/pubsub/pubsub.go
select { case sub.ch <- item: default: } } } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
internal/s3select/csv/reader.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/s3select/message.go
getProgressFunc func() (int64, int64) bytesReturned int64 payloadBuffer []byte payloadBufferIndex int payloadCh chan *bytes.Buffer finBytesScanned, finBytesProcessed int64 errCh chan []byte doneCh chan struct{} } func (writer *messageWriter) write(data []byte) bool { if _, err := writer.writer.Write(data); err != nil { return false }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/grid/grid.go
func getDeadline(d time.Duration) time.Duration { if d < time.Millisecond { return 0 } if d > MaxDeadline { return MaxDeadline } return d } type writerWrapper struct { ch chan<- []byte ctx context.Context } func (w *writerWrapper) Write(p []byte) (n int, err error) { buf := GetByteBufferCap(len(p)) buf = buf[:len(p)] copy(buf, p) select { case w.ch <- buf:
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0)