threadcontrollerimpl.h

/***************************************************************************
*   Copyright (C) 2005 by                                                 *
*   Pedro J. Fernandez Ruiz    pedroj.fernandez@dif.um.es                 *
*   Alejandro Perez Mendez     alejandro_perez@dif.um.es                  *
*                                                                         *
*   This library is free software; you can redistribute it and/or         *
*   modify it under the terms of the GNU Lesser General Public            *
*   License as published by the Free Software Foundation; either          *
*   version 2.1 of the License, or (at your option) any later version.    *
*                                                                         *
*   This library 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     *
*   Lesser General Public License for more details.                       *
*                                                                         *
*   You should have received a copy of the GNU Lesser General Public      *
*   License along with this library; if not, write to the Free Software   *
*   Foundation, Inc., 51 Franklin St, Fifth Floor,                        *
*   Boston, MA  02110-1301  USA                                           *
***************************************************************************/
#ifndef THREADCONTROLLERIMPL_H
#define THREADCONTROLLERIMPL_H

#include "runnable.h"
#include "condition.h"
#include "mutex.h"
#include "semaphore.h"
#include "ikesaexecuter.h"
#include "ikesacontroller.h"
#include "command.h"
#include "payload_tsi.h"
#include "payload_tsr.h"

using namespace std;

namespace openikev2 {

    class ThreadControllerImpl {

            /****************************** ATTRIBUTES ******************************/
        protected:
            map <uint64_t, IkeSaController*> ike_sa_collection;   
            auto_ptr<Mutex> mutex_ike_sa_collection;                
            deque<IkeSaController*> waiting_ike_sa_controller;    
            auto_ptr<Condition> condition_ike_sa_executer;          
            bool exiting;                                           
            uint32_t half_open_counter;                             
            auto_ptr<Mutex> mutex_half_open_counter;                
            /****************************** METHODS ******************************/
        public:

            virtual void initialize( uint16_t num_command_executers );

            virtual void startThread( Runnable& runnable ) = 0;

            virtual auto_ptr<Condition> getCondition() = 0;

            virtual auto_ptr<Mutex> getMutex() = 0;

            virtual auto_ptr<Semaphore> getSemaphore( uint32_t initial_value ) = 0;

            virtual void incHalfOpenCounter();

            virtual void decHalfOpenCounter();

            virtual bool useCookies();

            virtual IkeSaController& getWaitingIkeSaController();

            virtual void addWaitingIkeSaController( IkeSaController& ike_sa_controller );

            virtual uint64_t nextSpi() = 0;

            virtual void addIkeSaController( auto_ptr<IkeSaController> ike_sa_controller );

            virtual void requestChildSa( IpAddress& src_addr, IpAddress& dst_addr, auto_ptr<ChildSa> child_sa );
            
            virtual void requestChildSa( IpAddress& src_addr, IpAddress& dst_addr, Enums::PROTOCOL_ID ipsec_protocol, Enums::IPSEC_MODE mode, auto_ptr<Payload_TSi> payload_ts_i, auto_ptr<Payload_TSr> payload_ts_r, uint32_t request_id );

            virtual void deleteIkeSaController( IkeSaController& ike_sa_controller );

            virtual bool pushCommandBySpi( uint64_t spi, auto_ptr<Command> command, bool priority );

            virtual bool pushCommandByAddress( const IpAddress& addr, const IpAddress& peer_addr, auto_ptr<Command> command, bool priority );

            virtual void closeAllSas();

            virtual void exit();

            virtual bool isExiting();

            virtual ~ThreadControllerImpl();
    };
};
#endif

---