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/fetch__split__history_8cpp_source.html below:

NCBI C++ ToolKit: src/objtools/pubseq_gateway/cassandra/blob_task/fetch_split_history.cpp Source File

51

shared_ptr<CCassConnection> connection,

52  const string

& keyspace,

58

std::move(connection), keyspace, sat_key, kAllVersions, std::move(consume_callback), data_error_cb

64

shared_ptr<CCassConnection> connection,

65  const string

& keyspace,

71

:

CCassBlobWaiter

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

true

, std::move(data_error_cb))

72

, m_SplitVersion(split_version)

73

, m_ConsumeCallback(std::move(consume_callback))

86  "CCassBlobTaskFetchSplitHistory: DataReadyCB can't be assigned " 87  "after the loading process has started"

);

94  bool

restarted{

false

};

106  string sql

=

"SELECT split_version, last_modified, id2_info FROM "

+

GetKeySpace

() +

107  ".blob_split_history WHERE sat_key = ?"

;

112  sql

.append(

" and split_version = ?"

);

128  size_t

new_item_idx =

m_Result

.size();

131  m_Result

[new_item_idx].split_version =

query

->FieldGetInt32Value(0, 0);

132  m_Result

[new_item_idx].modified =

query

->FieldGetInt64Value(1, 0);

133  m_Result

[new_item_idx].id2_info =

query

->FieldGetStrValueDef(2,

""

);

135  if

(

query

->IsEOF()) {

144

}

else if

(restarted) {

156

snprintf(

msg

,

sizeof

(

msg

),

"Failed to fetch bioseq info (key=%s.%d.%d) unexpected state (%d)"

,

#define BEGIN_IDBLOB_SCOPE

function< void(CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)> TDataErrorCallback

CCassBlobTaskFetchSplitHistory(shared_ptr< CCassConnection > conn, const string &keyspace, CBlobRecord::TSatKey sat_key, TConsumeCallback consume_callback, TDataErrorCallback data_error_cb)

TConsumeCallback m_ConsumeCallback

unsigned int m_RestartCounter

function< void(vector< SSplitHistoryRecord > &&)> TConsumeCallback

vector< SSplitHistoryRecord > m_Result

SSplitHistoryRecord::TSplitVersion m_SplitVersion

void SetDataReadyCB(shared_ptr< CCassDataCallbackReceiver > callback)

static const SSplitHistoryRecord::TSplitVersion kAllVersions

void SetConsumeCallback(TConsumeCallback callback)

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)

BEGIN_IDBLOB_SCOPE USING_NCBI_SCOPE

@ 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.

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