<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html><head><meta http-equiv="Content-Type" content="text/html;charset=UTF-8">
<title>ccRTP: channel.h Source File</title>
<link href="tabs.css" rel="stylesheet" type="text/css">
<link href="doxygen.css" rel="stylesheet" type="text/css">
</head><body>
<!-- Generated by Doxygen 1.5.9 -->
<div class="navigation" id="top">
<div class="tabs">
<ul>
<li><a href="index.html"><span>Main Page</span></a></li>
<li><a href="modules.html"><span>Modules</span></a></li>
<li><a href="annotated.html"><span>Classes</span></a></li>
<li class="current"><a href="files.html"><span>Files</span></a></li>
<li><a href="examples.html"><span>Examples</span></a></li>
</ul>
</div>
<div class="tabs">
<ul>
<li><a href="files.html"><span>File List</span></a></li>
<li><a href="globals.html"><span>File Members</span></a></li>
</ul>
</div>
<h1>channel.h</h1><a href="channel_8h.html">Go to the documentation of this file.</a><div class="fragment"><pre class="fragment"><a name="l00001"></a>00001 <span class="comment">// Copyright (C) 2001-2005 Federico Montesino Pouzols <fedemp@altern.org></span>
<a name="l00002"></a>00002 <span class="comment">// </span>
<a name="l00003"></a>00003 <span class="comment">// This program is free software; you can redistribute it and/or modify</span>
<a name="l00004"></a>00004 <span class="comment">// it under the terms of the GNU General Public License as published by</span>
<a name="l00005"></a>00005 <span class="comment">// the Free Software Foundation; either version 2 of the License, or</span>
<a name="l00006"></a>00006 <span class="comment">// (at your option) any later version.</span>
<a name="l00007"></a>00007 <span class="comment">// </span>
<a name="l00008"></a>00008 <span class="comment">// This program is distributed in the hope that it will be useful,</span>
<a name="l00009"></a>00009 <span class="comment">// but WITHOUT ANY WARRANTY; without even the implied warranty of</span>
<a name="l00010"></a>00010 <span class="comment">// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the</span>
<a name="l00011"></a>00011 <span class="comment">// GNU General Public License for more details.</span>
<a name="l00012"></a>00012 <span class="comment">// </span>
<a name="l00013"></a>00013 <span class="comment">// You should have received a copy of the GNU General Public License</span>
<a name="l00014"></a>00014 <span class="comment">// along with this program; if not, write to the Free Software </span>
<a name="l00015"></a>00015 <span class="comment">// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.</span>
<a name="l00016"></a>00016 <span class="comment">// </span>
<a name="l00017"></a>00017 <span class="comment">// As a special exception, you may use this file as part of a free software</span>
<a name="l00018"></a>00018 <span class="comment">// library without restriction. Specifically, if other files instantiate</span>
<a name="l00019"></a>00019 <span class="comment">// templates or use macros or inline functions from this file, or you compile</span>
<a name="l00020"></a>00020 <span class="comment">// this file and link it with other files to produce an executable, this</span>
<a name="l00021"></a>00021 <span class="comment">// file does not by itself cause the resulting executable to be covered by</span>
<a name="l00022"></a>00022 <span class="comment">// the GNU General Public License. This exception does not however </span>
<a name="l00023"></a>00023 <span class="comment">// invalidate any other reasons why the executable file might be covered by</span>
<a name="l00024"></a>00024 <span class="comment">// the GNU General Public License. </span>
<a name="l00025"></a>00025 <span class="comment">//</span>
<a name="l00026"></a>00026 <span class="comment">// This exception applies only to the code released under the name GNU</span>
<a name="l00027"></a>00027 <span class="comment">// ccRTP. If you copy code from other releases into a copy of GNU</span>
<a name="l00028"></a>00028 <span class="comment">// ccRTP, as the General Public License permits, the exception does</span>
<a name="l00029"></a>00029 <span class="comment">// not apply to the code that you add in this way. To avoid misleading</span>
<a name="l00030"></a>00030 <span class="comment">// anyone as to the status of such modified files, you must delete</span>
<a name="l00031"></a>00031 <span class="comment">// this exception notice from them.</span>
<a name="l00032"></a>00032 <span class="comment">//</span>
<a name="l00033"></a>00033 <span class="comment">// If you write modifications of your own for GNU ccRTP, it is your choice</span>
<a name="l00034"></a>00034 <span class="comment">// whether to permit this exception to apply to your modifications.</span>
<a name="l00035"></a>00035 <span class="comment">// If you do not wish that, delete this exception notice.</span>
<a name="l00036"></a>00036 <span class="comment">//</span>
<a name="l00037"></a>00037
<a name="l00038"></a>00038 <span class="preprocessor">#ifndef CCRTP_CHANNEL_H_</span>
<a name="l00039"></a>00039 <span class="preprocessor"></span><span class="preprocessor">#define CCRTP_CHANNEL_H_</span>
<a name="l00040"></a>00040 <span class="preprocessor"></span>
<a name="l00041"></a>00041 <span class="preprocessor">#include <<a class="code" href="base_8h.html" title="Base elements for RTP stacks: constants, types and global functions.">ccrtp/base.h</a>></span>
<a name="l00042"></a>00042
<a name="l00043"></a>00043 <span class="preprocessor">#ifndef WIN32</span>
<a name="l00044"></a>00044 <span class="preprocessor"></span><span class="preprocessor">#include <sys/ioctl.h></span>
<a name="l00045"></a><a class="code" href="channel_8h.html#e446f38679316c3a6922cb60c2b4c1e0">00045</a> <span class="keyword">inline</span> <span class="keywordtype">size_t</span> <a class="code" href="channel_8h.html#e446f38679316c3a6922cb60c2b4c1e0">ccioctl</a>(SOCKET so, <span class="keywordtype">int</span> request, <span class="keywordtype">size_t</span>& len)
<a name="l00046"></a>00046 { return ::ioctl(so,request,&len); }
<a name="l00047"></a>00047 <span class="preprocessor">#else</span>
<a name="l00048"></a>00048 <span class="preprocessor"></span><span class="keyword">inline</span> <span class="keywordtype">size_t</span> <a class="code" href="channel_8h.html#e446f38679316c3a6922cb60c2b4c1e0">ccioctl</a>(SOCKET so, <span class="keywordtype">int</span> request, <span class="keywordtype">size_t</span>& len )
<a name="l00049"></a>00049 {
<a name="l00050"></a>00050 <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> l;
<a name="l00051"></a>00051 <span class="keywordtype">size_t</span> result = 0;
<a name="l00052"></a>00052 ::ioctlsocket(so,request,&l);
<a name="l00053"></a>00053 len = l;
<a name="l00054"></a>00054 <span class="keywordflow">return</span> result;
<a name="l00055"></a>00055 }
<a name="l00056"></a>00056 <span class="preprocessor">#endif</span>
<a name="l00057"></a>00057 <span class="preprocessor"></span>
<a name="l00058"></a>00058 <span class="preprocessor">#ifdef CCXX_NAMESPACES</span>
<a name="l00059"></a>00059 <span class="preprocessor"></span><span class="keyword">namespace </span>ost {
<a name="l00060"></a>00060 <span class="preprocessor">#endif</span>
<a name="l00061"></a>00061 <span class="preprocessor"></span>
<a name="l00096"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html">00096</a> <span class="keyword">class </span><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">RTPBaseUDPIPv4Socket</a> : <span class="keyword">private</span> UDPSocket
<a name="l00097"></a>00097 {
<a name="l00098"></a>00098 <span class="keyword">public</span>:
<a name="l00102"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#942fe8fa96ff9fc0b7f44a21db0af3dd">00102</a> <a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">RTPBaseUDPIPv4Socket</a>(<span class="keyword">const</span> InetAddress& ia, tpport_t port) :
<a name="l00103"></a>00103 UDPSocket(ia,port)
<a name="l00104"></a>00104 { }
<a name="l00105"></a>00105
<a name="l00106"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#7edf2b5d44ed98ef4901e5ea51708f87">00106</a> <span class="keyword">inline</span> ~<a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">RTPBaseUDPIPv4Socket</a>()
<a name="l00107"></a>00107 { endSocket(); }
<a name="l00108"></a>00108
<a name="l00109"></a>00109 <span class="keyword">inline</span> <span class="keywordtype">bool</span>
<a name="l00110"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#4aa31dc622eaed5e6d47e230cff13828">00110</a> isPendingRecv(<a class="code" href="base_8h.html#c16d853255145e6a903914eb376a84bb" title="Time interval expressed in microseconds.">microtimeout_t</a> timeout)
<a name="l00111"></a>00111 { <span class="keywordflow">return</span> UDPSocket::isPending(UDPSocket::pendingInput, timeout); }
<a name="l00112"></a>00112
<a name="l00113"></a>00113 <span class="keyword">inline</span> InetHostAddress
<a name="l00114"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#d5a0fa9c49f00d0037cc020be60db2a4">00114</a> getSender(tpport_t& port)<span class="keyword"> const</span>
<a name="l00115"></a>00115 <span class="keyword"> </span>{ <span class="keywordflow">return</span> UDPSocket::getSender(&port); }
<a name="l00116"></a>00116
<a name="l00117"></a>00117 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00118"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#1d728d866d678b1cbddad59a441a1e89">00118</a> recv(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* buffer, <span class="keywordtype">size_t</span> len)
<a name="l00119"></a>00119 { <span class="keywordflow">return</span> UDPSocket::receive(buffer, len); }
<a name="l00120"></a>00120
<a name="l00124"></a>00124 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00125"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#07e429babae6ee670d2506eb3508f939">00125</a> getNextPacketSize()<span class="keyword"> const</span>
<a name="l00126"></a>00126 <span class="keyword"> </span>{ <span class="keywordtype">size_t</span> len; <a class="code" href="channel_8h.html#e446f38679316c3a6922cb60c2b4c1e0">ccioctl</a>(UDPSocket::so,FIONREAD,len); <span class="keywordflow">return</span> len; }
<a name="l00127"></a>00127
<a name="l00128"></a>00128 Socket::Error
<a name="l00129"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#ba0c2d1108c5d4060ca6d25d52a3d747">00129</a> setMulticast(<span class="keywordtype">bool</span> enable)
<a name="l00130"></a>00130 { <span class="keywordflow">return</span> UDPSocket::setMulticast(enable); }
<a name="l00131"></a>00131
<a name="l00132"></a>00132 <span class="keyword">inline</span> Socket::Error
<a name="l00133"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#38e6593374c1d22c5e047a35f086794c">00133</a> join(<span class="keyword">const</span> InetMcastAddress& ia, uint32 iface)
<a name="l00134"></a>00134 { <span class="keywordflow">return</span> UDPSocket::join(ia,iface); }
<a name="l00135"></a>00135
<a name="l00136"></a>00136 <span class="keyword">inline</span> Socket::Error
<a name="l00137"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#7e2b71082a1c30ff9cb24a3b3e78a6d8">00137</a> drop(<span class="keyword">const</span> InetMcastAddress& ia)
<a name="l00138"></a>00138 { <span class="keywordflow">return</span> UDPSocket::drop(ia); }
<a name="l00139"></a>00139
<a name="l00140"></a>00140 <span class="keyword">inline</span> Socket::Error
<a name="l00141"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#a6024a17917beae585313f5457d68c34">00141</a> setTimeToLive(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span> ttl)
<a name="l00142"></a>00142 { <span class="keywordflow">return</span> UDPSocket::setTimeToLive(ttl); }
<a name="l00143"></a>00143
<a name="l00147"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#3762957851afe0ab042007a2e15078ac">00147</a> <a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">RTPBaseUDPIPv4Socket</a>() :
<a name="l00148"></a>00148 UDPSocket()
<a name="l00149"></a>00149 { }
<a name="l00150"></a>00150
<a name="l00151"></a>00151 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00152"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#f4767299e84db20fc9ead42990f457c1">00152</a> setPeer(<span class="keyword">const</span> InetAddress &ia, tpport_t port)
<a name="l00153"></a>00153 {UDPSocket::setPeer((InetHostAddress&)ia, port);}
<a name="l00154"></a>00154
<a name="l00155"></a>00155 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00156"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#86b52c1d28d07134ff07c0307ddd7647">00156</a> send(<span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* <span class="keyword">const</span> buffer, <span class="keywordtype">size_t</span> len)
<a name="l00157"></a>00157 { <span class="keywordflow">return</span> UDPSocket::send(buffer, len); }
<a name="l00158"></a>00158
<a name="l00159"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#f8e342b232be4dff73b988ab41d6a4c2">00159</a> <span class="keyword">inline</span> SOCKET getRecvSocket()<span class="keyword"> const</span>
<a name="l00160"></a>00160 <span class="keyword"> </span>{ <span class="keywordflow">return</span> UDPSocket::so; }
<a name="l00161"></a>00161
<a name="l00162"></a>00162 <span class="comment">// common</span>
<a name="l00163"></a>00163 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00164"></a><a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html#6d1144061f0f234d8a88a56b2bb3a0fe">00164</a> endSocket()
<a name="l00165"></a>00165 { UDPSocket::endSocket(); }
<a name="l00166"></a>00166 };
<a name="l00167"></a>00167
<a name="l00188"></a>00188 <span class="keyword">template</span><<span class="keyword">class</span> BaseSocket>
<a name="l00189"></a><a class="code" href="class_dual_r_t_p_channel.html">00189</a> <span class="keyword">class </span><a class="code" href="class_dual_r_t_p_channel.html">DualRTPChannel</a>
<a name="l00190"></a>00190 {
<a name="l00191"></a>00191 <span class="keyword">public</span>:
<a name="l00192"></a><a class="code" href="class_dual_r_t_p_channel.html#1741fdddc7e1ecd457343eae3d920813">00192</a> <a class="code" href="class_dual_r_t_p_channel.html">DualRTPChannel</a>(<span class="keyword">const</span> InetAddress& ia, tpport_t port)
<a name="l00193"></a>00193 {
<a name="l00194"></a>00194 recvSocket = <span class="keyword">new</span> BaseSocket(ia,port);
<a name="l00195"></a>00195 sendSocket = <span class="keyword">new</span> BaseSocket;
<a name="l00196"></a>00196 }
<a name="l00197"></a>00197
<a name="l00198"></a><a class="code" href="class_dual_r_t_p_channel.html#8dc7a9d8cc9e65b738b93e814318fe24">00198</a> <span class="keyword">inline</span> ~<a class="code" href="class_dual_r_t_p_channel.html">DualRTPChannel</a>()
<a name="l00199"></a>00199 { <span class="keyword">delete</span> sendSocket; <span class="keyword">delete</span> recvSocket; }
<a name="l00200"></a>00200
<a name="l00201"></a>00201 <span class="keyword">inline</span> <span class="keywordtype">bool</span>
<a name="l00202"></a><a class="code" href="class_dual_r_t_p_channel.html#2342b098bd3e3d4c1d448c636000c58f">00202</a> isPendingRecv(<a class="code" href="base_8h.html#c16d853255145e6a903914eb376a84bb" title="Time interval expressed in microseconds.">microtimeout_t</a> timeout)<span class="keyword"> const</span>
<a name="l00203"></a>00203 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->isPendingRecv(timeout); }
<a name="l00204"></a>00204
<a name="l00205"></a>00205 <span class="keyword">inline</span> InetHostAddress
<a name="l00206"></a><a class="code" href="class_dual_r_t_p_channel.html#5c2f42efe2cef733b8f5ac3c15e19bcc">00206</a> getSender(tpport_t& port)<span class="keyword"> const</span>
<a name="l00207"></a>00207 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->getSender(port); }
<a name="l00208"></a>00208
<a name="l00209"></a>00209 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00210"></a><a class="code" href="class_dual_r_t_p_channel.html#b3167dbbd68a392e4dd7722a8b5f116c">00210</a> recv(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* buffer, <span class="keywordtype">size_t</span> len)
<a name="l00211"></a>00211 { <span class="keywordflow">return</span> recvSocket->recv(buffer, len); }
<a name="l00212"></a>00212
<a name="l00213"></a>00213 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00214"></a><a class="code" href="class_dual_r_t_p_channel.html#550c23a347afeb334b3947faec8d83b0">00214</a> getNextPacketSize()<span class="keyword"> const</span>
<a name="l00215"></a>00215 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->getNextPacketSize(); }
<a name="l00216"></a>00216
<a name="l00217"></a>00217 <span class="keyword">inline</span> Socket::Error
<a name="l00218"></a><a class="code" href="class_dual_r_t_p_channel.html#f020618fc3666399d9e76a5683e67b0f">00218</a> setMulticast(<span class="keywordtype">bool</span> enable)
<a name="l00219"></a>00219 { Socket::Error error = recvSocket->setMulticast(enable);
<a name="l00220"></a>00220 <span class="keywordflow">if</span> (error) <span class="keywordflow">return</span> error;
<a name="l00221"></a>00221 <span class="keywordflow">return</span> sendSocket->setMulticast(enable); }
<a name="l00222"></a>00222
<a name="l00223"></a>00223 <span class="keyword">inline</span> Socket::Error
<a name="l00224"></a><a class="code" href="class_dual_r_t_p_channel.html#b39769ecc878ea7a942a17af87d0182d">00224</a> join(<span class="keyword">const</span> InetMcastAddress& ia, uint32 iface)
<a name="l00225"></a>00225 { <span class="keywordflow">return</span> recvSocket->join(ia,iface); }
<a name="l00226"></a>00226
<a name="l00227"></a>00227 <span class="keyword">inline</span> Socket::Error
<a name="l00228"></a><a class="code" href="class_dual_r_t_p_channel.html#141829518bb601f3a42263876aca6ed0">00228</a> drop(<span class="keyword">const</span> InetMcastAddress& ia)
<a name="l00229"></a>00229 { <span class="keywordflow">return</span> recvSocket->drop(ia); }
<a name="l00230"></a>00230
<a name="l00231"></a>00231 <span class="keyword">inline</span> Socket::Error
<a name="l00232"></a><a class="code" href="class_dual_r_t_p_channel.html#5248ded1570b9e1fc11da340decb3682">00232</a> setTimeToLive(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span> ttl)
<a name="l00233"></a>00233 { <span class="keywordflow">return</span> sendSocket->setTimeToLive(ttl); }
<a name="l00234"></a>00234
<a name="l00235"></a>00235 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00236"></a><a class="code" href="class_dual_r_t_p_channel.html#c81a2ef2df75c1896f498f242bc9b348">00236</a> setPeer(<span class="keyword">const</span> InetAddress& host, tpport_t port)
<a name="l00237"></a>00237 { sendSocket->setPeer(host,port); }
<a name="l00238"></a>00238
<a name="l00239"></a>00239 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00240"></a><a class="code" href="class_dual_r_t_p_channel.html#45f836877bb794e77d771012dcbb1222">00240</a> send(<span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* <span class="keyword">const</span> buffer, <span class="keywordtype">size_t</span> len)
<a name="l00241"></a>00241 { <span class="keywordflow">return</span> sendSocket->send(buffer, len); }
<a name="l00242"></a>00242
<a name="l00243"></a><a class="code" href="class_dual_r_t_p_channel.html#a077cd841692df565493f40d30647977">00243</a> <span class="keyword">inline</span> SOCKET getRecvSocket()<span class="keyword"> const</span>
<a name="l00244"></a>00244 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->getRecvSocket(); }
<a name="l00245"></a>00245
<a name="l00246"></a>00246 <span class="comment">// common.</span>
<a name="l00247"></a>00247 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00248"></a><a class="code" href="class_dual_r_t_p_channel.html#2d6b7cde9be544e10fe8f5849f2e600d">00248</a> endSocket()
<a name="l00249"></a>00249 { sendSocket->endSocket(); recvSocket->endSocket(); }
<a name="l00250"></a>00250
<a name="l00251"></a>00251 <span class="keyword">private</span>:
<a name="l00252"></a>00252 BaseSocket* sendSocket;
<a name="l00253"></a>00253 BaseSocket* recvSocket;
<a name="l00254"></a>00254 };
<a name="l00255"></a>00255
<a name="l00256"></a>00256 <span class="preprocessor">#ifdef CCXX_IPV6</span>
<a name="l00257"></a>00257 <span class="preprocessor"></span>
<a name="l00279"></a>00279 <span class="keyword">class </span>RTPBaseUDPIPv6Socket : <span class="keyword">private</span> UDPSocket
<a name="l00280"></a>00280 {
<a name="l00281"></a>00281 <span class="keyword">public</span>:
<a name="l00285"></a>00285 RTPBaseUDPIPv6Socket(<span class="keyword">const</span> IPV6Address& ia, tpport_t port) :
<a name="l00286"></a>00286 UDPSocket(ia,port)
<a name="l00287"></a>00287 { }
<a name="l00288"></a>00288
<a name="l00289"></a>00289 <span class="keyword">inline</span> ~RTPBaseUDPIPv6Socket()
<a name="l00290"></a>00290 { endSocket(); }
<a name="l00291"></a>00291
<a name="l00292"></a>00292 <span class="keyword">inline</span> <span class="keywordtype">bool</span>
<a name="l00293"></a>00293 isPendingRecv(<a class="code" href="base_8h.html#c16d853255145e6a903914eb376a84bb" title="Time interval expressed in microseconds.">microtimeout_t</a> timeout)
<a name="l00294"></a>00294 { <span class="keywordflow">return</span> UDPSocket::isPending(UDPSocket::pendingInput, timeout); }
<a name="l00295"></a>00295
<a name="l00296"></a>00296 <span class="keyword">inline</span> IPV6Host
<a name="l00297"></a>00297 getSender(tpport_t& port)<span class="keyword"> const</span>
<a name="l00298"></a>00298 <span class="keyword"> </span>{ <span class="keywordflow">return</span> UDPSocket::getIPV6Sender(&port); }
<a name="l00299"></a>00299
<a name="l00300"></a>00300 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00301"></a>00301 recv(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* buffer, <span class="keywordtype">size_t</span> len)
<a name="l00302"></a>00302 { <span class="keywordflow">return</span> UDPSocket::receive(buffer, len); }
<a name="l00303"></a>00303
<a name="l00307"></a>00307 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00308"></a>00308 getNextPacketSize()<span class="keyword"> const</span>
<a name="l00309"></a>00309 <span class="keyword"> </span>{ <span class="keywordtype">size_t</span> len; <a class="code" href="channel_8h.html#e446f38679316c3a6922cb60c2b4c1e0">ccioctl</a>(UDPSocket::so,FIONREAD,len); <span class="keywordflow">return</span> len; }
<a name="l00310"></a>00310
<a name="l00311"></a>00311 Socket::Error
<a name="l00312"></a>00312 setMulticast(<span class="keywordtype">bool</span> enable)
<a name="l00313"></a>00313 { <span class="keywordflow">return</span> UDPSocket::setMulticast(enable); }
<a name="l00314"></a>00314
<a name="l00315"></a>00315 <span class="keyword">inline</span> Socket::Error
<a name="l00316"></a>00316 join(<span class="keyword">const</span> IPV6Multicast& ia, uint32 iface)
<a name="l00317"></a>00317 { <span class="keywordflow">return</span> Socket::join(ia); }
<a name="l00318"></a>00318
<a name="l00319"></a>00319 <span class="keyword">inline</span> Socket::Error
<a name="l00320"></a>00320 drop(<span class="keyword">const</span> IPV6Multicast& ia)
<a name="l00321"></a>00321 { <span class="keywordflow">return</span> UDPSocket::drop(ia); }
<a name="l00322"></a>00322
<a name="l00323"></a>00323 <span class="keyword">inline</span> Socket::Error
<a name="l00324"></a>00324 setTimeToLive(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span> ttl)
<a name="l00325"></a>00325 { <span class="keywordflow">return</span> UDPSocket::setTimeToLive(ttl); }
<a name="l00326"></a>00326
<a name="l00330"></a>00330 RTPBaseUDPIPv6Socket() :
<a name="l00331"></a>00331 UDPSocket()
<a name="l00332"></a>00332 { }
<a name="l00333"></a>00333
<a name="l00334"></a>00334 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00335"></a>00335 setPeer(<span class="keyword">const</span> IPV6Host &ia, tpport_t port)
<a name="l00336"></a>00336 {UDPSocket::setPeer(ia, port);}
<a name="l00337"></a>00337
<a name="l00338"></a>00338 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00339"></a>00339 send(<span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* <span class="keyword">const</span> buffer, <span class="keywordtype">size_t</span> len)
<a name="l00340"></a>00340 { <span class="keywordflow">return</span> UDPSocket::send(buffer, len); }
<a name="l00341"></a>00341
<a name="l00342"></a>00342 <span class="keyword">inline</span> SOCKET getRecvSocket()<span class="keyword"> const</span>
<a name="l00343"></a>00343 <span class="keyword"> </span>{ <span class="keywordflow">return</span> UDPSocket::so; }
<a name="l00344"></a>00344
<a name="l00345"></a>00345 <span class="comment">// common</span>
<a name="l00346"></a>00346 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00347"></a>00347 endSocket()
<a name="l00348"></a>00348 { UDPSocket::endSocket(); }
<a name="l00349"></a>00349 };
<a name="l00350"></a>00350
<a name="l00371"></a>00371 <span class="keyword">template</span><<span class="keyword">class</span> BaseSocket>
<a name="l00372"></a>00372 <span class="keyword">class </span>DualRTPChannelIPV6
<a name="l00373"></a>00373 {
<a name="l00374"></a>00374 <span class="keyword">public</span>:
<a name="l00375"></a>00375 DualRTPChannelIPV6(<span class="keyword">const</span> IPV6Host& ia, tpport_t port)
<a name="l00376"></a>00376 {
<a name="l00377"></a>00377 recvSocket = <span class="keyword">new</span> BaseSocket(ia,port);
<a name="l00378"></a>00378 sendSocket = <span class="keyword">new</span> BaseSocket;
<a name="l00379"></a>00379 }
<a name="l00380"></a>00380
<a name="l00381"></a>00381 <span class="keyword">inline</span> ~DualRTPChannelIPV6()
<a name="l00382"></a>00382 { <span class="keyword">delete</span> sendSocket; <span class="keyword">delete</span> recvSocket; }
<a name="l00383"></a>00383
<a name="l00384"></a>00384 <span class="keyword">inline</span> <span class="keywordtype">bool</span>
<a name="l00385"></a>00385 isPendingRecv(<a class="code" href="base_8h.html#c16d853255145e6a903914eb376a84bb" title="Time interval expressed in microseconds.">microtimeout_t</a> timeout)<span class="keyword"> const</span>
<a name="l00386"></a>00386 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->isPendingRecv(timeout); }
<a name="l00387"></a>00387
<a name="l00388"></a>00388 <span class="keyword">inline</span> IPV6Host
<a name="l00389"></a>00389 getSender(tpport_t& port)<span class="keyword"> const</span>
<a name="l00390"></a>00390 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->getIPV6Sender(port); }
<a name="l00391"></a>00391
<a name="l00392"></a>00392 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00393"></a>00393 recv(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* buffer, <span class="keywordtype">size_t</span> len)
<a name="l00394"></a>00394 { <span class="keywordflow">return</span> recvSocket->recv(buffer, len); }
<a name="l00395"></a>00395
<a name="l00396"></a>00396 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00397"></a>00397 getNextPacketSize()<span class="keyword"> const</span>
<a name="l00398"></a>00398 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->getNextPacketSize(); }
<a name="l00399"></a>00399
<a name="l00400"></a>00400 <span class="keyword">inline</span> Socket::Error
<a name="l00401"></a>00401 setMulticast(<span class="keywordtype">bool</span> enable)
<a name="l00402"></a>00402 { Socket::Error error = recvSocket->setMulticast(enable);
<a name="l00403"></a>00403 <span class="keywordflow">if</span> (error) <span class="keywordflow">return</span> error;
<a name="l00404"></a>00404 <span class="keywordflow">return</span> sendSocket->setMulticast(enable); }
<a name="l00405"></a>00405
<a name="l00406"></a>00406 <span class="keyword">inline</span> Socket::Error
<a name="l00407"></a>00407 join(<span class="keyword">const</span> IPV6Multicast& ia, uint32 iface)
<a name="l00408"></a>00408 { <span class="keywordflow">return</span> recvSocket->join(ia,iface); }
<a name="l00409"></a>00409
<a name="l00410"></a>00410 <span class="keyword">inline</span> Socket::Error
<a name="l00411"></a>00411 drop(<span class="keyword">const</span> IPV6Multicast& ia)
<a name="l00412"></a>00412 { <span class="keywordflow">return</span> recvSocket->drop(ia); }
<a name="l00413"></a>00413
<a name="l00414"></a>00414 <span class="keyword">inline</span> Socket::Error
<a name="l00415"></a>00415 setTimeToLive(<span class="keywordtype">unsigned</span> <span class="keywordtype">char</span> ttl)
<a name="l00416"></a>00416 { <span class="keywordflow">return</span> sendSocket->setTimeToLive(ttl); }
<a name="l00417"></a>00417
<a name="l00418"></a>00418 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00419"></a>00419 setPeer(<span class="keyword">const</span> IPV6Host& host, tpport_t port)
<a name="l00420"></a>00420 { sendSocket->setPeer(host,port); }
<a name="l00421"></a>00421
<a name="l00422"></a>00422 <span class="keyword">inline</span> <span class="keywordtype">size_t</span>
<a name="l00423"></a>00423 send(<span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">char</span>* <span class="keyword">const</span> buffer, <span class="keywordtype">size_t</span> len)
<a name="l00424"></a>00424 { <span class="keywordflow">return</span> sendSocket->send(buffer, len); }
<a name="l00425"></a>00425
<a name="l00426"></a>00426 <span class="keyword">inline</span> SOCKET getRecvSocket()<span class="keyword"> const</span>
<a name="l00427"></a>00427 <span class="keyword"> </span>{ <span class="keywordflow">return</span> recvSocket->getRecvSocket(); }
<a name="l00428"></a>00428
<a name="l00429"></a>00429 <span class="comment">// common.</span>
<a name="l00430"></a>00430 <span class="keyword">inline</span> <span class="keywordtype">void</span>
<a name="l00431"></a>00431 endSocket()
<a name="l00432"></a>00432 { sendSocket->endSocket(); recvSocket->endSocket(); }
<a name="l00433"></a>00433
<a name="l00434"></a>00434 <span class="keyword">private</span>:
<a name="l00435"></a>00435 BaseSocket* sendSocket;
<a name="l00436"></a>00436 BaseSocket* recvSocket;
<a name="l00437"></a>00437 };
<a name="l00438"></a>00438
<a name="l00439"></a>00439
<a name="l00440"></a>00440 <span class="keyword">typedef</span> DualRTPChannelIPV6<RTPBaseUDPIPv6Socket> DualRTPUDPIPv6Channel;
<a name="l00441"></a>00441 <span class="keyword">typedef</span> RTPBaseUDPIPv6Socket SingleRTPChannelIPV6;
<a name="l00442"></a>00442 <span class="keyword">typedef</span> SingleRTPChannelIPV6 SymmetricRTPChannelIPV6;
<a name="l00443"></a>00443
<a name="l00444"></a>00444 <span class="preprocessor">#endif</span>
<a name="l00445"></a>00445 <span class="preprocessor"></span>
<a name="l00446"></a><a class="code" href="group__sockets.html#gf75e80d04833a6b4f6337361357df7fe">00446</a> <span class="keyword">typedef</span> <a class="code" href="class_dual_r_t_p_channel.html">DualRTPChannel<RTPBaseUDPIPv4Socket></a> <a class="code" href="class_dual_r_t_p_channel.html">DualRTPUDPIPv4Channel</a>;
<a name="l00447"></a>00447
<a name="l00452"></a><a class="code" href="group__sockets.html#gd1b98c43bdf92c12e62abc6803cba1e7">00452</a> <span class="keyword">typedef</span> <a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">RTPBaseUDPIPv4Socket</a> <a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">SingleRTPChannel</a>;
<a name="l00453"></a>00453
<a name="l00457"></a><a class="code" href="group__sockets.html#g17393838c3cd3a7f6af593338c18ace2">00457</a> <span class="keyword">typedef</span> <a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">SingleRTPChannel</a> <a class="code" href="class_r_t_p_base_u_d_p_i_pv4_socket.html" title="A UDP/IPv4 socket class targetted at RTP stacks.">SymmetricRTPChannel</a>;
<a name="l00458"></a>00458 <span class="comment">// sockets</span>
<a name="l00460"></a>00460
<a name="l00461"></a>00461 <span class="preprocessor">#ifdef CCXX_NAMESPACES</span>
<a name="l00462"></a>00462 <span class="preprocessor"></span>}
<a name="l00463"></a>00463 <span class="preprocessor">#endif</span>
<a name="l00464"></a>00464 <span class="preprocessor"></span>
<a name="l00465"></a>00465 <span class="preprocessor">#endif //CCRTP_CHANNEL_H_</span>
<a name="l00466"></a>00466 <span class="preprocessor"></span>
</pre></div></div>
<hr size="1"><address style="text-align: right;"><small>Generated on Fri Jul 24 21:42:25 2009 for ccRTP by
<a href="http://www.doxygen.org/index.html">
<img src="doxygen.png" alt="doxygen" align="middle" border="0"></a> 1.5.9 </small></address>
</body>
</html>
