| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 153 shards *shards member
377 type shards struct { struct
378 qm *QueueManager
379 queues []chan *model.Sample
380 done chan struct{}
381 running int32
382 ctx context.Context
383 cancel context.CancelFunc
403 func (s *shards) len() int {
407 func (s *shards) start() {
[all …]
|
| /dports/net-mgmt/prometheus1/prometheus-1.8.2/storage/remote/ |
| H A D | queue_manager.go | 146 shards *shards member
354 type shards struct { struct
355 qm *QueueManager
356 queues []chan *model.Sample
357 done chan struct{}
358 wg sync.WaitGroup
375 func (s *shards) len() int {
379 func (s *shards) start() {
385 func (s *shards) stop() {
392 func (s *shards) enqueue(sample *model.Sample) bool {
[all …]
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 173 shards *shards member
531 type shards struct { struct
532 mtx sync.RWMutex // With the WAL, this is never actually contended.
534 qm *QueueManager
535 queues []chan prompb.TimeSeries
539 done chan struct{}
540 running int32
543 softShutdown chan struct{}
547 hardShutdown context.CancelFunc
551 func (s *shards) start(n int) {
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 210 shards *shards member
626 type shards struct { struct
629 qm *QueueManager
630 queues []chan sample
634 done chan struct{}
635 running int32
638 softShutdown chan struct{}
642 hardShutdown context.CancelFunc
646 func (s *shards) start(n int) {
669 func (s *shards) stop() {
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 360 shards *shards member
890 type shards struct { struct
893 qm *QueueManager
894 queues []chan interface{}
896 enqueuedSamples atomic.Int64
897 enqueuedExemplars atomic.Int64
901 done chan struct{}
902 running atomic.Int32
905 softShutdown chan struct{}
915 func (s *shards) start(n int) {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 362 shards *shards member
911 type shards struct { struct
914 qm *QueueManager
915 queues []chan interface{}
917 enqueuedSamples atomic.Int64
918 enqueuedExemplars atomic.Int64
922 done chan struct{}
923 running atomic.Int32
926 softShutdown chan struct{}
936 func (s *shards) start(n int) {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 362 shards *shards member
911 type shards struct { struct
914 qm *QueueManager
915 queues []chan interface{}
917 enqueuedSamples atomic.Int64
918 enqueuedExemplars atomic.Int64
922 done chan struct{}
923 running atomic.Int32
926 softShutdown chan struct{}
936 func (s *shards) start(n int) {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 362 shards *shards member
911 type shards struct { struct
914 qm *QueueManager
915 queues []chan interface{}
917 enqueuedSamples atomic.Int64
918 enqueuedExemplars atomic.Int64
922 done chan struct{}
923 running atomic.Int32
926 softShutdown chan struct{}
936 func (s *shards) start(n int) {
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/storage/remote/ |
| H A D | queue_manager.go | 362 shards *shards member
911 type shards struct { struct
914 qm *QueueManager
915 queues []chan interface{}
917 enqueuedSamples atomic.Int64
918 enqueuedExemplars atomic.Int64
922 done chan struct{}
923 running atomic.Int32
926 softShutdown chan struct{}
936 func (s *shards) start(n int) {
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/innobase/include/ |
| H A D | ut0counter.h | 266 inline Type add(Shards<COUNT> &shards, size_t id, size_t n) { in add() argument
279 inline Type sub(Shards<COUNT> &shards, size_t id, size_t n) { in sub()
292 inline Type inc(Shards<COUNT> &shards, size_t id) { in inc()
301 inline Type dec(Shards<COUNT> &shards, size_t id) { in dec()
310 inline Type get(const Shards<COUNT> &shards, size_t id) noexcept { in get()
322 inline void for_each(const Shards<COUNT> &shards, Function &&f) noexcept { in for_each()
332 inline Type total(const Shards<COUNT> &shards) noexcept { in total()
343 inline void clear(Shards<COUNT> &shards) noexcept { in clear()
|
| /dports/net/zmap/zmap-2.1.1/test/ |
| H A D | test_sharding.py | 17 def shard_file_name(shards, threads): argument
21 def output_file_name(shards, shard, threads): argument
39 def _runTest(self, shards, max_threads): argument
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/index/src/java/org/apache/hadoop/contrib/index/mapred/ |
| H A D | IndexUpdater.java | 50 int numMapTasks, Shard[] shards) throws IOException { in run()
57 int numMapTasks, Shard[] shards) throws IOException { in createJob()
121 void setShardGeneration(Configuration conf, Shard[] shards) in setShardGeneration()
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/arc-swap-0.4.7/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/arc-swap-0.4.4/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/arc-swap-0.3.11/src/ |
| H A D | gen_lock.rs | 85 fn shards(&self) -> &Self::Shards; in shards() method
147 fn shards(&self) -> &Shards { in shards() method
205 fn shards(&self) -> &[Shard; 1] { in shards() method
231 shards: S, field
253 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/devel/desed/desed-1.2.0/cargo-crates/arc-swap-0.4.7/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/editors/xi-term/xi-term-d264767/cargo-crates/arc-swap-0.3.11/src/ |
| H A D | gen_lock.rs | 85 fn shards(&self) -> &Self::Shards; in shards() method
147 fn shards(&self) -> &Shards { in shards() method
205 fn shards(&self) -> &[Shard; 1] { in shards() method
231 shards: S, field
253 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/net/proby/proby-1.0.2/cargo-crates/arc-swap-0.4.7/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/graphics/viu/viu-1.1/cargo-crates/arc-swap-0.4.7/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/arc-swap-0.4.7/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/devel/gitui/gitui-0.10.1/cargo-crates/arc-swap-0.4.7/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/sysutils/diskonaut/diskonaut-0.11.0/cargo-crates/arc-swap-0.4.7/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/arc-swap-0.4.4/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/sysutils/fusefs-sandboxfs/sandboxfs-sandboxfs-0.2.0/cargo-crates/arc-swap-0.4.5/src/ |
| H A D | gen_lock.rs | 84 fn shards(&self) -> &Self::Shards; in shards() method
146 fn shards(&self) -> &Shards { in shards() method
203 fn shards(&self) -> &[Shard; 1] { in shards() method
229 shards: S, field
251 fn shards(&self) -> &Self::Shards { in shards() method
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/index/src/java/org/apache/hadoop/contrib/index/main/ |
| H A D | UpdateIndex.java | 121 Shard[] shards = new Shard[count >= numShards ? count : numShards]; in createShards() local
140 Shard[] shards = new Shard[numShards]; in createShards() local
201 Shard[] shards = null; in main() local
|