Thread portable class Gate portable class Timer class Pool class Terimber 2.0 About C++

Downloads Products & Services Support Clients Open Source About Home / Open source / Terimber 2.0 msg_conn.h Go to the documentation of this file. /* * The Software License * ================================================================================= * Copyright (c) 2003-.The Terimber Corporation. All rights reserved. * ================================================================================= * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * The end-user documentation included with the redistribution, if any, * must include the following acknowledgment: * "This product includes software developed by the Terimber Corporation." * ================================================================================= * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED WARRANTIES, * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. * IN NO EVENT SHALL THE TERIMBER CORPORATION OR ITS CONTRIBUTORS BE LIABLE FOR * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * ================================================================================ */ #ifndef _terimber_msg_conn_h_ #define _terimber_msg_conn_h_ #include "aiomsg/msg_cpp.h" #include "aiomsg/msg_comm.h" #include "base/primitives.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) static const size_t queue_thread_ident = 255; class msg_connection : public msg_queue_processor { protected: enum msg_conn_state { CONN_STATE_CLOSE, CONN_STATE_HANDSHAKE_INITIATOR, CONN_STATE_HANDSHAKE_RECEIVER, CONN_STATE_CONNECTED }; public: msg_connection( msg_communicator* communicator, const conf_listener& linfo, const conf_connection& info ); msg_connection( msg_communicator* communicator, const conf_connection& info ); virtual ~msg_connection(); virtual void push_msg( msg_cpp* msg ); inline const room_byte_t* get_crypt_key() { return _info._support_crypt && _info._crypt_private.size() > 2 ? &_info._crypt_private : 0; } inline void set_last_activity() { mutex_keeper keeper(_mtx_res); _last_activity = date(); } inline bool is_last_activity_timeout() { mutex_keeper keeper(_mtx_res); return _last_activity.is_time_over(_info._ping); } virtual void ping_notify(); inline const conf_connection& get_info() { return _info; } const rsa* get_rsa() const { return _info._support_crypt ? &_rsa : 0; } bool is_connected() const { return CONN_STATE_CONNECTED == _state; } msg_cpp* prepare_handshake_msg(); msg_cpp* prepare_handshake_reply(msg_cpp* msg); void validate_handshake_reply(msg_cpp* msg); void process_incoming_message(msg_cpp* msg ); protected: virtual void wakeup(); protected: conf_connection _info; conf_listener _linfo; msg_conn_state _state; rsa _rsa; private: date _last_activity; }; #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_msg_comm_h_

© Copyright Terimber 2003-.