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_comm.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_comm_h_ #define _terimber_msg_comm_h_ #include "base/except.h" #include "base/map.h" #include "base/keymaker.h" #include "crypt/crypt.h" #include "aiosock/aiosock.h" #include "threadpool/timer.h" #include "threadpool/threadpoolfactory.h" #include "xml/sxml.h" #include "aiomsg/msg_que.h" // guid generator extern guid_t uuid_gen(); BEGIN_TERIMBER_NAMESPACE #pragma pack(4) // forward declarations class msg_connection; class msg_communicator; class msg_listener; #ifdef _DEBUG const size_t rsa_key_size = 256; #else const size_t rsa_key_size = 2048; #endif static const size_t stay_on_alert_time = 10000; //10 sec static const size_t max_thread_capacity = 64; //64 class msg_communicator : public msg_queue_processor, public timer_callback, public terimber_log_helper { typedef list< msg_listener* > listener_list_t; typedef map< guid_t, msg_connection* > connection_map_t; typedef map< guid_t, msg_communicator* > this_map_t; public: msg_communicator(); ~msg_communicator(); void init( const char* info_, const char* ini_key_ ); void init( const void* info_, size_t len ); void init( xml_designer* nav ); // NB!!! throws exception class object void uninit(); void add_connection(msg_connection* connection ); // changes connection address void change_connection_address(const guid_t& old_address, msg_connection* connection ); void shutdown_connection(msg_connection* connection ); inline const guid_t& get_address() const { return _address; } msg_cpp* construct_msg(size_t size ); bool resize_msg( msg_cpp* msg, size_t size ); msg_cpp* copy_msg( msg_cpp* msg ); bool destroy_msg(msg_cpp* msg ); void get_msg_key(room_byte_t& crypt_private, const room_byte_t& crypt_external, const guid_t& session ) const; inline static msg_cpp* cast( msg_t* msg ) { try { return dynamic_cast< msg_cpp * >(static_cast< msg_cpp * >(msg)); } catch (...) { return 0; } } inline static const msg_cpp* cast( const msg_t* msg ) { try { return dynamic_cast< const msg_cpp * >(static_cast< const msg_cpp * >(msg)); } catch (...) { return 0; } } inline static bool set_receiver( msg_cpp* msg, const guid_t& receiver ) { if (!msg) return false; msg->_receiver = receiver; return true; } inline static bool get_sender( const msg_cpp* msg, guid_t& sender ) { if (!msg) return false; sender = msg->_sender; return true; } msg_connection* find_connection(const guid_t& addr ); msg_listener* find_listener( transport_type type ); bool validate_connection(const msg_connection* connection ) const; void comm_msg( msg_cpp* msg ); msg_cpp* construct_handshake(const rsa* rsa ); msg_cpp* reply_handshake(const msg_cpp* msg, room_byte_t* symetric_private_key ); void check_handshake(const guid_t& sessionid, const msg_cpp* reply, const rsa* rsa, room_byte_t& symetric_private_key ); msg_cpp* construct_ping(); aiosock& get_aiosock(); threadpool& get_thread_manager(); event_pool_t& get_event_pool(); void add_connection_config(const conf_connection& atom ); void add_listener_config(const conf_listener& atom, bool start ); void remove_connection_config(const guid_t& address ); void remove_listener_config(transport_type type ); static void parse_connection(xml_designer* nav, conf_connection& atom ); static void parse_listener( xml_designer* nav, conf_listener& atom ); static msg_communicator* loan_communicator(const guid_t& addr); static void return_communicator(const guid_t& addr, msg_communicator* comm); void doxray(); void log_msg( const msg_cpp* msg ); protected: virtual void v_do_job( size_t ident, void* user_data ); virtual void v_on(); virtual void v_off(); virtual void wakeup(); virtual void notify( size_t ident, size_t interval, size_t multiplier ); private: msg_connection* _connect( const conf_connection& info_, ub8_t timeout ); void _close_connection(const guid_t& addr ); msg_cpp* _generate_crypt_private_key(const rsa& rsa, room_byte_t& symetric_private_key ); msg_cpp* _pack_keys( const integer& n, const integer& e ); void _extract_keys( const msg_cpp* msg, integer& n, integer& e ); void _decrypt_private_key(const msg_cpp* reply, const rsa& rsa, room_byte_t& symetric_private_key ); void _turn_off_listeners(); void _turn_on_listeners(); void _destroy_listeners(); void _turn_off_connections(); void _turn_on_connections(); void _destroy_connections(); void _create_listeners(); void _create_listener(const conf_listener& atom ); void _register_this(); void _revoke_this(); private: guid_t _address; guid_t _debug_address; mutex _mtx_listeners; listener_list_t _listeners; mutex _mtx_conn; connection_map_t _connections; mem_pool_t _manager; threadpool _thread_manager; aiosock _aio_port; timer _ping_timer; mutex _mtx_config; conf_unit _config; event_pool_t _event_pool; static keylocker _this_access; static this_map_t _this_map; }; class msg_creator : public proto_creator< msg_creator, msg_cpp, size_t > { public: msg_creator( msg_communicator* communicator ) : _communicator(communicator) { } msg_cpp* create( size_t n ) { return _communicator->construct_msg(n); } void destroy( msg_cpp* obj ) { if (obj) _communicator->destroy_msg(obj); } private: msg_communicator* _communicator; }; typedef smart_pointer< msg_creator > msg_pointer_t; #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_msg_comm_h_

© Copyright Terimber 2003-.