LrIpcOutShared Class Reference

Public Member Functions
	LrIpcOutShared (asio::io_context &io_context)
	LrIpcOutShared (asio::io_context &io_context)

Static Private Member Functions
static void	SendOut (std::shared_ptr< LrIpcOutShared > lr_ipc_out_shared)
static void	SendOut (std::shared_ptr< LrIpcOutShared > lr_ipc_out_shared)

Private Attributes
rsj::ConcurrentQueue< std::string >	command_
friend	LrIpcOut
std::shared_ptr< std::atomic< bool > >	owner_alive_ {std::make_shared<std::atomic<bool>>(true)}
asio::ip::tcp::socket	socket_

Constructor & Destructor Documentation

LrIpcOutShared() [1/2]

LrIpcOutShared::LrIpcOutShared ( asio::io_context & io_context )

inlineexplicit

                                                       : socket_ {asio::make_strand(io_context)}
   {
   }

LrIpcOutShared() [2/2]

LrIpcOutShared::LrIpcOutShared ( asio::io_context & io_context )

inlineexplicit

                                                       : socket_ {asio::make_strand(io_context)}
   {
   }

Member Function Documentation

SendOut() [1/2]

void LrIpcOutShared::SendOut ( std::shared_ptr< LrIpcOutShared > lr_ipc_out_shared )

staticprivate

{
   try {
      auto command_copy {std::make_shared<std::string>(lr_ipc_out_shared->command_.pop())};
      if (*command_copy == kTerminate) [[unlikely]] { return; }
      if (command_copy->empty() || command_copy->back() != '\n') [[unlikely]] {
         command_copy->push_back('\n');
      } // ReSharper disable once CppLambdaCaptureNeverUsed
      asio::async_write(lr_ipc_out_shared->socket_, asio::buffer(*command_copy),
          [command_copy, lr_ipc_out_shared](const asio::error_code& error, std::size_t) mutable {
         // check owner token before re-arming
         const auto alive {lr_ipc_out_shared->owner_alive_};
         if (!alive || !alive->load(std::memory_order_acquire)) { return; }
 
         if (!error) [[likely]] { SendOut(std::move(lr_ipc_out_shared)); }
         else {
            rsj::Log(fmt::format("LR_IPC_Out Write: {}.", error.message()),
                std::source_location::current());
         }
      });
   }
   catch (const std::exception& e) {
      rsj::ExceptionResponse(e, std::source_location::current());
      throw;
   }
}

SendOut() [2/2]

void LrIpcOutShared::SendOut ( std::shared_ptr< LrIpcOutShared > lr_ipc_out_shared )

staticprivate

Member Data Documentation

command_

rsj::ConcurrentQueue< std::string > LrIpcOutShared::command_

private

LrIpcOut

LrIpcOut

private

owner_alive_

std::shared_ptr< std::atomic< bool > > LrIpcOutShared::owner_alive_ {std::make_shared<std::atomic<bool>>(true)}

private

{std::make_shared<std::atomic<bool>>(true)};

socket_

asio::ip::tcp::socket LrIpcOutShared::socket_

private

---

The documentation for this class was generated from the following file:

• C:/Users/rsjaf/source/repos/MIDI2LR/src/application/LR_IPC_Out.cpp