(low_level_reply.release()),
115 void SendOk(
const char* payload,
size_tpayload_len,
boolis_persist);
116 void Send202(
const char* payload,
size_tpayload_len);
117 void Send400(
const char* payload);
118 void Send401(
const char* payload);
119 void Send404(
const char* payload);
120 void Send409(
const char* payload);
121 void Send500(
const char* payload);
122 void Send502(
const char* payload);
123 void Send503(
const char* payload);
126shared_ptr<idblob::CCassDataCallbackReceiver>
GetDataReadyCB(
void);
163 const string& peer_user_agent);
170 const string& processor_id,
175 const string& processor_id,
176 const string& content,
179 const string& processor_id,
182 const string& processor_id,
188 const string& processor_id,
194 const string& processor_id,
196 const string& id2_info,
202 const string& processor_id,
203 const string& blob_id,
204 const string& content,
207 const string& processor_id,
208 const string& content,
211 const string& processor_id,
213 const string& id2_info,
214 const string& content);
216 const string& processor_id,
218 const string& id2_info,
219 const string& content);
221 const string& processor_id,
222 const string& blob_id,
223 const unsigned char* chunk_data,
224 unsigned intdata_size,
228 const string& processor_id,
229 const unsigned char* chunk_data,
230 unsigned intdata_size,
234 const string& processor_id,
235 const unsigned char* chunk_data,
236 unsigned intdata_size,
239 const string& id2_info);
241 const string& processor_id,
242 const unsigned char* chunk_data,
243 unsigned intdata_size,
246 const string& id2_info);
248 const string& processor_id,
251 const string& processor_id);
253 const string& processor_id);
255 const string& processor_id,
256 const string& blob_id,
263 const string& processor_id,
269 const string& processor_id,
271 const string& id2_info,
276 const string& processor_id,
279 const string& processor_id,
282 const string& processor_id);
284 const string& processor_id,
288 const string& processor_id,
289 const string& blob_id,
292 const string& processor_id,
293 unsigned longsent_mks_ago,
294 unsigned longuntil_resend_mks,
299 const string& blob_id,
301 const string& id2_info);
305 const string& id2_info,
306 const string& processor_id,
307 unsigned longsent_mks_ago,
308 unsigned longuntil_resend_mks);
310 const string& processor_id);
316 const string& public_comment,
317 const string& blob_id,
320 const string& public_comment,
322 const string& id2_info);
326 boolneed_update_last_activity=
true);
328 const string& processor_id,
329 const string& content);
332 const string& content);
334 const string& content);
342 const string& progress_status);
352 boolneed_update_last_activity=
true);
356 const string& processor_id,
359 const string& processor_id,
361 const string& id2_info,
367 const string& processor_id,
369 const string& id2_info,
void x_PrepareTSEBlobMessage(size_t item_id, const string &processor_id, int64_t id2_chunk, const string &id2_info, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
void PrepareBlobData(size_t item_id, const string &processor_id, const string &blob_id, const unsigned char *chunk_data, unsigned int data_size, int chunk_no, CBlobRecord::TTimestamp last_modified=-1)
void PrepareIPGResolveData(const string &processor_id, const string &content)
void x_PrepareTSEBlobPropMessage(size_t item_id, const string &processor_id, int64_t id2_chunk, const string &id2_info, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
void PrepareBioseqCompletion(size_t item_id, const string &processor_id, size_t chunk_count)
void PrepareBlobExcluded(const string &blob_id, const string &processor_id, EPSGS_BlobSkipReason skip_reason, CBlobRecord::TTimestamp last_modified=-1)
psg_time_point_t m_LastActivityTimestamp
void PrepareProcessorProgressMessage(const string &processor_id, const string &progress_status)
void PrepareTSEBlobPropMessage(CCassBlobFetch *fetch_details, const string &processor_id, int64_t id2_chunk, const string &id2_info, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
void SendPerNamedAnnotationResults(const string &content)
shared_ptr< idblob::CCassDataCallbackReceiver > GetDataReadyCB(void)
void UpdatePeerUserAgent(const string &peer_user_agent)
size_t GetBytesSent(void) const
void IncrementRejectedDueToSoftLimit(void)
int32_t m_TotalSentReplyChunks
int64_t GetConnectionId(void) const
void PrepareIPGInfoMessageAndMeta(const string &processor_id, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
void PrepareBlobCompletion(size_t item_id, const string &processor_id, size_t chunk_count)
void ConnectionCancel(void)
void SetContentLength(uint64_t content_length)
void PrepareBioseqData(size_t item_id, const string &processor_id, const string &content, SPSGS_ResolveRequest::EPSGS_OutputFormat output_format)
void PrepareBlobPropCompletion(size_t item_id, const string &processor_id, size_t chunk_count)
void SendTrace(const string &msg, const psg_time_point_t &create_timestamp, bool need_update_last_activity=true)
void SetContentType(EPSGS_ReplyMimeType mime_type)
void PrepareBlobMessage(size_t item_id, const string &processor_id, const string &blob_id, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity, CBlobRecord::TTimestamp last_modified=-1)
void PrepareTSEBlobPropCompletion(CCassBlobFetch *fetch_details, const string &processor_id)
void PrepareBlobPropData(size_t item_id, const string &processor_id, const string &blob_id, const string &content, CBlobRecord::TTimestamp last_modified=-1)
void x_PrepareTSEBlobPropCompletion(size_t item_id, const string &processor_id, size_t chunk_count)
unsigned long GetTimespanFromLastActivityToNowMks(void) const
void Send400(const char *payload)
void Send404(const char *payload)
void PrepareTSEBlobMessage(CCassBlobFetch *fetch_details, const string &processor_id, int64_t id2_chunk, const string &id2_info, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
size_t GetRequestId(void) const
void PrepareReplyMessage(const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity, bool need_update_last_activity=true)
bool IsOutputReady(void) const
psg_time_point_t GetLastActivityTimestamp(void) const
void SetRequestId(size_t request_id)
void PreparePublicComment(const string &processor_id, const string &public_comment, const string &blob_id, CBlobRecord::TTimestamp last_modified)
void PrepareNamedAnnotationData(const string &annot_name, const string &processor_id, const string &content)
bool IsClosed(void) const
bool IsCompleted(void) const
void Send503(const char *payload)
bool GetExceedSoftLimitFlag(void) const
void Send409(const char *payload)
void Send401(const char *payload)
void PrepareProcessorMessage(size_t item_id, const string &processor_id, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
void x_UpdateLastActivity(void)
void PrepareTSEBlobExcluded(const string &processor_id, EPSGS_BlobSkipReason skip_reason, const string &blob_id, int64_t id2_chunk, const string &id2_info)
void PrepareAccVerHistoryData(const string &processor_id, const string &content)
void PrepareTSEBlobPropData(size_t item_id, const string &processor_id, int64_t id2_chunk, const string &id2_info, const string &content)
void PrepareTSEBlobData(size_t item_id, const string &processor_id, const unsigned char *chunk_data, unsigned int data_size, int chunk_no, int64_t id2_chunk, const string &id2_info)
void Send502(const char *payload)
void PrepareTSEBlobCompletion(size_t item_id, const string &processor_id, size_t chunk_count)
atomic< bool > m_NextItemIdLock
void PrepareBlobPropMessage(size_t item_id, const string &processor_id, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
void Send202(const char *payload, size_t payload_len)
void PrepareBioseqMessage(size_t item_id, const string &processor_id, const string &msg, CRequestStatus::ECode status, int err_code, EDiagSev severity)
void PrepareReplyCompletion(CRequestStatus::ECode status, const psg_time_point_t &create_timestamp)
vector< h2o_iovec_t > m_Chunks
CHttpReply * GetHttpReply(void)
void UpdatePeerId(const string &peer_id)
volatile bool m_ConnectionCanceled
CPSGS_Reply(unique_ptr< CHttpReply > low_level_reply)
void ResetExceedSoftLimitFlag(void)
void UpdatePeerIdAndUserAgent(const string &peer_id, const string &peer_user_agent)
void PrepareRequestTimeoutMessage(const string &msg)
void Send500(const char *payload)
void Flush(EPSGS_ReplyFlush how)
bool IsFinished(void) const
CPSGS_Reply(CHttpReply *low_level_reply)
void SendOk(const char *payload, size_t payload_len, bool is_persist)
uint16_t GetConnCntAtOpen(void) const
EDiagSev
Severity level for the posted diagnostics.
chrono::steady_clock psg_clock_t
psg_clock_t::time_point psg_time_point_t
unsigned long GetTimespanToNowMks(const psg_time_point_t &t_point)
Defines CRequestStatus class for NCBI C++ diagnostic API.
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