0
0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00

alignedbuilder code cleanup

This commit is contained in:
dwight 2010-12-01 11:17:50 -05:00
parent 984e62f550
commit e77e309094
2 changed files with 52 additions and 44 deletions

View File

@ -21,59 +21,64 @@
namespace mongo { namespace mongo {
AlignedBuilder::AlignedBuilder(unsigned init_size) : _size(init_size) { AlignedBuilder::AlignedBuilder(unsigned initSize) {
_data = (char *) _malloc(_size);
if( _data == 0 )
uasserted(13584, "out of memory AlignedBuilder");
_len = 0; _len = 0;
_malloc(initSize);
uassert(13584, "out of memory AlignedBuilder", _p._allocationAddress);
} }
void* AlignedBuilder::mallocSelfAligned(unsigned sz) { void AlignedBuilder::mallocSelfAligned(unsigned sz) {
assert( sz == _p._size );
void *p = malloc(sz + Alignment - 1); void *p = malloc(sz + Alignment - 1);
_realAddr = p; _p._allocationAddress = p;
size_t s = (size_t) p; size_t s = (size_t) p;
size_t sold = s;
s += Alignment - 1; s += Alignment - 1;
s = (s/Alignment)*Alignment; s = (s/Alignment)*Alignment;
return (void*) s; dassert( s >= sold );
_p._data = (char *) s;
} }
/* "slow"/infrequent portion of 'grow()' */ /* "slow"/infrequent portion of 'grow()' */
void NOINLINE_DECL AlignedBuilder::grow_reallocate() { void NOINLINE_DECL AlignedBuilder::growReallocate(unsigned oldLen) {
unsigned a = _size * 2; unsigned a = _p._size;
assert( a ); assert( a );
if ( _len > a ) while( 1 ) {
a = _len + 16 * 1024; a *= 2;
assert( a < 0x20000000 ); assert( a < 0x20000000 );
_data = (char *) _realloc(_data, a, _len); if( _len < a )
_size = a; break;
}
_realloc(a, oldLen);
} }
void* AlignedBuilder::_malloc(unsigned sz) { void AlignedBuilder::_malloc(unsigned sz) {
_p._size = sz;
#if defined(_WIN32) #if defined(_WIN32)
void *p = VirtualAlloc(0, sz, MEM_COMMIT | MEM_RESERVE, PAGE_READWRITE); void *p = VirtualAlloc(0, sz, MEM_COMMIT | MEM_RESERVE, PAGE_READWRITE);
_realAddr = p; _p._allocationAddress = p;
//#elif defined(_POSIX_VERSION) _p._data = (char *) p;
// in theory _POSIX_VERSION should work, but it doesn't on OS X 10.4, and needs to be testeed on solaris.
// so for now, linux only for this.
#elif defined(__linux__) #elif defined(__linux__)
// in theory #ifdef _POSIX_VERSION should work, but it doesn't on OS X 10.4, and needs to be testeed on solaris.
// so for now, linux only for this.
void *p = 0; void *p = 0;
int res = posix_memalign(&p, Alignment, sz); int res = posix_memalign(&p, Alignment, sz);
massert(13524, "out of memory AlignedBuilder", res == 0); massert(13524, "out of memory AlignedBuilder", res == 0);
_realAddr = p; _p._allocationAddress = p;
_p._data = (char *) p;
#else #else
void *p = mallocSelfAligned(sz); void *p = mallocSelfAligned(sz);
assert( ((size_t) p) % Alignment == 0 ); assert( ((size_t) p) % Alignment == 0 );
#endif #endif
return p;
} }
void* AlignedBuilder::_realloc(void *ptr, unsigned newSize, unsigned oldSize) { void AlignedBuilder::_realloc(unsigned newSize, unsigned oldLen) {
// posix_memalign alignment is not maintained on reallocs // posix_memalign alignment is not maintained on reallocs, so we can't use realloc().
void *oldAddr = _realAddr; AllocationInfo old = _p;
void *p = _malloc(newSize); _malloc(newSize);
memcpy(p, ptr, oldSize); assert( oldLen <= _len );
_free(oldAddr); memcpy(_p._data, old._data, oldLen);
return p; _free(old._allocationAddress);
} }
void AlignedBuilder::_free(void *p) { void AlignedBuilder::_free(void *p) {
@ -85,9 +90,9 @@ namespace mongo {
} }
void AlignedBuilder::kill() { void AlignedBuilder::kill() {
_free(_realAddr); _free(_p._allocationAddress);
_data = 0; _p._allocationAddress = 0;
_realAddr = 0; _p._data = 0;
} }
} }

View File

@ -32,7 +32,7 @@ namespace mongo {
void reset() { _len = 0; } void reset() { _len = 0; }
/** note this may be deallocated (realloced) if you keep writing or reset(). */ /** note this may be deallocated (realloced) if you keep writing or reset(). */
const char* buf() const { return _data; } const char* buf() const { return _p._data; }
/** leave room for some stuff later /** leave room for some stuff later
@return offset in the buffer that was our current position @return offset in the buffer that was our current position
@ -43,7 +43,7 @@ namespace mongo {
return l; return l;
} }
char* atOfs(unsigned ofs) { return _data + ofs; } char* atOfs(unsigned ofs) { return _p._data + ofs; }
void appendChar(char j){ void appendChar(char j){
*((char*)grow(sizeof(char))) = j; *((char*)grow(sizeof(char))) = j;
@ -80,6 +80,7 @@ namespace mongo {
void appendStr(const StringData &str , bool includeEOO = true ) { void appendStr(const StringData &str , bool includeEOO = true ) {
const unsigned len = str.size() + ( includeEOO ? 1 : 0 ); const unsigned len = str.size() + ( includeEOO ? 1 : 0 );
assert( len < BSONObjMaxUserSize );
memcpy(grow(len), str.data(), len); memcpy(grow(len), str.data(), len);
} }
@ -93,23 +94,25 @@ namespace mongo {
inline char* grow(unsigned by) { inline char* grow(unsigned by) {
unsigned oldlen = _len; unsigned oldlen = _len;
_len += by; _len += by;
if ( _len > _size ) { if ( _len > _p._size ) {
grow_reallocate(); growReallocate(oldlen);
} }
return _data + oldlen; return _p._data + oldlen;
} }
void grow_reallocate(); void growReallocate(unsigned oldLenInUse);
void kill(); void kill();
void* mallocSelfAligned(unsigned sz); void mallocSelfAligned(unsigned sz);
void* _malloc(unsigned sz); void _malloc(unsigned sz);
void* _realloc(void *ptr, unsigned newSize, unsigned oldSize); void _realloc(unsigned newSize, unsigned oldLenInUse);
void _free(void*); void _free(void*);
char *_data; struct AllocationInfo {
unsigned _len; char *_data;
unsigned _size; void *_allocationAddress;
void *_realAddr; unsigned _size;
} _p;
unsigned _len; // bytes in use
}; };
} }