return;
}
assert(run_flag_.test_and_set() == false);
- recv_thread_ = move(unique_ptr<thread>(new thread{&Receiver::run, this}));
+ recv_thread_.reset(new thread{&Receiver::run, this});
}
void
/// in main thread packets can be consumed from the queue using getPkt
/// method.
class Receiver {
+public:
/// \brief Socket for receiving.
const BetterSocket& socket_;
+private:
/// \brief Flag indicating if thread should run (true) or not (false).
boost::atomic_flag run_flag_;
void
TestControl::consumeReceivedPackets(Receiver& receiver, const BetterSocket& socket) {
PktPtr pkt;
- while (pkt = receiver.getPkt()) {
+ while ((pkt = receiver.getPkt())) {
if (CommandOptions::instance().getIpVersion() == 4) {
Pkt4Ptr pkt4 = boost::dynamic_pointer_cast<Pkt4>(pkt);
processReceivedPacket4(socket, pkt4);