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 aiogate.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_h_ #define _terimber_aiogate_h_ #include "aiosock/aiosock.h" #include "base/map.h" #include "base/list.h" #include "aiogate/aiogatefactory.h" #include "threadpool/thread.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) enum aiogate_chunk { BUFFER_CHUNK = 1024*64 }; class fixed_size_buffer { public: fixed_size_buffer() : _begin(0), _end(0), _next(0) { } ub1_t _ptr[BUFFER_CHUNK]; size_t _begin; size_t _end; fixed_size_buffer* _next; }; class aiogate : public terimber_aiogate, public terimber_aiosock_callback, public terimber_thread_employer { class listener_info { public: listener_info( terimber_aiogate_pin_factory* factory, void* arg ) : _factory(factory), _arg(arg) { } listener_info(const listener_info& x) : _factory(x._factory), _arg(x._arg) { } terimber_aiogate_pin_factory* _factory; void* _arg; }; class pin_info_minimum { public: pin_info_minimum() : _pin(0), _rbuf(0), _shead(0), _factory(0) {} pin_info_minimum(const pin_info_minimum& x) : _pin(x._pin), _rbuf(x._rbuf), _shead(x._shead), _factory(x._factory) { } terimber_aiogate_pin* _pin; fixed_size_buffer* _rbuf; fixed_size_buffer* _shead; terimber_aiogate_pin_factory* _factory; }; class pin_info : public pin_info_minimum { public: pin_info() : pin_info_minimum(), _stail(0), _send_timeout(INFINITE), _recv_timeout(INFINITE), _in_progress_mask(0x0), _callback_invoking_mask(0x0), _still_alive(true), _tcp_udp(true) {} pin_info(const pin_info& x) : pin_info_minimum(x), _stail(x._stail), _send_timeout(x._send_timeout), _recv_timeout(x._recv_timeout), _in_progress_mask(x._in_progress_mask), _callback_invoking_mask(x._callback_invoking_mask), _still_alive(x._still_alive), _tcp_udp(x._tcp_udp) { } ub8_t _leader; fixed_size_buffer* _stail; size_t _send_timeout; size_t _recv_timeout; ub4_t _in_progress_mask; ub4_t _callback_invoking_mask; bool _still_alive; bool _tcp_udp; }; class pin_info_extra : public pin_info_minimum { public: pin_info_extra( const pin_info_minimum& x, size_t ident, size_t mask, bool invoke_callback ) : pin_info_minimum(x), _ident(ident), _mask(mask), _invoke_callback(invoke_callback) { } pin_info_extra(const pin_info_extra& x) : pin_info_minimum(x), _ident(x._ident), _mask(x._mask), _invoke_callback(x._invoke_callback) { } size_t _ident; size_t _mask; bool _invoke_callback; }; class udp_header { public: sockaddr_in _addr; ub4_t _payload; }; typedef map< size_t, listener_info > listener_map_t; typedef map< size_t, pin_info > pin_map_t; typedef node_allocator< fixed_size_buffer > chunk_allocator_t; typedef list< pin_info_extra > close_list_t; public: aiogate(size_t addional_working_threads, size_t mem_usage ); virtual ~aiogate(); public: // terimber_socket_callback methods 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& toaddr, void* userdata ); virtual void v_on_receive(size_t handle, void* buf, size_t requested, size_t processed, const sockaddr_in& toaddr, void* userdata ); virtual void v_on_accept(size_t handle, size_t handle_accepted, terimber_aiosock_callback*& callback, const sockaddr_in& peeraddr, void* userdata ); // terimber_aiogate methods 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 ); virtual void deaf( size_t ident ); 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 ); // UDP only methods virtual size_t bind( const char* address, unsigned short port, terimber_aiogate_pin_factory* factory, void* arg ); // UDP virtual bool send( size_t ident, const void* buf, size_t len, const sockaddr_in* toaddr ); virtual bool send_bulk( size_t ident, const terimber_aiogate_buffer* bulk, size_t count, const sockaddr_in* toaddr ); virtual bool recv( size_t ident, bool expect_delivery, const sockaddr_in* toaddr ); virtual bool close( size_t ident ); virtual bool set_send_timeout(size_t ident, size_t timeout ); virtual bool set_recv_timeout(size_t ident, size_t timeout ); virtual void doxray(); bool on(); void off(); protected: // terimber_thread_employer methods virtual bool v_has_job( size_t ident, void* user_data ); virtual void v_do_job( size_t ident, void* user_data ); private: void lock_pin( mutex_keeper& mtx, pin_info& info, ub4_t mask ); bool unlock_pin(mutex_keeper& mtx, size_t ident, ub4_t mask, bool unmask_in_progress ); void initiate_close(size_t ident, size_t mask, bool invoke_callback ); void final_close(pin_info_extra& info ); private: bool _on; mutex _pin_mtx; listener_map_t _listener_map; pin_map_t _pin_map; aiosock _pin_port; chunk_allocator_t _pin_allocator; close_list_t _pin_list; thread _pin_thread; }; #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_aiogate_h_

© Copyright Terimber 2003-.