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 aiogatefactory.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_aiogate_factory_h_ #define _terimber_aiogate_factory_h_ #include "log.h" // A few very important notes... // 1. aiogate guarantees that all sent blocks will be delivered in the original placed order "send" // 2. aiogate guarantees that all received blocks will be delivered through callback "on_recv" one by one // it's impossible to have two or more invoked callbacks "on_recv" at the same time for the same socket handle. // 3. All methods are thread-safe. // forward declaration class terimber_aiogate; const ub4_t aiogate_accept_mask = 0x00000001; const ub4_t aiogate_connect_mask = 0x00000002; const ub4_t aiogate_send_mask = 0x00000004; const ub4_t aiogate_recv_mask = 0x00000008; const ub4_t aiogate_bind_mask = 0x00000010; class terimber_aiogate_buffer { public: const void* buf; size_t len; }; class terimber_aiogate_pin { public: virtual ~terimber_aiogate_pin() {} virtual void on_accept( const sockaddr_in& local, const sockaddr_in& remote, size_t ident, terimber_aiogate* callback ) = 0; virtual void on_connect( const sockaddr_in& local, const sockaddr_in& remote, size_t ident, terimber_aiogate* callback ) = 0; virtual void on_bind( const sockaddr_in& local, size_t ident, terimber_aiogate* callback ) = 0; // \return true if it is expected of aiogate to automatically invoke recv method // expected_more param is just for performance optimization virtual bool on_recv( const void* buf, size_t len, const sockaddr_in& peeraddr, bool& expected_more ) = 0; virtual void on_send( const sockaddr_in& peeraddr ) = 0; // only internal action can be taken - no aiogate calls anymore for this pin virtual void on_close( ub4_t mask ) = 0; }; // user has to implement the code class terimber_aiogate_pin_factory { public: virtual ~terimber_aiogate_pin_factory() {} virtual terimber_aiogate_pin* create( void* arg ) = 0; virtual void destroy( terimber_aiogate_pin* pin ) = 0; }; class terimber_aiogate : public terimber_log_helper { public: virtual ~terimber_aiogate() {} virtual size_t listen( const char* address, unsigned short port, size_t max_connection, unsigned short buffered_acceptors, terimber_aiogate_pin_factory* factory, void* arg ) = 0; virtual void deaf( size_t ident ) = 0; virtual size_t connect( const char* remote, unsigned short rport, const char* local, unsigned short lport, size_t timeout, terimber_aiogate_pin_factory* factory, void* arg ) = 0; // UDP only methods virtual size_t bind( const char* address, unsigned short port, terimber_aiogate_pin_factory* factory, void* arg ) = 0; // /UDP virtual bool send( size_t ident, const void* buf, size_t len, const sockaddr_in* toaddr ) = 0; virtual bool send_bulk( size_t ident, const terimber_aiogate_buffer* bulk, size_t count, const sockaddr_in* toaddr ) = 0; virtual bool recv( size_t ident, bool expect_delivery, const sockaddr_in* toaddr ) = 0; virtual bool close( size_t ident ) = 0; virtual bool set_send_timeout(size_t ident, size_t timeout ) = 0; virtual bool set_recv_timeout(size_t ident, size_t timeout ) = 0; virtual void doxray() = 0; }; class terimber_aiogate_factory { public: terimber_aiogate_factory(); terimber_aiogate* get_terimber_aiogate(terimber_log* log, size_t addional_working_threads = 0, size_t max_mem_usage = 1024*1024*16 ); }; #endif // _terimber_aiogate_access_h_

© Copyright Terimber 2003-.