IOManager.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 "IOManager.hpp"
#include "IOThread.hpp"
#include <fcntl.h>
#include <Exception.hpp>
#include <cassert>

using namespace mermaid::support::io;
using mermaid::support::errorhandling::Exception;

shared_ptr<IOManager> IOManager::instance_ (shared_ptr<IOManager> (new IOManager()));

IOManager::IOManager() : ioThread_ (new IOThread()) { }

IOManager::~IOManager() { }

shared_ptr<IOManager> IOManager::getInstance()
{
  return instance_;
}

shared_ptr<DeviceHandle> IOManager::createDevice (std::string filename, shared_ptr<ActiveObject> owner, shared_ptr<DeviceConfigurator> deviceConfigurator, int expectedDataSize)
{

  int fileDescriptor = open (filename.c_str(), O_RDWR);
  if (fileDescriptor == -1) {
    throw Exception ("IOManager::createDevice:  Error opening device: " + filename);
  }
  
  shared_ptr<Device> device (new Device (expectedDataSize, fileDescriptor, owner, deviceConfigurator));
  
  deviceConfigurator->configureDevice (fileDescriptor);
  
  shared_ptr<DeviceHandle> deviceHandle (new DeviceHandle (device));
  deviceHandleMap_[device] = deviceHandle;
  
  return deviceHandle;
}

void IOManager::enableDeviceRead (shared_ptr<Device> device, shared_ptr<StreamOperationHandlerMethodBase> streamOperationHandlerRead)
{
  device->enableRead (streamOperationHandlerRead);
}

void IOManager::enableDeviceWrite (shared_ptr<Device> device)
{
  device->enableWrite();
}

shared_ptr<IOThread> IOManager::getIOThread() const
{
  return ioThread_;
}

void IOManager::closeDevice (shared_ptr<Device> device)
{
  assert (deviceHandleMap_.find (device) != deviceHandleMap_.end());
  deviceHandleMap_.erase (device);
  device->close();
}