]> git.vomp.tv Git - vompclient-marten.git/blob - afeed.cc
Fix for cant power down if server unavailable
[vompclient-marten.git] / 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();
81       }
82       else
83       {
84         nanosleep(&delayTime, NULL);
85       }
86     }
87     else
88     {
89       Demuxer::getInstance()->flushAudio();
90       usleep(100000);
91
92       // FIXME, no delay here now
93 //      if (demux_get_audio(demuxHandle, buffer, 1000) != 1000) nanosleep(&delayTime, NULL);
94     }
95   }
96 }
97