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.