Public Member Functions | |
uint64_t | readBlobChunk (PBMSBlobIDPtr blob_id, uint64_t rep_offset, uint64_t blob_offset, uint64_t buffer_size, char *buffer) |
void | writeBlobChunk (PBMSBlobIDPtr blob_id, uint64_t rep_offset, uint64_t blob_offset, uint64_t data_size, char *data) |
void | sendBlob (MSOpenTable *otab, uint64_t offset, uint64_t req_offset, uint64_t req_size, uint32_t auth_code, bool with_auth_code, bool info_only, CSHTTPOutputStream *stream) |
void | referenceBlob (MSOpenTable *otab, uint64_t offset, uint16_t head_size, uint32_t tab_id, uint64_t blob_id, uint64_t blob_ref_id, uint32_t auth_code, uint16_t col_index) |
void | setBlobMetaData (MSOpenTable *otab, uint64_t offset, const char *meta_data, uint16_t meta_data_len, bool reset_alias, const char *alias) |
void | releaseBlob (MSOpenTable *otab, uint64_t offset, uint16_t head_size, uint32_t tab_id, uint64_t blob_id, uint64_t blob_ref_id, uint32_t auth_code) |
void | commitBlob (MSOpenTable *otab, uint64_t offset, uint16_t head_size, uint32_t tab_id, uint64_t blob_id, uint64_t blob_ref_id, uint32_t auth_code) |
void | freeTableReference (MSOpenTable *otab, uint64_t offset, uint16_t head_size, uint32_t tab_id, uint64_t blob_id, uint32_t auth_code) |
void | checkBlob (CSStringBuffer *buffer, uint64_t offset, uint32_t auth_code, uint32_t temp_log_id, uint32_t temp_log_offset) |
void | updateAccess (MSBlobHeadPtr blob, uint64_t rep_offset) |
virtual void | returnToPool () |
virtual CSObject * | getNextLink () |
virtual CSObject * | getPrevLink () |
virtual void | setNextLink (CSObject *link) |
virtual void | setPrevLink (CSObject *link) |
CSOutputStream * | getOutputStream () |
CSOutputStream * | getOutputStream (off64_t offset) |
CSInputStream * | getInputStream () |
CSInputStream * | getInputStream (off64_t offset) |
virtual void | open (int mode) |
virtual void | lock () |
virtual void | unlock () |
virtual void | close () |
void | md5Digest (Md5Digest *digest) |
virtual off64_t | getEOF () |
virtual void | setEOF (off64_t offset) |
virtual size_t | read (void *data, off64_t offset, size_t size, size_t min_size) |
virtual void | write (const void *data, off64_t offset, size_t size) |
virtual void | flush () |
virtual void | sync () |
virtual void | touch () |
virtual const char * | getEOL () |
virtual const char * | getPathString () |
bool | exists () |
void | streamOut (CSOutputStream *dst_stream, off64_t src_offset, off64_t size, char *buffer, size_t buffer_size) |
void | streamIn (CSInputStream *src_stream, off64_t dst_offset, off64_t size, char *buffer, size_t buffer_size) |
bool | fs_isOpen () |
void | sf_open (const char *path, bool readonly, bool create) |
void | sf_close () |
size_t | sf_pread (void *data, size_t size, off64_t offset) |
void | sf_pwrite (const void *data, size_t size, off64_t offset) |
off64_t | sf_getEOF () |
void | sf_setEOF (off64_t offset) |
void | sf_sync () |
void | sf_lock (bool shared) |
void | sf_unlock () |
virtual void | retain () |
virtual void | release () |
uint32_t | getRefCount () |
virtual void | finalize () |
virtual CSObject * | getKey () |
virtual int | compareKey (CSObject *) |
virtual uint32_t | hashKey () |
virtual CSObject * | getHashLink () |
virtual void | setHashLink (CSObject *) |
Static Public Member Functions | |
static void | getBlobKey (MSBlobHeadPtr blob, CloudKeyPtr key) |
static bool | isDirNotFound (CSException *e) |
static bool | isDirExists (CSException *e) |
static bool | transfer (CSFile *dst_file, off64_t dst_offset, CSFile *src_file, off64_t src_offset, off64_t size, char *buffer, size_t buffer_size) |
static CSFile * | newFile (CSPath *path) |
static CSFile * | newFile (const char *path) |
static CSFile * | newFile (const char *dir_str, const char *path_str) |
static bool | isFileNotFound (CSException *e) |
Public Attributes | |
MSRepository * | myRepo |
bool | isFileInUse |
MSRepoFile * | nextFile |
CSPath * | myFilePath |
Static Public Attributes | |
static const int | DEFAULT = 0 |
static const int | READONLY = 1 |
static const int | CREATE = 2 |
static const int | TRUNCATE = 4 |
Private Member Functions | |
bool | getBlobRefSpace (MSOpenTable *otab, uint64_t offset, uint16_t head_size, uint32_t tab_id, uint64_t blob_id, uint64_t blob_ref_id, uint32_t auth_code, MSRepoTableRefPtr *tab_ref, MSRepoGenericRefPtr *free_ref, uint16_t *tab_ref_cnt, uint64_t *blob_size) |
void | realFreeBlob (MSOpenTable *otab, char *buffer, uint32_t auth_code, uint64_t offset, uint16_t head_size, uint64_t blob_size, size_t ref_size) |
void | update_blob_header (MSOpenTable *otab, uint64_t offset, uint64_t blob_size, uint16_t head_size, uint16_t new_head_size) |
void | removeBlob (MSOpenTable *otab, uint32_t tab_id, uint64_t blob_id, uint64_t offset, uint32_t auth_code) |
void | updateGarbage (uint64_t size) |
Static Private Member Functions | |
static MSRepoFile * | newRepoFile (MSRepository *repo, CSPath *path) |
Private Attributes | |
CSObject * | iNextLink |
CSObject * | iPrevLink |
Friends | |
class | MSRepository |
class | CSReadBufferedFile |
Definition at line 278 of file repository_ms.h.