Home
last modified time | relevance | path

Searched refs:rl (Results 76 – 100 of 13184) sorted by relevance

12345678910>>...528

/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/uber/jaeger-client-go/utils/
H A Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Drate_limiter.go70 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 Dinstance.yml8 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 Dinstance.yml8 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 Dzfcp_reqlist.h41 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 Dzfcp_reqlist.h41 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 Dzfcp_reqlist.h41 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 Dcallback_test.py41 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 Drl.c28 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 Drl.c28 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 Drl.c28 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 Dratelimiter.go52 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 Dro_layer.go27 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 Dro_layer.go27 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 Dro_layer.go27 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 …]

12345678910>>...528