shared_ptr<CCassConnection> connection,
49 const string&keyspace,
54:
CCassBlobWaiter(std::move(connection), keyspace, sat_key,
true, std::move(data_error_cb))
55, m_DoneWhen(done_when)
59shared_ptr<CCassConnection> connection,
60 const string&keyspace,
64:
CCassBlobWaiter(std::move(connection), keyspace, sat_key,
true, std::move(data_error_cb))
69 boolneed_repeat{
false};
82 "SELECT done_when, comment, public_comment, flags, replaces, username, replaces_ids, replaced_by_ids " 84 "WHERE sat_key = ? "+ (
m_DoneWhen.has_value() ?
"and done_when = ?":
"limit 1");
103 m_Record= make_unique<CBlobStatusHistoryRecord>();
106.SetDoneWhen(
query->FieldGetInt64Value(0, 0))
107.SetComment(
query->FieldGetStrValueDef(1,
""))
108.SetPublicComment(
query->FieldGetStrValueDef(2,
""))
109.SetFlags(
query->FieldGetInt64Value(3, 0))
110.SetReplaces(
query->FieldGetInt32Value(4, 0))
111.SetUserName(
query->FieldGetStrValueDef(5,
""));
112vector<int32_t> replaces_ids, replaced_by_ids;
113 query->FieldGetContainerValue(6, back_inserter(replaces_ids));
114 query->FieldGetContainerValue(7, back_inserter(replaced_by_ids));
115 m_Record->SetReplacesIds(std::move(replaces_ids));
116 m_Record->SetReplacedByIds(std::move(replaced_by_ids));
122 if(
query->IsEOF()) {
132snprintf(
msg,
sizeof(
msg),
"Failed to fetch blob status history (key=%i.%ld) unexpected state (%d)",
137}
while(need_repeat);
142unique_ptr<CBlobStatusHistoryRecord>
tmp;
#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
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)
unique_ptr< CBlobStatusHistoryRecord > Consume()
CCassStatusHistoryTaskFetch(shared_ptr< CCassConnection > conn, const string &keyspace, int32_t sat_key, int64_t done_when, TDataErrorCallback data_error_cb)
unique_ptr< CBlobStatusHistoryRecord > m_Record
optional< int64_t > m_DoneWhen
void swap(NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair1, NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair2)
@ eDiag_Error
Error message.
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