cygnal.h

Go to the documentation of this file.

// 
//   Copyright (C) 2005, 2006, 2007, 2008, 2009, 2010 Free Software
//   Foundation, Inc
// 
// This program 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.
// 
// 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., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

#ifndef __CYGNAL_H__
#define __CYGNAL_H__

#include <boost/cstdint.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/thread/mutex.hpp>
#include <vector>
#include <string>
#include <map>

#include "extension.h"
#include "handler.h"

namespace cygnal {    

    
class Cygnal
{
public:
    typedef Handler::cygnal_init_t (*initentry_t)();
    
    typedef struct {
        std::string hostname;
        short       port;
        bool        connected;
        int         fd;
        gnash::Network::protocols_supported_e protocol;
        std::vector<std::string> supported;
    } peer_t;
    static Cygnal& getDefaultInstance();
    ~Cygnal();

    bool loadPeersFile();
    bool loadPeersFile(const std::string &filespec);

    void probePeers();
    void probePeers(peer_t &peer);
    void probePeers(boost::shared_ptr<peer_t> peer);
    void probePeers(std::vector<boost::shared_ptr<peer_t> > &peers);

    void addHandler(const std::string &path, boost::shared_ptr<Handler> x) {
        _handlers[path] = x;
    };

    boost::shared_ptr<Handler> findHandler(const std::string &path);
    void removeHandler(const std::string &path);

    std::vector<boost::shared_ptr<peer_t> > & getActive() { return _active_peers; };

    void dump();

private:
    void addPeer(boost::shared_ptr<peer_t> x) {
        _peers.push_back(x);
    };

    std::vector<boost::shared_ptr<peer_t> > _peers;
    std::vector<boost::shared_ptr<peer_t> > _active_peers;
    std::map<std::string, boost::shared_ptr<Handler> > _handlers;
    boost::mutex _mutex;
};

class ThreadCounter
{
public:

    ThreadCounter() : _tids(0) {};
    void increment() { boost::mutex::scoped_lock lk(_tid_mutex); ++_tids; };
    void decrement() { boost::mutex::scoped_lock lk(_tid_mutex); --_tids; };
    int num_of_tids() { return _tids; };
private:
    boost::mutex  _tid_mutex;
    int           _tids;
    boost::thread _tid_handle;
};
  
// End of gnash namespace 
}

// __CYGNAL_H__
#endif


// local Variables:
// mode: C++
// indent-tabs-mode: t
// End: