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::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_buffer data, std::function<void()> callback);
 
  void sendCompleted();
 
private:
  void process();
 
  struct SendItem {
    std::shared_ptr<Socket>   sock;
    boost::asio::const_buffer data;
    std::function<void()>     callback;
  };
  struct SendItem {…};
 
  std::deque<SendItem> _itemQueue;
  std::mutex _queueMutex{};
  bool _ready = true;
};
class SocketSendQueue {…};
 
} // namespace precice::com