A RetroSearch Logo

Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Search Query:

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/status__history_2fetch_8cpp_source.html below:

NCBI C++ ToolKit: src/objtools/pubseq_gateway/cassandra/status_history/fetch.cpp Source File

48

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)

59

shared_ptr<CCassConnection> connection,

60  const string

&keyspace,

64

:

CCassBlobWaiter

(std::move(connection), keyspace, sat_key,

true

, std::move(data_error_cb))

69  bool

need_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,

""

));

112

vector<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()) {

132

snprintf(

msg

,

sizeof

(

msg

),

"Failed to fetch blob status history (key=%i.%ld) unexpected state (%d)"

,

137

}

while

(need_repeat);

142

unique_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