- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 3,232 for ctan (0.18 sec)
-
android/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();
- }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Aug 04 01:39:13 UTC 2022 - 1.3K bytes - Viewed (0) -
internal/store/batch.go
- var ErrBatchFull = errors.New("batch is full")
- const defaultCommitTimeout = 30 * time.Second
- // Batch represents an ordered batch
- type Batch[I any] struct {
- items []I
- limit uint32
- store Store[I]
- quitCh chan struct{}
- sync.Mutex
- }
- // BatchConfig represents the batch config
- type BatchConfig[I any] struct {
- Limit uint32
- Store Store[I]
- CommitTimeout time.Duration
- Log logger
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/s3select/json/preader.go
- input chan *queueItem // input for workers
- queue chan *queueItem // output from workers in order
- err error // global error state, only touched by Reader.Read
- bufferPool sync.Pool // pool of []byte objects for input
- kvDstPool sync.Pool // pool of []jstream.KV used for output
- close chan struct{} // used for shutting down the splitter before end of stream
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K 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 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/s3select/csv/reader.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/bpool/bpool.go
- package bpool
- import (
- "github.com/klauspost/reedsolomon"
- )
- // BytePoolCap implements a leaky pool of []byte in the form of a bounded channel.
- type BytePoolCap struct {
- c chan []byte
- w int
- wcap int
- }
- // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new
- // byte arrays sized based on width.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 3K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
- // Use buffered channel to take care of burst sends or slow w.Write()
- mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
- localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
- // Convert local messages to JSON and send to mergeCh
- go func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
cmd/untar.go
- case formatLZ4:
- r = lz4.NewReader(bf)
- case formatUnknown:
- r = bf
- default:
- return fmt.Errorf("Unsupported format %s", f)
- }
- tarReader := tar.NewReader(r)
- n := 0
- asyncWriters := make(chan struct{}, 16)
- var wg sync.WaitGroup
- var asyncErr error
- var asyncErrMu sync.Mutex
- for {
- if !o.ignoreErrs {
- asyncErrMu.Lock()
- err := asyncErr
- asyncErrMu.Unlock()
- if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 6K bytes - Viewed (2) -
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 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
internal/dsync/dsync_test.go
- // Borrowed from mutex_test.go
- func HammerMutex(m *DRWMutex, loops int, cdone chan bool) {
- for i := 0; i < loops; i++ {
- m.Lock(id, source)
- m.Unlock(context.Background())
- }
- cdone <- true
- }
- // Borrowed from mutex_test.go
- func TestMutex(t *testing.T) {
- loops := 200
- if testing.Short() {
- loops = 5
- }
- c := make(chan bool)
- m := NewDRWMutex(ds, "test")
- for i := 0; i < 10; i++ {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:35:19 UTC 2024 - 11.1K bytes - Viewed (0)