2 Copyright 2004-2006 Chris Tallon
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
21 #include "playerradio.h"
23 // ----------------------------------- Called from outside, one offs or info funcs
25 PlayerRadio::PlayerRadio(MessageQueue* tmessageQueue, void* tmessageReceiver, bool tIsRecording)
28 messageQueue = tmessageQueue;
29 messageReceiver = tmessageReceiver;
30 audio = Audio::getInstance();
31 logger = Log::getInstance();
32 vdr = VDR::getInstance();
42 isRecording = tIsRecording;
47 startupBlockSize = 20000;
48 preBufferSize = 20000;
51 PlayerRadio::~PlayerRadio()
53 if (initted) shutdown();
56 int PlayerRadio::init(ULLONG tlengthBytes, ULONG tlengthFrames)
58 if (initted) return 0;
60 pthread_mutex_init(&mutex, NULL);
62 mutex=CreateMutex(NULL,FALSE,NULL);
65 demuxer = new DemuxerVDR();
66 if (!demuxer) return 0;
68 if (!demuxer->init(this, audio, NULL))
70 logger->log("PlayerRadio", Log::ERR, "Demuxer failed to init");
78 lengthBytes = tlengthBytes;
79 lengthFrames = tlengthFrames;
81 logger->log("PlayerRadio", Log::DEBUG, "PlayerRadio has received length bytes of %llu", lengthBytes);
87 threadBuffer = vdr->getBlock(0, 10000, &thisRead);
90 logger->log("PlayerRadio", Log::ERR, "Failed to get start block");
95 success = demuxer->findPTS(threadBuffer, thisRead, &startPTS);
98 logger->log("PlayerRadio", Log::ERR, "Failed to get start PTS");
103 threadBuffer = vdr->getBlock(tlengthBytes - 10000, 10000, &thisRead);
106 logger->log("PlayerRadio", Log::ERR, "Failed to get end block");
111 success = demuxer->findPTS(threadBuffer, thisRead, &endPTS);
114 logger->log("PlayerRadio", Log::ERR, "Failed to get end PTS");
119 logger->log("PlayerRadio", Log::DEBUG, "Start: %llu, End: %llu", startPTS, endPTS);
121 if (startPTS < endPTS)
123 lengthSeconds = (endPTS - startPTS) / 90000;
127 lengthSeconds = (startPTS - endPTS) / 90000;
134 int PlayerRadio::shutdown()
136 if (!initted) return 0;
151 void PlayerRadio::setStartBytes(ULLONG startBytes)
153 streamPos = startBytes;
156 ULONG PlayerRadio::getLengthSeconds()
158 return lengthSeconds;
161 ULONG PlayerRadio::getCurrentSeconds()
163 if (startup) return 0;
167 // ----------------------------------- Externally called events
169 void PlayerRadio::play()
171 if (!initted) return;
172 if (state == S_PLAY) return;
178 void PlayerRadio::stop()
180 if (!initted) return;
181 if (state == S_STOP) return;
183 logger->log("PlayerRadio", Log::DEBUG, "Stop called lock");
188 void PlayerRadio::pause()
190 if (!initted) return;
193 if (state == S_PAUSE_P)
199 switchState(S_PAUSE_P);
205 void PlayerRadio::jumpToPercent(int percent)
208 logger->log("PlayerRadio", Log::DEBUG, "JUMP TO %i%%", percent);
209 ULONG newFrame = percent * lengthFrames / 100;
210 switchState(S_JUMP, newFrame);
214 void PlayerRadio::skipForward(int seconds)
217 logger->log("PlayerRadio", Log::DEBUG, "SKIP FORWARD %i SECONDS", seconds);
218 ULONG newFrame = getCurrentSeconds();
219 if (newFrame == 0) { unLock(); return; } // Current pos from demuxer is not valid
220 // newFrame += seconds * video->getFPS();
221 if (newFrame > lengthFrames) { switchState(S_PLAY); unLock(); }
222 else switchState(S_JUMP, newFrame);
226 void PlayerRadio::skipBackward(int seconds)
229 logger->log("PlayerRadio", Log::DEBUG, "SKIP BACKWARD %i SECONDS", seconds);
230 long newFrame = getCurrentSeconds();
231 if (newFrame == 0) { unLock(); return; } // Current pos from demuxer is not valid
232 // newFrame -= seconds * video->getFPS();
233 if (newFrame < 0) newFrame = 0;
234 switchState(S_JUMP, newFrame);
238 // ----------------------------------- Implementations called events
240 void PlayerRadio::switchState(UCHAR toState, ULONG jumpFrame)
242 if (!initted) return;
244 logger->log("PlayerRadio", Log::DEBUG, "Switch state from %u to %u", state, toState);
246 switch(state) // current state selector
248 case S_PLAY: // from S_PLAY -----------------------------------
252 case S_PLAY: // to S_PLAY
256 case S_PAUSE_P: // to S_PAUSE_P
262 case S_STOP: // to S_STOP
272 case S_JUMP: // to S_JUMP
274 restartAtFrame(jumpFrame);
279 case S_PAUSE_P: // from S_PAUSE_P -----------------------------------
283 case S_PLAY: // to S_PLAY
289 case S_PAUSE_P: // to S_PAUSE_P
293 case S_STOP: // to S_STOP
300 audio->systemMuteOff();
304 case S_JUMP: // to S_JUMP
308 restartAtFrame(jumpFrame);
313 case S_STOP: // from S_STOP -----------------------------------
317 case S_PLAY: // to S_PLAY
322 audio->systemMuteOff();
326 // FIXME use restartAtFrame here?
327 if (currentFrameNumber > lengthFrames) currentFrameNumber = 0;
328 demuxer->setFrameNum(currentFrameNumber);
336 logger->log("PlayerRadio", Log::DEBUG, "Immediate play");
340 else // do prebuffering
342 logger->log("PlayerRadio", Log::DEBUG, "Prebuffering...");
347 case S_PAUSE_P: // to S_PAUSE_P
351 case S_STOP: // to S_STOP
355 case S_JUMP: // to S_JUMP
361 // case S_JUMP cannot be selected as a start state because it auto flips to play
365 // ----------------------------------- Internal functions
367 void PlayerRadio::lock()
370 pthread_mutex_lock(&mutex);
371 logger->log("PlayerRadio", Log::DEBUG, "LOCKED");
374 WaitForSingleObject(mutex, INFINITE);
378 void PlayerRadio::unLock()
381 logger->log("PlayerRadio", Log::DEBUG, "UNLOCKING");
382 pthread_mutex_unlock(&mutex);
388 void PlayerRadio::restartAtFrame(ULONG newFrame)
394 currentFrameNumber = newFrame;
395 demuxer->setFrameNum(newFrame);
399 audio->systemMuteOff();
403 void PlayerRadio::doConnectionLost()
405 logger->log("PlayerRadio", Log::DEBUG, "Connection lost, sending message");
406 Message* m = new Message();
407 m->to = messageReceiver;
409 m->message = Message::PLAYER_EVENT;
410 m->parameter = PlayerRadio::CONNECTION_LOST;
411 messageQueue->postMessage(m);
414 // ----------------------------------- Callback
416 void PlayerRadio::call(void* caller)
418 threadSignalNoLock();
421 // ----------------------------------- Feed thread
423 void PlayerRadio::threadMethod()
427 if (state == S_PLAY) threadFeedPlay();
435 void PlayerRadio::threadFeedLive()
440 UINT preBufferTotal = 0;
452 askFor = startupBlockSize; // find audio streams sized block
454 askFor = blockSize; // normal
456 threadBuffer = vdr->getBlock(0, askFor, &thisRead);
458 if (!vdr->isConnected())
464 if (!threadBuffer) break;
468 int a_stream = demuxer->scan(threadBuffer, thisRead);
469 demuxer->setAudioStream(a_stream);
470 logger->log("PlayerRadio", Log::DEBUG, "Startup Audio stream chosen %x", a_stream);
476 preBufferTotal += thisRead;
477 if (preBufferTotal >= preBufferSize)
479 logger->log("PlayerRadio", Log::DEBUG, "Got >500K, prebuffering complete");
481 preBuffering = false;
486 // unLock(); // thread will be locked by play until here
487 // FIXME - see if this can segfault because it is starting threads out of the master mutex
493 while(writeLength < thisRead)
495 thisWrite = demuxer->put(threadBuffer + writeLength, thisRead - writeLength);
496 writeLength += thisWrite;
500 // demuxer is full and can't take anymore
502 threadWaitForSignal();
514 logger->log("PlayerRadio", Log::DEBUG, "Live play failed to start or interrupted");
518 Message* m = new Message(); // Must be done after this thread finishes, and must break into master mutex
519 m->to = messageReceiver;
521 m->message = Message::PLAYER_EVENT;
522 m->parameter = PlayerRadio::STREAM_END;
523 logger->log("PlayerRadio", Log::DEBUG, "Posting message to %p...", messageQueue);
524 messageQueue->postMessage(m);
525 logger->log("PlayerRadio", Log::DEBUG, "Message posted...");
528 void PlayerRadio::threadFeedPlay()
531 UINT thisRead, writeLength, thisWrite, askFor;
532 time_t lastRescan = time(NULL);
534 feedPosition = vdr->positionFromFrameNumber(currentFrameNumber);
535 if (!vdr->isConnected()) { doConnectionLost(); return; }
536 logger->log("PlayerRadio", Log::DEBUG, "startFeedPlay: wantedframe %i goto %llu", currentFrameNumber, feedPosition);
547 // If we havn't rescanned for a while..
548 if ((lastRescan + 60) < time(NULL))
550 lengthBytes = vdr->rescanRecording(&lengthFrames);
551 if (!vdr->isConnected()) { doConnectionLost(); return; }
552 logger->log("PlayerRadio", Log::DEBUG, "Rescanned and reset length: %llu", lengthBytes);
553 lastRescan = time(NULL);
556 if (feedPosition >= lengthBytes) break; // finished playback
560 if (startupBlockSize > lengthBytes)
561 askFor = lengthBytes; // is a very small recording!
563 askFor = startupBlockSize; // normal, but a startup sized block to detect all the audio streams
567 if ((feedPosition + blockSize) > lengthBytes) // last block of recording
568 askFor = lengthBytes - feedPosition;
573 threadBuffer = vdr->getBlock(feedPosition, askFor, &thisRead);
574 feedPosition += thisRead;
576 if (!vdr->isConnected())
582 if (!threadBuffer) break;
586 int a_stream = demuxer->scan(threadBuffer, thisRead);
587 demuxer->setAudioStream(a_stream);
588 logger->log("PlayerRadio", Log::DEBUG, "Startup Audio stream chosen %x", a_stream);
594 while(writeLength < thisRead)
596 thisWrite = demuxer->put(threadBuffer + writeLength, thisRead - writeLength);
597 writeLength += thisWrite;
601 // demuxer is full and can't take anymore
603 threadWaitForSignal();
616 logger->log("PlayerRadio", Log::DEBUG, "Recording playback ends");
621 Message* m = new Message(); // Must be done after this thread finishes, and must break into master mutex
622 m->to = messageReceiver;
624 m->message = Message::PLAYER_EVENT;
625 m->parameter = PlayerRadio::STOP_PLAYBACK;
626 logger->log("PlayerRadio", Log::DEBUG, "Posting message to %p...", messageQueue);
627 messageQueue->postMessage(m);
630 void PlayerRadio::threadPostStopCleanup()