1 #ifndef EVENTFILTER_UTILITIES_MASTERQUEUE_H
2 #define EVENTFILTER_UTILITIES_MASTERQUEUE_H
32 std::ostringstream ost;
33 ost <<
"failed to get message queue:"
50 std::cout <<
"snd::Master failed to post message - error:"
51 << strerror(errno) << std::endl;
57 unsigned long msg_type = ptr->mtype;
59 if (rc == -1 && errno != ENOMSG)
61 std::string serr =
"rcv::Master failed to get message from queue - error:";
62 serr += strerror(errno);
70 unsigned long msg_type = ptr->mtype;
72 if (rc == -1 && errno != ENOMSG)
74 std::string serr =
"rcvnb::Master failed to get message from queue - error:";
75 serr += strerror(errno);
85 std::cout <<
"disconnect of master queue failed - error:" << strerror(errno) << std::endl;
92 char cbuf[
sizeof(
struct msqid_ds)];
93 struct msqid_ds *buf= (
struct msqid_ds*)cbuf;
120 std::cout <<
"drained one message, occupancy now " <<
occup_ << std::endl;
#define MSGQ_MESSAGE_TYPE_RANGE
pid_t pidOfLastReceive() const
unsigned long rcvNonBlocking(MsgBuf &ptr)
unsigned long rcv(MsgBuf &ptr)
pid_t pidOfLastSend() const
MasterQueue(unsigned int ind)