afeed.cc

   1 /*
   2     Copyright 2004-2005 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, write to the Free Software
  18     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19 */
  20
  21 #include "afeed.h"
  22
  23 AFeed::AFeed(Callback* tcb)
  24 : cb(*tcb)
  25 {
  26   delayTime.tv_sec = 0;
  27   delayTime.tv_nsec = 100000000;
  28   audioEnabled = 1;
  29 }
  30
  31 int AFeed::init(int tfd)
  32 {
  33   fd = tfd;
  34   return 1;
  35 }
  36
  37 int AFeed::shutdown()
  38 {
  39   // FIXME
  40   return 1;
  41 }
  42
  43 void AFeed::disable()
  44 {
  45   audioEnabled = 0;
  46 }
  47
  48 void AFeed::enable()
  49 {
  50   audioEnabled = 1;
  51 }
  52
  53 int AFeed::start()
  54 {
  55   return threadStart();
  56 }
  57
  58 void AFeed::stop()
  59 {
  60   threadCancel();
  61 }
  62
  63 void AFeed::threadMethod()
  64 {
  65   Log::getInstance()->log("AFeed", Log::DEBUG, "Started");
  66
  67   int alen;
  68
  69   while(1)
  70   {
  71     threadCheckExit();
  72
  73     if (audioEnabled)
  74     {
  75       alen = Demuxer::getInstance()->writeAudio(fd); // FIXME ?
  76
  77       if (alen)
  78       {
  79 //        Log::getInstance()->log("AFeed", Log::DEBUG, "Written %i", alen);
  80         cb.call(this);
  81       }
  82       else
  83       {
  84 //        Log::getInstance()->log("AFeed", Log::DEBUG, "No data delay");
  85         nanosleep(&delayTime, NULL);
  86       }
  87     }
  88     else
  89     {
  90       Demuxer::getInstance()->flushAudio();
  91       usleep(100000);
  92
  93       // FIXME, no delay here now
  94 //      if (demux_get_audio(demuxHandle, buffer, 1000) != 1000) nanosleep(&delayTime, NULL);
  95     }
  96   }
  97 }
  98