summaryrefslogtreecommitdiff
path: root/cpp/zone.cpp
diff options
context:
space:
mode:
authorfrsyuki <frsyuki@5a5092ae-2292-43ba-b2d5-dcab9c1a2731>2009-02-15 09:09:56 +0000
committerfrsyuki <frsyuki@5a5092ae-2292-43ba-b2d5-dcab9c1a2731>2009-02-15 09:09:56 +0000
commit97bc0441b1204b3eb38f9cfc03f90e5ee675ab9a (patch)
treef83049ca457011380e907d6483e435cd2babc740 /cpp/zone.cpp
parent94cbe54cf377f16bcc18b80d8b6f81eefd50e723 (diff)
downloadmsgpack-python-97bc0441b1204b3eb38f9cfc03f90e5ee675ab9a.tar.gz
lang/c/msgpack: C++ binding: enlarged chunk size of zone
git-svn-id: file:///Users/frsyuki/project/msgpack-git/svn/x@58 5a5092ae-2292-43ba-b2d5-dcab9c1a2731
Diffstat (limited to 'cpp/zone.cpp')
-rw-r--r--cpp/zone.cpp25
1 files changed, 16 insertions, 9 deletions
diff --git a/cpp/zone.cpp b/cpp/zone.cpp
index de2de22..ea4c7e4 100644
--- a/cpp/zone.cpp
+++ b/cpp/zone.cpp
@@ -5,10 +5,17 @@ namespace msgpack {
void* zone::alloc()
{
- if(m_used >= m_pool.size()*MSGPACK_ZONE_CHUNK_SIZE) {
- m_pool.push_back(new chunk_t());
+ if(m_pool.size()*ZONE_CHUNK_SIZE <= m_used) {
+ cell_t* chunk = (cell_t*)malloc(sizeof(cell_t)*ZONE_CHUNK_SIZE);
+ if(!chunk) { throw std::bad_alloc(); }
+ try {
+ m_pool.push_back(chunk);
+ } catch (...) {
+ free(chunk);
+ throw;
+ }
}
- void* data = m_pool[m_used/MSGPACK_ZONE_CHUNK_SIZE]->cells[m_used%MSGPACK_ZONE_CHUNK_SIZE].data;
+ void* data = m_pool[m_used/ZONE_CHUNK_SIZE][m_used%ZONE_CHUNK_SIZE].data;
++m_used;
return data;
}
@@ -16,21 +23,21 @@ void* zone::alloc()
void zone::clear()
{
if(!m_pool.empty()) {
- for(size_t b=0; b < m_used/MSGPACK_ZONE_CHUNK_SIZE; ++b) {
- cell_t* c(m_pool[b]->cells);
- for(size_t e=0; e < MSGPACK_ZONE_CHUNK_SIZE; ++e) {
+ for(size_t b=0; b < m_used/ZONE_CHUNK_SIZE; ++b) {
+ cell_t* c(m_pool[b]);
+ for(size_t e=0; e < ZONE_CHUNK_SIZE; ++e) {
reinterpret_cast<object_class*>(c[e].data)->~object_class();
}
}
- cell_t* c(m_pool.back()->cells);
- for(size_t e=0; e < m_used%MSGPACK_ZONE_CHUNK_SIZE; ++e) {
+ cell_t* c(m_pool.back());
+ for(size_t e=0; e < m_used%ZONE_CHUNK_SIZE; ++e) {
reinterpret_cast<object_class*>(c[e].data)->~object_class();
}
for(pool_t::iterator it(m_pool.begin()), it_end(m_pool.end());
it != it_end;
++it) {
- delete *it;
+ free(*it);
}
m_pool.clear();
}