& keyspace,
62, m_ConsumeCallback(consume_callback)
74 "CCassSI2CSITaskFetch: DataReadyCB can't be assigned after the loading process has started");
81 static const string s_Select=
"SELECT sec_seq_id_type, accession, gi, sec_seq_state, " 82 "seq_id_type, version, writetime(accession) FROM ";
83 static const strings_Where_1 =
".SI2CSI WHERE sec_seq_id = ?";
84 static const strings_Where_2 = s_Where_1 +
" AND sec_seq_id_type = ?";
88 sql.append(s_Where_2);
93 sql.append(s_Where_1);
101 boolrestarted{
false};
132.SetSecSeqIdType(sec_seqid_type)
148}
else if(restarted) {
161snprintf(
msg,
sizeof(
msg),
"Failed to fetch canonical seq id (key=%s|%s|%d) unexpected state (%d)",
162keyspace.c_str(), sec_seqid.c_str(),
#define BEGIN_IDBLOB_SCOPE
function< void(CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)> TDataErrorCallback
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)
TSI2CSIConsumeCallback m_ConsumeCallback
unsigned int m_RestartCounter
void SetDataReadyCB(shared_ptr< CCassDataCallbackReceiver > callback)
vector< CSI2CSIRecord > m_Records
void SetConsumeCallback(TSI2CSIConsumeCallback callback)
CSi2CsiFetchRequest m_Request
CSI2CSIRecord::TSecSeqIdType GetSecSeqIdType() const
CSI2CSIRecord::TSecSeqId GetSecSeqId() const
bool HasField(EFields field) const
@ 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.
#define END_SCOPE(ns)
End the previously defined scope.
#define BEGIN_SCOPE(ns)
Define a new scope.
static EIO_Status s_Select(size_t n, SSOCK_Poll polls[], const struct timeval *tv, int asis)
function< void(vector< CSI2CSIRecord > &&)> TSI2CSIConsumeCallback
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