2 #include "interproccom.h"
6 #define SCOPED_LOCK(m) \
7 pthread_mutex_lock(&m); /* エラー処理は略 */ \
8 void u_(pthread_mutex_t** m_) { pthread_mutex_unlock(*m_); } \
9 __attribute__((__cleanup__(u_))) pthread_mutex_t* scoped_lock_ = &m
15 l7ag_interproccommunicate::l7ag_interproccommunicate()
20 pthread_mutex_init(&mutex_sbuf, NULL);
21 pthread_mutex_init(&mutex_rbuf, NULL);
28 l7ag_interproccommunicate::l7ag_interproccommunicate(l7ag_subagent *p_subagent)
33 pthread_mutex_init(&mutex_sbuf, NULL);
34 pthread_mutex_init(&mutex_rbuf, NULL);
36 set_parent(p_subagent);
43 l7ag_interproccommunicate::~l7ag_interproccommunicate()
54 l7ag_interproccommunicate::start_thread()
65 l7ag_interproccommunicate::send_mibdatacollect(std::string oid)
67 //make request message
76 l7ag_interproccommunicate::set_parent(l7ag_subagent *p_subagent)
86 l7ag_interproccommunicate::do_communicate(void *args)
88 l7ag_interproccommunicate *proccom = (l7ag_interproccommunicate *)args;
95 if (proccom->getStopFlag()) {
107 l7ag_interproccommunicate::setRequestMessage()