GFDataExchanger.h

 
#pragma once
 
#include <queue>
 
namespace GpgFrontend {
 
class GFDataExchanger {
 public:
  explicit GFDataExchanger(ssize_t size);
 
  auto Write(const std::byte* buffer, size_t size) -> ssize_t;
 
  auto Read(std::byte* buffer, size_t size) -> ssize_t;
 
  void CloseWrite();
 
 private:
  std::condition_variable not_full_, not_empty_;
  std::queue<std::byte> queue_;
  std::mutex mutex_;
  const ssize_t queue_max_size_;
  std::atomic_bool close_ = false;
};
 
}  // namespace GpgFrontend