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

NCBI C++ ToolKit: src/app/pubseq_gateway/server/psgs_request.cpp Source File

68

m_ConcurrentProcessorCount(0)

75  switch

(it.second->m_State) {

83  PSG_ERROR

(

"Reply is going to be deleted when a processor has " 84  "not unlocked an event"

);

93  PSG_ERROR

(

"Reply is going to be deleted when a processor is " 94  "locked on a condition variable"

);

95

it.second->m_WaitObject.notify_all();

104

unique_ptr<SPSGS_RequestBase> req,

106

m_HttpRequest(http_request),

107

m_Request(std::move(req)),

108

m_RequestContext(request_context),

111

m_ConcurrentProcessorCount(0)

133  "Multiple lock of the same event is not supported"

);

148  auto

it =

m_Wait

.find(event_name);

149  if

(it ==

m_Wait

.end()) {

154  switch

(it->second->m_State) {

162

it->second->m_WaitCount = 0;

164

it->second->m_WaitObject.notify_all();

179  auto

it =

m_Wait

.find(event_name);

180  if

(it ==

m_Wait

.end()) {

185  switch

(it->second->m_State) {

195

++it->second->m_WaitCount;

197  auto

status = it->second->m_WaitObject.wait_for(scope_lock,

198

chrono::seconds(timeout_sec));

199  if

(status == cv_status::timeout) {

202  if

(--it->second->m_WaitCount == 0)

205  string

message =

"Timeout ("

+ to_string(timeout_sec) +

206  " seconds) waiting on event '"

+ event_name +

"'"

;

240  "User request is not initialized"

);

250  "User request is not initialized"

);

260  "User request is not initialized"

);

271  return

GetRequest<SPSGS_BlobRequestBase>().m_IncludeHUP;

273  return

GetRequest<SPSGS_TSEChunkRequest>().m_IncludeHUP;

282  return

optional<bool>();

285  "User request is not initialized"

);

294  return

GetRequest<SPSGS_ResolveRequest>().m_Hops;

298  return

GetRequest<SPSGS_BlobRequestBase>().m_Hops;

300  return

GetRequest<SPSGS_TSEChunkRequest>().m_Hops;

302  return

GetRequest<SPSGS_AccessionVersionHistoryRequest>().m_Hops;

312  "User request is not initialized"

);

320  return "unknown (request is not initialized)"

;

349  msg

+=

"processor: "

+ item.first +

350  ", concurrency limit: "

+ to_string(item.second);

361  auto

now = psg_clock_t::now();

362  uint64_t

mks = chrono::duration_cast<chrono::microseconds>

370

json.

SetByKey

(

"enabled processors"

, enabled_procs);

376

json.

SetByKey

(

"disabled processors"

, disabled_procs);

419

json.

SetByKey

(

"exclude blobs"

, exclude_blobs);

453  for

(

const auto

& name :

m_Names

) {

454  names

.AppendString(name);

461  for

(

const auto

& seq_id :

m_SeqIds

) {

464

json.

SetByKey

(

"seq ids"

, seq_ids);

495

json.

SetString

(

"protein"

,

"<null>"

);

500

json.

SetString

(

"nucleotide"

,

"<null>"

);

520  if

(item.second == name) {

521

ret =

max

(ret, item.first);

551  if

(item.first >= priority) {

552  auto

it = find(ret.begin(), ret.end(), item.second);

553  if

(it != ret.end()) {

565  if

(item.second == annot_name)

572

vector<pair<TProcessorPriority, string>>

598  if

(it->second <

int

(rs)) {

599

it->second =

int

(rs);

622  if

(it->first == priority && it->second ==

m_Names

[0]) {

643  if

(it->second <

int

(rs)) {

644

it->second =

int

(rs);

static CJsonNode NewArrayNode()

Create a new JSON array node.

void SetString(const string &key, const string &value)

Set a JSON object element to the specified string value.

void AppendString(const string &value)

For an array node, add a string node at the end of the array.

void SetBoolean(const string &key, bool value)

Set a JSON object element to the specified boolean value.

void SetInteger(const string &key, Int8 value)

Set a JSON object element to the specified integer value.

void SetByKey(const string &key, CJsonNode::TInstance value)

For a JSON object node, insert a new element or update an existing element.

static CJsonNode NewObjectNode()

Create a new JSON object node.

void WaitFor(const string &event_name, size_t timeout_sec=10)

void Lock(const string &event_name)

map< string, SWaitData * > m_Wait

void SetRequestContext(void)

optional< bool > GetIncludeHUP(void)

virtual CJsonNode Serialize(void) const

CRef< CRequestContext > GetRequestContext(void)

EPSGS_Type GetRequestType(void) const

string GetLimitedProcessorsMessage(void)

CRef< CRequestContext > m_RequestContext

unique_ptr< SPSGS_RequestBase > m_Request

size_t m_ConcurrentProcessorCount

void Unlock(const string &event_name)

bool NeedProcessorEvents(void)

vector< pair< string, size_t > > m_LimitedProcessors

uint64_t m_BacklogTimeMks

@ ePSGS_AnnotationRequest

@ ePSGS_BlobBySatSatKeyRequest

@ ePSGS_IPGResolveRequest

@ ePSGS_AccessionVersionHistoryRequest

@ ePSGS_BlobBySeqIdRequest

psg_time_point_t GetStartTimestamp(void) const

virtual string GetName(void) const

const_iterator end() const

const_iterator find(const key_type &key) const

iterator_bool insert(const value_type &val)

The NCBI C++ standard methods for dealing with std::string.

static const struct name_t names[]

static void SetRequestContext(CRequestContext *ctx)

Shortcut to CDiagContextThreadData::GetThreadData().SetRequestContext()

static CRequestContext & GetRequestContext(void)

Shortcut to CDiagContextThreadData::GetThreadData().GetRequestContext()

CRef< CRequestContext > Clone(void) const

Copy current request context to a new one.

void SetReadOnly(bool read_only)

Switch request context to read-only mode.

#define NCBI_THROW(exception_class, err_code, message)

Generic macro to throw an exception, given the exception class, error code and message string.

unsigned int

A callback function used to compare two keys in a database.

size_t GetNextRequestId(void)

static atomic< bool > s_RequestIdLock(false)

static size_t s_NextRequestId

#define PSG_ERROR(message)

#define PSG_WARNING(message)

const int kUnknownPriority

psg_clock_t::time_point psg_time_point_t

long PSGToString(long signed_value, char *buf)

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

@ ePSGS_LockedSomebodyWaits

@ ePSGS_LockedNobodyWaits

virtual string GetName(void) const

virtual CJsonNode Serialize(void) const

EPSGS_CacheAndDbUse m_UseCache

TProcessorPriority RegisterProcessedName(TProcessorPriority priority, const string &name)

bool WasSent(const string &annot_name) const

map< string, int > m_ErrorAnnotations

vector< string > GetNotProcessedName(TProcessorPriority priority)

vector< pair< TProcessorPriority, string > > m_Processed

vector< pair< TProcessorPriority, string > > GetProcessedNames(void) const

vector< string > m_SeqIds

TProcessorPriority RegisterBioseqInfo(TProcessorPriority priority)

virtual string GetName(void) const

void ReportBlobError(TProcessorPriority priority, EPSGS_ResultStatus rs)

unsigned long m_ResendTimeoutMks

void ReportResultStatus(const string &annot_name, EPSGS_ResultStatus rs)

TProcessorPriority m_ProcessedBioseqInfo

virtual CJsonNode Serialize(void) const

virtual CJsonNode Serialize(void) const

virtual string GetName(void) const

CBlobRecord::TTimestamp m_LastModified

virtual CJsonNode Serialize(void) const

virtual string GetName(void) const

vector< string > m_ExcludeBlobs

unsigned long m_ResendTimeoutMks

EPSGS_AccSubstitutioOption m_AccSubstOption

EPSGS_CacheAndDbUse m_UseCache

static string TSEOptionToString(EPSGS_TSEOption option)

void AppendCommonParameters(CJsonNode &json) const

unsigned long m_SendBlobIfSmall

EPSGS_TSEOption m_TSEOption

optional< string > m_Protein

EPSGS_CacheAndDbUse m_UseCache

optional< string > m_Nucleotide

virtual CJsonNode Serialize(void) const

virtual string GetName(void) const

static string TraceToString(EPSGS_Trace trace)

static string CacheAndDbUseToString(EPSGS_CacheAndDbUse option)

vector< string > m_DisabledProcessors

vector< string > m_EnabledProcessors

static string AccSubstitutioOptionToString(EPSGS_AccSubstitutioOption option)

psg_time_point_t m_StartTimestamp

void AppendCommonParameters(CJsonNode &json) const

static string OutputFormatToString(EPSGS_OutputFormat format)

EPSGS_CacheAndDbUse m_UseCache

virtual CJsonNode Serialize(void) const

virtual string GetName(void) const

TPSGS_BioseqIncludeData m_IncludeDataFlags

EPSGS_OutputFormat m_OutputFormat

EPSGS_AccSubstitutioOption m_AccSubstOption

virtual CJsonNode Serialize(void) const

EPSGS_CacheAndDbUse m_UseCache

virtual string GetName(void) const


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