00001 #ifndef DIM_RPC_WRITER_H 00002 #define DIM_RPC_WRITER_H 00003 00004 #include <pthread.h> 00005 #include <string> 00006 00007 class AutoEnlargeBuffer; 00008 class DimRpcInfo; 00009 00010 class DimRpcWriter 00011 { 00012 public : 00013 00014 typedef const std::string WriterArgType; 00015 00016 DimRpcWriter(WriterArgType& name); 00017 virtual ~DimRpcWriter(); 00018 00019 int writeEvent(void *pevt, int size); 00020 int close(); 00021 00022 int stat(); 00023 00024 00025 private : 00026 00027 DimRpcWriter(); //stop default 00028 00029 00030 private : 00031 00032 int m_inCode; 00033 DimRpcInfo *m_rpc; 00034 00035 static pthread_mutex_t m_rpcLock; 00036 }; 00037 00038 #endif