2 Copyright 2005-2006 Mark Calderbank
4 This file is part of VOMP.
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.
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.
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
36 void Stream::shutdown()
48 int Stream::init(DrainTarget* tdt, int bufsize)
50 outbuf = (UCHAR*) malloc(bufsize);
51 if (!outbuf) return 0;
56 pthread_mutex_init(&mutex, NULL);
58 mutex=CreateMutex(NULL,FALSE,NULL);
68 if (draintarget) draintarget->ResetTimeOffsets();
71 int Stream::put(const UCHAR* inbuf, int len, UCHAR type)
74 if (!draintarget) return 0;
75 MediaPacket newPacket;
76 newPacket.length = len;
77 newPacket.pos_buffer = 0;
78 newPacket.type = type;
80 newPacket.synched=false;
81 newPacket.disconti=false;
83 newPacket.presentation_time=0;
84 if (type!=MPTYPE_MPEG_AUDIO_LAYER3) {//no PES
86 if ((inbuf[7] & 0x80) && len>14 ) {
87 newPacket.synched=true;
88 newPacket.pts=((ULLONG)(inbuf[9] & 0x0E) << 29 ) |
89 ( (ULLONG)(inbuf[10]) << 22 ) |
90 ( (ULLONG)(inbuf[11] & 0xFE) << 14 ) |
91 ( (ULLONG)(inbuf[12]) << 7 ) |
92 ( (ULLONG)(inbuf[13] & 0xFE) >> 1 );
93 //ok we have the pts now convert it to a continously time code in 100ns units
94 newPacket.presentation_time=(ULLONG)(newPacket.pts*10000LL/90LL);
95 newPacket.presentation_time-=draintarget->SetStartOffset(newPacket.presentation_time,&newPacket.disconti);
102 if (mediapackets.empty())
104 back = 0; front = bufferSize;
108 front = mediapackets.front().pos_buffer;
109 back = mediapackets.back().pos_buffer + mediapackets.back().length;
110 if (back == bufferSize) back = 0;
116 // The free space (if any) is in one continuous chunk.
117 if (len <= front - back) ret = len; // Is there enough of it?
119 else if (len <= bufferSize - back)
121 // There is enough space at the end of the buffer
124 else if (len <= front)
126 // There is enough space at the start of the buffer
131 if (ret) // Nonzero if we managed to find room for the packet
133 memcpy(outbuf + back, inbuf, len);
134 newPacket.pos_buffer = back;
136 mediapackets.push_back(newPacket);
146 UINT listlength = mediapackets.size();
149 draintarget->PrepareMediaSample(mediapackets, cur_packet_pos);
151 UINT consumed = draintarget->DeliverMediaSample(outbuf, &cur_packet_pos);
153 if (consumed != 0) ret = true;
154 if (consumed > listlength) consumed = listlength;
155 while (consumed--) mediapackets.pop_front();
164 pthread_mutex_lock(&mutex);
165 //logger->log("Player", Log::DEBUG, "LOCKED");
168 WaitForSingleObject(mutex, INFINITE );
172 void Stream::unLock()
175 //logger->log("Player", Log::DEBUG, "UNLOCKING");
176 pthread_mutex_unlock(&mutex);