Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for borrowed (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. internal/jwt/parser_test.go

    package jwt
    
    // This file is a re-implementation of the original code here with some
    // additional allocation tweaks reproduced using GODEBUG=allocfreetrace=1
    // original file https://github.com/golang-jwt/jwt/blob/main/parser.go
    // borrowed under MIT License https://github.com/golang-jwt/jwt/blob/main/LICENSE
    
    import (
    	"fmt"
    	"testing"
    	"time"
    
    	"github.com/golang-jwt/jwt/v4"
    )
    
    var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 6K bytes
    - Viewed (0)
  6. docs/sts/assume-role.md

    ## API Request Parameters
    
    ### 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*    |
    
    ### AUTHPARAMS
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 7.1K bytes
    - Viewed (0)
  7. 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)
  8. docs/sts/client-grants.md

    | *Required*           | *Yes*                                          |
    
    ### 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: Thu Sep 29 04:28:45 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top