From b298e49bad12f1795a744acd42721ea2b5816a1a Mon Sep 17 00:00:00 2001 From: sears Date: Tue, 9 Mar 2010 20:30:39 +0000 Subject: [PATCH] whitespace changes git-svn-id: svn+ssh://svn.corp.yahoo.com/yahoo/yrl/labs/pnuts/code/logstore@683 8dad8b1f-cf64-0410-95b6-bcf113ffbcfe --- regionAllocator.h | 192 +++++++++++++++++++++++----------------------- 1 file changed, 96 insertions(+), 96 deletions(-) diff --git a/regionAllocator.h b/regionAllocator.h index 7517162..41d1baf 100644 --- a/regionAllocator.h +++ b/regionAllocator.h @@ -8,109 +8,109 @@ #ifndef REGIONALLOCATOR_H_ #define REGIONALLOCATOR_H_ - class RegionAllocator +class RegionAllocator +{ +public: + + // Open an existing region allocator. + RegionAllocator(int xid, recordid rid) : + nextPage_(INVALID_PAGE), + endOfRegion_(INVALID_PAGE) { + rid_ = rid; + Tread(xid, rid_, &header_); + regionCount_ = TarrayListLength(xid, header_.region_list); + } + // Create a new region allocator. + RegionAllocator(int xid, pageid_t region_length) : + nextPage_(0), + endOfRegion_(0), + regionCount_(0) { - public: + rid_ = Talloc(xid, sizeof(header_)); + header_.region_list = TarrayListAlloc(xid, 1, 2, sizeof(pageid_t)); + header_.region_length = region_length; + Tset(xid, rid_, &header_); + } + // XXX handle disk full? + pageid_t alloc_extent(int xid, pageid_t extent_length) { + assert(nextPage_ != INVALID_PAGE); + pageid_t ret = nextPage_; + nextPage_ += extent_length; + if(nextPage_ >= endOfRegion_) { + ret = TregionAlloc(xid, header_.region_length, 42); // XXX assign a region allocator id + TarrayListExtend(xid, header_.region_list, 1); + recordid rid = header_.region_list; + rid.slot = regionCount_; + Tset(xid, rid, &ret); + assert(extent_length <= header_.region_length); // XXX could handle this case if we wanted to. Would remove this error case, and not be hard. + nextPage_ = ret + extent_length; + endOfRegion_ = ret + header_.region_length; + regionCount_++; + assert(regionCount_ == TarrayListLength(xid, header_.region_list)); + } + return ret; + } + bool grow_extent(pageid_t extension_length) { + assert(nextPage_ != INVALID_PAGE); + nextPage_ += extension_length; + return(nextPage_ < endOfRegion_); + } + void force_regions(int xid) { + assert(nextPage_ != INVALID_PAGE); + pageid_t regionCount = TarrayListLength(xid, header_.region_list); + for(recordid list_entry = header_.region_list; + list_entry.slot < regionCount; list_entry.slot++) { + pageid_t pid; + Tread(xid, list_entry, &pid); + TregionForce(xid, pid); + } + } + void dealloc_regions(int xid) { + pageid_t regionCount = TarrayListLength(xid, header_.region_list); - // Open an existing region allocator. - RegionAllocator(int xid, recordid rid) : - nextPage_(INVALID_PAGE), - endOfRegion_(INVALID_PAGE) { - rid_ = rid; - Tread(xid, rid_, &header_); - regionCount_ = TarrayListLength(xid, header_.region_list); - } - // Create a new region allocator. - RegionAllocator(int xid, pageid_t region_length) : - nextPage_(0), - endOfRegion_(0), - regionCount_(0) - { - rid_ = Talloc(xid, sizeof(header_)); - header_.region_list = TarrayListAlloc(xid, 1, 2, sizeof(pageid_t)); - header_.region_length = region_length; - Tset(xid, rid_, &header_); - } - // XXX handle disk full? - pageid_t alloc_extent(int xid, pageid_t extent_length) { - assert(nextPage_ != INVALID_PAGE); - pageid_t ret = nextPage_; - nextPage_ += extent_length; - if(nextPage_ >= endOfRegion_) { - ret = TregionAlloc(xid, header_.region_length, 42); // XXX assign a region allocator id - TarrayListExtend(xid, header_.region_list, 1); - recordid rid = header_.region_list; - rid.slot = regionCount_; - Tset(xid, rid, &ret); - assert(extent_length <= header_.region_length); // XXX could handle this case if we wanted to. Would remove this error case, and not be hard. - nextPage_ = ret + extent_length; - endOfRegion_ = ret + header_.region_length; - regionCount_++; - assert(regionCount_ == TarrayListLength(xid, header_.region_list)); - } - return ret; - } - bool grow_extent(pageid_t extension_length) { - assert(nextPage_ != INVALID_PAGE); - nextPage_ += extension_length; - return(nextPage_ < endOfRegion_); - } - void force_regions(int xid) { - assert(nextPage_ != INVALID_PAGE); - pageid_t regionCount = TarrayListLength(xid, header_.region_list); - for(recordid list_entry = header_.region_list; - list_entry.slot < regionCount; list_entry.slot++) { - pageid_t pid; - Tread(xid, list_entry, &pid); - TregionForce(xid, pid); - } - } - void dealloc_regions(int xid) { - pageid_t regionCount = TarrayListLength(xid, header_.region_list); + DEBUG("{%lld %lld %lld}\n", header_.region_list.page, (long long)header_.region_list.slot, (long long)header_.region_list.size); - DEBUG("{%lld %lld %lld}\n", header_.region_list.page, (long long)header_.region_list.slot, (long long)header_.region_list.size); - - for(recordid list_entry = header_.region_list; - list_entry.slot < regionCount; list_entry.slot++) { - pageid_t pid; - Tread(xid, list_entry, &pid); + for(recordid list_entry = header_.region_list; + list_entry.slot < regionCount; list_entry.slot++) { + pageid_t pid; + Tread(xid, list_entry, &pid); #ifndef CHECK_FOR_SCRIBBLING // Don't actually free the page if we'll be checking that pages are used exactly once below. - TregionDealloc(xid, pid); + TregionDealloc(xid, pid); #endif - } - TarrayListDealloc(xid, header_.region_list); - Tdealloc(xid, rid_); + } + TarrayListDealloc(xid, header_.region_list); + Tdealloc(xid, rid_); + } + pageid_t * list_regions(int xid, pageid_t * region_length, pageid_t * region_count) { + *region_count = TarrayListLength(xid, header_.region_list); + pageid_t * ret = (pageid_t*)malloc(sizeof(pageid_t) * *region_count); + recordid rid = header_.region_list; + for(pageid_t i = 0; i < *region_count; i++) { + rid.slot = i; + Tread(xid, rid, &ret[i]); } - pageid_t * list_regions(int xid, pageid_t * region_length, pageid_t * region_count) { - *region_count = TarrayListLength(xid, header_.region_list); - pageid_t * ret = (pageid_t*)malloc(sizeof(pageid_t) * *region_count); - recordid rid = header_.region_list; - for(pageid_t i = 0; i < *region_count; i++) { - rid.slot = i; - Tread(xid, rid, &ret[i]); - } - *region_length = header_.region_length; - return ret; - } - void done() { - nextPage_ = INVALID_PAGE; - endOfRegion_ = INVALID_PAGE; - } - recordid header_rid() { return rid_; } - private: - typedef struct { - recordid region_list; - pageid_t region_length; - } persistent_state; + *region_length = header_.region_length; + return ret; + } + void done() { + nextPage_ = INVALID_PAGE; + endOfRegion_ = INVALID_PAGE; + } + recordid header_rid() { return rid_; } +private: + typedef struct { + recordid region_list; + pageid_t region_length; + } persistent_state; - recordid rid_; - pageid_t nextPage_; - pageid_t endOfRegion_; - pageid_t regionCount_; - persistent_state header_; - public: - static const size_t header_size = sizeof(persistent_state); - }; + recordid rid_; + pageid_t nextPage_; + pageid_t endOfRegion_; + pageid_t regionCount_; + persistent_state header_; +public: + static const size_t header_size = sizeof(persistent_state); +}; #endif /* REGIONALLOCATOR_H_ */