Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 1,214 for Func (0.11 sec)

  1. cmd/signals.go

    	"github.com/minio/minio/internal/logger"
    )
    
    func shutdownHealMRFWithTimeout() {
    	const shutdownTimeout = time.Minute
    
    	finished := make(chan struct{})
    	go func() {
    		globalMRFState.shutdown()
    		close(finished)
    	}()
    	select {
    	case <-time.After(shutdownTimeout):
    	case <-finished:
    	}
    }
    
    func handleSignals() {
    	// Custom exit function
    	exit := func(success bool) {
    		if globalLoggerOutput != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub_test.go

    	}
    	ps.Unlock()
    	close(doneCh2)
    }
    
    type maskString string
    
    func (m maskString) Mask() uint64 {
    	return 1
    }
    
    func TestPubSub(t *testing.T) {
    	ps := New[Maskable, Maskable](1)
    	ch1 := make(chan Maskable, 1)
    	doneCh1 := make(chan struct{})
    	defer close(doneCh1)
    	if err := ps.Subscribe(MaskAll, ch1, doneCh1, func(entry Maskable) bool { return true }); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. cmd/erasure-metadata-utils.go

    func reduceReadQuorumErrs(ctx context.Context, errs []error, ignoredErrs []error, readQuorum int) (maxErr error) {
    	return reduceQuorumErrs(ctx, errs, ignoredErrs, readQuorum, errErasureReadQuorum)
    }
    
    // reduceWriteQuorumErrs behaves like reduceErrs but only for returning
    // values of maximally occurring errors validated against writeQuorum.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. internal/crypto/key_test.go

    	{ExtKey: [32]byte{}, Random: shortRandom(31), ShouldPass: false}, // 3
    }
    
    func TestGenerateKey(t *testing.T) {
    	defer func(l bool) { logger.DisableLog = l }(logger.DisableLog)
    	logger.DisableLog = true
    
    	for i, test := range generateKeyTests {
    		i, test := i, test
    		func() {
    			defer recoverTest(i, test.ShouldPass, t)
    			key := GenerateKey(test.ExtKey[:], test.Random)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  5. cmd/perf-tests.go

    	DownloadTimes madmin.TimeDurations
    	DownloadTTFB  madmin.TimeDurations
    	Error         string
    }
    
    func newRandomReader(size int) io.Reader {
    	return io.LimitReader(randreader.New(), int64(size))
    }
    
    type firstByteRecorder struct {
    	t *time.Time
    	r io.Reader
    }
    
    func (f *firstByteRecorder) Read(p []byte) (n int, err error) {
    	if f.t != nil || len(p) == 0 {
    		return f.r.Read(p)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. cmd/jwt_test.go

    		b.Fatal(err)
    	}
    
    	b.ResetTimer()
    	b.ReportAllocs()
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			err = xjwt.ParseWithClaims(token, xjwt.NewMapClaims(), func(*xjwt.MapClaims) ([]byte, error) {
    				return []byte(creds.SecretKey), nil
    			})
    			if err != nil {
    				b.Fatal(err)
    			}
    		}
    	})
    }
    
    func BenchmarkAuthenticateNode(b *testing.B) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. internal/s3select/sql/evaluate.go

    			return nil, err
    		}
    		res[i] = *v
    	}
    	return FromArray(res), nil
    }
    
    const floatCmpTolerance = 0.000001
    
    func (e *In) evalInNode(r Record, lhs *Value, tableAlias string) (*Value, error) {
    	// Compare two values in terms of in-ness.
    	var cmp func(a, b Value) bool
    	cmp = func(a, b Value) bool {
    		// Convert if needed.
    		inferTypesForCmp(&a, &b)
    
    		if a.Equals(b) {
    			return true
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. internal/s3select/sql/funceval.go

    		// TODO: implement
    		fallthrough
    
    	default:
    		return nil, errNotImplemented
    	}
    }
    
    func coalesce(args []*Value) (res *Value, err error) {
    	for _, arg := range args {
    		if arg.IsNull() {
    			continue
    		}
    		return arg, nil
    	}
    	return FromNull(), nil
    }
    
    func nullif(v1, v2 *Value) (res *Value, err error) {
    	// Handle Null cases
    	if v1.IsNull() || v2.IsNull() {
    		return v1, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 13.2K bytes
    - Viewed (0)
  9. internal/config/lambda/event/targetidset.go

    // IsEmpty returns true if the set is empty.
    func (set TargetIDSet) IsEmpty() bool {
    	return len(set) != 0
    }
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	for k, v := range set {
    		setCopy[k] = v
    	}
    	return setCopy
    }
    
    // add - adds TargetID to the set.
    func (set TargetIDSet) add(targetID TargetID) {
    	set[targetID] = struct{}{}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  10. api/go1.15.txt

    pkg bufio, var ErrBadReadCount error
    pkg crypto, method (Hash) String() string
    pkg crypto/ecdsa, func SignASN1(io.Reader, *PrivateKey, []uint8) ([]uint8, error)
    pkg crypto/ecdsa, func VerifyASN1(*PublicKey, []uint8, []uint8) bool
    pkg crypto/ecdsa, method (*PrivateKey) Equal(crypto.PrivateKey) bool
    pkg crypto/ecdsa, method (*PublicKey) Equal(crypto.PublicKey) bool
    pkg crypto/ed25519, method (PrivateKey) Equal(crypto.PrivateKey) bool
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jul 17 02:15:01 UTC 2020
    - 7.6K bytes
    - Viewed (0)
Back to top