00001 #ifndef __PACKETWRITERTEST_H 00002 #define __PACKETWRITERTEST_H 00003 00004 class PacketWriterTest : public PacketWriter { 00005 public: 00006 PacketWriterTest(); 00007 virtual ~PacketWriterTest(); 00008 00009 virtual int sendDataPacket(int serviceNumber, TpPacket* packet); 00010 void setSar(SAR* sar); 00011 00012 void setDropDataProbability(int p); 00013 void setDropAckProbability(int p); 00014 00015 static void* dataPusher(void*); 00016 void dataPusherImpl(); 00017 00018 private: 00019 SAR* m_sar; 00020 int m_dropDataProbability; 00021 int m_dropAckProbability; 00022 pthread_t m_dataPusherThreadId; 00023 ThreadMessageQueue<TpPacket>* m_packetQueue; 00024 TRanrotBGenerator m_randomNumberGenerator; 00025 }; 00026 00027 00028 #endif 00029