/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/net/traefik/traefik-2.6.1/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | rate_limiter.go | 70 rl.lock.Lock() 71 defer rl.lock.Unlock() 75 rl.balance -= itemCost 79 rl.updateBalance() 81 rl.balance -= itemCost 94 rl.balance += elapsedTime.Seconds() * rl.creditsPerSecond 95 if rl.balance > rl.maxBalance { 96 rl.balance = rl.maxBalance 105 rl.lock.Lock() 106 defer rl.lock.Unlock() [all …]
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/ngine_io/cloudstack/tests/integration/targets/cs_resourcelimit/tasks/ |
H A D | instance.yml | 8 register: rl 12 - rl is successful 15 - rl.limit == 20 23 register: rl 28 - rl is changed 38 register: rl 42 - rl is changed 52 register: rl 67 register: rl 84 register: rl [all …]
|
/dports/sysutils/ansible2/ansible-2.9.27/test/integration/targets/cs_resourcelimit/tasks/ |
H A D | instance.yml | 8 register: rl 12 - rl is successful 15 - rl.limit == 20 23 register: rl 28 - rl is changed 38 register: rl 42 - rl is changed 52 register: rl 67 register: rl 84 register: rl [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/s390/scsi/ |
H A D | zfcp_reqlist.h | 41 struct zfcp_reqlist *rl; in zfcp_reqlist_alloc() local 44 if (!rl) in zfcp_reqlist_alloc() 47 spin_lock_init(&rl->lock); in zfcp_reqlist_alloc() 50 INIT_LIST_HEAD(&rl->buckets[i]); in zfcp_reqlist_alloc() 52 return rl; in zfcp_reqlist_alloc() 66 if (!list_empty(&rl->buckets[i])) in zfcp_reqlist_isempty() 78 BUG_ON(!zfcp_reqlist_isempty(rl)); in zfcp_reqlist_free() 80 kfree(rl); in zfcp_reqlist_free() 110 spin_lock_irqsave(&rl->lock, flags); in zfcp_reqlist_find() 135 spin_lock_irqsave(&rl->lock, flags); in zfcp_reqlist_find_rm() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/s390/scsi/ |
H A D | zfcp_reqlist.h | 41 struct zfcp_reqlist *rl; in zfcp_reqlist_alloc() local 44 if (!rl) in zfcp_reqlist_alloc() 47 spin_lock_init(&rl->lock); in zfcp_reqlist_alloc() 50 INIT_LIST_HEAD(&rl->buckets[i]); in zfcp_reqlist_alloc() 52 return rl; in zfcp_reqlist_alloc() 66 if (!list_empty(&rl->buckets[i])) in zfcp_reqlist_isempty() 78 BUG_ON(!zfcp_reqlist_isempty(rl)); in zfcp_reqlist_free() 80 kfree(rl); in zfcp_reqlist_free() 110 spin_lock_irqsave(&rl->lock, flags); in zfcp_reqlist_find() 135 spin_lock_irqsave(&rl->lock, flags); in zfcp_reqlist_find_rm() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/s390/scsi/ |
H A D | zfcp_reqlist.h | 41 struct zfcp_reqlist *rl; in zfcp_reqlist_alloc() local 44 if (!rl) in zfcp_reqlist_alloc() 47 spin_lock_init(&rl->lock); in zfcp_reqlist_alloc() 50 INIT_LIST_HEAD(&rl->buckets[i]); in zfcp_reqlist_alloc() 52 return rl; in zfcp_reqlist_alloc() 66 if (!list_empty(&rl->buckets[i])) in zfcp_reqlist_isempty() 78 BUG_ON(!zfcp_reqlist_isempty(rl)); in zfcp_reqlist_free() 80 kfree(rl); in zfcp_reqlist_free() 110 spin_lock_irqsave(&rl->lock, flags); in zfcp_reqlist_find() 135 spin_lock_irqsave(&rl->lock, flags); in zfcp_reqlist_find_rm() [all …]
|
/dports/science/gramps/gramps-5.1.4/gramps/gen/utils/test/ |
H A D | callback_test.py | 41 rl = [] 42 def fn(i,r=rl): 62 rl = [] 63 def fn(i,r=rl): 99 rl = [] 126 rl = [] 127 def fn(r=rl): 161 rl = [] 186 rl = [] 226 rl = [] [all …]
|
/dports/multimedia/gstreamer1-libav/gst-libav-1.16.2/gst-libs/ext/libav/libavcodec/ |
H A D | rl.c | 28 void ff_rl_free(RLTable *rl) in ff_rl_free() argument 33 av_freep(&rl->max_run[i]); in ff_rl_free() 34 av_freep(&rl->max_level[i]); in ff_rl_free() 35 av_freep(&rl->index_run[i]); in ff_rl_free() 39 av_cold int ff_rl_init(RLTable *rl, in ff_rl_init() argument 54 end = rl->last; in ff_rl_init() 56 start = rl->last; in ff_rl_init() 57 end = rl->n; in ff_rl_init() 85 if (!rl->max_run[last]) in ff_rl_init() 101 ff_rl_free(rl); in ff_rl_init() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/ffmpeg/libavcodec/ |
H A D | rl.c | 28 void ff_rl_free(RLTable *rl) in ff_rl_free() argument 33 av_freep(&rl->max_run[i]); in ff_rl_free() 34 av_freep(&rl->max_level[i]); in ff_rl_free() 35 av_freep(&rl->index_run[i]); in ff_rl_free() 39 av_cold int ff_rl_init(RLTable *rl, in ff_rl_init() argument 54 end = rl->last; in ff_rl_init() 56 start = rl->last; in ff_rl_init() 57 end = rl->n; in ff_rl_init() 85 if (!rl->max_run[last]) in ff_rl_init() 101 ff_rl_free(rl); in ff_rl_init() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/ffmpeg/libavcodec/ |
H A D | rl.c | 28 void ff_rl_free(RLTable *rl) in ff_rl_free() argument 33 av_freep(&rl->max_run[i]); in ff_rl_free() 34 av_freep(&rl->max_level[i]); in ff_rl_free() 35 av_freep(&rl->index_run[i]); in ff_rl_free() 39 av_cold int ff_rl_init(RLTable *rl, in ff_rl_init() argument 54 end = rl->last; in ff_rl_init() 56 start = rl->last; in ff_rl_init() 57 end = rl->n; in ff_rl_init() 85 if (!rl->max_run[last]) in ff_rl_init() 101 ff_rl_free(rl); in ff_rl_init() [all …]
|
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/internal/ratelimiter/ |
H A D | ratelimiter.go | 52 rl := &RateLimiter{ 61 opt(rl) 64 rl.cache = lru.New(name, rl.cacheOptions...) 66 return rl 72 rl.now = now 86 rl.burstSize = burst 93 rl.blockedCount = m 100 rl.cacheOptions = append(rl.cacheOptions, lru.WithMaxSize(size)) 108 rl.cacheOptions = append(rl.cacheOptions, lru.WithCachedEntriesMetric(m)) 115 rl.cacheOptions = append(rl.cacheOptions, lru.WithCachedRequestsMetric(m)) [all …]
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/layer/ |
H A D | ro_layer.go | 27 rc, err := rl.layerStore.getTarStream(rl) 54 return rl.layerStore.driver.Diff(rl.cacheID, parentCacheID) 58 return rl.cacheID 62 return rl.chainID 66 return rl.diffID 70 if rl.parent == nil { 73 return rl.parent 77 if rl.parent != nil { 88 return rl.size, nil 92 return rl.layerStore.driver.GetMetadata(rl.cacheID) [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/layer/ |
H A D | ro_layer.go | 27 rc, err := rl.layerStore.getTarStream(rl) 54 return rl.layerStore.driver.Diff(rl.cacheID, parentCacheID) 58 return rl.cacheID 62 return rl.chainID 66 return rl.diffID 70 if rl.parent == nil { 73 return rl.parent 77 if rl.parent != nil { 88 return rl.size, nil 92 return rl.layerStore.driver.GetMetadata(rl.cacheID) [all …]
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/layer/ |
H A D | ro_layer.go | 27 rc, err := rl.layerStore.getTarStream(rl) 54 return rl.layerStore.driver.Diff(rl.cacheID, parentCacheID) 58 return rl.cacheID 62 return rl.chainID 66 return rl.diffID 70 if rl.parent == nil { 73 return rl.parent 77 if rl.parent != nil { 88 return rl.size, nil 92 return rl.layerStore.driver.GetMetadata(rl.cacheID) [all …]
|