📄 ida_8cpp-source.html
字号:
<a name="l00092"></a>00092 {<a name="l00093"></a>00093 lword size = <a class="code" href="class_raw_i_d_a.html#584a7b425d16b083cce42f5af573dc52">m_inputQueues</a>[i].MaxRetrievable();<a name="l00094"></a>00094 <a class="code" href="class_raw_i_d_a.html#584a7b425d16b083cce42f5af573dc52">m_inputQueues</a>[i].Put(inString, length);<a name="l00095"></a>00095 <span class="keywordflow">if</span> (size < 4 && size + length >= 4)<a name="l00096"></a>00096 {<a name="l00097"></a>00097 <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a>++;<a name="l00098"></a>00098 <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> == <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>)<a name="l00099"></a>00099 ProcessInputQueues();<a name="l00100"></a>00100 }<a name="l00101"></a>00101 <a name="l00102"></a>00102 <span class="keywordflow">if</span> (messageEnd)<a name="l00103"></a>00103 {<a name="l00104"></a>00104 <a class="code" href="class_raw_i_d_a.html#584a7b425d16b083cce42f5af573dc52">m_inputQueues</a>[i].MessageEnd();<a name="l00105"></a>00105 <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#584a7b425d16b083cce42f5af573dc52">m_inputQueues</a>[i].<a class="code" href="class_buffered_transformation.html#56bcbb4306a9c04cda838f96e85a2116" title="number of times MessageEnd() has been received minus messages retrieved or skipped...">NumberOfMessages</a>() == 1)<a name="l00106"></a>00106 {<a name="l00107"></a>00107 <a class="code" href="class_raw_i_d_a.html#1173bd790607b585dfe9eaeab8335a37">m_channelsFinished</a>++;<a name="l00108"></a>00108 <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#1173bd790607b585dfe9eaeab8335a37">m_channelsFinished</a> == <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>)<a name="l00109"></a>00109 {<a name="l00110"></a>00110 <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> = 0;<a name="l00111"></a>00111 <span class="keywordflow">for</span> (i=0; i<<a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>; i++)<a name="l00112"></a>00112 <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> += <a class="code" href="class_raw_i_d_a.html#584a7b425d16b083cce42f5af573dc52">m_inputQueues</a>[i].<a class="code" href="class_buffered_transformation.html#8c1e2ca57fc06a1f3694d8fe7f8508ff" title="returns whether any bytes are currently ready for retrieval">AnyRetrievable</a>();<a name="l00113"></a>00113 ProcessInputQueues();<a name="l00114"></a>00114 }<a name="l00115"></a>00115 }<a name="l00116"></a>00116 }<a name="l00117"></a>00117 }<a name="l00118"></a>00118 }<a name="l00119"></a>00119 <a name="l00120"></a>00120 lword RawIDA::InputBuffered(word32 channelId)<span class="keyword"> const</span><a name="l00121"></a>00121 <span class="keyword"></span>{<a name="l00122"></a>00122 <span class="keywordtype">int</span> i = LookupInputChannel(channelId);<a name="l00123"></a>00123 <span class="keywordflow">return</span> i < <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a> ? <a class="code" href="class_raw_i_d_a.html#584a7b425d16b083cce42f5af573dc52">m_inputQueues</a>[i].MaxRetrievable() : 0;<a name="l00124"></a>00124 }<a name="l00125"></a>00125 <a name="l00126"></a>00126 <span class="keywordtype">void</span> RawIDA::ComputeV(<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> i)<a name="l00127"></a>00127 {<a name="l00128"></a>00128 <span class="keywordflow">if</span> (i >= <a class="code" href="class_raw_i_d_a.html#b634332d6f20a199d5dae6189bb81c27">m_v</a>.size())<a name="l00129"></a>00129 {<a name="l00130"></a>00130 <a class="code" href="class_raw_i_d_a.html#b634332d6f20a199d5dae6189bb81c27">m_v</a>.resize(i+1);<a name="l00131"></a>00131 <a class="code" href="class_raw_i_d_a.html#eeecf596f67b49b762b131b80a5ccce0">m_outputToInput</a>.resize(i+1);<a name="l00132"></a>00132 }<a name="l00133"></a>00133 <a name="l00134"></a>00134 <a class="code" href="class_raw_i_d_a.html#eeecf596f67b49b762b131b80a5ccce0">m_outputToInput</a>[i] = LookupInputChannel(<a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>[i]);<a name="l00135"></a>00135 <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#eeecf596f67b49b762b131b80a5ccce0">m_outputToInput</a>[i] == <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a> && i * <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a> <= 1000*1000)<a name="l00136"></a>00136 {<a name="l00137"></a>00137 <a class="code" href="class_raw_i_d_a.html#b634332d6f20a199d5dae6189bb81c27">m_v</a>[i].resize(<a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>);<a name="l00138"></a>00138 PrepareBulkPolynomialInterpolationAt(field, <a class="code" href="class_raw_i_d_a.html#b634332d6f20a199d5dae6189bb81c27">m_v</a>[i].begin(), <a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>[i], &(<a class="code" href="class_raw_i_d_a.html#a282d4933e80efe030fb96361e1ff419">m_inputChannelIds</a>[0]), <a class="code" href="class_raw_i_d_a.html#c4230794f2fd020888e42f64a55b1560">m_w</a>.<a class="code" href="class_sec_block.html#11a05906688172579cd3520816799446">begin</a>(), <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>);<a name="l00139"></a>00139 }<a name="l00140"></a>00140 }<a name="l00141"></a>00141 <a name="l00142"></a>00142 <span class="keywordtype">void</span> RawIDA::AddOutputChannel(word32 channelId)<a name="l00143"></a>00143 {<a name="l00144"></a>00144 <a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>.push_back(channelId);<a name="l00145"></a>00145 <a class="code" href="class_raw_i_d_a.html#a2a11404f7b82de338821b549dd7b851">m_outputChannelIdStrings</a>.push_back(WordToString(channelId));<a name="l00146"></a>00146 <a class="code" href="class_raw_i_d_a.html#ae55af87cd9751e8b37923bde5aacd82">m_outputQueues</a>.push_back(<a class="code" href="class_byte_queue.html" title="Byte Queue.">ByteQueue</a>());<a name="l00147"></a>00147 <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#a282d4933e80efe030fb96361e1ff419">m_inputChannelIds</a>.size() == <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>)<a name="l00148"></a>00148 ComputeV((<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span>)<a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>.size() - 1);<a name="l00149"></a>00149 }<a name="l00150"></a>00150 <a name="l00151"></a>00151 <span class="keywordtype">void</span> RawIDA::PrepareInterpolation()<a name="l00152"></a>00152 {<a name="l00153"></a>00153 assert(<a class="code" href="class_raw_i_d_a.html#a282d4933e80efe030fb96361e1ff419">m_inputChannelIds</a>.size() == <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>);<a name="l00154"></a>00154 PrepareBulkPolynomialInterpolation(field, <a class="code" href="class_raw_i_d_a.html#c4230794f2fd020888e42f64a55b1560">m_w</a>.<a class="code" href="class_sec_block.html#11a05906688172579cd3520816799446">begin</a>(), &(<a class="code" href="class_raw_i_d_a.html#a282d4933e80efe030fb96361e1ff419">m_inputChannelIds</a>[0]), <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>);<a name="l00155"></a>00155 <span class="keywordflow">for</span> (<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> i=0; i<<a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>.size(); i++)<a name="l00156"></a>00156 ComputeV(i);<a name="l00157"></a>00157 }<a name="l00158"></a>00158 <a name="l00159"></a>00159 <span class="keywordtype">void</span> RawIDA::ProcessInputQueues()<a name="l00160"></a>00160 {<a name="l00161"></a>00161 <span class="keywordtype">bool</span> finished = (<a class="code" href="class_raw_i_d_a.html#1173bd790607b585dfe9eaeab8335a37">m_channelsFinished</a> == <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>);<a name="l00162"></a>00162 <span class="keywordtype">int</span> i;<a name="l00163"></a>00163 <a name="l00164"></a>00164 <span class="keywordflow">while</span> (finished ? <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> > 0 : <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> == <a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>)<a name="l00165"></a>00165 {<a name="l00166"></a>00166 <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> = 0;<a name="l00167"></a>00167 <span class="keywordflow">for</span> (i=0; i<<a class="code" href="class_raw_i_d_a.html#a2983c025ce40ed5b39aa41419cc8cbe">m_threshold</a>; i++)<a name="l00168"></a>00168 {<a name="l00169"></a>00169 <a class="code" href="class_message_queue.html" title="Message Queue.">MessageQueue</a> &queue = <a class="code" href="class_raw_i_d_a.html#584a7b425d16b083cce42f5af573dc52">m_inputQueues</a>[i];<a name="l00170"></a>00170 queue.GetWord32(<a class="code" href="class_raw_i_d_a.html#f18d09b7e8088ccb33e3b905fb326a4d">m_y</a>[i]);<a name="l00171"></a>00171 <a name="l00172"></a>00172 <span class="keywordflow">if</span> (finished)<a name="l00173"></a>00173 <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> += queue.AnyRetrievable();<a name="l00174"></a>00174 <span class="keywordflow">else</span><a name="l00175"></a>00175 <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> += queue.NumberOfMessages() > 0 || queue.MaxRetrievable() >= 4;<a name="l00176"></a>00176 }<a name="l00177"></a>00177 <a name="l00178"></a>00178 <span class="keywordflow">for</span> (i=0; (<span class="keywordtype">unsigned</span> int)i<<a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>.size(); i++)<a name="l00179"></a>00179 {<a name="l00180"></a>00180 <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#eeecf596f67b49b762b131b80a5ccce0">m_outputToInput</a>[i] != m_threshold)<a name="l00181"></a>00181 <a class="code" href="class_raw_i_d_a.html#ae55af87cd9751e8b37923bde5aacd82">m_outputQueues</a>[i].PutWord32(<a class="code" href="class_raw_i_d_a.html#f18d09b7e8088ccb33e3b905fb326a4d">m_y</a>[<a class="code" href="class_raw_i_d_a.html#eeecf596f67b49b762b131b80a5ccce0">m_outputToInput</a>[i]]);<a name="l00182"></a>00182 <span class="keywordflow">else</span> <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#b634332d6f20a199d5dae6189bb81c27">m_v</a>[i].size() == m_threshold)<a name="l00183"></a>00183 <a class="code" href="class_raw_i_d_a.html#ae55af87cd9751e8b37923bde5aacd82">m_outputQueues</a>[i].PutWord32(BulkPolynomialInterpolateAt(field, <a class="code" href="class_raw_i_d_a.html#f18d09b7e8088ccb33e3b905fb326a4d">m_y</a>.<a class="code" href="class_sec_block.html#11a05906688172579cd3520816799446">begin</a>(), <a class="code" href="class_raw_i_d_a.html#b634332d6f20a199d5dae6189bb81c27">m_v</a>[i].begin(), m_threshold));<a name="l00184"></a>00184 <span class="keywordflow">else</span><a name="l00185"></a>00185 {<a name="l00186"></a>00186 <a class="code" href="class_raw_i_d_a.html#59853e70a74011fd7d16a849ecdadda4">m_u</a>.<a class="code" href="class_sec_block.html#f9e98d3f4a7af1156fcf3e6e68f4ae5a" title="change size and preserve contents">resize</a>(m_threshold);<a name="l00187"></a>00187 PrepareBulkPolynomialInterpolationAt(field, <a class="code" href="class_raw_i_d_a.html#59853e70a74011fd7d16a849ecdadda4">m_u</a>.<a class="code" href="class_sec_block.html#11a05906688172579cd3520816799446">begin</a>(), <a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>[i], &(<a class="code" href="class_raw_i_d_a.html#a282d4933e80efe030fb96361e1ff419">m_inputChannelIds</a>[0]), <a class="code" href="class_raw_i_d_a.html#c4230794f2fd020888e42f64a55b1560">m_w</a>.<a class="code" href="class_sec_block.html#11a05906688172579cd3520816799446">begin</a>(), m_threshold);<a name="l00188"></a>00188 <a class="code" href="class_raw_i_d_a.html#ae55af87cd9751e8b37923bde5aacd82">m_outputQueues</a>[i].PutWord32(BulkPolynomialInterpolateAt(field, <a class="code" href="class_raw_i_d_a.html#f18d09b7e8088ccb33e3b905fb326a4d">m_y</a>.<a class="code" href="class_sec_block.html#11a05906688172579cd3520816799446">begin</a>(), <a class="code" href="class_raw_i_d_a.html#59853e70a74011fd7d16a849ecdadda4">m_u</a>.<a class="code" href="class_sec_block.html#11a05906688172579cd3520816799446">begin</a>(), m_threshold));<a name="l00189"></a>00189 }<a name="l00190"></a>00190 }<a name="l00191"></a>00191 }<a name="l00192"></a>00192 <a name="l00193"></a>00193 <span class="keywordflow">if</span> (<a class="code" href="class_raw_i_d_a.html#376de5858283ae6ec368ee49d53febad">m_outputChannelIds</a>.size() > 0 && <a class="code" href="class_raw_i_d_a.html#ae55af87cd9751e8b37923bde5aacd82">m_outputQueues</a>[0].AnyRetrievable())<a name="l00194"></a>00194 FlushOutputQueues();<a name="l00195"></a>00195 <a name="l00196"></a>00196 <span class="keywordflow">if</span> (finished)<a name="l00197"></a>00197 {<a name="l00198"></a>00198 OutputMessageEnds();<a name="l00199"></a>00199 <a name="l00200"></a>00200 <a class="code" href="class_raw_i_d_a.html#c6f20ebfa8c7d0bb793267d401905c27">m_channelsReady</a> = 0;<a name="l00201"></a>00201 <a class="code" href="class_raw_i_d_a.html#1173bd790607b585dfe9eaeab8335a37">m_channelsFinished</a> = 0;<a name="l00202"></a>00202 <a class="code" href="class_raw_i_d_a.html#b634332d6f20a199d5dae6189bb81c27">m_v</a>.clear();<a name="l00203"></a>00203
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -