MCPcopy Create free account
hub / github.com/ByConity/ByConity / getManyChecked

Method getManyChecked

src/Client/ConnectionPoolWithFailover.cpp:164–175  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

162}
163
164std::vector<ConnectionPoolWithFailover::TryResult> ConnectionPoolWithFailover::getManyChecked(
165 const ConnectionTimeouts & timeouts,
166 const Settings * settings, PoolMode pool_mode,
167 const QualifiedTableName & table_to_check)
168{
169 TryGetEntryFunc try_get_entry = [&](NestedPool & pool, std::string & fail_message)
170 {
171 return tryGetEntry(pool, timeouts, fail_message, settings, &table_to_check);
172 };
173
174 return getManyImpl(settings, pool_mode, try_get_entry);
175}
176
177ConnectionPoolWithFailover::Base::GetPriorityFunc ConnectionPoolWithFailover::makeGetPriorityFunc(const Settings * settings)
178{

Callers 3

runWritingJobMethod · 0.80
RemoteQueryExecutorMethod · 0.80
createForShardMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected