xbmc/cores/AudioEngine/Sinks/pipewire/Pipewire.cpp

   1 /*
   2  *  Copyright (C) 2010-2021 Team Kodi
   3  *  This file is part of Kodi - https://kodi.tv
   4  *
   5  *  SPDX-License-Identifier: GPL-2.0-or-later
   6  *  See LICENSES/README.md for more information.
   7  */
   8
   9 #include "Pipewire.h"
  10
  11 #include "PipewireContext.h"
  12 #include "PipewireCore.h"
  13 #include "PipewireRegistry.h"
  14 #include "PipewireThreadLoop.h"
  15 #include "commons/ilog.h"
  16 #include "utils/log.h"
  17
  18 #include <pipewire/pipewire.h>
  19
  20 using namespace std::chrono_literals;
  21
  22 using namespace KODI;
  23 using namespace PIPEWIRE;
  24
  25 CPipewire::CPipewire()
  26 {
  27   pw_init(nullptr, nullptr);
  28 }
  29
  30 CPipewire::~CPipewire()
  31 {
  32   if (m_loop)
  33   {
  34     m_loop->Unlock();
  35     m_loop->Stop();
  36   }
  37
  38   m_registry.reset();
  39   m_core.reset();
  40   m_context.reset();
  41   m_loop.reset();
  42
  43   pw_deinit();
  44 }
  45
  46 bool CPipewire::Start()
  47 {
  48   m_loop = std::make_unique<CPipewireThreadLoop>();
  49
  50   m_context = std::make_unique<CPipewireContext>(*m_loop);
  51
  52   PIPEWIRE::CLoopLockGuard lock(*m_loop);
  53
  54   if (!m_loop->Start())
  55   {
  56     CLog::Log(LOGERROR, "Pipewire: failed to start threaded mainloop: {}", strerror(errno));
  57     return false;
  58   }
  59
  60   try
  61   {
  62     m_core = std::make_unique<CPipewireCore>(*m_context);
  63   }
  64   catch (std::exception& e)
  65   {
  66     CLog::Log(LOGERROR, "Pipewire: failed to connect to server");
  67     return false;
  68   }
  69
  70   CLog::Log(LOGINFO, "Pipewire: connected to server");
  71
  72   m_registry = std::make_unique<CPipewireRegistry>(*m_core);
  73
  74   m_core->Sync();
  75
  76   int ret = m_loop->Wait(5s);
  77   if (ret == -ETIMEDOUT)
  78   {
  79     CLog::Log(LOGDEBUG, "Pipewire: timed out out waiting for synchronization");
  80     return false;
  81   }
  82
  83   return true;
  84 }
  85
  86 std::unique_ptr<CPipewire> CPipewire::Create()
  87 {
  88   struct PipewireMaker : public CPipewire
  89   {
  90     using CPipewire::CPipewire;
  91   };
  92
  93   try
  94   {
  95     auto pipewire = std::make_unique<PipewireMaker>();
  96
  97     if (!pipewire->Start())
  98       return {};
  99
 100     return pipewire;
 101   }
 102   catch (const std::exception& e)
 103   {
 104     CLog::Log(LOGWARNING, "Pipewire: Exception in 'Create': {}", e.what());
 105     return {};
 106   }
 107 }