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_sock.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_sock_h_ #define _terimber_msg_sock_h_ #include "aiomsg/msg_conn.h" #include "aiomsg/msg_lsnr.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) class msg_sock_connection : public msg_connection, public terimber_aiosock_callback { protected: msg_sock_connection(msg_communicator* communicator, const conf_connection& info ); msg_sock_connection(msg_communicator* communicator, size_t handle, const conf_listener& linfo, const conf_connection& cinfo ); public: virtual ~msg_sock_connection(); static msg_sock_connection* connect( msg_communicator* communicator, const conf_connection& info ); static void accept( size_t handle, msg_communicator* communicator, const conf_listener& info, terimber_aiosock_callback*& callback ); protected: virtual void v_do_job( size_t ident, void* user_data ); virtual bool v_has_job( size_t ident, void* user_data ); virtual void v_on_error( size_t handle, int err, aiosock_type mask, void* userdata ); virtual void v_on_connect( size_t handle, const sockaddr_in& peeraddr, void* userdata ); // port will call function after successfully sending buffer to socket virtual void v_on_send( size_t handle, void* buf, size_t requested, size_t processed, const sockaddr_in& peeraddr, void* userdata ); virtual void v_on_receive( size_t handle, void* buf, size_t requested, size_t processed, const sockaddr_in& peeraddr, void* userdata ); virtual void v_on_accept( size_t handle, size_t handle_accepted, terimber_aiosock_callback*& callback, const sockaddr_in& peeraddr, void* userdata ); protected: msg_cpp* _msg_send; ub4_t _offset_send; msg_cpp* _msg_recv; ub4_t _size_recv; ub4_t _offset_recv; size_t _handle; }; class msg_sock_listener : public msg_listener, public terimber_aiosock_callback { public: msg_sock_listener(msg_communicator* communicator, const conf_listener& info ); virtual ~msg_sock_listener(); virtual transport_type get_type() const { return sock; } protected: virtual void v_on(); virtual void v_off(); virtual void v_on_error( size_t handle, int err, aiosock_type mask, void* userdata ); virtual void v_on_connect( size_t handle, const sockaddr_in& peeraddr, void* userdata ); virtual void v_on_send( size_t handle, void* buf, size_t requested, size_t processed, const sockaddr_in& peeraddr, void* userdata ); virtual void v_on_receive( size_t handle, void* buf, size_t requested, size_t processed, const sockaddr_in& peeraddr, void* userdata ); virtual void v_on_accept( size_t handle, size_t handle_accepted, terimber_aiosock_callback*& callback, const sockaddr_in& peeraddr, void* userdata ); private: size_t _handle; }; #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_msg_sock_h_

© Copyright Terimber 2003-.