source: source/ariba/communication/modules/transport/protlib/tp.cpp@ 5638

/// ----------------------------------------*- mode: C++; -*--

/// @file tp.cpp

/// generic interface for sending/receiving network messages via a transport protocol 

/// ----------------------------------------------------------

/// $Id: tp.cpp 2872 2008-02-18 10:58:03Z bless $

/// $HeadURL: https://svn.ipv6.tm.uka.de/nsis/protlib/trunk/src/tp.cpp $

// ===========================================================

//                      

// Copyright (C) 2005-2007, all rights reserved by

// - Institute of Telematics, Universitaet Karlsruhe (TH)

//

// More information and contact:

// https://projekte.tm.uka.de/trac/NSIS

//                      

// This program is free software; you can redistribute it and/or modify

// it under the terms of the GNU General Public License as published by

// the Free Software Foundation; version 2 of the License

//

// This program 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 General Public License for more details.

//

// You should have received a copy of the GNU General Public License along

// with this program; if not, write to the Free Software Foundation, Inc.,

// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.

//

// ===========================================================



/** @ingroup transport

 * This is the interface for sending network messages over a transport 

 * protocol. You can receive messages through queues.

 */



#include "tp.h"

#include "threadsafe_db.h"

#include "logfile.h"



namespace protlib {



/** @addtogroup transport Transport Protocol

 * @ingroup network

 * @{

 */



  using namespace log;





/***** class TP *****/



/** Set ID of the underlying transport protocol, e.g. TCP, SCTP or UDP.

 * Init is set false here, set to true in constructors of derived classes if

 * initialization is done.

 * If the maximum payload is greater than the maximum size of a network

 * message, it is decreased.

 */

TP::TP(protocol_t p, const string& pname, const string& tpn, 

       const unsigned short common_header_length, 

       bool (*const getmsglength)(NetMsg& netmsg, uint32& msglen),

       uint32 mp) 

        : protocol(p), protoname(pname), tp_name(tpn), 

          common_header_length(common_header_length), 

          getmsglength(getmsglength),

          init(false), 

          max_payload((mp<NetMsg::max_size)?mp:(NetMsg::max_size))

          {}



/** TP destructor does nothing. */

TP::~TP() { init = false; }



/** Get the ID of the underlying transport protocol. */

protocol_t TP::get_underlying_protocol() const { return protocol; }



/** Get the name of the underlying transport protocol. */

string TP::get_underlying_protocol_name() const { return protoname; }



/** Get the name of this TP implementation. */

string TP::get_tp_name() const { return tp_name; }



uint32 TP::get_max_payload() const { return max_payload; }



/* @param msg NetMsg to send

 * @param addr destination address

 * @return true if args are OK.

 */



void TP::check_send_args(const NetMsg& msg, const address& addr)

                const {

  if (!init) {

    Log(ERROR_LOG,LOG_NORMAL, "TP", "TP::check_send_args: " << tp_name << " not initialized");

    throw TPErrorArgsNotInit();

  } // end if not init

  

  if ((msg.get_size()==0) || (msg.get_size()>max_payload)) {

    Log(ERROR_LOG,LOG_NORMAL, "TP", "TP::check_send_args: NetMsg empty or too big. Size: " << msg.get_size() << ", " << tp_name << ", max_payload " << max_payload);

    throw TPErrorPayload();

  } // end if too big



} // end check_send_args 





//@}



} // end namespace protlib