Lines Matching defs:Receiver
102 struct Receiver : public MessageHandler, public sigslot::has_slots<> { struct
103 Receiver(Thread* th, AsyncSocket* s, uint32_t bw) in Receiver() function
117 ~Receiver() override { thread->Clear(this); } in ~Receiver()
119 void OnReadPacket(AsyncPacketSocket* s, in OnReadPacket()
138 void OnMessage(Message* pmsg) override { in OnMessage()
152 Thread* thread;
153 std::unique_ptr<AsyncUDPSocket> socket;
154 uint32_t bandwidth;
155 bool done;
156 size_t count;
157 size_t sec_count;
158 double sum;
159 double sum_sq;
160 uint32_t samples;