User Manual, Developers Guide and API Documentation

Connection.cpp

Go to the documentation of this file.

/*******************************************************************************
 * This file is part of openWNS (open Wireless Network Simulator)
 * _____________________________________________________________________________
 *
 * Copyright (C) 2004-2007
 * Chair of Communication Networks (ComNets)
 * Kopernikusstr. 16, D-52074 Aachen, Germany
 * phone: ++49-241-80-27910,
 * fax: ++49-241-80-22242
 * email: info@openwns.org
 * www: http://www.openwns.org
 * _____________________________________________________________________________
 *
 * openWNS is free software; you can redistribute it and/or modify it under the
 * terms of the GNU Lesser General Public License version 2 as published by the
 * Free Software Foundation;
 *
 * openWNS 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 this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 ******************************************************************************/

#include <TCP/Connection.hpp>
#include <TCP/DataHandler.hpp>
#include <TCP/UpperConvergence.hpp>


using namespace tcp;

Connection::Connection(const wns::service::tl::FlowID& _flowID,
               UpperConvergence* _upperConvergence,
               const wns::pyconfig::View& _config) :
    flowID(_flowID),
    logger(_config.get("logger")),
    upperConvergence(_upperConvergence)
{
}

void
Connection::registerDataHandler(wns::service::tl::DataHandler* _dh)
{
    assure(_dh, "No valid instance of DataHandler");
    dh = _dh;
    MESSAGE_SINGLE(NORMAL, logger, "dataHandler set for flowID: " << flowID);
}

void
Connection::sendData(const wns::osi::PDUPtr& sdu)
{
    MESSAGE_SINGLE(NORMAL, logger, sdu->getLengthInBits()/8 << " bytes received from upper layer.");

    assure(upperConvergence, "UpperConvergence of TCP's FUN not set!");

    upperConvergence->sendData(this->flowID, sdu);
}

wns::service::tl::FlowID
Connection::getFlowID()
{
    return this->flowID;
}


void
Connection::onData(const wns::osi::PDUPtr& _pdu)
{
    MESSAGE_SINGLE(NORMAL, logger, "onData for flowID: " << flowID);
    assure(dh, "No DataHandler set!");
    dh->onData(_pdu);
}

---