/*
* IOManager.cpp
*
*  Created on: Oct 1, 2010
*      Author: daniele
*/

#include <string>
#include <iostream>

#include <boost/foreach.hpp>

#include "Chunk.h"
#include "IOManager.h"
#include "IOBuffer.h"
#include "IOFlush.h"
#include "IOOperation.h"

IOManager::IOManager()
{
	_input = new IOBuffer();
	_output = new IOBuffer();
}

IOManager::~IOManager()
{
	delete _input;
	delete _output;
}

bool IOManager::available( BufferDescriptor descriptor )
{
	return _input->contains( descriptor );
}

void IOManager::register_source_observer( ::prototype::BufferObserver& observer )
{
	_input->register_observer(observer);
}

void IOManager::remove_source_observer( ::prototype::BufferObserver& observer )
{
	_input->remove_observer(observer);
}

std::size_t IOManager::append_to_input( Chunk& c )
{
	return _input->append( c );
}

Chunk IOManager::read_for_parsing( BufferDescriptor descriptor )
{
	return _input->range(descriptor);
}

Chunk IOManager::read_from_output()
{
	Chunk chunk = _output->pop( _output->available( _output->offset() ) );
	return chunk;
}

void IOManager::queue_operation( ::prototype::IOOperation* operation )
{
	_pending_operations.push_front(operation);
}

void IOManager::queue_flush( std::size_t to_offset )
{
	queue_operation( new IOFlush( to_offset) );
}

void IOManager::process_pending()
{
	BOOST_FOREACH( ::prototype::IOOperation& command, _pending_operations ) {
		command.execute(this);
	}
	_pending_operations.clear();
}

void IOManager::flush(std::size_t to_offset)
{
	_input->flush(to_offset);
}

void IOManager::complete(std::size_t size)
{
	Chunk chunk = Chunk(_input->ptr(), size);
	_output->append( chunk );
}

void IOManager::append( Chunk& chunk )
{
	_output->append( chunk );
}

.