rstpclientmcif.h

/* libradar_stp
 * <http://www.k9nl.net/radar/> <radar@k9nl.net>
 * 
 * rstpclientifmc.h - RSTP client class interface
 * for multiple connections
 *
 * Copyright (C) 2007 Nicholas J. Luther
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License,
 * version 2, as published by the Free Software Foundation.
 * 
 * This program 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 this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 * You may contact the author by writing to Nick Luther, 1655 South
 * Westhaven Drive, Oshkosh, Wisconsin 54904, USA.
 * 
 */
 
#ifndef _LIBRSTP_INC_RSTPCLIENTMCIF_H
#define _LIBRSTP_INC_RSTPCLIENTMCIF_H
 
#include <string>
#include <vector>
#include <set>
#include <map>

#include "rstpclientif.h"

// Windows DLL stuff
#if defined(WIN32) || defined(WIN_NATIVE)
#ifdef LIBRADAR_STP_EXPORTS
#define LIBRADAR_STP_INTERFACE __declspec(dllexport)
#else
#define LIBRADAR_STP_INTERFACE __declspec(dllimport)
#endif
#else
#define LIBRADAR_STP_INTERFACE 
#endif


namespace libradar_stp {

class 
LIBRADAR_STP_INTERFACE
RSTPClientMCIf {
  public:
    
    RSTPClientMCIf();
    ~RSTPClientMCIf();
    
    int addConnection();
    
    RSTPClientIf& connection( int conn_id );
    const RSTPClientIf& connection( int conn_id ) const;
  
    bool start();               
  
    bool quit();
    
    typedef void (*CBFUNCDATA)( void*, const std::string&, const std::string& );
    typedef void (*CBFUNCERR)( void*, const std::string& );
  
    void setDataCallback( CBFUNCDATA func, void* arg = 0 );
    
    void setErrorCallback( CBFUNCERR func, void* arg = 0 );
    
    void setRepeatCheckEnabled( bool enabled = true );
    
    void setRepeatCheckDBSize( int size = 200 );
    
    bool loadFile( const std::string& filename );
    
    bool readConfig( std::istream& confin );
    
    void setRedundantPeerModeEnabled( bool enabled = true );
    
    void setRedundantPeerModeMaxTicks( int ticks = 10 );
    
    void eventRedundantPeerModeTick();
    
  private:
  
    CBFUNCDATA m_data_cb;
    void* m_data_cb_arg;
    CBFUNCERR m_error_cb;
    void* m_error_cb_arg;
    
    std::vector<RSTPClientIf*> m_connections;
    
    bool m_running;
    bool m_repeat_check;
    int m_repeat_db_size;
    std::set<std::string> m_repeat_db_1;
    std::set<std::string> m_repeat_db_2;
    
    bool m_redun_peer_mode;
    typedef std::map< std::string, std::string > redun_db_tick_el_t;
    std::vector< redun_db_tick_el_t > m_redun_db;
    bool m_redun_db_lock;
    int m_redun_tick;
    
    bool repeatCheckPassed( const std::string& data );
    std::string dataSignature( const std::string& data ) const;
  
  public:
  
    static void _data_cb( void* arg, const std::string& stream, const std::string& data );
    static void _error_cb( void* arg, const std::string& msg );
    
  }; // class
  
}; // namespace


#endif

---