1 #ifndef __INTERPROCCOM_H__
2 #define __INTERPROCCOM_H__
7 #include "l7ag_socket.h"
8 #include "tag_threadstat.h"
9 #include "dispatch_message.h"
10 #include "store_mibdata.h"
14 class l7ag_interproccommunicate : public l7ag_socket
17 l7ag_subagent * parent;
18 THREAD_STAT_TAG status;
21 pthread_mutex_t mutex_sbuf;
22 pthread_mutex_t mutex_rbuf;
27 l7ag_interproccommunicate();
29 static void * do_communicate( void * args );
32 l7ag_interproccommunicate( l7ag_subagent * p_subagent );
33 ~l7ag_interproccommunicate();
35 void set_parent( l7ag_subagent * p_subagent );
38 void stop_thread(){stop_flag=true;}
40 void send_mibdatacollect( std::string oid );
41 bool getStopFlag(){return stop_flag;}
42 void setRequestMessage();
45 #endif //__INTERPROCCOM_H__