| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/zenazn/goji/graceful/listener/ |
| H A D | shard.go | 5 type shard struct { struct
6 l *T
8 mu sync.Mutex
9 idle map[*conn]struct{}
10 all map[*conn]struct{}
11 wg sync.WaitGroup
12 drain bool
21 func (s *shard) init(l *T) {
39 func (s *shard) disown(c *conn) {
57 func (s *shard) markInUse(c *conn) {
[all …]
|
| /dports/net/zmap/zmap-2.1.1/src/ |
| H A D | shard.h | 18 typedef struct shard { struct
19 struct shard_state { argument
27 struct shard_params { argument
35 shard_complete_cb cb; argument
39 void shard_init(shard_t* shard, argument
|
| H A D | shard.c | 19 void shard_init(shard_t* shard, in shard_init()
98 uint32_t shard_get_cur_ip(shard_t *shard) in shard_get_cur_ip()
103 static inline uint32_t shard_get_next_elem(shard_t *shard) in shard_get_next_elem()
112 uint32_t shard_get_next_ip(shard_t *shard) in shard_get_next_ip()
|
| /dports/databases/couchdb3/apache-couchdb-3.2.1/src/docs/src/cluster/ |
| H A D | sharding.rst | 286 .. _cluster/sharding/copying:
288 Copying shard files
354 Set the target node to ``true`` maintenance mode
401 Updating cluster metadata to reflect the new target shard(s)
532 Forcing synchronization of the shard(s)
559 Monitor internal replication to ensure up-to-date shard(s)
573 Clear the target node's maintenance mode
588 Update cluster metadata again to remove the source shard
597 .. _cluster/sharding/remove-shard-files:
599 Remove the shard and secondary index files from the source node
|
| /dports/net-mgmt/promscale/promscale-0.6.2/pkg/migration-tool/writer/ |
| H A D | shards.go | 93 type shard struct { struct
94 ctx context.Context
95 client *utils.Client
96 queue chan *[]prompb.TimeSeries
97 copyShardSet *shardsSet
101 func (s *shard) run(shardIndex int) {
|
| /dports/textproc/kibana7/kibana-7.16.2-darwin-x86_64/src/plugins/console/server/lib/spec_definitions/json/overrides/ |
| H A D | cluster.reroute.json | 9 "shard": 0, number
14 "shard": 0, number
21 "shard": 0, number
25 "shard": 0, number
32 "shard": 0, number
36 "shard": 0, number
|
| /dports/textproc/kibana6/kibana-6.8.16-darwin-x86_64/src/legacy/core_plugins/console/api_server/spec/overrides/ |
| H A D | cluster.reroute.json | 9 "shard": 0, number
14 "shard": 0, number
21 "shard": 0, number
25 "shard": 0, number
32 "shard": 0, number
36 "shard": 0, number
|
| /dports/textproc/opensearch-dashboards/opensearch-dashboards-1.2.0-linux-x64/src/plugins/console/server/lib/spec_definitions/json/overrides/ |
| H A D | cluster.reroute.json | 9 "shard": 0, number
14 "shard": 0, number
21 "shard": 0, number
25 "shard": 0, number
32 "shard": 0, number
36 "shard": 0, number
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/catalog/ |
| H A D | sharding_catalog_enable_sharding_test.cpp | 70 ShardType shard; in TEST_F() local
109 ShardType shard; in TEST_F() local
121 ShardType shard; in TEST_F() local
130 ShardType shard; in TEST_F() local
139 ShardType shard; in TEST_F() local
|
| H A D | sharding_catalog_add_shard_to_zone_test.cpp | 49 ShardType shard; in TEST_F() local
67 ShardType shard; in TEST_F() local
88 ShardType shard; in TEST_F() local
109 ShardType shard; in TEST_F() local
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/ingester/ |
| H A D | series_map.go | 23 type shard struct { struct
24 mtx sync.Mutex
25 m map[model.Fingerprint]*memorySeries
28 …eLineSize - unsafe.Sizeof(sync.Mutex{}) - unsafe.Sizeof(map[model.Fingerprint]*memorySeries{})]byte
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/ingester/ |
| H A D | series_map.go | 23 type shard struct { struct
24 mtx sync.Mutex
25 m map[model.Fingerprint]*memorySeries
28 …eLineSize - unsafe.Sizeof(sync.Mutex{}) - unsafe.Sizeof(map[model.Fingerprint]*memorySeries{})]byte
|
| /dports/dns/dnsdist/dnsdist-1.6.1/ |
| H A D | test-dnsdistrings_cc.cc | 22 for (const auto& shard : rings.d_shards) { in BOOST_AUTO_TEST_SUITE() local
42 for (const auto& shard : rings.d_shards) { in BOOST_AUTO_TEST_SUITE() local
59 for (const auto& shard : rings.d_shards) { in BOOST_AUTO_TEST_SUITE() local
79 for (const auto& shard : rings.d_shards) { in BOOST_AUTO_TEST_SUITE() local
98 for (const auto& shard : rings.d_shards) { in BOOST_AUTO_TEST_SUITE() local
131 for (const auto& shard : rings.d_shards) { in ringReaderThread() local
235 for (const auto& shard : rings.d_shards) { in BOOST_AUTO_TEST_CASE() local
|
| H A D | dnsdist-cache.cc | 39 for (auto& shard : d_shards) { in DNSDistPacketCache() local
48 for (auto& shard : d_shards) { in ~DNSDistPacketCache() local
95 void DNSDistPacketCache::insertLocked(CacheShard& shard, uint32_t key, CacheValue& newValue) in insertLocked()
187 auto& shard = d_shards.at(shardIndex); in insert() local
223 auto& shard = d_shards.at(shardIndex); in get() local
312 for (auto& shard : d_shards) { in purgeExpired() local
349 for (auto& shard : d_shards) { in expunge() local
382 for (auto& shard : d_shards) { in expungeByName() local
411 for (auto& shard : d_shards) { in getSize() local
475 for (auto& shard : d_shards) { in dump() local
|
| /dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/mongodb/plugins/modules/ |
| H A D | mongodb_shard_tag.py | 124 def tag_exists(client, shard, tag): argument
140 def add_zone_tag(client, shard, tag): argument
154 def remove_zone_tag(client, shard, tag): argument
|
| H A D | mongodb_shard.py | 147 def shard_find(client, shard): argument
166 def shard_add(client, shard): argument
174 def shard_remove(client, shard): argument
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/mroonga/vendor/groonga/plugins/sharding/ |
| H A D | logical_table_remove.rb | 30 def remove_shard(shard, shard_range, target_range) argument
146 def collect_referenced_table_ids(shard, table) argument
168 def remove_table(shard, table) argument
299 def remove_referenced_tables(shard, referenced_table_ids) argument
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/mroonga/vendor/groonga/plugins/sharding/ |
| H A D | logical_table_remove.rb | 30 def remove_shard(shard, shard_range, target_range) argument
146 def collect_referenced_table_ids(shard, table) argument
168 def remove_table(shard, table) argument
299 def remove_referenced_tables(shard, referenced_table_ids) argument
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/mroonga/vendor/groonga/plugins/sharding/ |
| H A D | logical_table_remove.rb | 30 def remove_shard(shard, shard_range, target_range) argument
146 def collect_referenced_table_ids(shard, table) argument
168 def remove_table(shard, table) argument
299 def remove_referenced_tables(shard, referenced_table_ids) argument
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/mroonga/vendor/groonga/plugins/sharding/ |
| H A D | logical_table_remove.rb | 30 def remove_shard(shard, shard_range, target_range) argument
146 def collect_referenced_table_ids(shard, table) argument
168 def remove_table(shard, table) argument
299 def remove_referenced_tables(shard, referenced_table_ids) argument
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/mroonga/vendor/groonga/plugins/sharding/ |
| H A D | logical_table_remove.rb | 30 def remove_shard(shard, shard_range, target_range) argument
146 def collect_referenced_table_ids(shard, table) argument
168 def remove_table(shard, table) argument
299 def remove_referenced_tables(shard, referenced_table_ids) argument
|
| /dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/database/mongodb/ |
| H A D | mongodb_shard.py | 178 def shard_find(client, shard): argument
197 def shard_add(client, shard): argument
205 def shard_remove(client, shard): argument
|
| /dports/dns/powerdns/pdns-4.5.2/pdns/ |
| H A D | dnsdist-cache.cc | 39 for (auto& shard : d_shards) { in DNSDistPacketCache() local
48 for (auto& shard : d_shards) { in ~DNSDistPacketCache() local
95 void DNSDistPacketCache::insertLocked(CacheShard& shard, uint32_t key, CacheValue& newValue) in insertLocked()
187 auto& shard = d_shards.at(shardIndex); in insert() local
223 auto& shard = d_shards.at(shardIndex); in get() local
312 for (auto& shard : d_shards) { in purgeExpired() local
349 for (auto& shard : d_shards) { in expunge() local
382 for (auto& shard : d_shards) { in expungeByName() local
411 for (auto& shard : d_shards) { in getSize() local
475 for (auto& shard : d_shards) { in dump() local
|
| /dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/engine/spark/ |
| H A D | SparkSharder.java | 53 …public static <L extends Locatable, SB extends ShardBoundary> JavaRDD<Shard<L>> shard(JavaSparkCon… in shard() method in SparkSharder
73 …public static <L extends Locatable, SB extends ShardBoundary> JavaRDD<Shard<L>> shard(JavaSparkCon… in shard() method in SparkSharder
93 …public static <L extends Locatable, SB extends ShardBoundary> JavaRDD<Shard<L>> shard(JavaSparkCon… in shard() method in SparkSharder
118 …private static <L extends Locatable, SB extends ShardBoundary> JavaRDD<Shard<L>> shard(JavaSparkCo… in shard() method
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/wabt-sys-0.7.1/wabt/src/ |
| H A D | test-hexfloat.cc | 106 virtual void RunShard(int shard) { in RunShard()
131 virtual void RunShard(int shard) { in RunShard()
167 virtual void RunShard(int shard) { in RunShard()
190 virtual void RunShard(int shard) { in RunShard()
216 virtual void RunShard(int shard) { in RunShard()
253 virtual void RunShard(int shard) { in RunShard()
|