Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 792 for Prefer (0.14 seconds)

  1. internal/cachevalue/cache_test.go

    package cachevalue
    
    import (
    	"context"
    	"errors"
    	"testing"
    	"time"
    )
    
    func slowCaller(ctx context.Context) error {
    	sl := time.NewTimer(time.Second)
    	defer sl.Stop()
    
    	select {
    	case <-sl.C:
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    
    	return nil
    }
    
    func TestCacheCtx(t *testing.T) {
    	cache := New[time.Time]()
    	t.Parallel()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  2. cmd/update.go

    		if err != nil {
    			return nil, nil, err
    		}
    	} else {
    		return nil, nil, fmt.Errorf("unsupported protocol scheme: %s", u.Scheme)
    	}
    	defer xhttp.DrainBody(reader)
    
    	b := bytebufferpool.Get()
    	bc := bytebufferpool.Get()
    	defer func() {
    		b.Reset()
    		bc.Reset()
    
    		bytebufferpool.Put(b)
    		bytebufferpool.Put(bc)
    	}()
    
    	w, err := zstd.NewWriter(bc)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  3. internal/s3select/json/preader.go

    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    		defer r.readerWg.Done()
    		for {
    			next, err := r.nextSplit(jsonSplitSize, r.bufferPool.Get())
    			q := queueItem{
    				input: next,
    				dst:   make(chan []jstream.KVS, 1),
    				err:   err,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  4. cmd/peer-s3-client.go

    }
    
    func (client *remotePeerS3Client) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    	bi, err := listBucketsRPC.Call(ctx, client.gridConn(), &opts)
    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    	buckets := make([]BucketInfo, 0, len(bi.Value()))
    	for _, b := range bi.Value() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  5. cmd/site-replication.go

    		time.Sleep(duration)
    	}
    	c.RLock()
    	defer c.RUnlock()
    	if c.enabled {
    		logger.Info("Cluster replication initialized")
    	}
    	return nil
    }
    
    func (c *SiteReplicationSys) loadFromDisk(ctx context.Context, objAPI ObjectLayer) error {
    	buf, err := readConfig(ctx, objAPI, getSRStateFilePath())
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) {
    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  6. internal/event/target/redis.go

    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *RedisTarget) isActive() (bool, error) {
    	conn := target.pool.Get()
    	defer conn.Close()
    
    	_, pingErr := conn.Do("PING")
    	if pingErr != nil {
    		if xnet.IsConnRefusedErr(pingErr) {
    			return false, store.ErrNotConnected
    		}
    		return false, pingErr
    	}
    	return true, nil
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  7. internal/config/identity/openid/jwt.go

    			return err
    		}
    		pk.add(key.Kid, pkey)
    	}
    
    	return nil
    }
    
    func (pk *publicKeys) add(keyID string, key any) {
    	pk.Lock()
    	defer pk.Unlock()
    
    	pk.pkMap[keyID] = key
    }
    
    func (pk *publicKeys) get(kid string) any {
    	pk.RLock()
    	defer pk.RUnlock()
    	return pk.pkMap[kid]
    }
    
    // PopulatePublicKey - populates a new publickey from the JWKS URL.
    func (r *Config) PopulatePublicKey(arn arn.ARN) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool-decom_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	defer removeRoots(fsDirs)
    
    	meta := objLayer1.(*erasureServerPools).poolMeta
    	pools := objLayer1.(*erasureServerPools).serverPools
    
    	objLayer2, fsDirs, err := prepareErasurePools()
    	if err != nil {
    		t.Fatalf("Initialization of object layer failed for Erasure setup: %s", err)
    	}
    	defer removeRoots(fsDirs)
    
    	newPools := objLayer2.(*erasureServerPools).serverPools
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  9. internal/s3select/progress.go

    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    	}
    	pr.closed = true
    	if pr.closer != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 22 00:33:43 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  10. internal/ringbuffer/ring_buffer_test.go

    	testCancel := func(fn func()) {
    		t.Helper()
    		defer timeout(5 * time.Second)()
    		rb.Reset()
    		done := make(chan struct{})
    		go func() {
    			defer close(done)
    			time.Sleep(10 * time.Millisecond)
    			fn()
    		}()
    		rb.CloseWithError(errors.New("test error"))
    		<-done
    
    		rb.Reset()
    		done = make(chan struct{})
    		go func() {
    			defer close(done)
    			fn()
    		}()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
Back to Top