SAffinityDictDB;
68 const string*
const& rhs)
const 70 return(*lhs) < (*rhs);
162 size_t size(
void)
const;
163 bool CanAccept(
const string& aff_token,
164 size_tmax_records)
const;
165 bool CanAccept(
constvector<string> & aff_tokens,
166 size_tmax_records)
const;
167 unsigned int GetIDByToken(
const string& aff_token)
const;
172 unsigned intclient_id,
176vector<unsigned int> & aff_ids);
201 const string& scope,
209 void Dump(
const string& dump_dir_name,
210 const string& queue_name)
const;
211 void RemoveDump(
const string& dump_dir_name,
212 const string& queue_name)
const;
222 const string& queue_name);
237 map<
const string*,
259 const string& scope,
266 const string& scope,
269 unsigned intclient_id,
272 unsigned intclient_id,
275 unsigned intclient_id,
278 unsigned intclient_id,
281 const string& qname)
const;
void RemoveJobFromAffinity(unsigned int job_id, unsigned int aff_id)
void SetWaitClientForAffinities(unsigned int client_id, const TNSBitVector &aff_ids, ECommandGroup cmd_group)
void x_AddClient(SNSJobsAffinity &aff_data, unsigned int client_id, ECommandGroup command_group)
unsigned int ResolveAffinity(const string &token)
unsigned int m_LastAffinityID
TNSBitVector GetJobsWithAffinity(unsigned int aff_id) const
void AddClientToAffinities(unsigned int client_id, const TNSBitVector &aff_ids, ECommandGroup cmd_group)
void Dump(const string &dump_dir_name, const string &queue_name) const
size_t RemoveClientFromAffinities(unsigned int client_id, const TNSBitVector &aff_ids, ECommandGroup cmd_group)
void AddClientToAffinity(unsigned int client_id, unsigned int aff_id, ECommandGroup cmd_group)
void FinalizeAffinityDictionaryLoading(void)
TNSBitVector GetJobsWithAffinities(const TNSBitVector &affs) const
void RemoveDump(const string &dump_dir_name, const string &queue_name) const
string x_PrintSelected(const TNSBitVector &batch, const CQueue *queue, const CNSClientsRegistry &clients_registry, const TNSBitVector &scope_jobs, const string &scope, bool verbose) const
void x_RemoveClient(SNSJobsAffinity &aff_data, unsigned int client_id, ECommandGroup command_group)
bool CanAccept(const string &aff_token, size_t max_records) const
string Print(const CQueue *queue, const CNSClientsRegistry &clients_registry, const TNSBitVector &scope_jobs, const string &scope, size_t batch_size, bool verbose) const
string GetTokenByID(unsigned int aff_id) const
size_t x_RemoveClientFromAffinities(unsigned int client_id, const TNSBitVector &aff_ids, bool is_wait_client, ECommandGroup cmd_group)
void ResolveAffinities(const list< string > &tokens, TNSBitVector &resolved_affs, vector< unsigned int > &aff_ids)
void x_AddWaitClient(SNSJobsAffinity &aff_data, unsigned int client_id, ECommandGroup command_group)
TNSBitVector GetRegisteredAffinities(void) const
map< unsigned int, SNSJobsAffinity > m_JobsAffinity
unsigned int CollectGarbage(unsigned int max_to_del)
void x_RemoveWaitClient(SNSJobsAffinity &aff_data, unsigned int client_id, ECommandGroup command_group)
void LoadFromDump(const string &dump_dir_name, const string &queue_name)
unsigned int GetIDByToken(const string &aff_token) const
map< const string *, unsigned int, SNSTokenCompare > m_AffinityIDs
void x_InitLastAffinityID(unsigned int value)
string x_GetDumpFileName(const string &dump_dir_name, const string &qname) const
unsigned int CheckRemoveCandidates(void)
unsigned int ResolveAffinityToken(const string &token, unsigned int job_id, unsigned int client_id, ECommandGroup command_group)
TNSBitVector m_RegisteredAffinities
void AddJobToAffinity(unsigned int job_id, unsigned int aff_id)
unsigned int x_GetNextAffinityID(void)
TNSBitVector m_RemoveCandidates
size_t RemoveWaitClientFromAffinities(unsigned int client_id, const TNSBitVector &aff_ids, ECommandGroup cmd_group)
void x_DeleteAffinity(unsigned int aff_id, map< unsigned int, SNSJobsAffinity >::iterator found_aff)
CFastMutex m_LastAffinityIDLock
string x_PrintOne(unsigned int aff_id, const SNSJobsAffinity &jobs_affinity, const CQueue *queue, const CNSClientsRegistry &clients_registry, const TNSBitVector &scope_jobs, const string &scope, bool verbose) const
Bitvector Bit-vector container with runtime compression of bits.
bool set_bit(size_type n, bool val=true)
Sets bit n.
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
unsigned int
A callback function used to compare two keys in a database.
const GenericPointer< typename T::ValueType > T2 value
Multi-threading â mutexes; rw-locks; semaphore.
const string k_NoAffinityToken
const size_t k_OpLimitToOptimize
void RemoveReadWaitClient(unsigned int client_id)
void AddReaderClient(unsigned int client_id)
size_t m_WaitGetClientsOpCount
size_t m_WNClientsOpCount
void AddJob(unsigned int job_id)
size_t m_WaitReadClientsCount
void RemoveWNWaitClient(unsigned int client_id)
void x_ReaderClientsOp(void)
void RemoveWNClient(unsigned int client_id)
size_t m_ReaderClientsOpCount
void AddReadWaitClient(unsigned int client_id)
const string * m_AffToken
void AddWNWaitClient(unsigned int client_id)
TNSBitVector m_ReaderClients
void RemoveJob(unsigned int job_id)
void AddWNClient(unsigned int client_id)
bool CanBeDeleted(void) const
TNSBitVector m_WaitGetClients
TNSBitVector m_WaitReadClients
void RemoveReaderClient(unsigned int client_id)
bool operator()(const string *const &lhs, const string *const &rhs) const
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4