Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,179 for funcs (0.08 sec)

  1. internal/dsync/drwmutex_test.go

    	hammerRWMutex(t, 10, 5, n)
    }
    
    // Borrowed from rwmutex_test.go
    func TestUnlockPanic(t *testing.T) {
    	defer func() {
    		if recover() == nil {
    			t.Fatalf("unlock of unlocked RWMutex did not panic")
    		}
    	}()
    	mu := NewDRWMutex(ds, "test")
    	mu.Unlock(context.Background())
    }
    
    // Borrowed from rwmutex_test.go
    func TestUnlockPanic2(t *testing.T) {
    	mu := NewDRWMutex(ds, "test-unlock-panic-2")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  2. cmd/batch-replicate_gen_test.go

    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobReplicateCredentials(b *testing.B) {
    	v := BatchJobReplicateCredentials{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobReplicateCredentials(b *testing.B) {
    	v := BatchJobReplicateCredentials{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 29 18:27:23 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  3. internal/dsync/dsync_test.go

    		<-c
    	}
    }
    
    func BenchmarkMutexUncontended(b *testing.B) {
    	b.ResetTimer()
    	b.ReportAllocs()
    
    	type PaddedMutex struct {
    		*DRWMutex
    	}
    	b.RunParallel(func(pb *testing.PB) {
    		mu := PaddedMutex{NewDRWMutex(ds, "")}
    		for pb.Next() {
    			mu.Lock(id, source)
    			mu.Unlock(context.Background())
    		}
    	})
    }
    
    func benchmarkMutex(b *testing.B, slack, work bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. api/go1.7.txt

    pkg bytes, func ContainsAny([]uint8, string) bool
    pkg bytes, func ContainsRune([]uint8, int32) bool
    pkg bytes, method (*Reader) Reset([]uint8)
    pkg compress/flate, const HuffmanOnly = -2
    pkg compress/flate, const HuffmanOnly ideal-int
    pkg context, func Background() Context
    pkg context, func TODO() Context
    pkg context, func WithCancel(Context) (Context, CancelFunc)
    pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    }
    
    // LastConn - returns when the disk is seen to be connected the last time
    func (client *storageRESTClient) LastConn() time.Time {
    	return client.restClient.LastConn()
    }
    
    func (client *storageRESTClient) IsLocal() bool {
    	return false
    }
    
    func (client *storageRESTClient) Hostname() string {
    	return client.endpoint.Host
    }
    
    func (client *storageRESTClient) Endpoint() Endpoint {
    	return client.endpoint
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. clause/expression.go

    			builder.AddVar(builder, neq.Value)
    		}
    	}
    }
    
    func (neq Neq) NegationBuild(builder Builder) {
    	Eq(neq).Build(builder)
    }
    
    // Gt greater than for where
    type Gt Eq
    
    func (gt Gt) Build(builder Builder) {
    	builder.WriteQuoted(gt.Column)
    	builder.WriteString(" > ")
    	builder.AddVar(builder, gt.Value)
    }
    
    func (gt Gt) NegationBuild(builder Builder) {
    	Lte(gt).Build(builder)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Oct 10 06:45:48 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  7. cmd/batch-handlers_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobPrefix(b *testing.B) {
    	v := BatchJobPrefix{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobPrefix(b *testing.B) {
    	v := BatchJobPrefix{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. cmd/local-locker_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsglocalLockMap(b *testing.B) {
    	v := localLockMap{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsglocalLockMap(b *testing.B) {
    	v := localLockMap{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. internal/s3select/unused-errors.go

    //
    // /////////////////////////////////////////////////////////////////////
    func errExpressionTooLong(err error) *s3Error {
    	return &s3Error{
    		code:       "ExpressionTooLong",
    		message:    "The SQL expression is too long: The maximum byte-length for the SQL expression is 256 KB.",
    		statusCode: 400,
    		cause:      err,
    	}
    }
    
    func errColumnTooLong(err error) *s3Error {
    	return &s3Error{
    		code:       "ColumnTooLong",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 20 08:16:35 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  10. internal/http/server.go

    }
    
    // GetRequestCount - returns number of request in progress.
    func (srv *Server) GetRequestCount() int {
    	return int(atomic.LoadInt32(&srv.requestCount))
    }
    
    // Init - init HTTP server
    func (srv *Server) Init(listenCtx context.Context, listenErrCallback func(listenAddr string, err error)) (serve func() error, err error) {
    	// Take a copy of server fields.
    	var tlsConfig *tls.Config
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top