main.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., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
  19 */
  20
  21 #include <stdio.h>
  22 #include <stdlib.h>
  23 #include <string.h>
  24 #include <signal.h>
  25 #ifndef WIN32
  26 #include <unistd.h>
  27 #include <endian.h>
  28 #endif
  29
  30 #include "defines.h"
  31 #include "log.h"
  32 #include "timers.h"
  33 #include "vdr.h"
  34 #include "boxstack.h"
  35 #include "command.h"
  36
  37 #include "mtdmvp.h"
  38 #include "remotemvp.h"
  39 #include "ledmvp.h"
  40 #include "osdmvp.h"
  41 #include "audiomvp.h"
  42 #include "videomvp.h"
  43 #include "wol.h"
  44
  45 #ifndef WIN32
  46 void sighandler(int signalReceived);
  47 #endif
  48
  49 void shutdown(int code);
  50
  51 extern "C"
  52 {
  53   int ticonfig_main(int, char**);
  54 }
  55
  56 // Global variables --------------------------------------------------------------------------------------------------
  57 Log* logger;
  58 Remote* remote;
  59 Mtd* mtd;
  60 Led* led;
  61 Osd* osd;
  62 Timers* timers;
  63 BoxStack* boxstack;
  64 Command* command;
  65 VDR* vdr;
  66 Video* video;
  67 Audio* audio;
  68 Wol* wol;
  69
  70 // Linux MVP main function and sighandler
  71 #ifndef WIN32
  72 int main(int argc, char** argv)
  73 {
  74   if (strstr(argv[0], "ticonfig")) return ticonfig_main(argc, argv);
  75
  76   bool daemonize = true;
  77   bool debugEnabled = false;
  78   bool crashed = false;
  79   char* setServer = NULL;
  80   int c;
  81
  82   while ((c = getopt(argc, argv, "cdns:")) != -1)
  83   {
  84     switch (c)
  85     {
  86       case 'c':
  87         crashed = true;
  88         break;
  89       case 'd':
  90         debugEnabled = true; // and...
  91       case 'n':
  92         daemonize = false;
  93         break;
  94       case 's':
  95         setServer = optarg;
  96         break;
  97       case '?':
  98         printf("Unknown option\n");
  99         return 1;
 100       default:
 101         printf("Option error\n");
 102         return 1;
 103     }
 104   }
 105
 106   // Init global vars ------------------------------------------------------------------------------------------------
 107
 108   logger     = new Log();
 109   timers     = new Timers();
 110   vdr        = new VDR();
 111   mtd        = new MtdMVP();
 112   remote     = new RemoteMVP();
 113   led        = new LedMVP();
 114   osd        = new OsdMVP();
 115   audio      = new AudioMVP();
 116   video      = new VideoMVP();
 117   boxstack   = new BoxStack();
 118   command    = new Command();
 119   wol        = new Wol();
 120
 121   if (!logger || !remote || !mtd || !led || !osd || !video || !audio || !boxstack || !command || !wol)
 122   {
 123     printf("Could not create objects. Memory problems?\n");
 124     shutdown(1);
 125   }
 126
 127   // Get logging module started --------------------------------------------------------------------------------------
 128
 129   if (!logger->init(Log::DEBUG, "dummy", debugEnabled ? 1 : 0))
 130   {
 131     printf("Could not initialise log object. Aborting.\n");
 132     shutdown(1);
 133   }
 134
 135   logger->log("Core", Log::INFO, "Starting up...");
 136
 137   // Daemonize if not -d
 138
 139   if (daemonize)
 140   {
 141     // Fork away
 142     pid_t forkTest = fork();
 143     if (forkTest == -1)
 144     { printf("Cannot fork (1).\n"); exit(1); }
 145     if (forkTest != 0) _exit(0); // PID returned, I am the parent
 146     // otherwise, I am the child
 147     setsid();
 148     forkTest = fork();
 149     if (forkTest == -1)
 150     { printf("Cannot fork (2).\n"); exit(1); }
 151     if (forkTest != 0) _exit(0); // PID returned, I am the parent
 152     // otherwise, I am the child
 153     close(0);
 154     close(1);
 155     close(2);
 156   }
 157
 158   // Set up signal handling ------------------------------------------------------------------------------------------
 159
 160   sighandler_t sigtest;
 161
 162   sigtest = signal(SIGPIPE, SIG_IGN);
 163   if (sigtest == SIG_ERR)
 164   {
 165     logger->log("Core", Log::EMERG, "Could not set up signal handler for SIGPIPE. Aborting.");
 166     shutdown(1);
 167   }
 168   sigtest = signal(SIGINT, sighandler);
 169   if (sigtest == SIG_ERR)
 170   {
 171     logger->log("Core", Log::EMERG, "Could not set up signal handler for SIGINT. Aborting.");
 172     shutdown(1);
 173   }
 174   sigtest = signal(SIGTERM, sighandler);
 175   if (sigtest == SIG_ERR)
 176   {
 177     logger->log("Core", Log::EMERG, "Could not set up signal handler for SIGTERM. Aborting.");
 178     shutdown(1);
 179   }
 180   sigtest = signal(SIGUSR1, sighandler);
 181   if (sigtest == SIG_ERR)
 182   {
 183     logger->log("Core", Log::EMERG, "Could not set up signal handler for SIGUSR1. Aborting.");
 184     shutdown(1);
 185   }
 186 /*
 187   sigtest = signal(SIGUSR2, sighandler);
 188   if (sigtest == SIG_ERR)
 189   {
 190     logger->log("Core", Log::EMERG, "Could not set up signal handler for SIGUSR2. Aborting.");
 191     shutdown(1);
 192   }
 193 */
 194   sigtest = signal(SIGURG, sighandler);
 195   if (sigtest == SIG_ERR)
 196   {
 197     logger->log("Core", Log::EMERG, "Could not set up signal handler for SIGURG. Aborting.");
 198     shutdown(1);
 199   }
 200
 201   logger->log("Core", Log::INFO, "Signal handlers set up successfully");
 202
 203
 204   // Init modules ----------------------------------------------------------------------------------------------------
 205   int success;
 206
 207   success = remote->init("/dev/rawir");
 208   if (success)
 209   {
 210     logger->log("Core", Log::INFO, "Remote module initialised");
 211   }
 212   else
 213   {
 214     logger->log("Core", Log::EMERG, "Remote module failed to initialise");
 215     shutdown(1);
 216   }
 217
 218   success = led->init(((RemoteMVP*)remote)->getDevice());
 219   if (success)
 220   {
 221     logger->log("Core", Log::INFO, "LED module initialised");
 222   }
 223   else
 224   {
 225     logger->log("Core", Log::EMERG, "LED module failed to initialise");
 226     shutdown(1);
 227   }
 228
 229   success = mtd->init();
 230   if (success)
 231   {
 232     logger->log("Core", Log::INFO, "Mtd module initialised");
 233   }
 234   else
 235   {
 236     logger->log("Core", Log::EMERG, "Mtd module failed to initialise");
 237     shutdown(1);
 238   }
 239
 240   success = timers->init();
 241   if (success)
 242   {
 243     logger->log("Core", Log::INFO, "Timers module initialised");
 244   }
 245   else
 246   {
 247     logger->log("Core", Log::EMERG, "Timers module failed to initialise");
 248     shutdown(1);
 249   }
 250
 251   UCHAR videoFormat = (UCHAR)mtd->getPALorNTSC();
 252   if      (videoFormat == Video::PAL)  logger->log("Core", Log::INFO, "Read from MTD: PAL 720x576");
 253   else if (videoFormat == Video::NTSC) logger->log("Core", Log::INFO, "Read from MTD: NTSC 720x480");
 254   else                                 logger->log("Core", Log::INFO, "No help from MTD. Assuming NTSC 720x480");
 255
 256   success = video->init(videoFormat);
 257   if (success)
 258   {
 259     logger->log("Core", Log::INFO, "Video module initialised");
 260   }
 261   else
 262   {
 263     logger->log("Core", Log::EMERG, "Video module failed to initialise");
 264     shutdown(1);
 265   }
 266
 267   success = osd->init((void*)("/dev/stbgfx"));
 268   if (success)
 269   {
 270     logger->log("Core", Log::INFO, "OSD module initialised");
 271   }
 272   else
 273   {
 274     logger->log("Core", Log::EMERG, "OSD module failed to initialise");
 275     shutdown(1);
 276   }
 277
 278   success = audio->init(Audio::MPEG2_PES);
 279   if (success)
 280   {
 281     logger->log("Core", Log::INFO, "Audio module initialised");
 282   }
 283   else
 284   {
 285     logger->log("Core", Log::EMERG, "Audio module failed to initialise");
 286     shutdown(1);
 287   }
 288
 289   success = vdr->init(3024);
 290   if (success)
 291   {
 292     logger->log("Core", Log::INFO, "VDR module initialised");
 293   }
 294   else
 295   {
 296     logger->log("Core", Log::EMERG, "VDR module failed to initialise");
 297     shutdown(1);
 298   }
 299
 300   success = boxstack->init();
 301   if (success)
 302   {
 303     logger->log("Core", Log::INFO, "BoxStack module initialised");
 304   }
 305   else
 306   {
 307     logger->log("Core", Log::EMERG, "BoxStack module failed to initialise");
 308     shutdown(1);
 309   }
 310
 311   success = command->init(crashed, setServer);
 312   if (success)
 313   {
 314     logger->log("Core", Log::INFO, "Command module initialised");
 315   }
 316   else
 317   {
 318     logger->log("Core", Log::EMERG, "Command module failed to initialise");
 319     shutdown(1);
 320   }
 321
 322   // Other init ------------------------------------------------------------------------------------------------------
 323
 324   logger->log("Core", Log::NOTICE, "Startup successful");
 325
 326   // Run main loop ---------------------------------------------------------------------------------------------------
 327
 328   // Ok, all major device components and other bits are loaded and ready
 329   command->run();
 330
 331   // When that returns quit ------------------------------------------------------------------------------------------
 332
 333   shutdown(0);
 334   return 0;
 335 }
 336
 337 // -------------------------------------------------------------------------------------------------------------------
 338
 339 void sighandler(int signalReceived)
 340 {
 341   logger->log("Core", Log::NOTICE, "Signal %i received", signalReceived);
 342
 343   switch (signalReceived)
 344   {
 345     case SIGINT:
 346     {
 347       logger->log("Core", Log::NOTICE, "Interrupt signal, shutting down...");
 348       command->stop(); // FIXME this is probably not safe - use the messaging system / is that even safe?
 349       break;
 350     }
 351     case SIGTERM:
 352     {
 353       logger->log("Core", Log::NOTICE, "Term signal, shutting down...");
 354       command->stop(); // FIXME this is probably not safe - use the messaging system / is that even safe?
 355       break;
 356     }
 357     case SIGUSR1:
 358     {
 359       command->sig1();
 360       break;
 361     }
 362 /*
 363     case SIGUSR1:
 364     {
 365       logger->log("Core", Log::DEBUG, "SIGUSR1 caught");
 366       logger->upLogLevel();
 367       break;
 368     }
 369     case SIGUSR2:
 370     {
 371       logger->log("Core", Log::DEBUG, "SIGUSR2 caught");
 372       logger->downLogLevel();
 373       break;
 374     }
 375 */
 376     case SIGURG:
 377     {
 378       logger->log("Core", Log::DEBUG, "SIGURG caught");
 379       break;
 380     }
 381   }
 382 }
 383 #endif
 384
 385 // -------------------------------------------------------------------------------------------------------------------
 386
 387 void shutdown(int code)
 388 {
 389   if (boxstack)
 390   {
 391     boxstack->shutdown();
 392     delete boxstack;
 393     logger->log("Core", Log::NOTICE, "BoxStack module shut down");
 394   }
 395
 396   // FIXME, send a del all to boxstack first, then get rid of it after command?
 397   if (command) // shut down command here in case views have posted messages
 398   {
 399     command->shutdown();
 400     delete command;
 401     logger->log("Core", Log::NOTICE, "Command module shut down");
 402   }
 403
 404   if (vdr)
 405   {
 406     vdr->shutdown();
 407     delete vdr;
 408     logger->log("Core", Log::NOTICE, "VDR module shut down");
 409   }
 410
 411   if (osd)
 412   {
 413     osd->shutdown();
 414     delete osd;
 415     logger->log("Core", Log::NOTICE, "OSD module shut down");
 416   }
 417
 418   if (audio)
 419   {
 420     audio->shutdown();
 421     delete audio;
 422     logger->log("Core", Log::NOTICE, "Audio module shut down");
 423   }
 424
 425   if (video)
 426   {
 427     video->shutdown();
 428     delete video;
 429     logger->log("Core", Log::NOTICE, "Video module shut down");
 430   }
 431
 432   if (timers)
 433   {
 434     timers->shutdown();
 435     delete timers;
 436     logger->log("Core", Log::NOTICE, "Timers module shut down");
 437   }
 438
 439   if (mtd)
 440   {
 441     mtd->shutdown();
 442     delete mtd;
 443     logger->log("Core", Log::NOTICE, "MTD module shut down");
 444   }
 445
 446   if (led)
 447   {
 448     led->shutdown();
 449     delete led;
 450     logger->log("Core", Log::NOTICE, "LED module shut down");
 451   }
 452
 453   if (remote)
 454   {
 455     remote->shutdown();
 456     delete remote;
 457     logger->log("Core", Log::NOTICE, "Remote module shut down");
 458   }
 459
 460   if (wol)
 461   {
 462     delete wol;
 463     logger->log("Core", Log::NOTICE, "WOL module shut down");
 464   }
 465
 466   if (logger)
 467   {
 468     logger->log("Core", Log::NOTICE, "Log module shutting down... bye!\n\n");
 469     logger->shutdown();
 470     delete logger;
 471   }
 472
 473   exit(code);
 474 }
 475
 476 // -------------------------------------------------------------------------------------------------------------------
 477
 478 ULLONG ntohll(ULLONG a)
 479 {
 480   return htonll(a);
 481 }
 482
 483 ULLONG htonll(ULLONG a)
 484 {
 485   #if BYTE_ORDER == BIG_ENDIAN
 486     return a;
 487   #else
 488     ULLONG b = 0;
 489
 490     b = ((a << 56) & 0xFF00000000000000ULL)
 491       | ((a << 40) & 0x00FF000000000000ULL)
 492       | ((a << 24) & 0x0000FF0000000000ULL)
 493       | ((a <<  8) & 0x000000FF00000000ULL)
 494       | ((a >>  8) & 0x00000000FF000000ULL)
 495       | ((a >> 24) & 0x0000000000FF0000ULL)
 496       | ((a >> 40) & 0x000000000000FF00ULL)
 497       | ((a >> 56) & 0x00000000000000FFULL) ;
 498
 499     return b;
 500   #endif
 501 }
 502
 503 void MILLISLEEP(ULONG a)
 504 {
 505 #ifndef WIN32
 506   struct timespec delayTime;
 507   delayTime.tv_sec = a / 1000;
 508   delayTime.tv_nsec = (a % 1000) * 1000000;
 509   nanosleep(&delayTime, NULL);
 510 #else
 511   Sleep(a);
 512 #endif
 513 }
 514
 515 int max(int a, int b)
 516 {
 517   if (a > b) return a;
 518   else return b;
 519 }