]> git.vomp.tv Git - vompclient-marten.git/blob - audiowin.cc
Sync changes in demuxer
[vompclient-marten.git] / audiowin.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 "audiowin.h"
22 #include "videowin.h"
23
24
25
26
27
28 AudioWin::AudioWin()
29 {
30   initted = 0;
31   firstsynched=false;
32
33
34 }
35
36 AudioWin::~AudioWin()
37 {
38
39 }
40
41 int AudioWin::init(UCHAR tstreamType)
42 {
43   if (initted) return 0;
44   initted = 1;
45   return 1;
46 }
47
48 int AudioWin::shutdown()
49 {
50   if (!initted) return 0;
51   initted = 0;
52   return 1;
53 }
54
55 int AudioWin::getFD()
56 {
57   return 0;
58 }
59
60 int AudioWin::write(char *buf, int len)
61 {
62   return 0; //write(fdAudio, buf, len);
63 }
64
65 int AudioWin::setStreamType(UCHAR type)
66 {
67   if (!initted) return 0;
68   return 1;
69 }
70
71 int AudioWin::setChannel()
72 {
73   if (!initted) return 0;
74   return 1;
75 }
76
77 int AudioWin::setSource()
78 {
79   if (!initted) return 0;
80   return 1;
81 }
82
83 int AudioWin::sync()
84 {
85   if (!initted) return 0;
86   return 1;
87 }
88
89 int AudioWin::play()
90 {
91   if (!initted) return 0;
92   firstsynched=false;
93
94   return 1;
95 }
96
97 int AudioWin::stop()
98 {
99   if (!initted) return 0;
100   return 1;
101 }
102
103 int AudioWin::pause()
104 {
105   if (!initted) return 0;
106   return 1;
107 }
108
109 int AudioWin::unPause()
110 {
111   if (!initted) return 0;
112   return 1;
113 }
114
115 int AudioWin::reset()
116 {
117   if (!initted) return 0;
118   return 1;
119 }
120
121 int AudioWin::setVolume(int tvolume)
122 {
123   // parameter: 0 for silence, 20 for full
124   if ((tvolume < 0) || (tvolume > 20)) return 0;
125   return 1;
126 }
127
128 int AudioWin::mute()
129 {
130   if (!initted) return 0;
131   ((VideoWin*)Video::getInstance())->SetAudioState(false);
132   return 1;
133 }
134
135 int AudioWin::unMute()
136 {
137   if (!initted) return 0;
138   ((VideoWin*)Video::getInstance())->SetAudioState(true);
139   return 1;
140 }
141
142 UINT AudioWin::DeliverMediaSample(MediaPacket packet,
143      UCHAR* buffer,
144      UINT *samplepos)
145 {
146   /*First Check, if we have an audio sample*/
147   VideoWin *vw=(VideoWin*)Video::getInstance();
148   IMediaSample* ms=NULL;
149   REFERENCE_TIME reftime1=0;
150   REFERENCE_TIME reftime2=0;
151
152   UINT headerstrip=0;
153   if (packet.disconti) {
154     firstsynched=false;
155     vw->DeliverVideoMediaSample();
156   }
157
158
159
160   /*Inspect PES-Header */
161 /*  UINT header_length=buffer[(packet.pos_buffer+8)%bufferlength]+8/*is this right*;
162 */
163   if (*samplepos==0) {//stripheader
164     headerstrip=buffer[packet.pos_buffer+8]+9/*is this right*/;
165     *samplepos+=headerstrip;
166     if ( packet.synched ) {
167       vw->DeliverAudioMediaSample();//write out old data
168       if (packet.presentation_time<0) { //Preroll?
169         *samplepos=packet.length;//if we have not processed at least one
170         return packet.length;//synched packet ignore it!
171       }
172
173       reftime1=packet.presentation_time;
174       reftime2=reftime1+1;
175       firstsynched=true;
176     } else {
177       if (!firstsynched) {//
178         *samplepos=packet.length;//if we have not processed at least one
179         return packet.length;//synched packet ignore it!
180       }
181     }
182   }
183   BYTE *ms_buf;
184   UINT ms_length;
185   UINT ms_pos;
186   UINT haveToCopy;
187   if (!vw->getCurrentAudioMediaSample(&ms) || ms==NULL) {// get the current sample
188     samplepos=0;
189     MILLISLEEP(10);
190     return 0;
191   }
192   ms_pos=ms->GetActualDataLength();
193   ms_length=ms->GetSize();
194   haveToCopy=min(ms_length-ms_pos,packet.length-*samplepos);
195   if ((ms_length-ms_pos)<1) {
196     vw->DeliverAudioMediaSample(); //we are full!
197     if (!vw->getCurrentAudioMediaSample(&ms) || ms==NULL) {// get the current sample
198       samplepos=0;
199       MILLISLEEP(10);
200       return 0;
201     }
202     ms_pos=ms->GetActualDataLength();
203     ms_length=ms->GetSize();
204     haveToCopy=min(ms_length-ms_pos,packet.length-*samplepos);
205   }
206   ms->GetPointer(&ms_buf);
207
208   if (ms_pos==0) {//will only be changed on first packet
209     if (packet.disconti) {
210       ms->SetDiscontinuity(TRUE);
211     } else {
212       ms->SetDiscontinuity(FALSE);
213     }
214     if (packet.synched) {
215       ms->SetSyncPoint(TRUE);
216       ms->SetTime(&reftime1,&reftime2);
217       //ms->SetTime(NULL,NULL);
218       ms->SetMediaTime(NULL, NULL);
219     }else {
220       ms->SetSyncPoint(FALSE);
221       ms->SetTime(NULL,NULL);
222       ms->SetMediaTime(NULL, NULL);
223       ms->SetSyncPoint(TRUE);
224     }
225   }
226
227
228   memcpy(ms_buf+ms_pos,buffer+packet.pos_buffer+*samplepos,haveToCopy);
229     ms->SetActualDataLength(haveToCopy+ms_pos);
230
231   *samplepos+=haveToCopy;
232
233   return haveToCopy+headerstrip;
234
235 }
236
237 long long AudioWin::SetStartOffset(long long curreftime, bool *rsync){
238   VideoWin *vw=(VideoWin*)Video::getInstance();
239   return vw->SetStartAudioOffset(curreftime,rsync);
240 }
241
242 #ifdef DEV
243 int AudioWin::test()
244 {
245   return 0;
246 }
247 #endif