From 3302877136734d13caf708b78d4ae3360c223056 Mon Sep 17 00:00:00 2001 From: Nicholas Brown Date: Mon, 21 Jan 2019 13:21:28 +0000 Subject: [PATCH] Use idiomatic C++11 Modern for loop on a containers Silences several cpp_check warnings --- src/modules/ipfix/IpfixReceiverZmq.cpp | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/src/modules/ipfix/IpfixReceiverZmq.cpp b/src/modules/ipfix/IpfixReceiverZmq.cpp index e68b418..652dcca 100644 --- a/src/modules/ipfix/IpfixReceiverZmq.cpp +++ b/src/modules/ipfix/IpfixReceiverZmq.cpp @@ -55,7 +55,7 @@ IpfixReceiverZmq::IpfixReceiverZmq(std::vector endpoints, THROWEXCEPTION("Could not create ZMQ poller, cannot start ZMQ Receiver"); } - for (std::vector::iterator i = endpoints.begin(); i != endpoints.end(); i++) { + for (const auto& endpoint : endpoints) { zsock_t *sock = zsock_new(ZMQ_SUB); if (!sock) { THROWEXCEPTION("Could not create ZMQ socket"); @@ -64,7 +64,7 @@ IpfixReceiverZmq::IpfixReceiverZmq(std::vector endpoints, zsock_set_sndhwm(sock, zmq_high_watermark); zsock_set_rcvhwm(sock, zmq_high_watermark); - if (zsock_connect(sock, "%s", (*i).c_str())) { + if (zsock_connect(sock, "%s", (endpoint).c_str())) { THROWEXCEPTION("Could not connect ZMQ socket"); } @@ -72,18 +72,18 @@ IpfixReceiverZmq::IpfixReceiverZmq(std::vector endpoints, if (channels.empty()) { zsock_set_subscribe(sock, ""); } else { - for (std::vector::iterator j = channels.begin(); j != channels.end(); j++) { - zsock_set_subscribe(sock, (*j).c_str()); + for (const auto& channel : channels) { + zsock_set_subscribe(sock, (channel).c_str()); } } if (zpoller_add(zpoller, sock)) { - THROWEXCEPTION("Could not add %s ZMQ socket to ZMQ poller", (*i).c_str()); + THROWEXCEPTION("Could not add %s ZMQ socket to ZMQ poller", (endpoint).c_str()); } zmq_sockets.push_back(sock); - msg(LOG_NOTICE, "ZMQ Receiver listening on %s", (*i).c_str()); + msg(LOG_NOTICE, "ZMQ Receiver listening on %s", (endpoint).c_str()); } SensorManager::getInstance().addSensor(this, "IpfixReceiverZMQ", moduleId); @@ -96,8 +96,8 @@ IpfixReceiverZmq::~IpfixReceiverZmq() { zpoller_destroy(&zpoller); - for (std::vector::iterator i = zmq_sockets.begin(); i != zmq_sockets.end(); i++) { - zsock_destroy(&(*i)); + for (auto& zmq_socket : zmq_sockets) { + zsock_destroy(&zmq_socket); } msg(LOG_NOTICE, "Ipfix Receiver ZMQ poller and sockets destroyed"); @@ -151,8 +151,8 @@ void IpfixReceiverZmq::run() // send packet to all packet processors mutex.lock(); - for (std::list::iterator i = packetProcessors.begin(); i != packetProcessors.end(); i++) { - (*i)->processPacket(data, zframe_size(current_frame), sourceID); + for (auto& packetProcessor : packetProcessors) { + (packetProcessor)->processPacket(data, zframe_size(current_frame), sourceID); } mutex.unlock();