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

/// ----------------------------------------*- 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