Method GetIoBuffer

libcppcryptfs/file/iobufferpool.cpp:82–125

IoBuffer * IoBufferPool::GetIoBuffer(size_t buffer_size, size_t ivbuffer_size)
{

	IoBuffer* pb = nullptr;

	bool will_be_from_pool = false;

	auto total_size = buffer_size + ivbuffer_size;

	if (total_size <= m_max_pool_buffer_size) {

		lock_guard<mutex> lock(m_mutex);

		if (!m_buffers.empty()) {
			pb = m_buffers.front();			
			if (total_size > pb->m_storage.size()) {				
				auto growth = total_size - pb->m_storage.size();
				if (m_current_size + growth > m_max_size) {			
					pb = nullptr;
				} else {
					m_current_size += growth;
				}
			}			
			if (pb) {
				m_buffers.pop_front();
			}
		} else if (m_current_size + total_size <= m_max_size) {
			will_be_from_pool = true;
			m_current_size += total_size;
		}		
	}

	try {
		if (pb) {
			pb->reallocate(buffer_size, ivbuffer_size);
		} else {
			pb = new IoBuffer(will_be_from_pool, buffer_size, ivbuffer_size);
		}
	} catch (const std::bad_alloc&) {
		pb = nullptr;
	}	
	
	return pb;
}

void IoBufferPool::ReleaseIoBuffer(IoBuffer * pBuf)
{