/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_6_2_7/src/EventFilter/Utilities/interface/MasterQueue.h

Go to the documentation of this file.

#ifndef EVENTFILTER_UTILITIES_MASTERQUEUE_H
#define EVENTFILTER_UTILITIES_MASTERQUEUE_H

#include <stdio.h>       /* standard I/O functions.              */
#include <stdlib.h>      /* malloc(), free() etc.                */
#include <sys/types.h>   /* various type definitions.            */
#include <sys/ipc.h>     /* general SysV IPC structures          */
#include <sys/msg.h>     /* message queue functions and structs. */
#include <errno.h>
#include <string.h>

#include <iostream>
#include <sstream>
#include <vector>

#include "EventFilter/Utilities/interface/Exception.h"
#include "EventFilter/Utilities/interface/MsgBuf.h"

namespace evf {

class MasterQueue {

public:

        MasterQueue(unsigned int ind);
        ~MasterQueue();

        int post(MsgBuf &ptr);
        int postLength(MsgBuf &ptr, unsigned int length);
        unsigned long rcv(MsgBuf &ptr);
        bool rcvQuiet(MsgBuf &ptr);
        unsigned long rcvNonBlocking(MsgBuf &ptr);
        int disconnect();
        int id();
        int status();
        int occupancy() const;
        void drain();
        pid_t pidOfLastSend() const;
        pid_t pidOfLastReceive() const;

        std::vector<int> getReceivers() const { return receivers_; }

private:

        void updateReceivers();

private:

        int queue_id_; /* ID of the created queue.            */
        int status_;
        int occup_;
        int pidOfLastSend_;
        int pidOfLastReceive_;
        std::vector<int> receivers_;
};
}
#endif