mqueue_8h-source.html
来自「Crypto++是一个非常强大的密码学库,主要是功能全」· HTML 代码 · 共 112 行
HTML
112 行
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN"><html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1"><title>Crypto++: mqueue.h Source File</title><link href="doxygen.css" rel="stylesheet" type="text/css"></head><body><!-- Generated by Doxygen 1.3.2 --><div class="qindex"><a class="qindex" href="index.html">Main Page</a> | <a class="qindex" href="namespaces.html">Namespace List</a> | <a class="qindex" href="hierarchy.html">Class Hierarchy</a> | <a class="qindex" href="classes.html">Alphabetical List</a> | <a class="qindex" href="annotated.html">Compound List</a> | <a class="qindex" href="files.html">File List</a> | <a class="qindex" href="namespacemembers.html">Namespace Members</a> | <a class="qindex" href="functions.html">Compound Members</a> | <a class="qindex" href="globals.html">File Members</a></div><h1>mqueue.h</h1><div class="fragment"><pre>00001 <span class="preprocessor">#ifndef CRYPTOPP_MQUEUE_H</span>00002 <span class="preprocessor"></span><span class="preprocessor">#define CRYPTOPP_MQUEUE_H</span>00003 <span class="preprocessor"></span>00004 <span class="preprocessor">#include "queue.h"</span>00005 <span class="preprocessor">#include "filters.h"</span>00006 <span class="preprocessor">#include <deque></span>00007 00008 NAMESPACE_BEGIN(CryptoPP)00009 00010 <span class="comment">//! Message Queue</span><a name="l00011"></a><a class="code" href="class_message_queue.html">00011</a> <span class="comment"></span><span class="keyword">class </span>CRYPTOPP_DLL MessageQueue : <span class="keyword">public</span> AutoSignaling<BufferedTransformation>00012 {00013 <span class="keyword">public</span>:00014 MessageQueue(<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> nodeSize=256);00015 00016 <span class="keywordtype">void</span> IsolatedInitialize(<span class="keyword">const</span> <a class="code" href="class_name_value_pairs.html">NameValuePairs</a> &parameters)00017 {m_queue.IsolatedInitialize(parameters); m_lengths.assign(1, 0U); m_messageCounts.assign(1, 0U);}<a name="l00018"></a><a class="code" href="class_message_queue.html#_message_queuea2">00018</a> <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> Put2(<span class="keyword">const</span> byte *begin, <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> length, <span class="keywordtype">int</span> messageEnd, <span class="keywordtype">bool</span> blocking)00019 {00020 m_queue.Put(begin, length);00021 m_lengths.back() += length;00022 <span class="keywordflow">if</span> (messageEnd)00023 {00024 m_lengths.push_back(0);00025 m_messageCounts.back()++;00026 }00027 <span class="keywordflow">return</span> 0;00028 }00029 <span class="keywordtype">bool</span> IsolatedFlush(<span class="keywordtype">bool</span> hardFlush, <span class="keywordtype">bool</span> blocking) {<span class="keywordflow">return</span> <span class="keyword">false</span>;}00030 <span class="keywordtype">bool</span> IsolatedMessageSeriesEnd(<span class="keywordtype">bool</span> blocking)00031 {m_messageCounts.push_back(0); <span class="keywordflow">return</span> <span class="keyword">false</span>;}00032 <a name="l00033"></a><a class="code" href="class_message_queue.html#_message_queuea5">00033</a> <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> MaxRetrievable()<span class="keyword"> const</span>00034 <span class="keyword"> </span>{<span class="keywordflow">return</span> m_lengths.front();}<a name="l00035"></a><a class="code" href="class_message_queue.html#_message_queuea6">00035</a> <span class="keywordtype">bool</span> AnyRetrievable()<span class="keyword"> const</span>00036 <span class="keyword"> </span>{<span class="keywordflow">return</span> m_lengths.front() > 0;}00037 00038 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> TransferTo2(<a class="code" href="class_buffered_transformation.html">BufferedTransformation</a> &target, <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> &transferBytes, <span class="keyword">const</span> std::string &channel=NULL_CHANNEL, <span class="keywordtype">bool</span> blocking=<span class="keyword">true</span>);00039 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> CopyRangeTo2(<a class="code" href="class_buffered_transformation.html">BufferedTransformation</a> &target, <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> &begin, <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> end=ULONG_MAX, <span class="keyword">const</span> std::string &channel=NULL_CHANNEL, <span class="keywordtype">bool</span> blocking=<span class="keyword">true</span>) <span class="keyword">const</span>;00040 00041 <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> TotalBytesRetrievable()<span class="keyword"> const</span>00042 <span class="keyword"> </span>{<span class="keywordflow">return</span> m_queue.MaxRetrievable();}<a name="l00043"></a><a class="code" href="class_message_queue.html#_message_queuea10">00043</a> <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> NumberOfMessages()<span class="keyword"> const</span>00044 <span class="keyword"> </span>{<span class="keywordflow">return</span> m_lengths.size()-1;}00045 <span class="keywordtype">bool</span> GetNextMessage();00046 00047 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> NumberOfMessagesInThisSeries()<span class="keyword"> const</span>00048 <span class="keyword"> </span>{<span class="keywordflow">return</span> m_messageCounts[0];}00049 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> NumberOfMessageSeries()<span class="keyword"> const</span>00050 <span class="keyword"> </span>{<span class="keywordflow">return</span> m_messageCounts.size()-1;}00051 00052 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> CopyMessagesTo(<a class="code" href="class_buffered_transformation.html">BufferedTransformation</a> &target, <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> count=UINT_MAX, <span class="keyword">const</span> std::string &channel=NULL_CHANNEL) <span class="keyword">const</span>;00053 00054 <span class="keyword">const</span> byte * Spy(<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> &contiguousSize) <span class="keyword">const</span>;00055 00056 <span class="keywordtype">void</span> swap(MessageQueue &rhs);00057 00058 <span class="keyword">private</span>:00059 <a class="code" href="class_byte_queue.html">ByteQueue</a> m_queue;00060 std::deque<unsigned long> m_lengths, m_messageCounts;00061 };00062 00063 <span class="comment"></span>00064 <span class="comment">//! A filter that checks messages on two channels for equality</span><a name="l00065"></a><a class="code" href="class_equality_comparison_filter.html">00065</a> <span class="comment"></span><span class="keyword">class </span>CRYPTOPP_DLL EqualityComparisonFilter : <span class="keyword">public</span> Unflushable<Multichannel<Filter> >00066 {00067 <span class="keyword">public</span>:00068 <span class="keyword">struct </span>MismatchDetected : <span class="keyword">public</span> <a class="code" href="class_exception.html">Exception</a> {MismatchDetected() : <a class="code" href="class_exception.html">Exception</a>(DATA_INTEGRITY_CHECK_FAILED, <span class="stringliteral">"EqualityComparisonFilter: did not receive the same data on two channels"</span>) {}};00069 <span class="comment"></span>00070 <span class="comment"> /*! if throwIfNotEqual is false, this filter will output a '\0' byte when it detects a mismatch, '\1' otherwise */</span><a name="l00071"></a><a class="code" href="class_equality_comparison_filter.html#_equality_comparison_filtera0">00071</a> EqualityComparisonFilter(<a class="code" href="class_buffered_transformation.html">BufferedTransformation</a> *attachment=NULL, <span class="keywordtype">bool</span> throwIfNotEqual=<span class="keyword">true</span>, <span class="keyword">const</span> std::string &firstChannel=<span class="stringliteral">"0"</span>, <span class="keyword">const</span> std::string &secondChannel=<span class="stringliteral">"1"</span>)00072 : Unflushable<Multichannel<<a class="code" href="class_filter.html">Filter</a>> >(attachment), m_throwIfNotEqual(throwIfNotEqual), m_mismatchDetected(false)00073 , m_firstChannel(firstChannel), m_secondChannel(secondChannel) {}00074 00075 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> ChannelPut2(<span class="keyword">const</span> std::string &channel, <span class="keyword">const</span> byte *begin, <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> length, <span class="keywordtype">int</span> messageEnd, <span class="keywordtype">bool</span> blocking);00076 00077 <span class="keywordtype">void</span> ChannelInitialize(<span class="keyword">const</span> std::string &channel, <span class="keyword">const</span> <a class="code" href="class_name_value_pairs.html">NameValuePairs</a> &parameters=g_nullNameValuePairs, <span class="keywordtype">int</span> propagation=-1);00078 <span class="keywordtype">bool</span> ChannelMessageSeriesEnd(<span class="keyword">const</span> std::string &channel, <span class="keywordtype">int</span> propagation=-1, <span class="keywordtype">bool</span> blocking=<span class="keyword">true</span>);00079 00080 <span class="keyword">private</span>:00081 <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> MapChannel(<span class="keyword">const</span> std::string &channel) <span class="keyword">const</span>;00082 <span class="keywordtype">bool</span> HandleMismatchDetected(<span class="keywordtype">bool</span> blocking);00083 00084 <span class="keywordtype">bool</span> m_throwIfNotEqual, m_mismatchDetected;00085 std::string m_firstChannel, m_secondChannel;00086 MessageQueue m_q[2];00087 };00088 00089 NAMESPACE_END00090 00091 NAMESPACE_BEGIN(std)00092 <span class="keyword">template</span><> <span class="keyword">inline</span> <span class="keywordtype">void</span> swap(CryptoPP::MessageQueue &a, CryptoPP::MessageQueue &b)00093 {00094 a.swap(b);00095 }00096 NAMESPACE_END00097 00098 <span class="preprocessor">#endif</span></pre></div><hr size="1"><address style="align: right;"><small>Generated on Tue Jul 8 23:34:20 2003 for Crypto++ by<a href="http://www.doxygen.org/index.html"><img src="doxygen.png" alt="doxygen" align="middle" border=0 > </a>1.3.2 </small></address></body></html>⌨️ 快捷键说明
复制代码Ctrl + C
搜索代码Ctrl + F
全屏模式F11
增大字号Ctrl + =
减小字号Ctrl + -
显示快捷键?