StreamReader.cpp

/*
Copyright 2007, 2008, 2009, 2010, 2011 Instituto de Sistemas e Robotica, Instituto Superior Tecnico

This file is part of MeRMaID.

MeRMaID is free software: you can redistribute it and/or modify
it under the terms of the GNU Lesser General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.

MeRMaID is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public License
along with MeRMaID.  If not, see <http://www.gnu.org/licenses/>.
*/



#include "config.h"

#include "StreamReader.hpp"
#include "IOManager.hpp"
#include <ace/Asynch_IO.h>
#include <ace/Message_Block.h>
#include <ace/Proactor.h>
#include <Exception.hpp>

using namespace mermaid::support::io;

using mermaid::support::errorhandling::Exception;

StreamReader::~StreamReader()
{

}

StreamReader::StreamReader (Device* device) : device_ (device)
{
}

void StreamReader::onRead (size_t bytesRead, size_t requestedBytesRead, const char* data, bool success)
{
  device_->callReadHandler (bytesRead, requestedBytesRead, data, success);
  doRead();
}

void StreamReader::open (ACE_Handler* streamHandler, ACE_Proactor* proactor)
{
  int ret = readStream_.open (*streamHandler, device_->getFileDescriptor(), 0, proactor);
  if (ret != 0)
    throw Exception ("StreamReader::open(): Error opening ACE_Asynch_Read_Stream.");
}

void StreamReader::doRead()
{
  ACE_Message_Block* mb;
  ACE_NEW_NORETURN (mb, ACE_Message_Block (device_->getExpectedDataSize()));
  int ret = readStream_.read (*mb, mb->space());
  
  if (ret != 0) {
    mb->release();
    throw Exception ("StreamReader::doRead(): Error performing an asynch read operation.");
  }
}