m_FinishedRead(
false),
65m_ExcludeBlobCacheUpdated(
false)
70m_FinishedRead(
false),
74m_ClientId(client_id),
76m_ExcludeBlobCacheUpdated(
false)
80{ RemoveFromExcludeBlobCache(); }
87{
returnm_Loader.get(); }
90{ m_FinishedRead =
true; }
93{
returnm_FetchType; }
96{
returnm_FinishedRead; }
105{
returnm_Canceled; }
128{
returnm_ClientId; }
130 voidRemoveFromExcludeBlobCache(
void);
135{ m_ExcludeBlobCacheUpdated =
value; }
137 voidSetExcludeBlobCacheCompleted(
void);
186 for(
const string& name : m_Names) {
187 if(!
names.empty())
191 return "CCassNamedAnnotFetch. Keyspace: "+ m_Keyspace +
" Names: "+
names;
199m_Loader.reset(fetch);
206 virtual voidResetCallbacks(
void);
230 return "CCassAccVerHistoryFetch";
235{ m_Loader.reset(fetch); }
241 virtual voidResetCallbacks(
void);
250 CCassFetch(blob_request.m_ClientId, blob_id),
251m_TSEOption(blob_request.m_TSEOption),
252m_BlobPropSent(
false),
253m_UserProvidedBlobId(
false),
254m_TotalSentBlobChunks(0),
256m_BlobChunkItemId(0),
257m_NeedAddId2ChunkId2Info(
false)
264 CCassFetch(blob_request.m_ClientId, blob_id),
265m_TSEOption(blob_request.m_TSEOption),
266m_BlobPropSent(
false),
267m_UserProvidedBlobId(
true),
268m_TotalSentBlobChunks(0),
270m_BlobChunkItemId(0),
271m_NeedAddId2ChunkId2Info(
false)
278 CCassFetch(blob_request.m_ClientId, blob_id),
279m_TSEOption(blob_request.m_TSEOption),
280m_BlobPropSent(
false),
281m_UserProvidedBlobId(
true),
282m_TotalSentBlobChunks(0),
284m_BlobChunkItemId(0),
285m_NeedAddId2ChunkId2Info(
false)
294 return "CCassBlobFetch; BlobId: "+ m_BlobId.ToString() +
295 " BlobPropSent: "+ to_string(m_BlobPropSent) +
296 " TotalSentBlobChunks: "+ to_string(m_TotalSentBlobChunks);
308m_BlobPropSent(
false),
309m_UserProvidedBlobId(
false),
310m_TotalSentBlobChunks(0),
312m_BlobChunkItemId(0),
313m_NeedAddId2ChunkId2Info(
false)
320m_BlobPropSent(
false),
321m_UserProvidedBlobId(
true),
322m_TotalSentBlobChunks(0),
324m_BlobChunkItemId(0),
325m_NeedAddId2ChunkId2Info(
false)
336{
returnm_TSEOption; }
339{
returnm_UserProvidedBlobId; }
342{
returnm_TotalSentBlobChunks; }
345{ ++m_TotalSentBlobChunks; }
348{ m_TotalSentBlobChunks = 0; }
351{ m_BlobPropSent =
true; }
356{
return!m_BlobPropSent; }
359{ m_NeedAddId2ChunkId2Info =
val; }
362{
returnm_NeedAddId2ChunkId2Info; }
365{ m_Loader.reset(fetch); }
374 virtual voidResetCallbacks(
void);
413 return "CCassBioseqInfoFetch";
418{ m_Loader.reset(fetch); }
424 virtual voidResetCallbacks(
void);
441 return "CCassSi2csiFetch";
446{ m_Loader.reset(fetch); }
452 virtual voidResetCallbacks(
void);
463m_Chunk(chunk_request.m_Id2Chunk),
464m_SplitVersion(split_version),
465m_UseCache(chunk_request.m_UseCache)
475 return "CCassSplitHistoryFetch";
486{
returnm_SplitVersion; }
489{
returnm_UseCache; }
492{ m_Loader.reset(fetch); }
498 virtual voidResetCallbacks(
void);
518m_Identification(ePSGS_ByCassBlob),
530 return "CCassPublicCommentFetch";
536 returnm_Identification;
542m_Identification = ePSGS_ByCassBlob;
544m_LastModified = last_modified;
548 const string& id2_info)
550m_Identification = ePSGS_ById2;
551m_Id2Chunk = id2_chunk;
552m_Id2Info = id2_info;
559{
returnm_LastModified; }
562{
returnm_Id2Chunk; }
565{
returnm_Id2Info; }
568{ m_Loader.reset(fetch); }
574 virtual voidResetCallbacks(
void);
606 return "CCassIPGFetch";
611{ m_Loader.reset(fetch); }
617 virtual voidResetCallbacks(
void);
CCassAccVerHistoryFetch(const SPSGS_AccessionVersionHistoryRequest &acc_version_history_request)
void SetLoader(CCassAccVerHistoryTaskFetch *fetch)
virtual string Serialize(void) const
virtual ~CCassAccVerHistoryFetch()
CCassAccVerHistoryFetch()
CCassAccVerHistoryTaskFetch * GetLoader(void)
CCassBioseqInfoTaskFetch * GetLoader(void)
void SetLoader(CCassBioseqInfoTaskFetch *fetch)
virtual string Serialize(void) const
virtual ~CCassBioseqInfoFetch()
bool m_UserProvidedBlobId
void IncrementTotalSentBlobChunks(void)
CCassBlobFetch(const SPSGS_BlobBySatSatKeyRequest &blob_request, const SCass_BlobId &blob_id)
void SetLoader(CCassBlobTaskLoadBlob *fetch)
CCassBlobFetch(const SPSGS_BlobBySeqIdRequest &blob_request, const SCass_BlobId &blob_id)
CCassBlobFetch(const SPSGS_AnnotRequest &blob_request, const SCass_BlobId &blob_id)
void SetBlobPropSent(void)
bool GetNeedAddId2ChunkId2Info(void) const
int32_t GetTotalSentBlobChunks(void) const
CCassBlobTaskLoadBlob * GetLoader(void)
bool GetUserProvidedBlobId(void) const
SPSGS_BlobRequestBase::EPSGS_TSEOption m_TSEOption
void SetNeedAddId2ChunkId2Info(bool val)
virtual ~CCassBlobFetch()
virtual string Serialize(void) const
SPSGS_BlobRequestBase::EPSGS_TSEOption GetTSEOption(void) const
CCassBlobFetch(const SPSGS_TSEChunkRequest &chunk_request, const SCass_BlobId &tse_id)
int32_t m_TotalSentBlobChunks
bool IsBlobPropStage(void) const
bool m_NeedAddId2ChunkId2Info
void ResetTotalSentBlobChunks(void)
string GetKeySpace() const
virtual void ResetCallbacks(void)=0
void SetReadFinished(void)
bool IsBlobFetch(void) const
bool ReadFinished(void) const
string GetClientId(void) const
bool Canceled(void) const
EPSGS_DbFetchType m_FetchType
SCass_BlobId GetBlobId(void) const
void SetExcludeBlobCacheUpdated(bool value)
unique_ptr< CCassBlobWaiter > m_Loader
CCassBlobWaiter * GetLoader(void)
virtual string Serialize(void) const =0
EPSGS_DbFetchType GetFetchType(void) const
CCassFetch(const string &client_id, const SCass_BlobId &blob_id)
bool m_ExcludeBlobCacheUpdated
void SetLoader(CPubseqGatewayFetchIpgReport *fetch)
virtual string Serialize(void) const
CCassIPGFetch(const SPSGS_IPGResolveRequest &ipg_resolve_request)
CPubseqGatewayFetchIpgReport * GetLoader(void)
vector< string > GetAnnotNames() const
virtual string Serialize(void) const
CCassNAnnotTaskFetch * GetLoader(void)
virtual ~CCassNamedAnnotFetch()
CCassNamedAnnotFetch(const SPSGS_AnnotRequest &annot_request)
void SetLoader(CCassNAnnotTaskFetch *fetch)
void SetLoader(CCassSI2CSITaskFetch *fetch)
virtual string Serialize(void) const
virtual ~CCassSi2csiFetch()
CCassSI2CSITaskFetch * GetLoader(void)
CCassBlobTaskFetchSplitHistory * GetLoader(void)
SCass_BlobId GetTSEId(void) const
int64_t GetChunk(void) const
SPSGS_RequestBase::EPSGS_CacheAndDbUse m_UseCache
CCassSplitHistoryFetch(const SPSGS_TSEChunkRequest &chunk_request, const SCass_BlobId &tse_id, int64_t split_version)
virtual ~CCassSplitHistoryFetch()
virtual string Serialize(void) const
SPSGS_RequestBase::EPSGS_CacheAndDbUse GetUseCache(void) const
void SetLoader(CCassBlobTaskFetchSplitHistory *fetch)
int64_t GetSplitVersion(void) const
static const struct name_t names[]
const GenericPointer< typename T::ValueType > T2 value
@ ePSGS_BlobBySatSatKeyFetch
@ ePSGS_SplitHistoryFetch
@ ePSGS_AnnotationBlobFetch
@ ePSGS_PublicCommentFetch
@ ePSGS_AccVerHistoryFetch
psg_clock_t::time_point psg_time_point_t
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