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_user.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_user_h_ #define _terimber_msg_user_h_ #include "aiomsg/msg_conn.h" #include "aiomsg/msg_lsnr.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) class msg_wait_reply { public: msg_wait_reply( event* event_ ); ~msg_wait_reply() { } inline void set_reply( msg_cpp* msg_ ) { // assigns reply pointer _reply = msg_; // sets signal _event->signal(); } inline msg_cpp* get_reply() { // remembers reply message pointer msg_cpp* retVal = _reply; // reset _reply = 0; // return return retVal; } private: event* _event; msg_cpp* _reply; }; class msg_wait_async_reply { public: msg_wait_async_reply(const guid_t& ident, ub8_t timeout_ ); ~msg_wait_async_reply() { } inline void set_reply( msg_cpp* msg_ ) { _reply = msg_; } inline msg_cpp* get_reply() { // remembers reply message pointer msg_cpp* retVal = _reply; // reset _reply = 0; // return return retVal; } inline msg_cpp* get_reply_data( guid_t& ident ) { // remembers reply message pointer msg_cpp* retVal = _reply; // reset _reply = 0; // assign ident ident = _ident; // return return retVal; } inline bool is_expired(sb8_t now) const { return _expired < now; } private: guid_t _ident; msg_cpp* _reply; sb8_t _expired; }; class msg_user_connection : public msg_connection { // typedefs typedef map< guid_t, msg_wait_reply > reply_map_t; typedef map< guid_t, msg_wait_async_reply > reply_async_map_t; typedef list< msg_wait_async_reply > reply_async_list_t; public: msg_user_connection(msg_communicator* communicator, msg_callback_notify* callback, const conf_connection& info, size_t additional_threads = 0 ); virtual ~msg_user_connection(); virtual void push_msg( msg_cpp* msg ); static msg_user_connection* connect( msg_communicator* communicator, msg_callback_notify* callback, const conf_connection& info, size_t additional_threads ); bool send( bool copy, msg_cpp* msg, msg_cpp*& reply ); guid_t send_async( bool copy, msg_cpp* msg ); bool post( bool copy, msg_cpp* msg ); inline const char* get_last_error() const { return _error; } protected: inline bool peek_async() const { mutex_keeper keeper(_mtx_async_wait); return !_async_list.empty(); } bool pop_async( msg_cpp*& msg, guid_t& ident ); bool peek_async(); bool pop_async_timeouted(guid_t& ident ); bool peek_async_timeouted(); virtual void ping_notify(); protected: virtual bool v_has_job( size_t ident, void* user_data ); virtual void v_do_job( size_t ident, void* user_data ); virtual void wakeup(); virtual void v_off(); private: void process_income_message(); private: string_t _error; msg_callback_notify* _callback; mutex _mtx_wait; mutex _mtx_async_wait; reply_map_t _map; reply_async_map_t _async_map; reply_async_list_t _async_list; size_t _additional_threads; }; #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_msg_comm_h_

© Copyright Terimber 2003-.