hsms_cnx.h

/*   
 *   (c) Copyright 2008 Philipp Skadorov (philipp_s@users.sourceforge.net)
 *
 *   This file is part of FREESECS.
 *
 *   FREESECS is free software: you can redistribute it and/or modify
 *   it under the terms of the GNU General Public License as published by
 *   the Free Software Foundation, either version 3 of the License, or
 *   (at your option) any later version.
 *
 *   FREESECS is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *   GNU General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with FREESECS, see COPYING.
 *   If not, see <http://www.gnu.org/licenses/>.
 */
#ifndef hsms_cnx_t_class
#define hsms_cnx_t_class

#include <string.h>
#include <stdint.h>
#include "signals.h"
#include "shared_ptr.h"
#include "hsms_msg.h"
#include "hsms_socket.h"
#include "async_reception.h"
#include "hsms_statemachine.h"

namespace freesecs
{
    /*
     * \brief HSMS connection base class.
     * Implements HSMS state machine base class
     * virtual methods for managing tcp cnx
     * and sending/receiving data over tcp via
     * hsms async socket class object
     */
    class hsms_cnx_t: public virtual hsms_sm_t
    {
    public:
        typedef hsms_socket_t::data_t  data_t;
        typedef hsms_socket_t::pdata_t pdata_t;
        
    public:
        virtual ~hsms_cnx_t();

        const char *name() const;

        uint16_t session_id() const;

        int start();
        int stop();
        int send(pdata_t);

        signal_one_arg_t<pdata_t>     rx_signal;
        

    protected:
        virtual int open_tcp();
        virtual int close_tcp();
        virtual int send_over_tcp(hsms_socket_t::pdata_t);
        virtual int recv_from_tcp(hsms_socket_t::pdata_t);
        virtual void hsms_msg_received(hsms_socket_t::pdata_t);

    protected:
        hsms_cnx_t(const char *name, uint16_t session_id, const char *remote_ip, unsigned remote_port);
        hsms_cnx_t(const char *name, uint16_t session_id, unsigned local_port);
        
    private:
        int sock_cnx_state_change_handler(const hsms_socket_t::cnx_state_et&);
        int sock_cnx_failed_handler();
        int sock_msg_rcv_handler(const pdata_t&);
        int sock_data_partially_recvd_handler();
        int sock_recv_error_handler();

    private:
        hsms_socket_async_t   _socket;

    private:
        std::string _name;
        uint16_t    _session_id;

    private:
        hsms_cnx_t();

    };

    class hsms_active_cnx_t : public hsms_cnx_t, public active_hsms_sm_t
    {
    public:
        hsms_active_cnx_t(const hsms_active_params_t&);
        virtual ~hsms_active_cnx_t();
    };

    class hsms_passive_cnx_t : public hsms_cnx_t, public passive_hsms_sm_t
    {
    public:
        hsms_passive_cnx_t(const hsms_passive_params_t&); 
        virtual ~hsms_passive_cnx_t(); 
    };
}//namespace

#endif //hsms_cnx_t_class

---