source: source/ariba/communication/modules/transport/protlib/queuemanager.h@ 5638

/// ----------------------------------------*- mode: C++; -*--
/// @file queuemanager.h
/// This is the queuemanager which records queues and message source IDs
/// ----------------------------------------------------------
/// $Id: queuemanager.h 2549 2007-04-02 22:17:37Z bless $
/// $HeadURL: https://svn.ipv6.tm.uka.de/nsis/protlib/trunk/include/queuemanager.h $
// ===========================================================
//                      
// Copyright (C) 2005-2007, all rights reserved by
// - Institute of Telematics, Universitaet Karlsruhe (TH)
//
// More information and contact:
// https://projekte.tm.uka.de/trac/NSIS
//                      
// 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; version 2 of the License
//
// 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 Street, Fifth Floor, Boston, MA 02110-1301 USA.
//
// ===========================================================
/** @ingroup queuemanager
 *
 * This is the queuemanager which records queues and message source IDs.
 */

#ifndef QUEUE_MANAGER_H
#define QUEUE_MANAGER_H

#include "protlib_types.h"
#include "cleanuphandler.h"

#include <vector>

#include "fqueue.h"
#include "messages.h"

namespace protlib { 

/** @addtogroup queuemanager Queue Manager
 * \ingroup fastqueue
 * @{
 */

/// QueueManager errors
class QueueManagerError : public ProtLibException {
public:
        /// error codes
        enum error_t {
                ERROR_NO_QUEUE_MANAGER,
                ERROR_REGISTER
        }; // end error_t
        const error_t err;
        /// constructor
        QueueManagerError(error_t e);
        virtual const char* getstr() const;
        virtual const char *what() const throw() { return getstr(); }
private:
        /// QueueManager error strings
        static const char* const errstr[];
}; // end class QueueManagerError


/**
 * The Queue Manager singleton.
 *
 * The QueueManager manages several FastQueue objects. A queue is registered
 * with the manager using a simple (key, value) scheme. The key is of type
 * message:qaddr_t, and the value is a FastQueue object.
 *
 * You can send messages to a registered queue using the message::send_to(dest)
 * method, where dest has to be the message::qaddr_t which has been used for
 * registering the queue.
 *
 * This class is used as a singleton, so there will usually be only one
 * object of this class.
 */
class QueueManager {
public:
        /// return QueueManager singleton instance
        static QueueManager* instance();
        /// clear QueueManager 
        static void clear();
        /// register a queue
        void register_queue(FastQueue* fq, message::qaddr_t s);
        /// deregister a queue
        void unregister_queue(message::qaddr_t s);

        /// get queue
        FastQueue* get_queue(message::qaddr_t s) const;
private:
        /// QueueManager instance
        static QueueManager* inst;
        /// constructor
        QueueManager();
        /// Destruktor
        ~QueueManager();
        /// QueueManager array
        typedef vector<FastQueue*> qm_array_t;
        /// QueueManager array iterator
        typedef qm_array_t::iterator qm_array_it_t;
        /// array
        qm_array_t queue_arr;
        /// locking
        mutable pthread_mutex_t mutex;

        static const size_t INITIAL_ARRAY_SIZE = 128;
};

//@}

} // end namespace protlib

#endif