_pion_engine_8cpp-source.html

用c++编写http server的源码库,对socket等网络处理的代码可迅速转为己用.

<a name="l00079"></a>00079             std::for_each(m_thread_pool.begin(), m_thread_pool.end(),
<a name="l00080"></a>00080                           boost::bind(&amp;boost::thread::join, _1));
<a name="l00081"></a>00081 
<a name="l00082"></a>00082             <span class="comment">// clear the thread pool (also deletes thread objects)</span>
<a name="l00083"></a>00083             m_thread_pool.clear();
<a name="l00084"></a>00084         }
<a name="l00085"></a>00085 
<a name="l00086"></a>00086 <span class="preprocessor">#ifdef PION_WIN32</span>
<a name="l00087"></a>00087 <span class="preprocessor"></span>        <span class="comment">// pause for 1 extra second to work-around shutdown crash on Windows</span>
<a name="l00088"></a>00088         <span class="comment">// which seems related to static objects used in the ASIO library</span>
<a name="l00089"></a>00089         boost::xtime stop_time;
<a name="l00090"></a>00090         stop_time.sec = time(NULL) + 1;
<a name="l00091"></a>00091         boost::thread::sleep(stop_time);
<a name="l00092"></a>00092 <span class="preprocessor">#endif</span>
<a name="l00093"></a>00093 <span class="preprocessor"></span>
<a name="l00094"></a>00094         PION_LOG_INFO(m_logger, <span class="stringliteral">"Pion has shutdown"</span>);
<a name="l00095"></a>00095 
<a name="l00096"></a>00096         m_is_running = <span class="keyword">false</span>;
<a name="l00097"></a>00097         m_engine_has_stopped.notify_all();
<a name="l00098"></a>00098     }
<a name="l00099"></a>00099     
<a name="l00100"></a>00100     <span class="keywordflow">if</span> (reset_servers) {
<a name="l00101"></a>00101         m_asio_service.stop();
<a name="l00102"></a>00102         m_servers.clear();
<a name="l00103"></a>00103     }
<a name="l00104"></a>00104 }
<a name="l00105"></a>00105 
<a name="l00106"></a><a class="code" href="classpion_1_1_pion_engine.html#e9ae5bdbf1ef328a83e9a1a12037d08e">00106</a> <span class="keywordtype">void</span> <a class="code" href="classpion_1_1_pion_engine.html#e9ae5bdbf1ef328a83e9a1a12037d08e" title="the calling thread will sleep until the engine has stopped">PionEngine::join</a>(<span class="keywordtype">void</span>)
<a name="l00107"></a>00107 {
<a name="l00108"></a>00108     boost::mutex::scoped_lock engine_lock(m_mutex);
<a name="l00109"></a>00109     <span class="keywordflow">if</span> (m_is_running) {
<a name="l00110"></a>00110         <span class="comment">// sleep until engine_has_stopped condition is signaled</span>
<a name="l00111"></a>00111         m_engine_has_stopped.wait(engine_lock);
<a name="l00112"></a>00112     }
<a name="l00113"></a>00113 }
<a name="l00114"></a>00114 
<a name="l00115"></a>00115 <span class="keywordtype">void</span> PionEngine::run(<span class="keywordtype">void</span>)
<a name="l00116"></a>00116 {
<a name="l00117"></a>00117     <span class="keywordflow">try</span> {
<a name="l00118"></a>00118         <span class="comment">// handle I/O events managed by the service</span>
<a name="l00119"></a>00119         m_asio_service.run();
<a name="l00120"></a>00120     } <span class="keywordflow">catch</span> (std::exception&amp; e) {
<a name="l00121"></a>00121         PION_LOG_FATAL(m_logger, <span class="stringliteral">"Caught exception in pool thread: "</span> &lt;&lt; e.what());
<a name="l00122"></a>00122         <a class="code" href="classpion_1_1_pion_engine.html#2c6d002ad46191a4c4c4046537db329e">stop</a>();
<a name="l00123"></a>00123     }
<a name="l00124"></a>00124 }
<a name="l00125"></a>00125 
<a name="l00126"></a><a class="code" href="classpion_1_1_pion_engine.html#39c7e8b0eeca284001cf7a9455cbb5ae">00126</a> <span class="keywordtype">bool</span> <a class="code" href="classpion_1_1_pion_engine.html#39c7e8b0eeca284001cf7a9455cbb5ae">PionEngine::addServer</a>(<a class="code" href="namespacepion.html#a54ac170d28fb8b88d560775581a9b8f" title="data type for a TCPServer pointer">TCPServerPtr</a> tcp_server)
<a name="l00127"></a>00127 {
<a name="l00128"></a>00128     <span class="comment">// lock mutex for thread safety</span>
<a name="l00129"></a>00129     boost::mutex::scoped_lock engine_lock(m_mutex);
<a name="l00130"></a>00130     
<a name="l00131"></a>00131     <span class="comment">// attempt to insert tcp_server into the server map</span>
<a name="l00132"></a>00132     std::pair&lt;TCPServerMap::iterator, bool&gt; result =
<a name="l00133"></a>00133         m_servers.insert( std::make_pair(tcp_server-&gt;getPort(), tcp_server) );
<a name="l00134"></a>00134 
<a name="l00135"></a>00135     <span class="keywordflow">return</span> result.second;
<a name="l00136"></a>00136 }
<a name="l00137"></a>00137 
<a name="l00138"></a><a class="code" href="classpion_1_1_pion_engine.html#caa79f07e5eb562eb4b3ba99230ee941">00138</a> <a class="code" href="namespacepion.html#7ed8c1f0fbb318801a8a19dda04f7001" title="data type for a HTTP protocol handler pointer">HTTPServerPtr</a> <a class="code" href="classpion_1_1_pion_engine.html#caa79f07e5eb562eb4b3ba99230ee941">PionEngine::addHTTPServer</a>(<span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> tcp_port)
<a name="l00139"></a>00139 {
<a name="l00140"></a>00140     <a class="code" href="namespacepion.html#7ed8c1f0fbb318801a8a19dda04f7001" title="data type for a HTTP protocol handler pointer">HTTPServerPtr</a> http_server(<a class="code" href="classpion_1_1_h_t_t_p_server.html#ad3704c715ed243c9133eceff99fc851">HTTPServer::create</a>(tcp_port));
<a name="l00141"></a>00141 
<a name="l00142"></a>00142     <span class="comment">// lock mutex for thread safety</span>
<a name="l00143"></a>00143     boost::mutex::scoped_lock engine_lock(m_mutex);
<a name="l00144"></a>00144     
<a name="l00145"></a>00145     <span class="comment">// attempt to insert http_server into the server map</span>
<a name="l00146"></a>00146     std::pair&lt;TCPServerMap::iterator, bool&gt; result =
<a name="l00147"></a>00147         m_servers.insert( std::make_pair(tcp_port, http_server) );
<a name="l00148"></a>00148 
<a name="l00149"></a>00149     <span class="keywordflow">if</span> (! result.second) http_server.reset();
<a name="l00150"></a>00150     
<a name="l00151"></a>00151     <span class="keywordflow">return</span> http_server;
<a name="l00152"></a>00152 }
<a name="l00153"></a>00153 
<a name="l00154"></a><a class="code" href="classpion_1_1_pion_engine.html#d2a1e4fc8c01020702b067508c027d6d">00154</a> <a class="code" href="namespacepion.html#a54ac170d28fb8b88d560775581a9b8f" title="data type for a TCPServer pointer">TCPServerPtr</a> <a class="code" href="classpion_1_1_pion_engine.html#d2a1e4fc8c01020702b067508c027d6d">PionEngine::getServer</a>(<span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> tcp_port)
<a name="l00155"></a>00155 {
<a name="l00156"></a>00156     <span class="comment">// lock mutex for thread safety</span>
<a name="l00157"></a>00157     boost::mutex::scoped_lock engine_lock(m_mutex);
<a name="l00158"></a>00158     
<a name="l00159"></a>00159     <span class="comment">// check if a server already exists</span>
<a name="l00160"></a>00160     TCPServerMap::iterator i = m_servers.find(tcp_port);
<a name="l00161"></a>00161     
<a name="l00162"></a>00162     <span class="keywordflow">return</span> (i==m_servers.end() ? <a class="code" href="namespacepion.html#a54ac170d28fb8b88d560775581a9b8f" title="data type for a TCPServer pointer">TCPServerPtr</a>() : i-&gt;second);
<a name="l00163"></a>00163 }
<a name="l00164"></a>00164 
<a name="l00165"></a>00165 }   <span class="comment">// end namespace pion</span>
</pre></div><hr size="1"><address style="text-align: right;"><small>Generated on Tue Jun 19 13:29:22 2007 for libpion by&nbsp;
<a href="http://www.doxygen.org/index.html">
<img src="doxygen.png" alt="doxygen" align="middle" border="0"></a> 1.5.2 </small></address>
</body>
</html>