/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/tests/ |
H A D | test_metadata_cache_group.cc | 32 using metadata_cache::InstanceStatus; 33 using metadata_cache::LookupResult; 34 using metadata_cache::ServerMode; 35 using InstanceVector = std::vector<metadata_cache::ManagedInstance>; 41 class MetadataCacheAPIStub : public metadata_cache::MetadataCacheAPIBase { 51 metadata_cache::ReplicasetStateListenerInterface *listener) override { in add_listener() 57 metadata_cache::ReplicasetStateListenerInterface *) override { in remove_listener() 118 std::vector<metadata_cache::ManagedInstance> instance_vector_; 155 {kReplicasetName, "uuid1", metadata_cache::ServerMode::ReadOnly, "3308", in TEST_F() 174 {kReplicasetName, "uuid1", metadata_cache::ServerMode::ReadOnly, "3307", in TEST_F() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/metadata_cache/tests/helper/ |
H A D | mock_metadata.h | 58 metadata_cache::ManagedInstance ms1; 59 metadata_cache::ManagedInstance ms2; 60 metadata_cache::ManagedInstance ms3; 61 metadata_cache::ManagedInstance ms4; 62 metadata_cache::ManagedInstance ms5; 63 metadata_cache::ManagedInstance ms6; 64 metadata_cache::ManagedInstance ms7; 65 metadata_cache::ManagedInstance ms8; 66 metadata_cache::ManagedInstance ms9; 73 std::vector<metadata_cache::ManagedInstance> replicaset_1_vector; [all …]
|
H A D | mock_metadata.cc | 47 ms1.mode = metadata_cache::ServerMode::ReadWrite; in MockNG() 54 ms2.mode = metadata_cache::ServerMode::ReadOnly; in MockNG() 61 ms3.mode = metadata_cache::ServerMode::ReadOnly; in MockNG() 68 ms4.mode = metadata_cache::ServerMode::ReadWrite; in MockNG() 75 ms5.mode = metadata_cache::ServerMode::ReadOnly; in MockNG() 82 ms6.mode = metadata_cache::ServerMode::ReadOnly; in MockNG() 89 ms7.mode = metadata_cache::ServerMode::ReadWrite; in MockNG() 96 ms8.mode = metadata_cache::ServerMode::ReadWrite; in MockNG() 103 ms9.mode = metadata_cache::ServerMode::ReadWrite; in MockNG() 150 const std::vector<metadata_cache::ManagedInstance> & /*instances*/, in fetch_instances() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/metadata_cache/src/ |
H A D | metadata_cache.cc | 72 metadata_cache->refresh_thread(); in run_thread() 251 bool metadata_cache::ManagedInstance::operator==( in operator ==() 261 metadata_cache::ManagedInstance::ManagedInstance( in ManagedInstance() 313 case metadata_cache::ServerMode::ReadWrite: in to_string() 315 case metadata_cache::ServerMode::ReadOnly: in to_string() 317 case metadata_cache::ServerMode::Unavailable: in to_string() 410 metadata_cache::ManagedInstance *instance = nullptr; in mark_instance_reachability() 428 case metadata_cache::InstanceStatus::Reachable: in mark_instance_reachability() 430 case metadata_cache::InstanceStatus::InvalidHost: in mark_instance_reachability() 438 case metadata_cache::InstanceStatus::Unreachable: in mark_instance_reachability() [all …]
|
H A D | cluster_metadata_gr.cc | 121 metadata_cache::ManagedReplicaSet in update_replicaset_status() 195 case metadata_cache::ReplicasetStatus:: in update_replicaset_status() 268 using MI = metadata_cache::ManagedInstance; in check_replicaset_status() 284 using metadata_cache::ReplicasetStatus; in check_replicaset_status() 285 using metadata_cache::ServerMode; in check_replicaset_status() 527 throw metadata_cache::metadata_error( in fetch_instances_from_metadata_server() 533 metadata_cache::ManagedInstance s; in fetch_instances_from_metadata_server() 554 throw metadata_cache::metadata_error(e.what()); in fetch_instances_from_metadata_server() 612 throw metadata_cache::metadata_error( in fetch_instances_from_metadata_server() 618 metadata_cache::ManagedInstance instance; in fetch_instances_from_metadata_server() [all …]
|
H A D | metadata_cache.h | 55 : public metadata_cache::ReplicasetStateNotifierInterface { 99 using metadata_servers_list_t = std::vector<metadata_cache::ManagedInstance>; 123 metadata_cache::InstanceStatus status); 152 metadata_cache::ReplicasetStateListenerInterface *listener) override; 162 metadata_cache::ReplicasetStateListenerInterface *listener) override; 164 metadata_cache::MetadataCacheAPIBase::RefreshStatus refresh_status() { in refresh_status() 200 const metadata_cache::ManagedInstance &metadata_server); 215 std::map<std::string, metadata_cache::ManagedReplicaSet> replicaset_data_; 290 std::set<metadata_cache::ReplicasetStateListenerInterface *>> 312 std::string to_string(metadata_cache::ServerMode mode); [all …]
|
H A D | cluster_metadata_ar.cc | 41 const std::vector<metadata_cache::ManagedInstance> &instances, in fetch_instances() 43 std::vector<metadata_cache::ManagedInstance> new_instances; in fetch_instances() 111 metadata_cache::ManagedReplicaSet replicaset; in fetch_instances() 146 std::vector<metadata_cache::ManagedInstance> 149 std::vector<metadata_cache::ManagedInstance> result; in fetch_instances_from_member() 179 throw metadata_cache::metadata_error( in fetch_instances_from_member() 185 metadata_cache::ManagedInstance instance; in fetch_instances_from_member() 193 ? metadata_cache::ServerMode::ReadWrite in fetch_instances_from_member() 194 : metadata_cache::ServerMode::ReadOnly; in fetch_instances_from_member() 211 throw metadata_cache::metadata_error(e.what()); in fetch_instances_from_member()
|
H A D | cluster_metadata.h | 52 const metadata_cache::ManagedInstance &mi)>; 102 const metadata_cache::ManagedInstance &metadata_server) noexcept override; 117 bool update_router_version(const metadata_cache::ManagedInstance &rw_instance, 121 const metadata_cache::ManagedInstance &rw_instance, 131 const metadata_cache::ManagedInstance &mi); 171 bool set_instance_ports(metadata_cache::ManagedInstance &instance, 176 void set_instance_attributes(metadata_cache::ManagedInstance &instance,
|
H A D | metadata.h | 47 std::map<std::string, metadata_cache::ManagedReplicaSet>; 60 const std::vector<metadata_cache::ManagedInstance> &instances, 65 const metadata_cache::ManagedInstance &rw_instance, 69 const metadata_cache::ManagedInstance &rw_instance, 73 const metadata_cache::ManagedInstance &metadata_server) = 0; 78 const std::vector<metadata_cache::ManagedInstance> &instances,
|
H A D | group_replication_metadata.cc | 64 throw metadata_cache::metadata_error( in IMPORT_LOG_FUNCTIONS() 83 throw metadata_cache::metadata_error(e.what()); in IMPORT_LOG_FUNCTIONS() 84 } catch (const metadata_cache::metadata_error &) { in IMPORT_LOG_FUNCTIONS() 124 throw metadata_cache::metadata_error( in fetch_group_replication_members() 145 throw metadata_cache::metadata_error( in fetch_group_replication_members() 200 throw metadata_cache::metadata_error(e.what()); in fetch_group_replication_members() 201 } catch (const metadata_cache::metadata_error &) { in fetch_group_replication_members()
|
H A D | cluster_metadata.cc | 87 throw metadata_cache::metadata_error( in ClusterMetadata() 104 const metadata_cache::ManagedInstance &mi) { in do_connect() 121 const metadata_cache::ManagedInstance &metadata_server) noexcept { in connect_and_setup_session() 167 throw metadata_cache::metadata_error(mysqlrouter::string_format( in get_and_check_metadata_schema_version() 178 bool set_instance_ports(metadata_cache::ManagedInstance &instance, in set_instance_ports() 221 const metadata_cache::ManagedInstance &rw_instance, in update_router_version() 281 const metadata_cache::ManagedInstance &rw_instance, in update_router_last_check_in() 415 return get_bool_tag(attributes, metadata_cache::kNodeTagHidden, in get_hidden() 416 metadata_cache::kNodeTagHiddenDefault, out_warning); in get_hidden() 422 metadata_cache::kNodeTagDisconnectWhenHiddenDefault, in get_disconnect_existing_sessions_when_hidden() [all …]
|
H A D | plugin_config.cc | 50 {"address", metadata_cache::kDefaultMetadataAddress}, in get_default() 51 {"ttl", ms_to_seconds_string(metadata_cache::kDefaultMetadataTTL)}, in get_default() 53 ms_to_seconds_string(metadata_cache::kDefaultAuthCacheTTL)}, in get_default() 55 ms_to_seconds_string(metadata_cache::kDefaultAuthCacheRefreshInterval)}, in get_default() 56 {"connect_timeout", to_string(metadata_cache::kDefaultConnectTimeout)}, in get_default() 57 {"read_timeout", to_string(metadata_cache::kDefaultReadTimeout)}, in get_default()
|
H A D | cluster_metadata_gr.h | 89 const std::vector<metadata_cache::ManagedInstance> & /*instances*/, in fetch_instances() 103 const std::vector<metadata_cache::ManagedInstance> &instances, in setup_notifications_listener() 152 metadata_cache::ManagedReplicaSet &replicaset); 154 metadata_cache::ReplicasetStatus check_replicaset_status( 155 std::vector<metadata_cache::ManagedInstance> &instances,
|
H A D | metadata_cache_plugin.cc | 47 using metadata_cache::LookupResult; 93 : public metadata_cache::ReplicasetStateListenerInterface { 100 metadata_cache::MetadataCacheAPI::instance()->remove_listener( in ~MetadataServersStateListener() 179 ? metadata_cache::kDefaultMetadataCluster in start() 197 auto md_cache = metadata_cache::MetadataCacheAPI::instance(); in start() 239 metadata_cache::MetadataCacheAPI::instance()->cache_stop(); in start()
|
H A D | cluster_metadata_ar.h | 94 const std::vector<metadata_cache::ManagedInstance> &instances, 105 const std::vector<metadata_cache::ManagedInstance> & /*instances*/, in setup_notifications_listener() 121 std::vector<metadata_cache::ManagedInstance> fetch_instances_from_member(
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/src/ |
H A D | dest_metadata_cache.h | 45 public metadata_cache::ReplicasetStateListenerInterface { 51 const std::string &metadata_cache, const std::string &replicaset, 55 metadata_cache::MetadataCacheAPIBase *cache_api = 56 metadata_cache::MetadataCacheAPI::instance(), 156 const metadata_cache::LookupResult &managed_servers, 160 const metadata_cache::LookupResult &managed_servers) const; 172 metadata_cache::MetadataCacheAPIBase *cache_api_; 179 void on_instances_change(const metadata_cache::LookupResult &instances, 183 void notify(const metadata_cache::LookupResult &instances,
|
H A D | dest_metadata_cache.cc | 54 using metadata_cache::ManagedInstance; 198 metadata_cache::MetadataCacheAPIBase *cache_api, in DestMetadataCacheGroup() 201 cache_name_(metadata_cache), in DestMetadataCacheGroup() 218 const metadata_cache::LookupResult &managed_servers, in get_available() 257 (it.mode == metadata_cache::ServerMode::ReadWrite || in get_available() 266 it.mode == metadata_cache::ServerMode::ReadOnly) { in get_available() 274 it.mode == metadata_cache::ServerMode::ReadWrite) { in get_available() 293 if (it.mode == metadata_cache::ServerMode::ReadWrite) { in get_available_primaries() 461 metadata_cache::InstanceStatus::Unreachable); in get_server_socket_gr() 574 const metadata_cache::LookupResult &instances, in on_instances_change() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/rest_metadata_cache/src/ |
H A D | rest_clusters_nodes.cc | 41 static const char *server_mode_to_string(metadata_cache::ServerMode mode) { in server_mode_to_string() 43 case metadata_cache::ServerMode::ReadOnly: in server_mode_to_string() 45 case metadata_cache::ServerMode::ReadWrite: in server_mode_to_string() 47 case metadata_cache::ServerMode::Unavailable: in server_mode_to_string() 65 metadata_cache::LookupResult res = in on_handle_request() 66 metadata_cache::MetadataCacheAPI::instance()->lookup_replicaset( in on_handle_request()
|
H A D | rest_metadata_cache_status.cc | 53 metadata_cache::MetadataCacheAPI::instance()->instance_name()) { in on_handle_request() 66 metadata_cache::MetadataCacheAPI::RefreshStatus refresh_status; in on_handle_request() 69 metadata_cache::MetadataCacheAPI::instance()->get_refresh_status(); in on_handle_request()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/metadata_cache/tests/ |
H A D | test_cache_plugin.cc | 65 using metadata_cache::ManagedInstance; 77 metadata_cache::MetadataCacheAPI::instance()->cache_init( in SetUp() 83 metadata_cache::MetadataCacheAPI::instance()->cache_start(); in SetUp() 110 metadata_cache::MetadataCacheAPI::instance()->cache_stop(); in TearDown() 113 metadata_cache::MetadataCacheAPIBase *cache_api_{ 114 metadata_cache::MetadataCacheAPI::instance()};
|
H A D | test_plugin_config.cc | 125 {"foo", metadata_cache::kDefaultMetadataTTL, "", 184 TCPAddress("foobar", metadata_cache::kDefaultMetadataPort), 187 TCPAddress("fuzzbozz", metadata_cache::kDefaultMetadataPort), 202 {"foo", metadata_cache::kDefaultMetadataTTL, "", 205 TCPAddress("foobar", metadata_cache::kDefaultMetadataPort), 231 TCPAddress("foobar", metadata_cache::kDefaultMetadataPort), 234 TCPAddress("fuzzbozz", metadata_cache::kDefaultMetadataPort),
|
/dports/sysutils/py-ranger/ranger-1.9.3/ranger/core/ |
H A D | metadata.py | 29 self.metadata_cache = dict() 35 self.metadata_cache.clear() 40 return ostruct(copy.deepcopy(self.metadata_cache[filename])) 84 self.metadata_cache[filename] = entry 91 if filename in self.metadata_cache: 92 return self.metadata_cache[filename] 108 self.metadata_cache[filename] = entry
|
/dports/www/elgg/elgg-3.3.23/vendor/elgg/elgg/engine/classes/Elgg/Database/ |
H A D | MetadataTable.php | 27 protected $metadata_cache; variable in Elgg\\Database\\MetadataTable 49 * @param MetadataCache $metadata_cache A cache for this table 54 MetadataCache $metadata_cache, argument 58 $this->metadata_cache = $metadata_cache; 245 $this->metadata_cache->clear($metadata->entity_guid); 328 $this->metadata_cache->clear($metadata->entity_guid); 370 $this->metadata_cache->clear($metadata->entity_guid); 441 $this->metadata_cache->invalidateByOptions($options); 474 if ($this->metadata_cache->isLoaded($entity_guid)) { 475 $ids = $this->metadata_cache->getSingleId($entity_guid, $name);
|
/dports/devel/mercurial/mercurial-6.0/mercurial/revlogutils/ |
H A D | rewrite.py | 579 metadata_cache=None, argument 595 if metadata_cache is not None: 596 metadata_cache[filerev] = has_meta 618 metadata_cache, 629 metadata_cache, argument 641 metadata_cache[filerev] = False 655 metadata_cache, 676 metadata_cache, 728 metadata_cache = {} 792 metadata_cache, [all …]
|
/dports/textproc/py-isbnlib/isbnlib-3.10.9/isbnlib/ |
H A D | registry.py | 115 metadata_cache = IMCache() # should be an instance variable 120 global metadata_cache 121 metadata_cache = cache
|