packets_queue.hpp

Go to the documentation of this file.

#pragma once
 
#include <list>
#include <optional>
 
#include "network/tarcap/tarcap_version.hpp"
#include "network/threadpool/packets_blocking_mask.hpp"
#include "packet_data.hpp"
 
namespace taraxa::network::threadpool {
 
class PacketsQueue {
 public:
  PacketsQueue() = default;
 
  void pushBack(std::pair<tarcap::TarcapVersion, PacketData>&& packet);
 
  std::optional<std::pair<tarcap::TarcapVersion, PacketData>> pop(const PacketsBlockingMask& packets_blocking_mask);
 
  bool maxWorkersCountReached() const;
 
  void setMaxWorkersCount(size_t max_workers_count);
 
  void incrementActWorkersCount();
 
  void decrementActWorkersCount();
 
  bool empty() const;
 
  size_t size() const;
 
  size_t getActiveWorkersNum() const;
 
 private:
  std::list<std::pair<tarcap::TarcapVersion, PacketData>> packets_;
 
  // How many workers can process packets from this queue at the same time
  size_t kMaxWorkersCount_{0};
 
  // How many workers are currently processing packets from this queue at the same time
  std::atomic<size_t> act_workers_count_{0};
 
  // How many packets are currently inside the queue
  std::atomic<size_t> act_packets_count_{0};
};
 
}  // namespace taraxa::network::threadpool