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);
  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   removeBar();
 321   player->stop();
 322   vdr->stopStreaming();
 323   delete player;
 324
 325   playing = false;
 326
 327   if (!vdr->isConnected()) { Command::getInstance()->connectionLost(); return; }
 328   Log::getInstance()->log("VRadioRec", Log::DEBUG, "Post stopPlay");
 329 }
 330
 331 void VRadioRec::doBar(int action)
 332 {
 333   barShowing = true;
 334
 335   rectangle(barRegion, barBlue);
 336
 337   /* Work out what to display - choices:
 338
 339   Playing  >
 340   Paused   ||
 341
 342   Specials, informed by parameter
 343
 344   Skip forward 10s    >|
 345   Skip backward 10s   |<
 346   Skip forward 1m     >>|
 347   Skip backward 1m    |<<
 348
 349   */
 350
 351   WSymbol w;
 352   TEMPADD(&w);
 353   w.nextSymbol = 0;
 354   w.setPosition(barRegion.x + 66, barRegion.y + 16);
 355
 356   UCHAR playerState = 0;
 357
 358   if (action)
 359   {
 360     if (action == 1)       w.nextSymbol = WSymbol::SKIPFORWARD;
 361     else if (action == 2)  w.nextSymbol = WSymbol::SKIPBACK;
 362     else if (action == 3)  w.nextSymbol = WSymbol::SKIPFORWARD2;
 363     else if (action == 4)  w.nextSymbol = WSymbol::SKIPBACK2;
 364   }
 365   else
 366   {
 367     playerState = player->getState();
 368     if (playerState == Player::S_PAUSE_P)      w.nextSymbol = WSymbol::PAUSE;
 369     else if (playerState == Player::S_PAUSE_I) w.nextSymbol = WSymbol::PAUSE;
 370     else                                       w.nextSymbol = WSymbol::PLAY;
 371   }
 372
 373   w.draw();
 374
 375   drawBarClocks();
 376
 377   BoxStack::getInstance()->update(this, &barRegion);
 378
 379   timers->setTimerD(this, 1, 4); // only set the getridofbar timer if not ffwd/fbwd
 380   timers->setTimerD(this, 2, 0, 200000000);
 381 }
 382
 383 void VRadioRec::timercall(int clientReference)
 384 {
 385   switch(clientReference)
 386   {
 387     case 1:
 388     {
 389       // Remove bar
 390       removeBar();
 391       break;
 392     }
 393     case 2:
 394     {
 395       // Update clock
 396       if (!barShowing) break;
 397       drawBarClocks();
 398       boxstack->update(this, &barRegion);
 399
 400       timers->setTimerD(this, 2, 0, 200000000);
 401       break;
 402     }
 403   }
 404 }
 405
 406 void VRadioRec::drawBarClocks()
 407 {
 408   Log* logger = Log::getInstance();
 409   logger->log("VRadioRec", Log::DEBUG, "Draw bar clocks");
 410
 411   // Draw RTC
 412   // Blank the area first
 413   rectangle(barRegion.x + 624, barRegion.y + 12, 60, 30, barBlue);
 414   char timeString[20];
 415   time_t t;
 416   time(&t);
 417   struct tm* tms = localtime(&t);
 418   strftime(timeString, 19, "%H:%M", tms);
 419   drawText(timeString, barRegion.x + 624, barRegion.y + 12, Colour::LIGHTTEXT);
 420
 421   // Draw clocks
 422
 423   rectangle(clocksRegion, barBlue);
 424
 425 /*
 426   ULONG currentFrameNum = player->getCurrentFrameNum();
 427   ULONG lengthFrames;
 428   if (myRec->recInfo->timerEnd > time(NULL))
 429   {
 430     // chasing playback
 431     // Work out an approximate length in frames (good to 1s...)
 432     lengthFrames = (myRec->recInfo->timerEnd - myRec->recInfo->timerStart) * video->getFPS();
 433   }
 434   else
 435   {
 436 //    lengthFrames = player->getLengthFrames();
 437     lengthFrames = 0;
 438   }
 439
 440   hmsf currentFrameHMSF = video->framesToHMSF(currentFrameNum);
 441   hmsf lengthHMSF = video->framesToHMSF(lengthFrames);
 442
 443   char buffer[100];
 444   if (currentFrameNum >= lengthFrames)
 445   {
 446     strcpy(buffer, "-:--:-- / -:--:--");
 447   }
 448   else
 449   {
 450     SNPRINTF(buffer, 99, "%01i:%02i:%02i / %01i:%02i:%02i", currentFrameHMSF.hours, currentFrameHMSF.minutes, currentFrameHMSF.seconds, lengthHMSF.hours, lengthHMSF.minutes, lengthHMSF.seconds);
 451     logger->log("VRadioRec", Log::DEBUG, buffer);
 452   }
 453 */
 454
 455   ULONG currentSeconds = player->getCurrentSeconds();
 456   ULONG lengthSeconds = player->getLengthSeconds();
 457   char buffer[100];
 458
 459   if (lengthSeconds && (currentSeconds < lengthSeconds))
 460   {
 461     ULONG dcurrentSeconds = currentSeconds;
 462     ULONG dlengthSeconds = lengthSeconds;
 463
 464     ULONG currentHours = dcurrentSeconds / 3600;
 465     dcurrentSeconds %= 3600;
 466     ULONG currentMinutes = dcurrentSeconds / 60;
 467     dcurrentSeconds %= 60;
 468
 469     ULONG lengthHours = dlengthSeconds / 3600;
 470     dlengthSeconds %= 3600;
 471     ULONG lengthMinutes = dlengthSeconds / 60;
 472     dlengthSeconds %= 60;
 473
 474     SNPRINTF(buffer, 99, "%01lu:%02lu:%02lu / %01lu:%02lu:%02lu", currentHours, currentMinutes, dcurrentSeconds, lengthHours, lengthMinutes, dlengthSeconds);
 475     logger->log("VRadioRec", Log::DEBUG, buffer);
 476   }
 477   else
 478   {
 479     strcpy(buffer, "-:--:-- / -:--:--");
 480   }
 481
 482   drawText(buffer, clocksRegion.x, clocksRegion.y, Colour::LIGHTTEXT);
 483
 484   // Draw progress bar
 485   int progBarXbase = barRegion.x + 300;
 486
 487   rectangle(barRegion.x + progBarXbase, barRegion.y + 12, 310, 24, Colour::LIGHTTEXT);
 488   rectangle(barRegion.x + progBarXbase + 2, barRegion.y + 14, 306, 20, barBlue);
 489
 490   if (currentSeconds > lengthSeconds) return;
 491   if (lengthSeconds == 0) return;
 492
 493   // Draw yellow portion
 494   int progressWidth = 302 * currentSeconds / lengthSeconds;
 495   rectangle(barRegion.x + progBarXbase + 4, barRegion.y + 16, progressWidth, 16, Colour::SELECTHIGHLIGHT);
 496 /*
 497
 498   if (myRec->recInfo->timerEnd > time(NULL)) // if chasing
 499   {
 500     int nrWidth = (int)(302 * ((double)(lengthFrames - 0) / lengthFrames)); // 0 inserted instead of getlengthframes
 501
 502     Log::getInstance()->log("GVASDF", Log::DEBUG, "Length Frames: %lu", lengthFrames);
 503 //    Log::getInstance()->log("GVASDF", Log::DEBUG, "Player lf: %lu", player->getLengthFrames());
 504     Log::getInstance()->log("GVASDF", Log::DEBUG, "NR WDITH: %i", nrWidth);
 505     rectangle(barRegion.x + progBarXbase + 4 + 302 - nrWidth, barRegion.y + 16, nrWidth, 16, Colour::RED);
 506   }
 507 */
 508
 509   logger->log("VRadioRec", Log::DEBUG, "blips");
 510
 511   // Now calc position for start margin blips
 512   int posPix;
 513
 514   posPix = 302 * startMargin / lengthSeconds;
 515   logger->log("VRadioRec", Log::DEBUG, "posPix %i", posPix);
 516
 517   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 - 2, 2, 2, Colour::LIGHTTEXT);
 518   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 + 24, 2, 2, Colour::LIGHTTEXT);
 519
 520   posPix = 302 * (lengthSeconds - endMargin) / lengthSeconds;
 521
 522   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 - 2, 2, 2, Colour::LIGHTTEXT);
 523   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 + 24, 2, 2, Colour::LIGHTTEXT);
 524 }
 525
 526 void VRadioRec::removeBar()
 527 {
 528   if (!barShowing) return;
 529   timers->cancelTimer(this, 2);
 530   barShowing = false;
 531   rectangle(barRegion, Colour::BLACK);
 532   boxstack->update(this, &barRegion);
 533 }
 534