ccRTP
ext.h
Go to the documentation of this file.
00001 // Copyright (C) 1999-2003 Open Source Telecom Corporation.
00002 //
00003 // This program is free software; you can redistribute it and/or modify
00004 // it under the terms of the GNU General Public License as published by
00005 // the Free Software Foundation; either version 2 of the License, or
00006 // (at your option) any later version.
00007 //
00008 // This program is distributed in the hope that it will be useful,
00009 // but WITHOUT ANY WARRANTY; without even the implied warranty of
00010 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00011 // GNU General Public License for more details.
00012 //
00013 // You should have received a copy of the GNU General Public License
00014 // along with this program; if not, write to the Free Software
00015 // Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
00016 //
00017 // As a special exception, you may use this file as part of a free software
00018 // library without restriction.  Specifically, if other files instantiate
00019 // templates or use macros or inline functions from this file, or you compile
00020 // this file and link it with other files to produce an executable, this
00021 // file does not by itself cause the resulting executable to be covered by
00022 // the GNU General Public License.  This exception does not however
00023 // invalidate any other reasons why the executable file might be covered by
00024 // the GNU General Public License.
00025 //
00026 // This exception applies only to the code released under the name GNU
00027 // ccRTP.  If you copy code from other releases into a copy of GNU
00028 // ccRTP, as the General Public License permits, the exception does
00029 // not apply to the code that you add in this way.  To avoid misleading
00030 // anyone as to the status of such modified files, you must delete
00031 // this exception notice from them.
00032 //
00033 // If you write modifications of your own for GNU ccRTP, it is your choice
00034 // whether to permit this exception to apply to your modifications.
00035 // If you do not wish that, delete this exception notice.
00036 //
00037 
00043 #ifndef CCXX_RTP_EXT_H
00044 #define CCXX_RTP_EXT_H
00045 
00046 #ifndef COMMONCPP_SOCKET_H_
00047 #include <commoncpp/socket.h>
00048 #include <commoncpp/udp.h>
00049 #endif
00050 
00051 #include <ccrtp/ioqueue.h>
00052 #include <ccrtp/channel.h>
00053 
00054 NAMESPACE_COMMONCPP
00055 
00071 class __EXPORT RTPDuplex : public RTPDataQueue,
00072                     protected UDPReceive, public UDPTransmit
00073 {
00074 public:
00080     RTPDuplex(const InetAddress &bind, tpport_t local, tpport_t remote);
00081 
00085     virtual
00086     ~RTPDuplex();
00087 
00094     UDPTransmit::Error
00095     connect(const InetHostAddress &host, tpport_t port = 0);
00096 
00097 protected:
00098 
00103     bool
00104     isPendingData(microtimeout_t timeout)
00105     { return isPendingReceive(timeout); }
00106 
00112     size_t
00113     sendData(const unsigned char *const buffer, size_t len)
00114     { return UDPTransmit::transmit((const char *)buffer, len); }
00115 
00123     size_t
00124     recvData(unsigned char *buffer, size_t len,
00125          InetHostAddress& na, tpport_t& tp)
00126     { /* na = UDPReceive::getPeer(&tp);  FIX name ambiguity */
00127     return UDPReceive::receive(buffer, len); }
00128 
00133         inline void
00134         setDataPeer(const InetAddress&, tpport_t)
00135     { }
00136 
00141         inline void
00142         setControlPeer(const InetAddress&, tpport_t)
00143     { }
00144 
00145     inline size_t
00146     getNextDataPacketSize() const
00147     {
00148         // the const cast is a trick only needed for cc++2 <= 1.0.10
00149         size_t len; ccioctl(const_cast<RTPDuplex*>(this)->UDPReceive::getReceiver(),FIONREAD,len); return len;
00150     }
00151 
00155     SyncSource &getPeer();
00156 
00157 private:
00158     tpport_t dataBasePort;
00159 };
00160  // rtpext
00162 
00163 END_NAMESPACE
00164 
00165 #endif //CCXX_RTP_EXT_H
00166