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

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

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;

144  bool

do_next =

true

;

151

record.

gi

=

m_QueryArr

[0].query->FieldGetInt64Value( 1, 0);

155

record.

sat

=

m_QueryArr

[0].query->FieldGetInt16Value( 5, 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)"

,

198

}

while

( restarted);

#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)


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