xbmc/cores/AudioEngine/Sinks/pipewire/PipewireThreadLoop.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 "PipewireThreadLoop.h"
  10
  11 #include "utils/log.h"
  12
  13 #include <stdexcept>
  14
  15 using namespace KODI;
  16 using namespace PIPEWIRE;
  17
  18 CPipewireThreadLoop::CPipewireThreadLoop()
  19 {
  20   m_mainloop.reset(pw_thread_loop_new("pipewire", nullptr));
  21   if (!m_mainloop)
  22   {
  23     CLog::Log(LOGERROR, "CPipewireThreadLoop: failed to create main loop: {}", strerror(errno));
  24     throw std::runtime_error("CPipewireThreadLoop: failed to create main loop");
  25   }
  26 }
  27
  28 bool CPipewireThreadLoop::Start()
  29 {
  30   return pw_thread_loop_start(m_mainloop.get()) == 0;
  31 }
  32
  33 void CPipewireThreadLoop::Stop()
  34 {
  35   pw_thread_loop_stop(m_mainloop.get());
  36 }
  37
  38 void CPipewireThreadLoop::Lock() const
  39 {
  40   pw_thread_loop_lock(m_mainloop.get());
  41 }
  42
  43 void CPipewireThreadLoop::Unlock() const
  44 {
  45   pw_thread_loop_unlock(m_mainloop.get());
  46 }
  47
  48 int CPipewireThreadLoop::Wait(std::chrono::nanoseconds timeout)
  49 {
  50   timespec abstime;
  51   pw_thread_loop_get_time(m_mainloop.get(), &abstime, timeout.count());
  52
  53   return pw_thread_loop_timed_wait_full(m_mainloop.get(), &abstime);
  54 }
  55
  56 void CPipewireThreadLoop::Signal(bool accept)
  57 {
  58   pw_thread_loop_signal(m_mainloop.get(), accept);
  59 }