- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for borrowed (0.08 sec)
-
internal/jwt/parser.go
return HashBorrower{pool: &s.HasherPool, borrowed: make([]hash.Hash, 0, 2)} } // HashBorrower keeps track of borrowed hashers and allows to return them all. type HashBorrower struct { pool *sync.Pool borrowed []hash.Hash } // Borrow a single hasher. func (h *HashBorrower) Borrow() hash.Hash { hasher := h.pool.Get().(hash.Hash) h.borrowed = append(h.borrowed, hasher) hasher.Reset() return hasher }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 14.1K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
rwm.RUnlock(context.Background()) } } _ = foo }) } // Borrowed from rwmutex_test.go func BenchmarkRWMutexWrite100(b *testing.B) { benchmarkRWMutex(b, 0, 100) } // Borrowed from rwmutex_test.go func BenchmarkRWMutexWrite10(b *testing.B) { benchmarkRWMutex(b, 0, 10) } // Borrowed from rwmutex_test.go func BenchmarkRWMutexWorkWrite100(b *testing.B) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
// Test cases below are copied 1 to 1 from sync/rwmutex_test.go (adapted to use LRWMutex) // Borrowed from rwmutex_test.go func parallelReader(ctx context.Context, m *LRWMutex, clocked, cunlock, cdone chan bool) { if m.GetRLock(ctx, "", "", time.Second) { clocked <- true <-cunlock m.RUnlock() cdone <- true } } // Borrowed from rwmutex_test.go func doTestParallelReaders(numReaders, gomaxprocs int) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/dsync/dsync_test.go
t.Fatal("Unlock timed out, which should not happen") case <-timer.C: } } // 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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:35:19 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/healthcheck-handler.go
case http.MethodGet: writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return } } if globalEtcdClient != nil { // Borrowed from // https://github.com/etcd-io/etcd/blob/main/etcdctl/ctlv3/command/ep_command.go#L118 ctx, cancel := context.WithTimeout(r.Context(), defaultContextTimeout) defer cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0) -
common-protos/k8s.io/api/flowcontrol/v1beta3/generated.proto
optional LimitResponse limitResponse = 2; // `lendablePercent` prescribes the fraction of the level's NominalCL that // can be borrowed by other priority levels. The value of this // field must be between 0 and 100, inclusive, and it defaults to 0. // The number of seats that other levels can borrow from this level, known // as this level's LendableConcurrencyLimit (LendableCL), is defined as follows. //
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.5K bytes - Viewed (0) -
common-protos/k8s.io/api/flowcontrol/v1beta1/generated.proto
optional LimitResponse limitResponse = 2; // `lendablePercent` prescribes the fraction of the level's NominalCL that // can be borrowed by other priority levels. The value of this // field must be between 0 and 100, inclusive, and it defaults to 0. // The number of seats that other levels can borrow from this level, known // as this level's LendableConcurrencyLimit (LendableCL), is defined as follows. //
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api.h
// particular named input list, which may only be part of the op's inputs). TF_CAPI_EXPORT extern int TFE_OpGetFlatInputCount(const TFE_Op* op, TF_Status* status); // Returns a borrowed reference to one of `op`'s inputs. Use // `TFE_TensorHandleCopySharingTensor` to make a new reference. TF_CAPI_EXPORT extern TFE_TensorHandle* TFE_OpGetFlatInput(const TFE_Op* op,
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 22.8K bytes - Viewed (0) -
docs/sts/web-identity.md
| :-- | :-- | | *Type* | *String* | | *Required* | *No* | ### Version Indicates STS API version information, the only supported value is '2011-06-15'. This value is borrowed from AWS STS API documentation for compatibility reasons. | Params | Value | | :-- | :-- | | *Type* | *String* | | *Required* | *Yes* | ### DurationSeconds
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 10 20:16:44 UTC 2024 - 18.9K bytes - Viewed (0) -
common-protos/k8s.io/api/flowcontrol/v1alpha1/generated.proto
optional LimitResponse limitResponse = 2; // `lendablePercent` prescribes the fraction of the level's NominalCL that // can be borrowed by other priority levels. The value of this // field must be between 0 and 100, inclusive, and it defaults to 0. // The number of seats that other levels can borrow from this level, known // as this level's LendableConcurrencyLimit (LendableCL), is defined as follows. //
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.4K bytes - Viewed (0)