BufferedIPCChannel.h

Go to the documentation of this file.

/**********************************************************************
 
  Audacity: A Digital Audio Editor
 
  @file BufferedIPCChannel.h
 
  @author Vitaly Sverchinsky
 
  Part of lib-ipc library
 
**********************************************************************/
 
#pragma once
 
#include <mutex>
#include <condition_variable>
#include <memory>
#include <vector>
#include <thread>
 
#include "ipc-types.h"
#include "IPCChannel.h"
 
class IPCChannelStatusCallback;
 
class BufferedIPCChannel final : public IPCChannel
{
   static constexpr int DefaultOutputBufferCapacity  { 2048 };
   static constexpr int DefaultInputBufferSize { 2048 };
 
   bool mAlive {true};
   std::mutex mSocketSync;
   std::condition_variable mSendCondition;
 
   std::unique_ptr<std::thread> mRecvRoutine;
   std::unique_ptr<std::thread> mSendRoutine;
   
   SOCKET mSocket {INVALID_SOCKET};
   
   std::vector<char> mOutputBuffer;
   
public:
 
   BufferedIPCChannel();
 
   ~BufferedIPCChannel() override;
 
   void Send(const void* bytes, size_t length) override;
 
   void StartConversation(SOCKET socket, IPCChannelStatusCallback& callback);
};