NCBI C++ ToolKit
Public Types | Public Member Functions | Private Attributes | List of all members
NDirectNetStorageImpl::CROFileTrack Class Reference

Search Toolkit Book for NDirectNetStorageImpl::CROFileTrack

#include "state.hpp"
(Private to src/misc/netstorage.)

+ Inheritance diagram for NDirectNetStorageImpl::CROFileTrack:
+ Collaboration diagram for NDirectNetStorageImpl::CROFileTrack:

Public Types

typedef CRef< SFileTrackDownloadTRequest

Public Member Functions

 CROFileTrack (bool *cancel_relocate)
void Set (TRequest request)
ERW_Result Read (void *buf, size_t count, size_t *read) override
 Read as many as "count" bytes into a buffer pointed to by the "buf" argument. More...
ERW_Result PendingCount (size_t *count) override
 Via parameter "count" (which is guaranteed to be supplied non-NULL) return the number of bytes that are ready to be read from the input device without blocking. More...
bool Eof () override
void Close () override
void Abort () override
- Public Member Functions inherited from NDirectNetStorageImpl::CROState
 CROState (bool *cancel_relocate)
void CancelRelocate () override
- Public Member Functions inherited from SNetStorageObjectIState
ERW_Result Write (const void *buf, size_t count, size_t *written) final
 Write up to "count" bytes from the buffer pointed to by the "buf" argument onto the output device. More...
ERW_Result Flush () final
 Flush pending data (if any) down to the output device. More...
- Public Member Functions inherited from SNetStorageObjectIoState
Uint8 GetSize () final
list< stringGetAttributeList () const final
string GetAttribute (const string &name) const final
void SetAttribute (const string &name, const string &value) final
CNetStorageObjectInfo GetInfo () final
void SetExpiration (const CTimeout &ttl) final
string FileTrack_Path () final
string Relocate (TNetStorageFlags flags, TNetStorageProgressCb cb) final
bool Exists () final
ENetStorageRemoveResult Remove () final
- Public Member Functions inherited from INetStorageObjectState
virtual string GetLoc () const =0
virtual pair< string, stringGetUserInfo ()
virtual CNetStorageObjectLocLocator ()
- Public Member Functions inherited from IReader
virtual ERW_Result Pushback (const void *buf, size_t count, void *del_ptr=0)
 This method gets called by RStream buffer destructor to return buffered yet still unread (from the stream) portion of data back to the device. More...
virtual ~IReader ()
- Public Member Functions inherited from IWriter
virtual ~IWriter ()

Private Attributes

TRequest m_Request

Additional Inherited Members

- Protected Member Functions inherited from INetStorageObjectState
void EnterState (INetStorageObjectState *state)
void ExitState ()

Detailed Description

Definition at line 207 of file state.hpp.

Member Typedef Documentation

◆ TRequest

Definition at line 210 of file state.hpp.

Constructor & Destructor Documentation

◆ CROFileTrack()

NDirectNetStorageImpl::CROFileTrack::CROFileTrack ( bool cancel_relocate)

Definition at line 212 of file state.hpp.

Member Function Documentation

◆ Abort()

void NDirectNetStorageImpl::CROFileTrack::Abort ( void  )

◆ Close()

void NDirectNetStorageImpl::CROFileTrack::Close ( void  )

◆ Eof()

bool NDirectNetStorageImpl::CROFileTrack::Eof ( void  )

Implements INetStorageObjectState.

Definition at line 174 of file state.cpp.

References SFileTrackDownload::Eof(), and m_Request.

◆ PendingCount()

ERW_Result NDirectNetStorageImpl::CROFileTrack::PendingCount ( size_t *  count)

Via parameter "count" (which is guaranteed to be supplied non-NULL) return the number of bytes that are ready to be read from the input device without blocking.

Return eRW_Success if the number of pending bytes has been stored at the location pointed to by "count". Return eRW_NotImplemented if the number cannot be determined. Otherwise, return other eRW_... condition to reflect the problem ("*count" does not need to be updated in the case of non-eRW_Success). Note that if reporting 0 bytes ready, the method may return either both eRW_Success and zero "*count", or return eRW_NotImplemented alone.

Implements IReader.

Definition at line 167 of file state.cpp.

References eRW_Success.

◆ Read()

ERW_Result NDirectNetStorageImpl::CROFileTrack::Read ( void *  buf,
size_t  count,
size_t *  bytes_read 

Read as many as "count" bytes into a buffer pointed to by the "buf" argument.

Always store the number of bytes actually read (0 if read none) via the pointer "bytes_read", if provided non-NULL. Return non-eRW_Success code if EOF / error condition has been encountered during the operation (some data may have been read, nevertheless, and reflected in "*bytes_read"). Special case: if "count" is passed as 0, then the value of "buf" must be ignored, and no change should be made to the state of the input device (but may return non-eRW_Success to indicate that the input device has already been in an error condition).

Apparently, may not return eRW_Success if hasn't been able to read "count" bytes as requested, and "bytes_read" was provided as NULL.
When returning "*bytes_read" as zero for a non-zero "count" requested, the return status should not indicate eRW_Success.
"*bytes_read" may never be returned greater than "count".
It is implementation-dependent whether the call blocks until the entire buffer is read or the call returns when at least some data are available. In general, it is advised that this call is made within a loop that checks for EOF condition and proceeds with the reading until the required amount of data has been retrieved.

Implements IReader.

Definition at line 161 of file state.cpp.

References buf, m_Request, and SFileTrackDownload::Read().

◆ Set()

void NDirectNetStorageImpl::CROFileTrack::Set ( TRequest  request)

Definition at line 214 of file state.hpp.

References m_Request.

Member Data Documentation

◆ m_Request

TRequest NDirectNetStorageImpl::CROFileTrack::m_Request

Definition at line 227 of file state.hpp.

Referenced by Abort(), Close(), Eof(), Read(), and Set().

The documentation for this class was generated from the following files:
Modified on Mon Mar 04 05:10:15 2024 by rev. 669887