PipewireSharedContext.hpp

#pragma once
 
#include <libremidi/backends/linux/pipewire/context.hpp>
 
#include <QDebug>
 
#include <memory>
 
namespace Gfx::PipeWire
{
 
using SharedPipewireContext = std::shared_ptr<libremidi::pipewire::context>;
 
inline SharedPipewireContext acquireSharedContext(const char* who) noexcept
{
  using connection_state = libremidi::pipewire::connection_state;
 
  auto ctx = libremidi::pipewire::shared_context();
  if(!ctx)
    return {};
 
  if(ctx->state() == connection_state::broken)
  {
    if(ctx.use_count() == 1)
    {
      ctx->reconnect();
    }
    else
    {
      qWarning() << who
                 << ": shared PipeWire connection is flagged broken but is "
                    "still held by"
                 << (ctx.use_count() - 1)
                 << "other client(s) with live streams on it; reusing it "
                    "instead of tearing it down";
    }
  }
 
  if(!ctx->ok() && !(ctx->pw_core_ptr() && ctx->thread_loop_handle()))
    return {};
 
  return ctx;
}
 
}