shared_ptr<CCassConnection> connection,
50 const string& keyspace,
58std::move(connection), keyspace,
60std::move(data_error_cb)
62, m_Accession(std::move( accession))
64, m_SeqIdType(seq_id_type)
65, m_Consume(std::move( consume_callback))
74shared_ptr<CCassDataCallbackReceiver> callback)
79 "CCassAccVerHistoryTaskFetch: DataReadyCB can't be assigned " 80 "after the loading process has started");
87 boolrestarted =
false;
104 " version, gi, date, chain, id_type, sat, sat_key" 108 unsigned intparams = 1;
111 sql+=
" AND version = ?";
116 sql+=
" AND id_type = ? ALLOW FILTERING";
123 unsigned intparam = 1;
144 booldo_next =
true;
151record.
gi=
m_QueryArr[0].query->FieldGetInt64Value( 1, 0);
155record.
sat=
m_QueryArr[0].query->FieldGetInt16Value( 5, 0);
160do_next =
m_Consume( std::move( record),
false);
190snprintf(
msg,
sizeof(
msg),
191 "Failed to fetch accession history (key=%s.%s|%hd|%hd) unexpected state (%d)",
198}
while( restarted);
#define BEGIN_IDBLOB_SCOPE
BEGIN_IDBLOB_SCOPE USING_NCBI_SCOPE
function< bool(SAccVerHistRec &&, bool last)> TAccVerHistConsumeCallback
function< void(CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)> TDataErrorCallback
TAccVerHistConsumeCallback m_Consume
void SetDataReadyCB(shared_ptr< CCassDataCallbackReceiver > callback)
CCassAccVerHistoryTaskFetch(shared_ptr< CCassConnection > connection, const string &keyspace, string accession, TAccVerHistConsumeCallback consume_callback, TDataErrorCallback data_error_cb, int16_t version=0, int16_t seq_id_type=0)
void SetConsumeCallback(TAccVerHistConsumeCallback callback)
unsigned int m_RestartCounter
atomic< int32_t > m_State
string GetKeySpace() const
void SetDataReadyCB3(shared_ptr< CCassDataCallbackReceiver > datareadycb3)
TCassConsistency GetReadConsistency() const
void SetupQueryCB3(shared_ptr< CCassQuery > &query)
bool CheckReady(shared_ptr< CCassQuery > qry, unsigned int restart_counter, bool &need_repeat)
vector< SQueryRec > m_QueryArr
shared_ptr< CCassQuery > ProduceQuery() const
void Error(CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
@ eDiag_Error
Error message.
#define NCBI_THROW(exception_class, err_code, message)
Generic macro to throw an exception, given the exception class, error code and message string.
const string version
version string
static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)
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