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()