]> git.vomp.tv Git - vompclient-marten.git/blob - vradiorec.cc
Client side timeouts
[vompclient-marten.git] / vradiorec.cc
1 /*
2     Copyright 2004-2006 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., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
19 */
20
21 #include "vradiorec.h"
22
23 #include "command.h"
24 #include "osd.h"
25 #include "player.h"
26 #include "wsymbol.h"
27 #include "recording.h"
28 #include "message.h"
29 #include "vdr.h"
30 #include "video.h"
31 #include "timers.h"
32 #include "playerradio.h"
33 #include "boxstack.h"
34 #include "remote.h"
35 #include "vinfo.h"
36 #include "i18n.h"
37
38 VRadioRec::VRadioRec(Recording* rec)
39 {
40   boxstack = BoxStack::getInstance();
41   vdr = VDR::getInstance();
42   video = Video::getInstance();
43   timers = Timers::getInstance();
44   myRec = rec;
45   playing = false;
46   startMargin = 0;
47   endMargin = 0;
48
49   player = new PlayerRadio(Command::getInstance(), this, true);
50
51   char* cstartMargin = vdr->configLoad("Timers", "Start margin");
52   char* cendMargin = vdr->configLoad("Timers", "End margin");
53   if (!cstartMargin)
54   {
55     startMargin = 300; // 5 mins default
56   }
57   else
58   {
59     startMargin = atoi(cstartMargin) * 60;
60     delete[] cstartMargin;
61   }
62
63   if (!cendMargin)
64   {
65     endMargin = 300; // 5 mins default
66   }
67   else
68   {
69     endMargin = atoi(cendMargin) * 60;
70     delete[] cendMargin;
71   }
72
73   Log::getInstance()->log("VRadioRec", Log::DEBUG, "SM: %u EM: %u", startMargin, endMargin);
74
75   setSize(video->getScreenWidth(), video->getScreenHeight());
76   createBuffer();
77   setPosition(0, 0);
78
79   barRegion.x = 0;
80   barRegion.y = video->getScreenHeight() - 58;   // FIXME, need to be - 1? and below?
81   barRegion.w = video->getScreenWidth();
82   barRegion.h = 58;
83
84   clocksRegion.x = barRegion.x + 140;
85   clocksRegion.y = barRegion.y + 12;
86   clocksRegion.w = 170;
87   clocksRegion.h = surface->getFontHeight();
88
89
90   barBlue.set(0, 0, 150, 150);
91
92   barShowing = false;
93 }
94
95 VRadioRec::~VRadioRec()
96 {
97   if (playing) stopPlay();
98
99   timers->cancelTimer(this, 1);
100   timers->cancelTimer(this, 2);
101
102   // kill recInfo in case resumePoint has changed (likely)
103   myRec->dropRecInfo();
104   // FIXME - do this properly - save the resume point back to the server manually and update
105   // rec->recInfo->resumePoint - this will fix the ~10s offset problem as well
106 }
107
108 void VRadioRec::draw()
109 {
110   fillColour(Colour::BLACK);
111 }
112
113 void VRadioRec::go()
114 {
115   Log::getInstance()->log("VRadioRec", Log::DEBUG, "Starting stream: %s", myRec->getFileName());
116   ULONG lengthFrames = 0;
117   ULLONG lengthBytes = vdr->streamRecording(myRec->getFileName(), &lengthFrames);
118
119   bool cantStart = false;
120
121   if (!lengthBytes) cantStart = true;
122   else if (!player->init(lengthBytes, lengthFrames)) cantStart = true;
123   else
124   {
125     doBar(0);
126   //  player->setStartBytes(startBytes);
127     player->play();
128     playing = true;
129   }
130
131   if (cantStart)
132   {
133     stopPlay(); // clean up
134
135     if (!vdr->isConnected())
136     {
137       Command::getInstance()->connectionLost();
138       return;
139     }
140
141     Message* m = new Message();
142     m->message = Message::CLOSE_ME;
143     m->from = this;
144     m->to = boxstack;
145     Command::getInstance()->postMessageNoLock(m);
146
147     VInfo* vi = new VInfo();
148     vi->setSize(400, 150);
149     vi->createBuffer();
150     if (video->getFormat() == Video::PAL)
151       vi->setPosition(170, 200);
152     else
153       vi->setPosition(160, 150);
154     vi->setExitable();
155     vi->setBorderOn(1);
156     vi->setTitleBarOn(0);
157     vi->setOneLiner(tr("Error playing recording"));
158     vi->draw();
159
160     m = new Message();
161     m->message = Message::ADD_VIEW;
162     m->to = boxstack;
163     m->parameter = (ULONG)vi;
164     Command::getInstance()->postMessageNoLock(m);
165   }
166 }
167
168 int VRadioRec::handleCommand(int command)
169 {
170   switch(command)
171   {
172     case Remote::PLAY:
173     {
174       player->play();
175       doBar(0);
176       return 2;
177     }
178
179     case Remote::STOP:
180     case Remote::BACK:
181     case Remote::MENU:
182     {
183       if (playing) stopPlay();
184       return 4;
185     }
186     case Remote::PAUSE:
187     {
188       player->pause();
189       doBar(0);
190       return 2;
191     }
192     case Remote::SKIPFORWARD:
193     {
194       doBar(3);
195       player->skipForward(60);
196       return 2;
197     }
198     case Remote::SKIPBACK:
199     {
200       doBar(4);
201       player->skipBackward(60);
202       return 2;
203     }
204     case Remote::YELLOW:
205     {
206       doBar(2);
207       player->skipBackward(10);
208       return 2;
209     }
210     case Remote::BLUE:
211     {
212       doBar(1);
213       player->skipForward(10);
214       return 2;
215     }
216     case Remote::OK:
217     {
218       if (barShowing) removeBar();
219       else doBar(0);
220       return 2;
221     }
222
223     case Remote::ZERO:  player->jumpToPercent(0);  doBar(0);  return 2;
224     case Remote::ONE:   player->jumpToPercent(10); doBar(0);  return 2;
225     case Remote::TWO:   player->jumpToPercent(20); doBar(0);  return 2;
226     case Remote::THREE: player->jumpToPercent(30); doBar(0);  return 2;
227     case Remote::FOUR:  player->jumpToPercent(40); doBar(0);  return 2;
228     case Remote::FIVE:  player->jumpToPercent(50); doBar(0);  return 2;
229     case Remote::SIX:   player->jumpToPercent(60); doBar(0);  return 2;
230     case Remote::SEVEN: player->jumpToPercent(70); doBar(0);  return 2;
231     case Remote::EIGHT: player->jumpToPercent(80); doBar(0);  return 2;
232     case Remote::NINE:  player->jumpToPercent(90); doBar(0);  return 2;
233
234 #ifdef DEV
235     case Remote::RED:
236     {
237       //player->test1();
238
239       return 2;
240     }
241     case Remote::GREEN:
242     {
243       //player->test2();
244       return 2;
245     }
246 #endif
247
248   }
249
250   return 1;
251 }
252
253 void VRadioRec::processMessage(Message* m)
254 {
255   if (m->message == Message::MOUSE_LBDOWN)
256   {
257     int x=(m->parameter>>16)-(int)getScreenX();
258     int y=(m->parameter&0xFFFF)-(int)getScreenY();
259     if (!barShowing)
260     {
261       boxstack->handleCommand(Remote::OK); //simulate rok press
262     }
263     else if ((int)barRegion.x<=x && (int)barRegion.y<=y && ((int)barRegion.x+(int)barRegion.w)>=x
264              &&  ((int)barRegion.y+(int)barRegion.h)>=y)
265     {
266       int progBarXbase = barRegion.x + 300;
267       if (x>=(int)barRegion.x + progBarXbase + 24
268         && x<=(int)barRegion.x + progBarXbase + 4 + 302
269         && y>=(int)barRegion.y + 12 - 2
270         && y<=(int)barRegion.y + 12 - 2+28)
271       {
272         int cx=x-(barRegion.x + progBarXbase + 4);
273         double percent=((double)cx)/302.*100.;
274         player->jumpToPercent(percent);
275         doBar(3);
276         return;
277         //  int progressWidth = 302 * currentFrameNum / lengthFrames;
278         //  rectangle(barRegion.x + progBarXbase + 4, barRegion.y + 16, progressWidth, 16, Colour::SELECTHIGHLIGHT);
279       }
280     }
281     else
282     {
283       boxstack->handleCommand(Remote::OK); //simulate rok press
284     }
285   }
286   else if (m->message == Message::PLAYER_EVENT)
287   {
288     if (m->from != player) return;
289
290     Log::getInstance()->log("VRadioRec", Log::DEBUG, "Message received");
291
292     switch(m->parameter)
293     {
294       case Player::CONNECTION_LOST: // connection lost detected
295       {
296         // I can't handle this, send it to command
297         Message* m2 = new Message();
298         m2->to = Command::getInstance();
299         m2->message = Message::CONNECTION_LOST;
300         Command::getInstance()->postMessageNoLock(m2);
301         break;
302       }
303       case Player::STOP_PLAYBACK:
304       {
305         // FIXME Obselete ish - improve this
306         Message* m2 = new Message(); // Must be done after this thread finishes, and must break into master mutex
307         m2->to = Command::getInstance();
308         m2->message = Message::STOP_PLAYBACK;
309         Command::getInstance()->postMessageNoLock(m2);
310         break;
311       }
312     }
313   }
314 }
315
316 void VRadioRec::stopPlay()
317 {
318   Log::getInstance()->log("VRadioRec", Log::DEBUG, "Pre stopPlay");
319
320   // FIXME work out a better soln for this
321   // Fix a problem to do with thread sync here
322   // because the bar gets a timer every 0.2s and it seems to take up to 0.1s,
323   // (or maybe just the wrong thread being selected?) for the main loop to lock and process
324   // the video stop message it is possible for a bar message to stack up after a stop message
325   // when the bar message is finally processed the prog crashes because this is deleted by then
326   removeBar();
327   //
328
329   player->stop();
330   vdr->stopStreaming();
331   delete player;
332
333   playing = false;
334
335   if (!vdr->isConnected()) { Command::getInstance()->connectionLost(); return; }
336   Log::getInstance()->log("VRadioRec", Log::DEBUG, "Post stopPlay");
337 }
338
339 void VRadioRec::doBar(int action)
340 {
341   barShowing = true;
342
343   rectangle(barRegion, barBlue);
344
345   /* Work out what to display - choices:
346
347   Playing  >
348   Paused   ||
349
350   Specials, informed by parameter
351
352   Skip forward 10s    >|
353   Skip backward 10s   |<
354   Skip forward 1m     >>|
355   Skip backward 1m    |<<
356
357   */
358
359   WSymbol w;
360   TEMPADD(&w);
361   w.nextSymbol = 0;
362   w.setPosition(barRegion.x + 66, barRegion.y + 16);
363
364   UCHAR playerState = 0;
365
366   if (action)
367   {
368     if (action == 1)       w.nextSymbol = WSymbol::SKIPFORWARD;
369     else if (action == 2)  w.nextSymbol = WSymbol::SKIPBACK;
370     else if (action == 3)  w.nextSymbol = WSymbol::SKIPFORWARD2;
371     else if (action == 4)  w.nextSymbol = WSymbol::SKIPBACK2;
372   }
373   else
374   {
375     playerState = player->getState();
376     if (playerState == Player::S_PAUSE_P)      w.nextSymbol = WSymbol::PAUSE;
377     else if (playerState == Player::S_PAUSE_I) w.nextSymbol = WSymbol::PAUSE;
378     else                                       w.nextSymbol = WSymbol::PLAY;
379   }
380
381   w.draw();
382
383   drawBarClocks();
384
385   BoxStack::getInstance()->update(this, &barRegion);
386
387   timers->setTimerD(this, 1, 4); // only set the getridofbar timer if not ffwd/fbwd
388   timers->setTimerD(this, 2, 0, 200000000);
389 }
390
391 void VRadioRec::timercall(int clientReference)
392 {
393   switch(clientReference)
394   {
395     case 1:
396     {
397       // Remove bar
398       removeBar();
399       break;
400     }
401     case 2:
402     {
403       // Update clock
404       if (!barShowing) break;
405       drawBarClocks();
406       Message* m = new Message();
407       m->message = Message::REDRAW;
408       m->to = boxstack;
409       m->from = this;
410       m->parameter = (ULONG)&barRegion;
411       Command::getInstance()->postMessageFromOuterSpace(m);
412       timers->setTimerD(this, 2, 0, 200000000);
413       break;
414     }
415   }
416 }
417
418 void VRadioRec::drawBarClocks()
419 {
420   Log* logger = Log::getInstance();
421   logger->log("VRadioRec", Log::DEBUG, "Draw bar clocks");
422
423   // Draw RTC
424   // Blank the area first
425   rectangle(barRegion.x + 624, barRegion.y + 12, 60, 30, barBlue);
426   char timeString[20];
427   time_t t;
428   time(&t);
429   struct tm* tms = localtime(&t);
430   strftime(timeString, 19, "%H:%M", tms);
431   drawText(timeString, barRegion.x + 624, barRegion.y + 12, Colour::LIGHTTEXT);
432
433   // Draw clocks
434
435   rectangle(clocksRegion, barBlue);
436
437 /*
438   ULONG currentFrameNum = player->getCurrentFrameNum();
439   ULONG lengthFrames;
440   if (myRec->recInfo->timerEnd > time(NULL))
441   {
442     // chasing playback
443     // Work out an approximate length in frames (good to 1s...)
444     lengthFrames = (myRec->recInfo->timerEnd - myRec->recInfo->timerStart) * video->getFPS();
445   }
446   else
447   {
448 //    lengthFrames = player->getLengthFrames();
449     lengthFrames = 0;
450   }
451
452   hmsf currentFrameHMSF = video->framesToHMSF(currentFrameNum);
453   hmsf lengthHMSF = video->framesToHMSF(lengthFrames);
454
455   char buffer[100];
456   if (currentFrameNum >= lengthFrames)
457   {
458     strcpy(buffer, "-:--:-- / -:--:--");
459   }
460   else
461   {
462     SNPRINTF(buffer, 99, "%01i:%02i:%02i / %01i:%02i:%02i", currentFrameHMSF.hours, currentFrameHMSF.minutes, currentFrameHMSF.seconds, lengthHMSF.hours, lengthHMSF.minutes, lengthHMSF.seconds);
463     logger->log("VRadioRec", Log::DEBUG, buffer);
464   }
465 */
466
467   ULONG currentSeconds = player->getCurrentSeconds();
468   ULONG lengthSeconds = player->getLengthSeconds();
469   char buffer[100];
470
471   if (lengthSeconds && (currentSeconds < lengthSeconds))
472   {
473     ULONG dcurrentSeconds = currentSeconds;
474     ULONG dlengthSeconds = lengthSeconds;
475
476     ULONG currentHours = dcurrentSeconds / 3600;
477     dcurrentSeconds %= 3600;
478     ULONG currentMinutes = dcurrentSeconds / 60;
479     dcurrentSeconds %= 60;
480
481     ULONG lengthHours = dlengthSeconds / 3600;
482     dlengthSeconds %= 3600;
483     ULONG lengthMinutes = dlengthSeconds / 60;
484     dlengthSeconds %= 60;
485
486     SNPRINTF(buffer, 99, "%01lu:%02lu:%02lu / %01lu:%02lu:%02lu", currentHours, currentMinutes, dcurrentSeconds, lengthHours, lengthMinutes, dlengthSeconds);
487     logger->log("VRadioRec", Log::DEBUG, buffer);
488   }
489   else
490   {
491     strcpy(buffer, "-:--:-- / -:--:--");
492   }
493
494   drawText(buffer, clocksRegion.x, clocksRegion.y, Colour::LIGHTTEXT);
495
496
497
498
499   // Draw progress bar
500   int progBarXbase = barRegion.x + 300;
501
502   rectangle(barRegion.x + progBarXbase, barRegion.y + 12, 310, 24, Colour::LIGHTTEXT);
503   rectangle(barRegion.x + progBarXbase + 2, barRegion.y + 14, 306, 20, barBlue);
504
505   if (currentSeconds > lengthSeconds) return;
506   if (lengthSeconds == 0) return;
507
508   // Draw yellow portion
509   int progressWidth = 302 * currentSeconds / lengthSeconds;
510   rectangle(barRegion.x + progBarXbase + 4, barRegion.y + 16, progressWidth, 16, Colour::SELECTHIGHLIGHT);
511 /*
512
513   if (myRec->recInfo->timerEnd > time(NULL)) // if chasing
514   {
515     int nrWidth = (int)(302 * ((double)(lengthFrames - 0) / lengthFrames)); // 0 inserted instead of getlengthframes
516
517     Log::getInstance()->log("GVASDF", Log::DEBUG, "Length Frames: %lu", lengthFrames);
518 //    Log::getInstance()->log("GVASDF", Log::DEBUG, "Player lf: %lu", player->getLengthFrames());
519     Log::getInstance()->log("GVASDF", Log::DEBUG, "NR WDITH: %i", nrWidth);
520     rectangle(barRegion.x + progBarXbase + 4 + 302 - nrWidth, barRegion.y + 16, nrWidth, 16, Colour::RED);
521   }
522 */
523
524   logger->log("VRadioRec", Log::DEBUG, "blips");
525
526   // Now calc position for start margin blips
527   int posPix;
528
529   posPix = 302 * startMargin / lengthSeconds;
530   logger->log("VRadioRec", Log::DEBUG, "posPix %i", posPix);
531
532   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 - 2, 2, 2, Colour::LIGHTTEXT);
533   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 + 24, 2, 2, Colour::LIGHTTEXT);
534
535   posPix = 302 * (lengthSeconds - endMargin) / lengthSeconds;
536
537   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 - 2, 2, 2, Colour::LIGHTTEXT);
538   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 + 24, 2, 2, Colour::LIGHTTEXT);
539 }
540
541 void VRadioRec::removeBar()
542 {
543   if (!barShowing) return;
544   timers->cancelTimer(this, 2);
545   barShowing = false;
546   rectangle(barRegion, Colour::BLACK);
547
548   Message* m = new Message();
549   m->message = Message::REDRAW;
550   m->to = boxstack;
551   m->from = this;
552   m->parameter = (ULONG)&barRegion;
553   Command::getInstance()->postMessageFromOuterSpace(m);
554 }