vfeed.cc

   1 /*
   2     Copyright 2004-2020 Chris Tallon
   3
   4     This file is part of VOMP.
   5
   6     VOMP is free software; you can redistribute it and/or modify
   7     it under the terms of the GNU General Public License as published by
   8     the Free Software Foundation; either version 2 of the License, or
   9     (at your option) any later version.
  10
  11     VOMP is distributed in the hope that it will be useful,
  12     but WITHOUT ANY WARRANTY; without even the implied warranty of
  13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14     GNU General Public License for more details.
  15
  16     You should have received a copy of the GNU General Public License
  17     along with VOMP.  If not, see <https://www.gnu.org/licenses/>.
  18 */
  19
  20 #include "log.h"
  21 #include "demuxer.h"
  22 #include "callback.h"
  23
  24 #include "vfeed.h"
  25
  26 VFeed::VFeed(Callback* tcb)
  27 : cb(*tcb)
  28 {
  29 }
  30
  31 void VFeed::start()
  32 {
  33   threadStartProtect.lock();
  34   feedThread = std::thread( [this]
  35   {
  36     threadStartProtect.lock();
  37     threadStartProtect.unlock();
  38     threadMethod();
  39   });
  40   threadStartProtect.unlock();
  41 }
  42
  43 void VFeed::stop()
  44 {
  45   Log::getInstance()->log("VFeed", Log::DEBUG, "Stop1");
  46   if (!feedThread.joinable()) return;
  47   stopThread = true;
  48   feedThread.join();
  49   stopThread = false;
  50   Log::getInstance()->log("VFeed", Log::DEBUG, "Stop2");
  51 }
  52
  53 void VFeed::threadMethod()
  54 {
  55   bool vlen;
  56
  57   Log::getInstance()->log("VFeed", Log::DEBUG, "Started");
  58
  59   while(1)
  60   {
  61     if (stopThread) return;
  62     vlen = Demuxer::getInstance()->writeVideo();
  63
  64     if (vlen)
  65     {
  66       cb.call(this);
  67     }
  68     else
  69     {
  70       //Log::getInstance()->log("VFeed", Log::DEBUG, "No data delay FPS");
  71       MILLISLEEP(5);
  72     }
  73   }
  74 }
  75