channels_8cpp-source.html

著名的密码库Crypto++的文档 C++语言的杰作。程序员必备。

<a name="l00092"></a>00092 <span class="comment">//</span>
<a name="l00093"></a>00093 <span class="comment">// ChannelRouteIterator</span><span class="comment"></span>
<a name="l00094"></a>00094 <span class="comment">//////////////////////////</span>
<a name="l00095"></a>00095 <span class="comment"></span>
<a name="l00096"></a><a class="code" href="class_channel_route_iterator.html#862708d9e96fb0d6f884fb7e022a5b5a">00096</a> <span class="keywordtype">void</span> <a class="code" href="class_channel_route_iterator.html#862708d9e96fb0d6f884fb7e022a5b5a">ChannelRouteIterator::Reset</a>(<span class="keyword">const</span> std::string &amp;channel)
<a name="l00097"></a>00097 {
<a name="l00098"></a>00098         <a class="code" href="class_channel_route_iterator.html#c20002a033d7ad5915b0761aa3458117">m_channel</a> = channel;
<a name="l00099"></a>00099         pair&lt;MapIterator, MapIterator&gt; range = <a class="code" href="class_channel_route_iterator.html#82070a7b3f4a83f552313bce17157e8e">m_cs</a>.<a class="code" href="class_channel_switch.html#45e75e6e549254ddc760a71b070e8f87">m_routeMap</a>.equal_range(channel);
<a name="l00100"></a>00100         <span class="keywordflow">if</span> (range.first == range.second)
<a name="l00101"></a>00101         {
<a name="l00102"></a>00102                 <a class="code" href="class_channel_route_iterator.html#c7d6fde8284bcaa8d684bae3c079f57c">m_useDefault</a> = <span class="keyword">true</span>;
<a name="l00103"></a>00103                 <a class="code" href="class_channel_route_iterator.html#534b382fe373be38f7800d1d92946592">m_itListCurrent</a> = <a class="code" href="class_channel_route_iterator.html#82070a7b3f4a83f552313bce17157e8e">m_cs</a>.<a class="code" href="class_channel_switch.html#902b88a8d4bf0d4753734a6be4a8c8d7">m_defaultRoutes</a>.begin();
<a name="l00104"></a>00104                 <a class="code" href="class_channel_route_iterator.html#26e6feec14621814bb0047cbc946f0a7">m_itListEnd</a> = <a class="code" href="class_channel_route_iterator.html#82070a7b3f4a83f552313bce17157e8e">m_cs</a>.<a class="code" href="class_channel_switch.html#902b88a8d4bf0d4753734a6be4a8c8d7">m_defaultRoutes</a>.end();
<a name="l00105"></a>00105         }
<a name="l00106"></a>00106         <span class="keywordflow">else</span>
<a name="l00107"></a>00107         {
<a name="l00108"></a>00108                 <a class="code" href="class_channel_route_iterator.html#c7d6fde8284bcaa8d684bae3c079f57c">m_useDefault</a> = <span class="keyword">false</span>;
<a name="l00109"></a>00109                 <a class="code" href="class_channel_route_iterator.html#643eecd7fa8742e83a962176aacd96cb">m_itMapCurrent</a> = range.first;
<a name="l00110"></a>00110                 <a class="code" href="class_channel_route_iterator.html#ecaa9bae6db03a9b39088cc0e7394d8c">m_itMapEnd</a> = range.second;
<a name="l00111"></a>00111         }
<a name="l00112"></a>00112 }
<a name="l00113"></a>00113 
<a name="l00114"></a><a class="code" href="class_channel_route_iterator.html#14f8502d1e6f319381d411091ec02365">00114</a> <span class="keywordtype">bool</span> <a class="code" href="class_channel_route_iterator.html#14f8502d1e6f319381d411091ec02365">ChannelRouteIterator::End</a>()<span class="keyword"> const</span>
<a name="l00115"></a>00115 <span class="keyword"></span>{
<a name="l00116"></a>00116         <span class="keywordflow">return</span> <a class="code" href="class_channel_route_iterator.html#c7d6fde8284bcaa8d684bae3c079f57c">m_useDefault</a> ? <a class="code" href="class_channel_route_iterator.html#534b382fe373be38f7800d1d92946592">m_itListCurrent</a> == <a class="code" href="class_channel_route_iterator.html#26e6feec14621814bb0047cbc946f0a7">m_itListEnd</a> : <a class="code" href="class_channel_route_iterator.html#643eecd7fa8742e83a962176aacd96cb">m_itMapCurrent</a> == <a class="code" href="class_channel_route_iterator.html#ecaa9bae6db03a9b39088cc0e7394d8c">m_itMapEnd</a>;
<a name="l00117"></a>00117 }
<a name="l00118"></a>00118 
<a name="l00119"></a><a class="code" href="class_channel_route_iterator.html#76ebd766280e96f582072e7a2fea3bec">00119</a> <span class="keywordtype">void</span> <a class="code" href="class_channel_route_iterator.html#76ebd766280e96f582072e7a2fea3bec">ChannelRouteIterator::Next</a>()
<a name="l00120"></a>00120 {
<a name="l00121"></a>00121         <span class="keywordflow">if</span> (<a class="code" href="class_channel_route_iterator.html#c7d6fde8284bcaa8d684bae3c079f57c">m_useDefault</a>)
<a name="l00122"></a>00122                 ++<a class="code" href="class_channel_route_iterator.html#534b382fe373be38f7800d1d92946592">m_itListCurrent</a>;
<a name="l00123"></a>00123         <span class="keywordflow">else</span>
<a name="l00124"></a>00124                 ++<a class="code" href="class_channel_route_iterator.html#643eecd7fa8742e83a962176aacd96cb">m_itMapCurrent</a>;
<a name="l00125"></a>00125 }
<a name="l00126"></a>00126 
<a name="l00127"></a><a class="code" href="class_channel_route_iterator.html#c52ae006ff11d2423aca39b261ca6d67">00127</a> <a class="code" href="class_buffered_transformation.html" title="interface for buffered transformations">BufferedTransformation</a> &amp; <a class="code" href="class_channel_route_iterator.html#c52ae006ff11d2423aca39b261ca6d67">ChannelRouteIterator::Destination</a>()
<a name="l00128"></a>00128 {
<a name="l00129"></a>00129         <span class="keywordflow">return</span> <a class="code" href="class_channel_route_iterator.html#c7d6fde8284bcaa8d684bae3c079f57c">m_useDefault</a> ? *<a class="code" href="class_channel_route_iterator.html#534b382fe373be38f7800d1d92946592">m_itListCurrent</a>-&gt;first : *<a class="code" href="class_channel_route_iterator.html#643eecd7fa8742e83a962176aacd96cb">m_itMapCurrent</a>-&gt;second.first;
<a name="l00130"></a>00130 }
<a name="l00131"></a>00131 
<a name="l00132"></a><a class="code" href="class_channel_route_iterator.html#bb4fc50d81f6658df516bfb714103368">00132</a> <span class="keyword">const</span> std::string &amp; <a class="code" href="class_channel_route_iterator.html#bb4fc50d81f6658df516bfb714103368">ChannelRouteIterator::Channel</a>()
<a name="l00133"></a>00133 {
<a name="l00134"></a>00134         <span class="keywordflow">if</span> (<a class="code" href="class_channel_route_iterator.html#c7d6fde8284bcaa8d684bae3c079f57c">m_useDefault</a>)
<a name="l00135"></a>00135                 <span class="keywordflow">return</span> <a class="code" href="class_channel_route_iterator.html#534b382fe373be38f7800d1d92946592">m_itListCurrent</a>-&gt;second.get() ? *<a class="code" href="class_channel_route_iterator.html#534b382fe373be38f7800d1d92946592">m_itListCurrent</a>-&gt;second.get() : <a class="code" href="class_channel_route_iterator.html#c20002a033d7ad5915b0761aa3458117">m_channel</a>;
<a name="l00136"></a>00136         <span class="keywordflow">else</span>
<a name="l00137"></a>00137                 <span class="keywordflow">return</span> <a class="code" href="class_channel_route_iterator.html#643eecd7fa8742e83a962176aacd96cb">m_itMapCurrent</a>-&gt;second.second;
<a name="l00138"></a>00138 }
<a name="l00139"></a>00139 
<a name="l00140"></a>00140 
<a name="l00141"></a>00141 <span class="comment">//</span>
<a name="l00142"></a>00142 <span class="comment">// ChannelSwitch</span><span class="comment"></span>
<a name="l00143"></a>00143 <span class="comment">///////////////////</span>
<a name="l00144"></a>00144 <span class="comment"></span>
<a name="l00145"></a><a class="code" href="class_channel_switch.html#19e244d0593c91190858739b3240489c">00145</a> <span class="keywordtype">size_t</span> <a class="code" href="class_channel_switch.html#19e244d0593c91190858739b3240489c">ChannelSwitch::ChannelPut2</a>(<span class="keyword">const</span> std::string &amp;channel, <span class="keyword">const</span> byte *begin, <span class="keywordtype">size_t</span> length, <span class="keywordtype">int</span> messageEnd, <span class="keywordtype">bool</span> blocking)
<a name="l00146"></a>00146 {
<a name="l00147"></a>00147         <span class="keywordflow">if</span> (m_blocked)
<a name="l00148"></a>00148         {
<a name="l00149"></a>00149                 m_blocked = <span class="keyword">false</span>;
<a name="l00150"></a>00150                 <span class="keywordflow">goto</span> WasBlocked;
<a name="l00151"></a>00151         }
<a name="l00152"></a>00152 
<a name="l00153"></a>00153         m_it.<a class="code" href="class_channel_route_iterator.html#862708d9e96fb0d6f884fb7e022a5b5a">Reset</a>(channel);
<a name="l00154"></a>00154 
<a name="l00155"></a>00155         <span class="keywordflow">while</span> (!m_it.<a class="code" href="class_channel_route_iterator.html#14f8502d1e6f319381d411091ec02365">End</a>())
<a name="l00156"></a>00156         {
<a name="l00157"></a>00157 WasBlocked:
<a name="l00158"></a>00158                 <span class="keywordflow">if</span> (m_it.<a class="code" href="class_channel_route_iterator.html#c52ae006ff11d2423aca39b261ca6d67">Destination</a>().<a class="code" href="class_buffered_transformation.html#825c38044d268f6d561cb7f849e04b13">ChannelPut2</a>(m_it.<a class="code" href="class_channel_route_iterator.html#bb4fc50d81f6658df516bfb714103368">Channel</a>(), begin, length, messageEnd, blocking))
<a name="l00159"></a>00159                 {
<a name="l00160"></a>00160                         m_blocked = <span class="keyword">true</span>;
<a name="l00161"></a>00161                         <span class="keywordflow">return</span> 1;
<a name="l00162"></a>00162                 }
<a name="l00163"></a>00163 
<a name="l00164"></a>00164                 m_it.<a class="code" href="class_channel_route_iterator.html#76ebd766280e96f582072e7a2fea3bec">Next</a>();
<a name="l00165"></a>00165         }
<a name="l00166"></a>00166 
<a name="l00167"></a>00167         <span class="keywordflow">return</span> 0;
<a name="l00168"></a>00168 }
<a name="l00169"></a>00169 
<a name="l00170"></a><a class="code" href="class_channel_switch.html#f663620f334464f987001187102bbb49">00170</a> <span class="keywordtype">void</span> <a class="code" href="class_channel_switch.html#f663620f334464f987001187102bbb49">ChannelSwitch::IsolatedInitialize</a>(<span class="keyword">const</span> <a class="code" href="class_name_value_pairs.html" title="interface for retrieving values given their names">NameValuePairs</a> &amp;parameters<span class="comment">/* =g_nullNameValuePairs */</span>)
<a name="l00171"></a>00171 {
<a name="l00172"></a>00172         m_routeMap.clear();
<a name="l00173"></a>00173         m_defaultRoutes.clear();
<a name="l00174"></a>00174         m_blocked = <span class="keyword">false</span>;
<a name="l00175"></a>00175 }
<a name="l00176"></a>00176 
<a name="l00177"></a><a class="code" href="class_channel_switch.html#35f25c2c035162f840088df46d905584">00177</a> <span class="keywordtype">bool</span> <a class="code" href="class_channel_switch.html#35f25c2c035162f840088df46d905584">ChannelSwitch::ChannelFlush</a>(<span class="keyword">const</span> std::string &amp;channel, <span class="keywordtype">bool</span> completeFlush, <span class="keywordtype">int</span> propagation, <span class="keywordtype">bool</span> blocking)
<a name="l00178"></a>00178 {
<a name="l00179"></a>00179         <span class="keywordflow">if</span> (m_blocked)
<a name="l00180"></a>00180         {
<a name="l00181"></a>00181                 m_blocked = <span class="keyword">false</span>;
<a name="l00182"></a>00182                 <span class="keywordflow">goto</span> WasBlocked;
<a name="l00183"></a>00183         }
<a name="l00184"></a>00184 
<a name="l00185"></a>00185         m_it.<a class="code" href="class_channel_route_iterator.html#862708d9e96fb0d6f884fb7e022a5b5a">Reset</a>(channel);
<a name="l00186"></a>00186 
<a name="l00187"></a>00187         <span class="keywordflow">while</span> (!m_it.<a class="code" href="class_channel_route_iterator.html#14f8502d1e6f319381d411091ec02365">End</a>())
<a name="l00188"></a>00188         {
<a name="l00189"></a>00189           WasBlocked:
<a name="l00190"></a>00190                 <span class="keywordflow">if</span> (m_it.<a class="code" href="class_channel_route_iterator.html#c52ae006ff11d2423aca39b261ca6d67">Destination</a>().<a class="code" href="class_buffered_transformation.html#6b504b2694ecb5d709a9858c5b93a0f7">ChannelFlush</a>(m_it.<a class="code" href="class_channel_route_iterator.html#bb4fc50d81f6658df516bfb714103368">Channel</a>(), completeFlush, propagation, blocking))
<a name="l00191"></a>00191                 {
<a name="l00192"></a>00192                         m_blocked = <span class="keyword">true</span>;
<a name="l00193"></a>00193                         <span class="keywordflow">return</span> <span class="keyword">true</span>;
<a name="l00194"></a>00194                 }
<a name="l00195"></a>00195 
<a name="l00196"></a>00196                 m_it.<a class="code" href="class_channel_route_iterator.html#76ebd766280e96f582072e7a2fea3bec">Next</a>();
<a name="l00197"></a>00197         }
<a name="l00198"></a>00198 
<a name="l00199"></a>00199         <span class="keywordflow">return</span> <span class="keyword">false</span>;
<a name="l00200"></a>00200 }
<a name="l00201"></a>00201 
<a name="l00202"></a><a class="code" href="class_channel_switch.html#1459e69e94c5cd4aef42191635c07c1c">00202</a> <span class="keywordtype">bool</span> <a class="code" href="class_channel_switch.html#1459e69e94c5cd4aef42191635c07c1c">ChannelSwitch::ChannelMessageSeriesEnd</a>(<span class="keyword">const</span> std::string &amp;channel, <span class="keywordtype">int</span> propagation, <span class="keywordtype">bool</span> blocking)
<a name="l00203"></a>00203 {