49 shared_ptr<CCassConnection> connection,
50 const string & keyspace,
58 std::move(connection), keyspace,
60 std::move(data_error_cb)
62 , m_Accession(std::move( accession))
64 , m_SeqIdType(seq_id_type)
65 , m_Consume(std::move( consume_callback))
74 shared_ptr<CCassDataCallbackReceiver> callback)
79 "CCassAccVerHistoryTaskFetch: DataReadyCB can't be assigned "
80 "after the loading process has started");
87 bool restarted =
false;
104 " version, gi, date, chain, id_type, sat, sat_key"
108 unsigned int params = 1;
111 sql +=
" AND version = ?";
116 sql +=
" AND id_type = ? ALLOW FILTERING";
123 unsigned int param = 1;
151 record.
gi =
m_QueryArr[0].query->FieldGetInt64Value( 1, 0);
160 do_next =
m_Consume( std::move( record),
false);
190 snprintf(
msg,
sizeof(
msg),
191 "Failed to fetch accession history (key=%s.%s|%hd|%hd) unexpected state (%d)",
#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)