lib/dvb/decoder.cpp

   1 #include <lib/base/ebase.h>
   2 #include <lib/base/eerror.h>
   3 #include <lib/dvb/decoder.h>
   4 #if HAVE_DVB_API_VERSION < 3
   5 #define audioStatus audio_status
   6 #define videoStatus video_status
   7 #define pesType pes_type
   8 #define playState play_state
   9 #define audioStreamSource_t audio_stream_source_t
  10 #define videoStreamSource_t video_stream_source_t
  11 #define streamSource stream_source
  12 #define dmxPesFilterParams dmx_pes_filter_params
  13 #define DMX_PES_VIDEO0 DMX_PES_VIDEO
  14 #define DMX_PES_AUDIO0 DMX_PES_AUDIO
  15 #define DMX_PES_VIDEO1 DMX_PES_VIDEO
  16 #define DMX_PES_AUDIO1 DMX_PES_AUDIO
  17 #include <ost/dmx.h>
  18 #include <ost/video.h>
  19 #include <ost/audio.h>
  20 #else
  21 #include <linux/dvb/audio.h>
  22 #include <linux/dvb/video.h>
  23 #include <linux/dvb/dmx.h>
  24 #endif
  25
  26 #include <unistd.h>
  27 #include <fcntl.h>
  28 #include <sys/ioctl.h>
  29 #include <sys/types.h>
  30 #include <sys/stat.h>
  31 #include <errno.h>
  32
  33         /* these are quite new... */
  34 #ifndef AUDIO_GET_PTS
  35 #define AUDIO_GET_PTS              _IOR('o', 19, __u64)
  36 #define VIDEO_GET_PTS              _IOR('o', 57, __u64)
  37 #endif
  38
  39 DEFINE_REF(eDVBAudio);
  40
  41 eDVBAudio::eDVBAudio(eDVBDemux *demux, int dev)
  42         :m_demux(demux), m_dev(dev)
  43 {
  44         char filename[128];
  45 #if HAVE_DVB_API_VERSION < 3
  46         sprintf(filename, "/dev/dvb/card%d/audio%d", demux->adapter, dev);
  47 #else
  48         sprintf(filename, "/dev/dvb/adapter%d/audio%d", demux->adapter, dev);
  49 #endif
  50         m_fd = ::open(filename, O_RDWR);
  51         if (m_fd < 0)
  52                 eWarning("%s: %m", filename);
  53 #if HAVE_DVB_API_VERSION < 3
  54         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
  55 #else
  56         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
  57 #endif
  58         m_fd_demux = ::open(filename, O_RDWR);
  59         if (m_fd_demux < 0)
  60                 eWarning("%s: %m", filename);
  61 }
  62
  63 #if HAVE_DVB_API_VERSION < 3
  64 int eDVBAudio::setPid(int pid, int type)
  65 {
  66         if ((m_fd < 0) || (m_fd_demux < 0))
  67                 return -1;
  68
  69         int bypass = 0;
  70
  71         switch (type)
  72         {
  73         case aMPEG:
  74                 bypass = 1;
  75                 break;
  76         case aAC3:
  77                 bypass = 0;
  78                 break;
  79                 /*
  80         case aDTS:
  81                 bypass = 2;
  82                 break;
  83                 */
  84         }
  85
  86         if (::ioctl(m_fd, AUDIO_SET_BYPASS_MODE, bypass) < 0)
  87                 eDebug("failed (%m)");
  88
  89         dmx_pes_filter_params pes;
  90
  91         pes.pid      = pid;
  92         pes.input    = DMX_IN_FRONTEND;
  93         pes.output   = DMX_OUT_DECODER;
  94         pes.pes_type = m_dev ? DMX_PES_AUDIO1 : DMX_PES_AUDIO0; /* FIXME */
  95         pes.flags    = 0;
  96         eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - audio - ", pid);
  97         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
  98         {
  99                 eDebug("failed (%m)");
 100                 return -errno;
 101         }
 102         eDebug("ok");
 103
 104         return 0;
 105 }
 106
 107 int eDVBAudio::startPid()
 108 {
 109         eDebugNoNewLine("DEMUX_START - audio - ");
 110         if (::ioctl(m_fd_demux, DMX_START) < 0)
 111         {
 112                 eDebug("failed (%m)");
 113                 return -errno;
 114         }
 115         eDebug("ok");
 116         return 0;
 117 }
 118
 119 int eDVBAudio::start()
 120 {
 121         eDebugNoNewLine("AUDIO_PLAY - ");
 122         if (::ioctl(m_fd, AUDIO_PLAY) < 0)
 123         {
 124                 eDebug("failed (%m)");
 125                 return -errno;
 126         }
 127         eDebug("ok");
 128         return 0;
 129 }
 130
 131 int eDVBAudio::stopPid()
 132 {
 133         eDebugNoNewLine("DEMUX_STOP - audio - ");
 134         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 135         {
 136                 eDebug("failed (%m)");
 137                 return -errno;
 138         }
 139         eDebug("ok");
 140         return 0;
 141 }
 142
 143 int eDVBAudio::setAVSync(int val)
 144 {
 145         eDebugNoNewLine("AUDIO_SET_AV_SYNC - ");
 146         if (::ioctl(m_fd, AUDIO_SET_AV_SYNC, val) < 0)
 147         {
 148                 eDebug("failed (%m)");
 149                 return -errno;
 150         }
 151         eDebug("ok");
 152         return 0;
 153 }
 154 #else
 155 int eDVBAudio::startPid(int pid, int type)
 156 {
 157         if ((m_fd < 0) || (m_fd_demux < 0))
 158                 return -1;
 159         dmx_pes_filter_params pes;
 160
 161         pes.pid      = pid;
 162         pes.input    = DMX_IN_FRONTEND;
 163         pes.output   = DMX_OUT_DECODER;
 164         pes.pes_type = m_dev ? DMX_PES_AUDIO1 : DMX_PES_AUDIO0; /* FIXME */
 165         pes.flags    = 0;
 166         eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - audio - ", pid);
 167         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 168         {
 169                 eDebug("failed (%m)");
 170                 return -errno;
 171         }
 172         eDebug("ok");
 173         eDebugNoNewLine("DEMUX_START - audio - ");
 174         if (::ioctl(m_fd_demux, DMX_START) < 0)
 175         {
 176                 eDebug("failed (%m)");
 177                 return -errno;
 178         }
 179         eDebug("ok");
 180         int bypass = 0;
 181
 182         switch (type)
 183         {
 184         case aMPEG:
 185                 bypass = 1;
 186                 break;
 187         case aAC3:
 188                 bypass = 0;
 189                 break;
 190         case aDTS:
 191                 bypass = 2;
 192                 break;
 193         case aAAC:
 194                 bypass = 8;
 195                 break;
 196         case aAACHE:
 197                 bypass = 9;
 198                 break;
 199         }
 200
 201         eDebugNoNewLine("AUDIO_SET_BYPASS(%d) - ", bypass);
 202         if (::ioctl(m_fd, AUDIO_SET_BYPASS_MODE, bypass) < 0)
 203                 eDebug("failed (%m)");
 204         else
 205                 eDebug("ok");
 206         freeze();  // why freeze here?!? this is a problem when only a pid change is requested... because of the unfreeze logic in Decoder::setState
 207         eDebugNoNewLine("AUDIO_PLAY - ");
 208         if (::ioctl(m_fd, AUDIO_PLAY) < 0)
 209                 eDebug("failed (%m)");
 210         else
 211                 eDebug("ok");
 212         return 0;
 213 }
 214 #endif
 215
 216 void eDVBAudio::stop()
 217 {
 218 #if HAVE_DVB_API_VERSION > 2
 219         flush();
 220 #endif
 221         eDebugNoNewLine("AUDIO_STOP - ");
 222         if (::ioctl(m_fd, AUDIO_STOP) < 0)
 223                 eDebug("failed (%m)");
 224         else
 225                 eDebug("ok");
 226 #if HAVE_DVB_API_VERSION > 2
 227         eDebugNoNewLine("DEMUX_STOP - audio - ");
 228         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 229                 eDebug("failed (%m)");
 230         else
 231                 eDebug("ok");
 232 #endif
 233 }
 234
 235 void eDVBAudio::flush()
 236 {
 237         eDebugNoNewLine("AUDIO_CLEAR_BUFFER - ");
 238         if (::ioctl(m_fd, AUDIO_CLEAR_BUFFER) < 0)
 239                 eDebug("failed (%m)");
 240         else
 241                 eDebug("ok");
 242 }
 243
 244 void eDVBAudio::freeze()
 245 {
 246         eDebugNoNewLine("AUDIO_PAUSE - ");
 247         if (::ioctl(m_fd, AUDIO_PAUSE) < 0)
 248                 eDebug("failed (%m)");
 249         else
 250                 eDebug("ok");
 251 }
 252
 253 void eDVBAudio::unfreeze()
 254 {
 255         eDebugNoNewLine("AUDIO_CONTINUE - ");
 256         if (::ioctl(m_fd, AUDIO_CONTINUE) < 0)
 257                 eDebug("failed (%m)");
 258         else
 259                 eDebug("ok");
 260 }
 261
 262 void eDVBAudio::setChannel(int channel)
 263 {
 264         int val = AUDIO_STEREO;
 265         switch (channel)
 266         {
 267         case aMonoLeft: val = AUDIO_MONO_LEFT; break;
 268         case aMonoRight: val = AUDIO_MONO_RIGHT; break;
 269         default: break;
 270         }
 271         eDebugNoNewLine("AUDIO_CHANNEL_SELECT(%d) - ", val);
 272         if (::ioctl(m_fd, AUDIO_CHANNEL_SELECT, val) < 0)
 273                 eDebug("failed (%m)");
 274         else
 275                 eDebug("ok");
 276 }
 277
 278 int eDVBAudio::getPTS(pts_t &now)
 279 {
 280         if (::ioctl(m_fd, AUDIO_GET_PTS, &now) < 0)
 281                 eDebug("AUDIO_GET_PTS failed (%m)");
 282         return 0;
 283 }
 284
 285 eDVBAudio::~eDVBAudio()
 286 {
 287         unfreeze();  // why unfreeze here... but not unfreeze video in ~eDVBVideo ?!?
 288         if (m_fd >= 0)
 289                 ::close(m_fd);
 290         if (m_fd_demux >= 0)
 291                 ::close(m_fd_demux);
 292 }
 293
 294 DEFINE_REF(eDVBVideo);
 295
 296 eDVBVideo::eDVBVideo(eDVBDemux *demux, int dev)
 297         : m_demux(demux), m_dev(dev),
 298         m_width(-1), m_height(-1), m_framerate(-1), m_aspect(-1), m_progressive(-1)
 299 {
 300         char filename[128];
 301 #if HAVE_DVB_API_VERSION < 3
 302         sprintf(filename, "/dev/dvb/card%d/video%d", demux->adapter, dev);
 303         m_fd_video = ::open("/dev/video", O_RDWR);
 304         if (m_fd_video < 0)
 305                 eWarning("/dev/video: %m");
 306 #else
 307         sprintf(filename, "/dev/dvb/adapter%d/video%d", demux->adapter, dev);
 308 #endif
 309         m_fd = ::open(filename, O_RDWR);
 310         if (m_fd < 0)
 311                 eWarning("%s: %m", filename);
 312         else
 313         {
 314                 m_sn = eSocketNotifier::create(eApp, m_fd, eSocketNotifier::Priority);
 315                 CONNECT(m_sn->activated, eDVBVideo::video_event);
 316         }
 317         eDebug("Video Device: %s", filename);
 318 #if HAVE_DVB_API_VERSION < 3
 319         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
 320 #else
 321         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
 322 #endif
 323         m_fd_demux = ::open(filename, O_RDWR);
 324         if (m_fd_demux < 0)
 325                 eWarning("%s: %m", filename);
 326         eDebug("demux device: %s", filename);
 327 }
 328
 329 // not finally values i think.. !!
 330 #define VIDEO_STREAMTYPE_MPEG2 0
 331 #define VIDEO_STREAMTYPE_MPEG4_H264 1
 332 #define VIDEO_STREAMTYPE_VC1 3
 333 #define VIDEO_STREAMTYPE_MPEG4_Part2 4
 334 #define VIDEO_STREAMTYPE_VC1_SM 5
 335 #define VIDEO_STREAMTYPE_MPEG1 6
 336
 337 #if HAVE_DVB_API_VERSION < 3
 338 int eDVBVideo::setPid(int pid)
 339 {
 340         if ((m_fd < 0) || (m_fd_demux < 0))
 341                 return -1;
 342         dmx_pes_filter_params pes;
 343
 344         pes.pid      = pid;
 345         pes.input    = DMX_IN_FRONTEND;
 346         pes.output   = DMX_OUT_DECODER;
 347         pes.pes_type = m_dev ? DMX_PES_VIDEO1 : DMX_PES_VIDEO0; /* FIXME */
 348         pes.flags    = 0;
 349         eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - video - ", pid);
 350         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 351         {
 352                 eDebug("failed (%m)");
 353                 return -errno;
 354         }
 355         eDebug("ok");
 356         return 0;
 357 }
 358
 359 int eDVBVideo::startPid()
 360 {
 361         eDebugNoNewLine("DEMUX_START - video - ");
 362         if (::ioctl(m_fd_demux, DMX_START) < 0)
 363         {
 364                 eDebug("failed (%m)");
 365                 return -errno;
 366         }
 367         eDebug("ok");
 368         return 0;
 369 }
 370
 371 int eDVBVideo::start()
 372 {
 373         eDebugNoNewLine("VIDEO_PLAY - ");
 374         if (::ioctl(m_fd, VIDEO_PLAY) < 0)
 375         {
 376                 eDebug("failed (%m)");
 377                 return -errno;
 378         }
 379         eDebug("ok");
 380         return 0;
 381 }
 382
 383 int eDVBVideo::stopPid()
 384 {
 385         eDebugNoNewLine("DEMUX_STOP - video - ");
 386         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 387         {
 388                 eDebug("failed (%m)");
 389                 return -errno;
 390         }
 391         eDebug("ok");
 392         return 0;
 393 }
 394 #else
 395 int eDVBVideo::startPid(int pid, int type)
 396 {
 397         int streamtype = VIDEO_STREAMTYPE_MPEG2;
 398
 399         if ((m_fd < 0) || (m_fd_demux < 0))
 400                 return -1;
 401         dmx_pes_filter_params pes;
 402
 403         switch(type)
 404         {
 405         default:
 406         case MPEG2:
 407                 break;
 408         case MPEG4_H264:
 409                 streamtype = VIDEO_STREAMTYPE_MPEG4_H264;
 410                 break;
 411         case MPEG1:
 412                 streamtype = VIDEO_STREAMTYPE_MPEG1;
 413                 break;
 414         case MPEG4_Part2:
 415                 streamtype = VIDEO_STREAMTYPE_MPEG4_Part2;
 416                 break;
 417         case VC1:
 418                 streamtype = VIDEO_STREAMTYPE_VC1;
 419                 break;
 420         case VC1_SM:
 421                 streamtype = VIDEO_STREAMTYPE_VC1_SM;
 422                 break;
 423         }
 424
 425         eDebugNoNewLine("VIDEO_SET_STREAMTYPE %d - ", streamtype);
 426         if (::ioctl(m_fd, VIDEO_SET_STREAMTYPE, streamtype) < 0)
 427                 eDebug("failed (%m)");
 428         else
 429                 eDebug("ok");
 430
 431         pes.pid      = pid;
 432         pes.input    = DMX_IN_FRONTEND;
 433         pes.output   = DMX_OUT_DECODER;
 434         pes.pes_type = m_dev ? DMX_PES_VIDEO1 : DMX_PES_VIDEO0; /* FIXME */
 435         pes.flags    = 0;
 436         eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - video - ", pid);
 437         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 438         {
 439                 eDebug("failed (%m)");
 440                 return -errno;
 441         }
 442         eDebug("ok");
 443         eDebugNoNewLine("DEMUX_START - video - ");
 444         if (::ioctl(m_fd_demux, DMX_START) < 0)
 445         {
 446                 eDebug("failed (%m)");
 447                 return -errno;
 448         }
 449         eDebug("ok");
 450         freeze();  // why freeze here?!? this is a problem when only a pid change is requested... because of the unfreeze logic in Decoder::setState
 451         eDebugNoNewLine("VIDEO_PLAY - ");
 452         if (::ioctl(m_fd, VIDEO_PLAY) < 0)
 453                 eDebug("failed (%m)");
 454         else
 455                 eDebug("ok");
 456         return 0;
 457 }
 458 #endif
 459
 460 void eDVBVideo::stop()
 461 {
 462 #if HAVE_DVB_API_VERSION > 2
 463         eDebugNoNewLine("DEMUX_STOP - video - ");
 464         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 465                 eDebug("failed (%m)");
 466         else
 467                 eDebug("ok");
 468 #endif
 469         eDebugNoNewLine("VIDEO_STOP - ");
 470         if (::ioctl(m_fd, VIDEO_STOP, 1) < 0)
 471                 eDebug("failed (%m)");
 472         else
 473                 eDebug("ok");
 474 }
 475
 476 void eDVBVideo::flush()
 477 {
 478         eDebugNoNewLine("VIDEO_CLEAR_BUFFER - ");
 479         if (::ioctl(m_fd, VIDEO_CLEAR_BUFFER) < 0)
 480                 eDebug("failed (%m)");
 481         else
 482                 eDebug("ok");
 483 }
 484
 485 void eDVBVideo::freeze()
 486 {
 487         eDebugNoNewLine("VIDEO_FREEZE - ");
 488         if (::ioctl(m_fd, VIDEO_FREEZE) < 0)
 489                 eDebug("failed (%m)");
 490         else
 491                 eDebug("ok");
 492 }
 493
 494 void eDVBVideo::unfreeze()
 495 {
 496         eDebugNoNewLine("VIDEO_CONTINUE - ");
 497         if (::ioctl(m_fd, VIDEO_CONTINUE) < 0)
 498                 eDebug("failed (%m)");
 499         else
 500                 eDebug("ok");
 501 }
 502
 503 int eDVBVideo::setSlowMotion(int repeat)
 504 {
 505         eDebugNoNewLine("VIDEO_SLOWMOTION(%d) - ", repeat);
 506         int ret = ::ioctl(m_fd, VIDEO_SLOWMOTION, repeat);
 507         if (ret < 0)
 508                 eDebug("failed(%m)");
 509         else
 510                 eDebug("ok");
 511         return ret;
 512 }
 513
 514 int eDVBVideo::setFastForward(int skip)
 515 {
 516         eDebugNoNewLine("VIDEO_FAST_FORWARD(%d) - ", skip);
 517         int ret = ::ioctl(m_fd, VIDEO_FAST_FORWARD, skip);
 518         if (ret < 0)
 519                 eDebug("failed(%m)");
 520         else
 521                 eDebug("ok");
 522         return ret;
 523 }
 524
 525 int eDVBVideo::getPTS(pts_t &now)
 526 {
 527 #if HAVE_DVB_API_VERSION < 3
 528         #define VIDEO_GET_PTS_OLD           _IOR('o', 1, unsigned int*)
 529         unsigned int pts;
 530         int ret = ::ioctl(m_fd_video, VIDEO_GET_PTS_OLD, &pts);
 531         now = pts;
 532         now *= 2;
 533 #else
 534         int ret = ::ioctl(m_fd, VIDEO_GET_PTS, &now);
 535 #endif
 536         if (ret < 0)
 537                 eDebug("VIDEO_GET_PTS failed(%m)");
 538         return ret;
 539 }
 540
 541 eDVBVideo::~eDVBVideo()
 542 {
 543         if (m_fd >= 0)
 544                 ::close(m_fd);
 545         if (m_fd_demux >= 0)
 546                 ::close(m_fd_demux);
 547 #if HAVE_DVB_API_VERSION < 3
 548         if (m_fd_video >= 0)
 549                 ::close(m_fd_video);
 550 #endif
 551 }
 552
 553 void eDVBVideo::video_event(int)
 554 {
 555 #if HAVE_DVB_API_VERSION >= 3
 556         struct video_event evt;
 557         eDebugNoNewLine("VIDEO_GET_EVENT - ");
 558         if (::ioctl(m_fd, VIDEO_GET_EVENT, &evt) < 0)
 559                 eDebug("failed (%m)");
 560         else
 561         {
 562                 eDebug("ok");
 563                 if (evt.type == VIDEO_EVENT_SIZE_CHANGED)
 564                 {
 565                         struct iTSMPEGDecoder::videoEvent event;
 566                         event.type = iTSMPEGDecoder::videoEvent::eventSizeChanged;
 567                         m_aspect = event.aspect = evt.u.size.aspect_ratio == 0 ? 2 : 3;  // convert dvb api to etsi
 568                         m_height = event.height = evt.u.size.h;
 569                         m_width = event.width = evt.u.size.w;
 570                         /* emit */ m_event(event);
 571                 }
 572                 else if (evt.type == VIDEO_EVENT_FRAME_RATE_CHANGED)
 573                 {
 574                         struct iTSMPEGDecoder::videoEvent event;
 575                         event.type = iTSMPEGDecoder::videoEvent::eventFrameRateChanged;
 576                         m_framerate = event.framerate = evt.u.frame_rate;
 577                         /* emit */ m_event(event);
 578                 }
 579                 else if (evt.type == 16 /*VIDEO_EVENT_PROGRESSIVE_CHANGED*/)
 580                 {
 581                         struct iTSMPEGDecoder::videoEvent event;
 582                         event.type = iTSMPEGDecoder::videoEvent::eventProgressiveChanged;
 583                         m_progressive = event.progressive = evt.u.frame_rate;
 584                         /* emit */ m_event(event);
 585                 }
 586                 else
 587                         eDebug("unhandled DVBAPI Video Event %d", evt.type);
 588         }
 589 #else
 590 #warning "FIXMEE!! Video Events not implemented for old api"
 591 #endif
 592 }
 593
 594 RESULT eDVBVideo::connectEvent(const Slot1<void, struct iTSMPEGDecoder::videoEvent> &event, ePtr<eConnection> &conn)
 595 {
 596         conn = new eConnection(this, m_event.connect(event));
 597         return 0;
 598 }
 599
 600 static int readMpegProc(char *str, int decoder)
 601 {
 602         int val = -1;
 603         char tmp[64];
 604         sprintf(tmp, "/proc/stb/vmpeg/%d/%s", decoder, str);
 605         FILE *f = fopen(tmp, "r");
 606         if (f)
 607         {
 608                 fscanf(f, "%x", &val);
 609                 fclose(f);
 610         }
 611         return val;
 612 }
 613
 614 static int readApiSize(int fd, int &xres, int &yres, int &aspect)
 615 {
 616 #if HAVE_DVB_API_VERSION >= 3
 617         video_size_t size;
 618         if (!::ioctl(fd, VIDEO_GET_SIZE, &size))
 619         {
 620                 xres = size.w;
 621                 yres = size.h;
 622                 aspect = size.aspect_ratio == 0 ? 2 : 3;  // convert dvb api to etsi
 623                 return 0;
 624         }
 625 //      eDebug("VIDEO_GET_SIZE failed (%m)");
 626 #endif
 627         return -1;
 628 }
 629
 630 static int readApiFrameRate(int fd, int &framerate)
 631 {
 632 #if HAVE_DVB_API_VERSION >= 3
 633         unsigned int frate;
 634         if (!::ioctl(fd, VIDEO_GET_FRAME_RATE, &frate))
 635         {
 636                 framerate = frate;
 637                 return 0;
 638         }
 639 //      eDebug("VIDEO_GET_FRAME_RATE failed (%m)");
 640 #endif
 641         return -1;
 642 }
 643
 644 int eDVBVideo::getWidth()
 645 {
 646         if (m_width == -1)
 647                 readApiSize(m_fd, m_width, m_height, m_aspect);
 648         if (m_width == -1)
 649                 m_width = readMpegProc("xres", m_dev);
 650         return m_width;
 651 }
 652
 653 int eDVBVideo::getHeight()
 654 {
 655         if (m_height == -1)
 656                 readApiSize(m_fd, m_width, m_height, m_aspect);
 657         if (m_height == -1)
 658                 m_height = readMpegProc("yres", m_dev);
 659         return m_height;
 660 }
 661
 662 int eDVBVideo::getAspect()
 663 {
 664         if (m_aspect == -1)
 665                 readApiSize(m_fd, m_width, m_height, m_aspect);
 666         if (m_aspect == -1)
 667                 m_aspect = readMpegProc("aspect", m_dev);
 668         return m_aspect;
 669 }
 670
 671 int eDVBVideo::getProgressive()
 672 {
 673         if (m_progressive == -1)
 674                 m_progressive = readMpegProc("progressive", m_dev);
 675         return m_progressive;
 676 }
 677
 678 int eDVBVideo::getFrameRate()
 679 {
 680         if (m_framerate == -1)
 681                 readApiFrameRate(m_fd, m_framerate);
 682         if (m_framerate == -1)
 683                 m_framerate = readMpegProc("framerate", m_dev);
 684         return m_framerate;
 685 }
 686
 687 DEFINE_REF(eDVBPCR);
 688
 689 eDVBPCR::eDVBPCR(eDVBDemux *demux): m_demux(demux)
 690 {
 691         char filename[128];
 692 #if HAVE_DVB_API_VERSION < 3
 693         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
 694 #else
 695         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
 696 #endif
 697         m_fd_demux = ::open(filename, O_RDWR);
 698         if (m_fd_demux < 0)
 699                 eWarning("%s: %m", filename);
 700 }
 701
 702 #if HAVE_DVB_API_VERSION < 3
 703 int eDVBPCR::setPid(int pid)
 704 {
 705         if (m_fd_demux < 0)
 706                 return -1;
 707         dmx_pes_filter_params pes;
 708
 709         pes.pid      = pid;
 710         pes.input    = DMX_IN_FRONTEND;
 711         pes.output   = DMX_OUT_DECODER;
 712         pes.pes_type = DMX_PES_PCR;
 713         pes.flags    = 0;
 714
 715         eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - pcr - ", pid);
 716         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 717         {
 718                 eDebug("failed (%m)");
 719                 return -errno;
 720         }
 721         eDebug("ok");
 722         return 0;
 723 }
 724
 725 int eDVBPCR::startPid()
 726 {
 727         if (m_fd_demux < 0)
 728                 return -1;
 729         eDebugNoNewLine("DEMUX_START - pcr - ");
 730         if (::ioctl(m_fd_demux, DMX_START) < 0)
 731         {
 732                 eDebug("failed (%m)");
 733                 return -errno;
 734         }
 735         eDebug("ok");
 736         return 0;
 737 }
 738 #else
 739 int eDVBPCR::startPid(int pid)
 740 {
 741         if (m_fd_demux < 0)
 742                 return -1;
 743         dmx_pes_filter_params pes;
 744
 745         pes.pid      = pid;
 746         pes.input    = DMX_IN_FRONTEND;
 747         pes.output   = DMX_OUT_DECODER;
 748         pes.pes_type = DMX_PES_PCR;
 749         pes.flags    = 0;
 750         eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - pcr - ", pid);
 751         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 752         {
 753                 eDebug("failed (%m)");
 754                 return -errno;
 755         }
 756         eDebug("ok");
 757         eDebugNoNewLine("DEMUX_START - pcr - ");
 758         if (::ioctl(m_fd_demux, DMX_START) < 0)
 759         {
 760                 eDebug("failed (%m)");
 761                 return -errno;
 762         }
 763         eDebug("ok");
 764         return 0;
 765 }
 766 #endif
 767
 768 void eDVBPCR::stop()
 769 {
 770         eDebugNoNewLine("DEMUX_STOP - pcr - ");
 771         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 772                 eDebug("failed(%m)");
 773         else
 774                 eDebug("ok");
 775 }
 776
 777 eDVBPCR::~eDVBPCR()
 778 {
 779         if (m_fd_demux >= 0)
 780                 ::close(m_fd_demux);
 781 }
 782
 783 DEFINE_REF(eDVBTText);
 784
 785 eDVBTText::eDVBTText(eDVBDemux *demux): m_demux(demux)
 786 {
 787         char filename[128];
 788 #if HAVE_DVB_API_VERSION < 3
 789         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
 790 #else
 791         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
 792 #endif
 793         m_fd_demux = ::open(filename, O_RDWR);
 794         if (m_fd_demux < 0)
 795                 eWarning("%s: %m", filename);
 796 }
 797
 798 int eDVBTText::startPid(int pid)
 799 {
 800         if (m_fd_demux < 0)
 801                 return -1;
 802         dmx_pes_filter_params pes;
 803
 804         pes.pid      = pid;
 805         pes.input    = DMX_IN_FRONTEND;
 806         pes.output   = DMX_OUT_DECODER;
 807         pes.pes_type = DMX_PES_TELETEXT;
 808         pes.flags    = 0;
 809
 810         eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - ttx - ", pid);
 811         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 812         {
 813                 eDebug("failed(%m)");
 814                 return -errno;
 815         }
 816         eDebug("ok");
 817         eDebugNoNewLine("DEMUX_START - ttx - ");
 818         if (::ioctl(m_fd_demux, DMX_START) < 0)
 819         {
 820                 eDebug("failed(%m)");
 821                 return -errno;
 822         }
 823         eDebug("ok");
 824         return 0;
 825 }
 826
 827 void eDVBTText::stop()
 828 {
 829         eDebugNoNewLine("DEMUX_STOP - ttx - ");
 830         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 831                 eDebug("failed(%m)");
 832         else
 833                 eDebug("ok");
 834 }
 835
 836 eDVBTText::~eDVBTText()
 837 {
 838         if (m_fd_demux >= 0)
 839                 ::close(m_fd_demux);
 840 }
 841
 842 DEFINE_REF(eTSMPEGDecoder);
 843
 844 int eTSMPEGDecoder::setState()
 845 {
 846         int res = 0;
 847
 848         int noaudio = (m_state != statePlay) && (m_state != statePause);
 849         int nott = noaudio; /* actually same conditions */
 850
 851         if ((noaudio && m_audio) || (!m_audio && !noaudio))
 852                 m_changed |= changeAudio | changeState;
 853
 854         if ((nott && m_text) || (!m_text && !nott))
 855                 m_changed |= changeText | changeState;
 856
 857         const char *decoder_states[] = {"stop", "pause", "play", "decoderfastforward", "trickmode", "slowmotion"};
 858         eDebug("decoder state: %s, vpid=%d, apid=%d", decoder_states[m_state], m_vpid, m_apid);
 859
 860         bool changed = !!m_changed;
 861 #if HAVE_DVB_API_VERSION < 3
 862         bool checkAVSync = m_changed & (changeAudio|changeVideo|changePCR);
 863         if (m_changed & changeAudio && m_audio)
 864                 m_audio->stopPid();
 865         if (m_changed & changeVideo && m_video)
 866                 m_video->stopPid();
 867         if (m_changed & changePCR && m_pcr)
 868         {
 869                 m_pcr->stop();
 870                 m_pcr=0;
 871                 if (!(m_pcrpid >= 0 && m_pcrpid < 0x1ff))
 872                         m_changed &= ~changePCR;
 873         }
 874         if (m_changed & changeAudio && m_audio)
 875         {
 876                 m_audio->stop();
 877                 m_audio=0;
 878                 if (!(m_apid >= 0 && m_apid < 0x1ff))
 879                         m_changed &= ~changeAudio;
 880         }
 881         if (m_changed & changeVideo && m_video)
 882         {
 883                 m_video->stop();
 884                 m_video=0;
 885                 m_video_event_conn=0;
 886                 if (!(m_vpid >= 0 && m_vpid < 0x1ff))
 887                         m_changed &= ~changeVideo;
 888         }
 889         if (m_changed & changeVideo)
 890         {
 891                 m_video = new eDVBVideo(m_demux, m_decoder);
 892                 m_video->connectEvent(slot(*this, &eTSMPEGDecoder::video_event), m_video_event_conn);
 893                 if (m_video->setPid(m_vpid))
 894                         res -1;
 895         }
 896         if (m_changed & changePCR)
 897         {
 898                 m_pcr = new eDVBPCR(m_demux);
 899                 if (m_pcr->setPid(m_pcrpid))
 900                         res = -1;
 901         }
 902         if (m_changed & changeAudio)
 903         {
 904                 m_audio = new eDVBAudio(m_demux, m_decoder);
 905                 if (m_audio->setPid(m_apid, m_atype))
 906                         res = -1;
 907         }
 908         if (m_changed & changePCR)
 909         {
 910                 if (m_pcr->startPid())
 911                         res = -1;
 912                 m_changed &= ~changePCR;
 913         }
 914         else if (checkAVSync && m_audio && m_video)
 915         {
 916                 if (m_audio->setAVSync(1))
 917                         res = -1;
 918         }
 919         if (m_changed & changeVideo)
 920         {
 921                 if (m_video->startPid() || m_video->start())
 922                         res = -1;
 923                 m_changed &= ~changeVideo;
 924         }
 925         if (m_changed & changeAudio)
 926         {
 927                 if (m_audio->start() || m_audio->startPid())
 928                         res = -1;
 929                 m_changed &= ~changeAudio;
 930         }
 931 #else
 932         if (m_changed & changePCR)
 933         {
 934                 if (m_pcr)
 935                         m_pcr->stop();
 936                 m_pcr = 0;
 937         }
 938         if (m_changed & changeVideo)
 939         {
 940                 if (m_video)
 941                 {
 942                         m_video->stop();
 943                         m_video = 0;
 944                         m_video_event_conn = 0;
 945                 }
 946         }
 947         if (m_changed & changeAudio)
 948         {
 949                 if (m_audio)
 950                         m_audio->stop();
 951                 m_audio = 0;
 952         }
 953         if (m_changed & changeText)
 954         {
 955                 if (m_text)
 956                         m_text->stop();
 957                 m_text = 0;
 958         }
 959         if (m_changed & changePCR)
 960         {
 961                 if ((m_pcrpid >= 0) && (m_pcrpid < 0x1FFF))
 962                 {
 963                         m_pcr = new eDVBPCR(m_demux);
 964                         if (m_pcr->startPid(m_pcrpid))
 965                                 res = -1;
 966                 }
 967                 m_changed &= ~changePCR;
 968         }
 969         if (m_changed & changeAudio)
 970         {
 971                 if ((m_apid >= 0) && (m_apid < 0x1FFF) && !noaudio)
 972                 {
 973                         m_audio = new eDVBAudio(m_demux, m_decoder);
 974                         if (m_audio->startPid(m_apid, m_atype))
 975                                 res = -1;
 976                 }
 977                 m_changed &= ~changeAudio;
 978         }
 979         if (m_changed & changeVideo)
 980         {
 981                 if ((m_vpid >= 0) && (m_vpid < 0x1FFF))
 982                 {
 983                         m_video = new eDVBVideo(m_demux, m_decoder);
 984                         m_video->connectEvent(slot(*this, &eTSMPEGDecoder::video_event), m_video_event_conn);
 985                         if (m_video->startPid(m_vpid, m_vtype))
 986                                 res = -1;
 987                 }
 988                 m_changed &= ~changeVideo;
 989         }
 990         if (m_changed & changeText)
 991         {
 992                 if ((m_textpid >= 0) && (m_textpid < 0x1FFF) && !nott)
 993                 {
 994                         m_text = new eDVBTText(m_demux);
 995                         if (m_text->startPid(m_textpid))
 996                                 res = -1;
 997                 }
 998                 m_changed &= ~changeText;
 999         }
1000 #endif
1001
1002         if (m_changed & changeState)
1003         {
1004                                         /* play, slowmotion, fast-forward */
1005                 int state_table[6][4] =
1006                         {
1007                                 /* [stateStop] =                 */ {0, 0, 0},
1008                                 /* [statePause] =                */ {0, 0, 0},
1009                                 /* [statePlay] =                 */ {1, 0, 0},
1010                                 /* [stateDecoderFastForward] =   */ {1, 0, m_ff_sm_ratio},
1011                                 /* [stateHighspeedFastForward] = */ {1, 0, 1},
1012                                 /* [stateSlowMotion] =           */ {1, m_ff_sm_ratio, 0}
1013                         };
1014                 int *s = state_table[m_state];
1015                 if (m_video)
1016                 {
1017                         m_video->setSlowMotion(s[1]);
1018                         m_video->setFastForward(s[2]);
1019                         if (s[0])
1020                                 m_video->unfreeze();
1021                         else
1022                                 m_video->freeze();
1023                 }
1024                 if (m_audio)
1025                 {
1026                         if (s[0])
1027                                 m_audio->unfreeze();
1028                         else
1029                                 m_audio->freeze();
1030                 }
1031                 m_changed &= ~changeState;
1032         }
1033
1034         if (changed && !m_video && m_audio && m_radio_pic.length())
1035                 showSinglePic(m_radio_pic.c_str());
1036
1037         return res;
1038 }
1039
1040 int eTSMPEGDecoder::m_pcm_delay=-1,
1041         eTSMPEGDecoder::m_ac3_delay=-1;
1042
1043 RESULT eTSMPEGDecoder::setPCMDelay(int delay)
1044 {
1045         if (m_decoder == 0 && delay != m_pcm_delay )
1046         {
1047                 FILE *fp = fopen("/proc/stb/audio/audio_delay_pcm", "w");
1048                 if (fp)
1049                 {
1050                         fprintf(fp, "%x", delay*90);
1051                         fclose(fp);
1052                         m_pcm_delay = delay;
1053                         return 0;
1054                 }
1055         }
1056         return -1;
1057 }
1058
1059 RESULT eTSMPEGDecoder::setAC3Delay(int delay)
1060 {
1061         if ( m_decoder == 0 && delay != m_ac3_delay )
1062         {
1063                 FILE *fp = fopen("/proc/stb/audio/audio_delay_bitstream", "w");
1064                 if (fp)
1065                 {
1066                         fprintf(fp, "%x", delay*90);
1067                         fclose(fp);
1068                         m_ac3_delay = delay;
1069                         return 0;
1070                 }
1071         }
1072         return -1;
1073 }
1074
1075 eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder)
1076         : m_demux(demux),
1077                 m_vpid(-1), m_vtype(-1), m_apid(-1), m_atype(-1), m_pcrpid(-1), m_textpid(-1),
1078                 m_changed(0), m_decoder(decoder), m_video_clip_fd(-1), m_showSinglePicTimer(eTimer::create(eApp))
1079 {
1080         demux->connectEvent(slot(*this, &eTSMPEGDecoder::demux_event), m_demux_event_conn);
1081         CONNECT(m_showSinglePicTimer->timeout, eTSMPEGDecoder::finishShowSinglePic);
1082         m_state = stateStop;
1083 }
1084
1085 eTSMPEGDecoder::~eTSMPEGDecoder()
1086 {
1087         finishShowSinglePic();
1088         m_vpid = m_apid = m_pcrpid = m_textpid = pidNone;
1089         m_changed = -1;
1090         setState();
1091 }
1092
1093 RESULT eTSMPEGDecoder::setVideoPID(int vpid, int type)
1094 {
1095         if ((m_vpid != vpid) || (m_vtype != type))
1096         {
1097                 m_changed |= changeVideo;
1098                 m_vpid = vpid;
1099                 m_vtype = type;
1100         }
1101         return 0;
1102 }
1103
1104 RESULT eTSMPEGDecoder::setAudioPID(int apid, int type)
1105 {
1106         if ((m_apid != apid) || (m_atype != type))
1107         {
1108                 m_changed |= changeAudio;
1109                 m_atype = type;
1110                 m_apid = apid;
1111         }
1112         return 0;
1113 }
1114
1115 int eTSMPEGDecoder::m_audio_channel = -1;
1116
1117 RESULT eTSMPEGDecoder::setAudioChannel(int channel)
1118 {
1119         if (channel == -1)
1120                 channel = ac_stereo;
1121         if (m_decoder == 0 && m_audio_channel != channel)
1122         {
1123                 if (m_audio)
1124                 {
1125                         m_audio->setChannel(channel);
1126                         m_audio_channel=channel;
1127                 }
1128                 else
1129                         eDebug("eTSMPEGDecoder::setAudioChannel but no audio decoder exist");
1130         }
1131         return 0;
1132 }
1133
1134 int eTSMPEGDecoder::getAudioChannel()
1135 {
1136         return m_audio_channel == -1 ? ac_stereo : m_audio_channel;
1137 }
1138
1139 RESULT eTSMPEGDecoder::setSyncPCR(int pcrpid)
1140 {
1141         if (m_pcrpid != pcrpid)
1142         {
1143                 m_changed |= changePCR;
1144                 m_pcrpid = pcrpid;
1145         }
1146         return 0;
1147 }
1148
1149 RESULT eTSMPEGDecoder::setTextPID(int textpid)
1150 {
1151         if (m_textpid != textpid)
1152         {
1153                 m_changed |= changeText;
1154                 m_textpid = textpid;
1155         }
1156         return 0;
1157 }
1158
1159 RESULT eTSMPEGDecoder::setSyncMaster(int who)
1160 {
1161         return -1;
1162 }
1163
1164 RESULT eTSMPEGDecoder::set()
1165 {
1166         return setState();
1167 }
1168
1169 RESULT eTSMPEGDecoder::play()
1170 {
1171         if (m_state == statePlay)
1172         {
1173                 if (!m_changed)
1174                         return 0;
1175         }
1176 //      else
1177 /* commented out because the changeState is needed to unfreeze decoders in decoder::setState... needed by normal pmt changes
1178 tmbinc please recheck this! */
1179         {
1180                 m_state = statePlay;
1181                 m_changed |= changeState;
1182         }
1183         return setState();
1184 }
1185
1186 RESULT eTSMPEGDecoder::pause()
1187 {
1188         if (m_state == statePause)
1189                 return 0;
1190         m_state = statePause;
1191         m_changed |= changeState;
1192         return setState();
1193 }
1194
1195 RESULT eTSMPEGDecoder::setFastForward(int frames_to_skip)
1196 {
1197         if ((m_state == stateDecoderFastForward) && (m_ff_sm_ratio == frames_to_skip))
1198                 return 0;
1199
1200         m_state = stateDecoderFastForward;
1201         m_ff_sm_ratio = frames_to_skip;
1202         m_changed |= changeState;
1203         return setState();
1204
1205 //              return m_video->setFastForward(frames_to_skip);
1206 }
1207
1208 RESULT eTSMPEGDecoder::setSlowMotion(int repeat)
1209 {
1210         if ((m_state == stateSlowMotion) && (m_ff_sm_ratio == repeat))
1211                 return 0;
1212
1213         m_state = stateSlowMotion;
1214         m_ff_sm_ratio = repeat;
1215         m_changed |= changeState;
1216         return setState();
1217 }
1218
1219 RESULT eTSMPEGDecoder::setTrickmode()
1220 {
1221         if (m_state == stateTrickmode)
1222                 return 0;
1223
1224         m_state = stateTrickmode;
1225         m_changed |= changeState;
1226         return setState();
1227 }
1228
1229 RESULT eTSMPEGDecoder::flush()
1230 {
1231         if (m_audio)
1232                 m_audio->flush();
1233         if (m_video)
1234                 m_video->flush();
1235         return 0;
1236 }
1237
1238 void eTSMPEGDecoder::demux_event(int event)
1239 {
1240         switch (event)
1241         {
1242         case eDVBDemux::evtFlush:
1243                 flush();
1244                 break;
1245         default:
1246                 break;
1247         }
1248 }
1249
1250 RESULT eTSMPEGDecoder::getPTS(int what, pts_t &pts)
1251 {
1252         if (what == 0) /* auto */
1253                 what = m_video ? 1 : 2;
1254
1255         if (what == 1) /* video */
1256         {
1257                 if (m_video)
1258                         return m_video->getPTS(pts);
1259                 else
1260                         return -1;
1261         }
1262
1263         if (what == 2) /* audio */
1264         {
1265                 if (m_audio)
1266                         return m_audio->getPTS(pts);
1267                 else
1268                         return -1;
1269         }
1270
1271         return -1;
1272 }
1273
1274 RESULT eTSMPEGDecoder::setRadioPic(const std::string &filename)
1275 {
1276         m_radio_pic = filename;
1277         return 0;
1278 }
1279
1280 RESULT eTSMPEGDecoder::showSinglePic(const char *filename)
1281 {
1282         if (m_decoder == 0)
1283         {
1284                 eDebug("showSinglePic %s", filename);
1285                 int f = open(filename, O_RDONLY);
1286                 if (f >= 0)
1287                 {
1288                         struct stat s;
1289                         fstat(f, &s);
1290                         if (m_video_clip_fd == -1)
1291                                 m_video_clip_fd = open("/dev/dvb/adapter0/video0", O_WRONLY|O_NONBLOCK);
1292                         if (m_video_clip_fd >= 0)
1293                         {
1294                                 bool seq_end_avail = false;
1295                                 size_t pos=0;
1296                                 unsigned char pes_header[] = { 0x00, 0x00, 0x01, 0xE0, 0x00, 0x00, 0x80, 0x00, 0x00 };
1297                                 unsigned char seq_end[] = { 0x00, 0x00, 0x01, 0xB7 };
1298                                 unsigned char iframe[s.st_size];
1299                                 unsigned char stuffing[8192];
1300                                 int streamtype = VIDEO_STREAMTYPE_MPEG2;
1301                                 memset(stuffing, 0, 8192);
1302                                 read(f, iframe, s.st_size);
1303                                 if (ioctl(m_video_clip_fd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_MEMORY) < 0)
1304                                         eDebug("VIDEO_SELECT_SOURCE MEMORY failed (%m)");
1305                                 if (ioctl(m_video_clip_fd, VIDEO_SET_STREAMTYPE, streamtype) < 0)
1306                                         eDebug("VIDEO_SET_STREAMTYPE failed(%m)");
1307                                 if (ioctl(m_video_clip_fd, VIDEO_PLAY) < 0)
1308                                         eDebug("VIDEO_PLAY failed (%m)");
1309                                 if (ioctl(m_video_clip_fd, VIDEO_CONTINUE) < 0)
1310                                         eDebug("video: VIDEO_CONTINUE: %m");
1311                                 if (ioctl(m_video_clip_fd, VIDEO_CLEAR_BUFFER) < 0)
1312                                         eDebug("video: VIDEO_CLEAR_BUFFER: %m");
1313                                 while(pos <= (s.st_size-4) && !(seq_end_avail = (!iframe[pos] && !iframe[pos+1] && iframe[pos+2] == 1 && iframe[pos+3] == 0xB7)))
1314                                         ++pos;
1315                                 if ((iframe[3] >> 4) != 0xE) // no pes header
1316                                         write(m_video_clip_fd, pes_header, sizeof(pes_header));
1317                                 else
1318                                         iframe[4] = iframe[5] = 0x00;
1319                                 write(m_video_clip_fd, iframe, s.st_size);
1320                                 if (!seq_end_avail)
1321                                         write(m_video_clip_fd, seq_end, sizeof(seq_end));
1322                                 write(m_video_clip_fd, stuffing, 8192);
1323                                 m_showSinglePicTimer->start(150, true);
1324                         }
1325                         close(f);
1326                 }
1327                 else
1328                 {
1329                         eDebug("couldnt open %s", filename);
1330                         return -1;
1331                 }
1332         }
1333         else
1334         {
1335                 eDebug("only show single pics on first decoder");
1336                 return -1;
1337         }
1338         return 0;
1339 }
1340
1341 void eTSMPEGDecoder::finishShowSinglePic()
1342 {
1343         if (m_video_clip_fd >= 0)
1344         {
1345                 if (ioctl(m_video_clip_fd, VIDEO_STOP, 0) < 0)
1346                         eDebug("VIDEO_STOP failed (%m)");
1347                 if (ioctl(m_video_clip_fd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_DEMUX) < 0)
1348                                 eDebug("VIDEO_SELECT_SOURCE DEMUX failed (%m)");
1349                 close(m_video_clip_fd);
1350                 m_video_clip_fd = -1;
1351         }
1352 }
1353
1354 RESULT eTSMPEGDecoder::connectVideoEvent(const Slot1<void, struct videoEvent> &event, ePtr<eConnection> &conn)
1355 {
1356         conn = new eConnection(this, m_video_event.connect(event));
1357         return 0;
1358 }
1359
1360 void eTSMPEGDecoder::video_event(struct videoEvent event)
1361 {
1362         /* emit */ m_video_event(event);
1363 }
1364
1365 int eTSMPEGDecoder::getVideoWidth()
1366 {
1367         if (m_video)
1368                 return m_video->getWidth();
1369         return -1;
1370 }
1371
1372 int eTSMPEGDecoder::getVideoHeight()
1373 {
1374         if (m_video)
1375                 return m_video->getHeight();
1376         return -1;
1377 }
1378
1379 int eTSMPEGDecoder::getVideoProgressive()
1380 {
1381         if (m_video)
1382                 return m_video->getProgressive();
1383         return -1;
1384 }
1385
1386 int eTSMPEGDecoder::getVideoFrameRate()
1387 {
1388         if (m_video)
1389                 return m_video->getFrameRate();
1390         return -1;
1391 }
1392
1393 int eTSMPEGDecoder::getVideoAspect()
1394 {
1395         if (m_video)
1396                 return m_video->getAspect();
1397         return -1;
1398 }