SocketSendQueue.hpp

Go to the documentation of this file.

#pragma once
 
#include <boost/asio.hpp>
#include <deque>
#include <functional>
#include <memory>
#include <mutex>
#include <string>
#include "logging/Logger.hpp"
 
namespace precice {
namespace com {
 
class SocketSendQueue {
public:
  using Socket = boost::asio::ip::tcp::socket;
 
  SocketSendQueue() = default;
  ~SocketSendQueue();
 
  SocketSendQueue(SocketSendQueue const &) = delete;
  SocketSendQueue &operator=(SocketSendQueue const &) = delete;
 
  void dispatch(std::shared_ptr<Socket> sock, boost::asio::const_buffers_1 data, std::function<void()> callback);
 
  void sendCompleted();
 
private:
  void process();
 
  struct SendItem {
    std::shared_ptr<Socket>      sock;
    boost::asio::const_buffers_1 data;
    std::function<void()>        callback;
  };
 
  std::deque<SendItem> _itemQueue;
  std::mutex _queueMutex{};
  bool _ready = true;
};
 
} // namespace com
} // namespace precice