code.vuplus.com Git - vuplus_dvbapp/blob - 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 <errno.h>
  30
  31         /* these are quite new... */
  32 #ifndef AUDIO_GET_PTS
  33 #define AUDIO_GET_PTS              _IOR('o', 19, __u64)
  34 #define VIDEO_GET_PTS              _IOR('o', 57, __u64)
  35 #endif
  36
  37 DEFINE_REF(eDVBAudio);
  38
  39 eDVBAudio::eDVBAudio(eDVBDemux *demux, int dev): m_demux(demux), m_dev(dev)
  40 {
  41         char filename[128];
  42 #if HAVE_DVB_API_VERSION < 3
  43         sprintf(filename, "/dev/dvb/card%d/audio%d", demux->adapter, dev);
  44 #else
  45         sprintf(filename, "/dev/dvb/adapter%d/audio%d", demux->adapter, dev);
  46 #endif
  47         m_fd = ::open(filename, O_RDWR);
  48         if (m_fd < 0)
  49                 eWarning("%s: %m", filename);
  50 #if HAVE_DVB_API_VERSION < 3
  51         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
  52 #else
  53         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
  54 #endif
  55         m_fd_demux = ::open(filename, O_RDWR);
  56         if (m_fd_demux < 0)
  57                 eWarning("%s: %m", filename);
  58 }
  59
  60 int eDVBAudio::startPid(int pid, int type)
  61 {
  62         if ((m_fd < 0) || (m_fd_demux < 0))
  63                 return -1;
  64         dmx_pes_filter_params pes;
  65
  66         pes.pid      = pid;
  67         pes.input    = DMX_IN_FRONTEND;
  68         pes.output   = DMX_OUT_DECODER;
  69         pes.pes_type = m_dev ? DMX_PES_AUDIO1 : DMX_PES_AUDIO0; /* FIXME */
  70         pes.flags    = 0;
  71         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
  72         {
  73                 eWarning("audio: DMX_SET_PES_FILTER: %m");
  74                 return -errno;
  75         }
  76         if (::ioctl(m_fd_demux, DMX_START) < 0)
  77         {
  78                 eWarning("audio: DMX_START: %m");
  79                 return -errno;
  80         }
  81
  82         int bypass = 0;
  83
  84         switch (type)
  85         {
  86         case aMPEG:
  87                 bypass = 1;
  88                 break;
  89         case aAC3:
  90                 bypass = 0;
  91                 break;
  92                 /*
  93         case aDTS:
  94                 bypass = 2;
  95                 break;
  96                 */
  97         }
  98
  99         if (::ioctl(m_fd, AUDIO_SET_BYPASS_MODE, bypass) < 0)
 100                 eWarning("audio: AUDIO_SET_BYPASS_MODE: %m");
 101
 102         if (::ioctl(m_fd, AUDIO_PLAY) < 0)
 103                 eWarning("audio: AUDIO_PLAY: %m");
 104         return 0;
 105 }
 106
 107 void eDVBAudio::stop()
 108 {
 109         if (::ioctl(m_fd, AUDIO_STOP) < 0)
 110                 eWarning("audio: AUDIO_STOP: %m");
 111 #if HAVE_DVB_API_VERSION > 2
 112         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 113                 eWarning("audio: DMX_STOP: %m");
 114 #endif
 115 }
 116
 117 #if HAVE_DVB_API_VERSION < 3
 118 void eDVBAudio::stopPid()
 119 {
 120         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 121                 eWarning("audio: DMX_STOP: %m");
 122 }
 123 #endif
 124
 125 void eDVBAudio::flush()
 126 {
 127         if (::ioctl(m_fd, AUDIO_CLEAR_BUFFER) < 0)
 128                 eDebug("audio: AUDIO_CLEAR_BUFFER: %m");
 129 }
 130
 131 void eDVBAudio::freeze()
 132 {
 133         if (::ioctl(m_fd, AUDIO_PAUSE) < 0)
 134                 eDebug("video: AUDIO_PAUSE: %m");
 135 }
 136
 137 void eDVBAudio::unfreeze()
 138 {
 139         if (::ioctl(m_fd, AUDIO_CONTINUE) < 0)
 140                 eDebug("video: AUDIO_CONTINUE: %m");
 141 }
 142
 143 void eDVBAudio::setChannel(int channel)
 144 {
 145         int val = AUDIO_STEREO;
 146         switch (channel)
 147         {
 148         case aMonoLeft: val = AUDIO_MONO_LEFT; break;
 149         case aMonoRight: val = AUDIO_MONO_RIGHT; break;
 150         default: break;
 151         }
 152         if (::ioctl(m_fd, AUDIO_CHANNEL_SELECT, val) < 0)
 153                 eDebug("video: AUDIO_CHANNEL_SELECT: %m");
 154 }
 155
 156 int eDVBAudio::getPTS(pts_t &now)
 157 {
 158         return ::ioctl(m_fd, AUDIO_GET_PTS, &now);
 159 }
 160
 161 eDVBAudio::~eDVBAudio()
 162 {
 163         if (m_fd >= 0)
 164                 ::close(m_fd);
 165         if (m_fd_demux >= 0)
 166                 ::close(m_fd_demux);
 167 }
 168
 169 DEFINE_REF(eDVBVideo);
 170
 171 eDVBVideo::eDVBVideo(eDVBDemux *demux, int dev): m_demux(demux), m_dev(dev)
 172 {
 173         char filename[128];
 174 #if HAVE_DVB_API_VERSION < 3
 175         sprintf(filename, "/dev/dvb/card%d/video%d", demux->adapter, dev);
 176 #else
 177         sprintf(filename, "/dev/dvb/adapter%d/video%d", demux->adapter, dev);
 178 #endif
 179         m_fd = ::open(filename, O_RDWR);
 180         if (m_fd < 0)
 181                 eWarning("%s: %m", filename);
 182         else
 183         {
 184                 m_sn = new eSocketNotifier(eApp, m_fd, eSocketNotifier::Priority);
 185                 CONNECT(m_sn->activated, eDVBVideo::video_event);
 186         }
 187         eDebug("Video Device: %s", filename);
 188 #if HAVE_DVB_API_VERSION < 3
 189         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
 190 #else
 191         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
 192 #endif
 193         m_fd_demux = ::open(filename, O_RDWR);
 194         if (m_fd_demux < 0)
 195                 eWarning("%s: %m", filename);
 196         eDebug("demux device: %s", filename);
 197 }
 198
 199 // not finally values i think.. !!
 200 #define VIDEO_STREAMTYPE_MPEG2 0
 201 #define VIDEO_STREAMTYPE_MPEG4_H264 1
 202
 203 int eDVBVideo::startPid(int pid, int type)
 204 {
 205         if ((m_fd < 0) || (m_fd_demux < 0))
 206                 return -1;
 207         dmx_pes_filter_params pes;
 208
 209         if (::ioctl(m_fd, VIDEO_SET_STREAMTYPE,
 210                 type == MPEG4_H264 ? VIDEO_STREAMTYPE_MPEG4_H264 : VIDEO_STREAMTYPE_MPEG2) < 0)
 211                 eWarning("video: VIDEO_SET_STREAMTYPE: %m");
 212
 213         pes.pid      = pid;
 214         pes.input    = DMX_IN_FRONTEND;
 215         pes.output   = DMX_OUT_DECODER;
 216         pes.pes_type = m_dev ? DMX_PES_VIDEO1 : DMX_PES_VIDEO0; /* FIXME */
 217         pes.flags    = 0;
 218         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 219         {
 220                 eWarning("video: DMX_SET_PES_FILTER: %m");
 221                 return -errno;
 222         }
 223         if (::ioctl(m_fd_demux, DMX_START) < 0)
 224         {
 225                 eWarning("video: DMX_START: %m");
 226                 return -errno;
 227         }
 228         if (::ioctl(m_fd, VIDEO_PLAY) < 0)
 229                 eWarning("video: VIDEO_PLAY: %m");
 230         return 0;
 231 }
 232
 233 void eDVBVideo::stop()
 234 {
 235 #if HAVE_DVB_API_VERSION > 2
 236         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 237                 eWarning("video: DMX_STOP: %m");
 238 #endif
 239         eDebug("VIDEO_STOP");
 240         if (::ioctl(m_fd, VIDEO_STOP, 1) < 0)
 241                 eWarning("video: VIDEO_STOP: %m");
 242 }
 243
 244 #if HAVE_DVB_API_VERSION < 3
 245 void eDVBVideo::stopPid()
 246 {
 247         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 248                 eWarning("video: DMX_STOP: %m");
 249 }
 250 #endif
 251
 252 void eDVBVideo::flush()
 253 {
 254         if (::ioctl(m_fd, VIDEO_CLEAR_BUFFER) < 0)
 255                 eDebug("video: VIDEO_CLEAR_BUFFER: %m");
 256 }
 257
 258 void eDVBVideo::freeze()
 259 {
 260         if (::ioctl(m_fd, VIDEO_FREEZE) < 0)
 261                 eDebug("video: VIDEO_FREEZE: %m");
 262 }
 263
 264 void eDVBVideo::unfreeze()
 265 {
 266         if (::ioctl(m_fd, VIDEO_CONTINUE) < 0)
 267                 eDebug("video: VIDEO_CONTINUE: %m");
 268 }
 269
 270 int eDVBVideo::setSlowMotion(int repeat)
 271 {
 272         m_is_slow_motion = repeat;
 273         return ::ioctl(m_fd, VIDEO_SLOWMOTION, repeat);
 274 }
 275
 276 int eDVBVideo::setFastForward(int skip)
 277 {
 278         m_is_fast_forward = skip;
 279         return ::ioctl(m_fd, VIDEO_FAST_FORWARD, skip);
 280 }
 281
 282 int eDVBVideo::getPTS(pts_t &now)
 283 {
 284         return ::ioctl(m_fd, VIDEO_GET_PTS, &now);
 285 }
 286
 287 eDVBVideo::~eDVBVideo()
 288 {
 289         if (m_sn)
 290                 delete m_sn;
 291         if (m_is_slow_motion)
 292                 setSlowMotion(0);
 293         if (m_is_fast_forward)
 294                 setFastForward(0);
 295         if (m_fd >= 0)
 296                 ::close(m_fd);
 297         if (m_fd_demux >= 0)
 298                 ::close(m_fd_demux);
 299 }
 300
 301 void eDVBVideo::video_event(int)
 302 {
 303 #if HAVE_DVB_API_VERSION >= 3
 304         struct video_event evt;
 305         if (::ioctl(m_fd, VIDEO_GET_EVENT, &evt) < 0)
 306                 eDebug("VIDEO_GET_EVENT failed(%m)");
 307         else
 308         {
 309                 if (evt.type == VIDEO_EVENT_SIZE_CHANGED)
 310                 {
 311                         struct iTSMPEGDecoder::videoEvent event;
 312                         event.type = iTSMPEGDecoder::videoEvent::eventSizeChanged;
 313                         event.aspect = evt.u.size.aspect_ratio;
 314                         event.height = evt.u.size.h;
 315                         event.width = evt.u.size.w;
 316                         /* emit */ m_event(event);
 317                 }
 318                 else
 319                         eDebug("unhandled DVBAPI Video Event %d", evt.type);
 320         }
 321 #else
 322 #warning "FIXMEE!! Video Events not implemented for old api"
 323 #endif
 324 }
 325
 326 RESULT eDVBVideo::connectEvent(const Slot1<void, struct iTSMPEGDecoder::videoEvent> &event, ePtr<eConnection> &conn)
 327 {
 328         conn = new eConnection(this, m_event.connect(event));
 329         return 0;
 330 }
 331
 332 DEFINE_REF(eDVBPCR);
 333
 334 eDVBPCR::eDVBPCR(eDVBDemux *demux): m_demux(demux)
 335 {
 336         char filename[128];
 337 #if HAVE_DVB_API_VERSION < 3
 338         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
 339 #else
 340         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
 341 #endif
 342         m_fd_demux = ::open(filename, O_RDWR);
 343         if (m_fd_demux < 0)
 344                 eWarning("%s: %m", filename);
 345 }
 346
 347 int eDVBPCR::startPid(int pid)
 348 {
 349         if (m_fd_demux < 0)
 350                 return -1;
 351         dmx_pes_filter_params pes;
 352
 353         pes.pid      = pid;
 354         pes.input    = DMX_IN_FRONTEND;
 355         pes.output   = DMX_OUT_DECODER;
 356         pes.pes_type = DMX_PES_PCR;
 357         pes.flags    = 0;
 358         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 359         {
 360                 eWarning("video: DMX_SET_PES_FILTER: %m");
 361                 return -errno;
 362         }
 363         if (::ioctl(m_fd_demux, DMX_START) < 0)
 364         {
 365                 eWarning("video: DMX_START: %m");
 366                 return -errno;
 367         }
 368         return 0;
 369 }
 370
 371 void eDVBPCR::stop()
 372 {
 373         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 374                 eWarning("video: DMX_STOP: %m");
 375 }
 376
 377 eDVBPCR::~eDVBPCR()
 378 {
 379         if (m_fd_demux >= 0)
 380                 ::close(m_fd_demux);
 381 }
 382
 383 DEFINE_REF(eDVBTText);
 384
 385 eDVBTText::eDVBTText(eDVBDemux *demux): m_demux(demux)
 386 {
 387         char filename[128];
 388 #if HAVE_DVB_API_VERSION < 3
 389         sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
 390 #else
 391         sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
 392 #endif
 393         m_fd_demux = ::open(filename, O_RDWR);
 394         if (m_fd_demux < 0)
 395                 eWarning("%s: %m", filename);
 396 }
 397
 398 int eDVBTText::startPid(int pid)
 399 {
 400         if (m_fd_demux < 0)
 401                 return -1;
 402         dmx_pes_filter_params pes;
 403
 404         pes.pid      = pid;
 405         pes.input    = DMX_IN_FRONTEND;
 406         pes.output   = DMX_OUT_DECODER;
 407         pes.pes_type = DMX_PES_TELETEXT;
 408         pes.flags    = 0;
 409         if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
 410         {
 411                 eWarning("video: DMX_SET_PES_FILTER: %m");
 412                 return -errno;
 413         }
 414         if (::ioctl(m_fd_demux, DMX_START) < 0)
 415         {
 416                 eWarning("video: DMX_START: %m");
 417                 return -errno;
 418         }
 419         return 0;
 420 }
 421
 422 void eDVBTText::stop()
 423 {
 424         if (::ioctl(m_fd_demux, DMX_STOP) < 0)
 425                 eWarning("video: DMX_STOP: %m");
 426 }
 427
 428 eDVBTText::~eDVBTText()
 429 {
 430         if (m_fd_demux >= 0)
 431                 ::close(m_fd_demux);
 432 }
 433
 434 DEFINE_REF(eTSMPEGDecoder);
 435
 436 int eTSMPEGDecoder::setState()
 437 {
 438         int res = 0;
 439
 440         int noaudio = m_is_sm || m_is_ff || m_is_trickmode;
 441         int nott = noaudio; /* actually same conditions */
 442
 443         if ((noaudio && m_audio) || (!m_audio && !noaudio))
 444                 m_changed |= changeAudio;
 445
 446         if ((nott && m_text) || (!m_text && !nott))
 447                 m_changed |= changeText;
 448
 449         bool changed = !!m_changed;
 450 #if HAVE_DVB_API_VERSION < 3
 451         if (m_changed & changeAudio && m_audio)
 452                 m_audio->stopPid();
 453         if (m_changed & changeVideo && m_video)
 454                 m_video->stopPid();
 455         if (m_changed & changePCR && m_pcr)
 456         {
 457                 m_pcr->stop();
 458                 m_pcr=0;
 459         }
 460         if (m_changed & changeAudio && m_audio)
 461         {
 462                 m_audio->stop();
 463                 m_audio=0;
 464         }
 465         if (m_changed & changeVideo && m_video)
 466         {
 467                 m_video->stop();
 468                 m_video=0;
 469                 m_video_event_conn=0;
 470         }
 471         if (m_changed & changePCR)
 472         {
 473                 m_pcr = new eDVBPCR(m_demux);
 474                 if (m_pcr->startPid(m_pcrpid))
 475                 {
 476                         eWarning("pcr: startpid failed!");
 477                         res = -1;
 478                 }
 479                 m_changed &= ~changePCR;
 480         }
 481         if (m_changed & changeVideo)
 482         {
 483                 m_video = new eDVBVideo(m_demux, m_decoder);
 484                 m_video->connectEvent(slot(*this, &eTSMPEGDecoder::video_event), m_video_event_conn);
 485                 if (m_video->startPid(m_vpid))
 486                 {
 487                         eWarning("video: startpid failed!");
 488                         res = -1;
 489                 }
 490                 m_changed &= ~changeVideo;
 491         }
 492         if (m_changed & changeAudio)
 493         {
 494                 m_audio = new eDVBAudio(m_demux, m_decoder);
 495                 if (m_audio->startPid(m_apid, m_atype))
 496                 {
 497                         eWarning("audio: startpid failed!");
 498                         res = -1;
 499                 }
 500                 m_changed &= ~changeAudio;
 501         }
 502 #else
 503         if (m_changed & changePCR)
 504         {
 505                 if (m_pcr)
 506                         m_pcr->stop();
 507                 m_pcr = 0;
 508                 if ((m_pcrpid >= 0) && (m_pcrpid < 0x1FFF))
 509                 {
 510                         m_pcr = new eDVBPCR(m_demux);
 511                         if (m_pcr->startPid(m_pcrpid))
 512                         {
 513                                 eWarning("pcr: startpid failed!");
 514                                 res = -1;
 515                         }
 516                 }
 517                 m_changed &= ~changePCR;
 518         }
 519         if (m_changed & changeVideo)
 520         {
 521                 eDebug("VIDEO CHANGED (to %04x)", m_vpid);
 522                 if (m_video)
 523                 {
 524                         eDebug("STOP");
 525                         m_video->stop();
 526                         m_video = 0;
 527                         m_video_event_conn = 0;
 528                 }
 529                 if ((m_vpid >= 0) && (m_vpid < 0x1FFF))
 530                 {
 531                         eDebug("new video");
 532                         m_video = new eDVBVideo(m_demux, m_decoder);
 533                         m_video->connectEvent(slot(*this, &eTSMPEGDecoder::video_event), m_video_event_conn);
 534                         if (m_video->startPid(m_vpid, m_vtype))
 535                         {
 536                                 eWarning("video: startpid failed!");
 537                                 res = -1;
 538                         }
 539                 }
 540                 m_changed &= ~changeVideo;
 541         }
 542         if (m_changed & changeAudio)
 543         {
 544                 if (m_audio)
 545                         m_audio->stop();
 546                 m_audio = 0;
 547                 if ((m_apid >= 0) && (m_apid < 0x1FFF) && !noaudio)
 548                 {
 549                         m_audio = new eDVBAudio(m_demux, m_decoder);
 550                         if (m_audio->startPid(m_apid, m_atype))
 551                         {
 552                                 eWarning("audio: startpid failed!");
 553                                 res = -1;
 554                         }
 555                 }
 556                 m_changed &= ~changeAudio;
 557         }
 558         if (m_changed & changeText)
 559         {
 560                 if (m_text)
 561                         m_text->stop();
 562                 m_text = 0;
 563                 if ((m_textpid >= 0) && (m_textpid < 0x1FFF) && !nott)
 564                 {
 565                         m_text = new eDVBTText(m_demux);
 566                         if (m_text->startPid(m_textpid))
 567                         {
 568                                 eWarning("text: startpid failed!");
 569                                 res = -1;
 570                         }
 571                 }
 572                 m_changed &= ~changeText;
 573         }
 574 #endif
 575         if (changed && !m_video && m_audio && m_radio_pic.length())
 576                 showSinglePic(m_radio_pic.c_str());
 577
 578         return res;
 579 }
 580
 581 int eTSMPEGDecoder::m_pcm_delay=-1,
 582         eTSMPEGDecoder::m_ac3_delay=-1;
 583
 584 RESULT eTSMPEGDecoder::setPCMDelay(int delay)
 585 {
 586         if (m_decoder == 0 && delay != m_pcm_delay )
 587         {
 588                 FILE *fp = fopen("/proc/stb/audio/audio_delay_pcm", "w");
 589                 if (fp)
 590                 {
 591                         fprintf(fp, "%x", delay*90);
 592                         fclose(fp);
 593                         m_pcm_delay = delay;
 594                         return 0;
 595                 }
 596         }
 597         return -1;
 598 }
 599
 600 RESULT eTSMPEGDecoder::setAC3Delay(int delay)
 601 {
 602         if ( m_decoder == 0 && delay != m_ac3_delay )
 603         {
 604                 FILE *fp = fopen("/proc/stb/audio/audio_delay_bitstream", "w");
 605                 if (fp)
 606                 {
 607                         fprintf(fp, "%x", delay*90);
 608                         fclose(fp);
 609                         m_ac3_delay = delay;
 610                         return 0;
 611                 }
 612         }
 613         return -1;
 614 }
 615
 616 eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder): m_demux(demux), m_changed(0), m_decoder(decoder)
 617 {
 618         demux->connectEvent(slot(*this, &eTSMPEGDecoder::demux_event), m_demux_event_conn);
 619         m_is_ff = m_is_sm = m_is_trickmode = 0;
 620 }
 621
 622 eTSMPEGDecoder::~eTSMPEGDecoder()
 623 {
 624         m_vpid = m_apid = m_pcrpid = pidNone;
 625         m_changed = -1;
 626         setState();
 627 }
 628
 629 RESULT eTSMPEGDecoder::setVideoPID(int vpid, int type)
 630 {
 631         if (m_vpid != vpid)
 632         {
 633                 m_changed |= changeVideo;
 634                 m_vpid = vpid;
 635                 m_vtype = type;
 636         }
 637         return 0;
 638 }
 639
 640 RESULT eTSMPEGDecoder::setAudioPID(int apid, int type)
 641 {
 642         if ((m_apid != apid) || (m_atype != type))
 643         {
 644                 m_changed |= changeAudio;
 645                 m_atype = type;
 646                 m_apid = apid;
 647         }
 648         return 0;
 649 }
 650
 651 int eTSMPEGDecoder::m_audio_channel = -1;
 652
 653 RESULT eTSMPEGDecoder::setAudioChannel(int channel)
 654 {
 655         if (channel == -1)
 656                 channel = ac_stereo;
 657         if (m_decoder == 0 && m_audio_channel != channel)
 658         {
 659                 if (m_audio)
 660                 {
 661                         m_audio->setChannel(channel);
 662                         m_audio_channel=channel;
 663                 }
 664                 else
 665                         eDebug("eTSMPEGDecoder::setAudioChannel but no audio decoder exist");
 666         }
 667         return 0;
 668 }
 669
 670 int eTSMPEGDecoder::getAudioChannel()
 671 {
 672         return m_audio_channel == -1 ? ac_stereo : m_audio_channel;
 673 }
 674
 675 RESULT eTSMPEGDecoder::setSyncPCR(int pcrpid)
 676 {
 677         if (m_pcrpid != pcrpid)
 678         {
 679                 m_changed |= changePCR;
 680                 m_pcrpid = pcrpid;
 681         }
 682         return 0;
 683 }
 684
 685 RESULT eTSMPEGDecoder::setTextPID(int textpid)
 686 {
 687         if (m_textpid != textpid)
 688         {
 689                 m_changed |= changeText;
 690                 m_textpid = textpid;
 691         }
 692         return 0;
 693 }
 694
 695 RESULT eTSMPEGDecoder::setSyncMaster(int who)
 696 {
 697         return -1;
 698 }
 699
 700 RESULT eTSMPEGDecoder::start()
 701 {
 702         return setState();
 703 }
 704
 705 RESULT eTSMPEGDecoder::freeze(int cont)
 706 {
 707         if (m_video)
 708                 m_video->freeze();
 709
 710         if (m_audio)
 711                 m_audio->freeze();
 712
 713         return 0;
 714 }
 715
 716 RESULT eTSMPEGDecoder::unfreeze()
 717 {
 718         if (m_video)
 719                 m_video->unfreeze();
 720
 721         if (m_audio)
 722                 m_audio->unfreeze();
 723
 724         return 0;
 725 }
 726
 727 RESULT eTSMPEGDecoder::setSinglePictureMode(int when)
 728 {
 729         return -1;
 730 }
 731
 732 RESULT eTSMPEGDecoder::setPictureSkipMode(int what)
 733 {
 734         return -1;
 735 }
 736
 737 RESULT eTSMPEGDecoder::setFastForward(int frames_to_skip)
 738 {
 739         m_is_ff = frames_to_skip != 0;
 740
 741         setState();
 742
 743         if (m_video)
 744                 return m_video->setFastForward(frames_to_skip);
 745         else
 746                 return -1;
 747 }
 748
 749 RESULT eTSMPEGDecoder::setSlowMotion(int repeat)
 750 {
 751         m_is_sm = repeat != 0;
 752
 753         setState();
 754
 755         if (m_video)
 756                 return m_video->setSlowMotion(repeat);
 757         else
 758                 return -1;
 759 }
 760
 761 RESULT eTSMPEGDecoder::setZoom(int what)
 762 {
 763         return -1;
 764 }
 765
 766 RESULT eTSMPEGDecoder::flush()
 767 {
 768         if (m_audio)
 769                 m_audio->flush();
 770         if (m_video)
 771                 m_video->flush();
 772         return 0;
 773 }
 774
 775 void eTSMPEGDecoder::demux_event(int event)
 776 {
 777         switch (event)
 778         {
 779         case eDVBDemux::evtFlush:
 780                 flush();
 781                 break;
 782         default:
 783                 break;
 784         }
 785 }
 786
 787 RESULT eTSMPEGDecoder::setTrickmode(int what)
 788 {
 789         m_is_trickmode = what;
 790         setState();
 791         return 0;
 792 }
 793
 794 RESULT eTSMPEGDecoder::getPTS(int what, pts_t &pts)
 795 {
 796         if (what == 0) /* auto */
 797                 what = m_video ? 1 : 2;
 798
 799         if (what == 1) /* video */
 800         {
 801                 if (m_video)
 802                         return m_video->getPTS(pts);
 803                 else
 804                         return -1;
 805         }
 806
 807         if (what == 2) /* audio */
 808         {
 809                 if (m_audio)
 810                         return m_audio->getPTS(pts);
 811                 else
 812                         return -1;
 813         }
 814
 815         return -1;
 816 }
 817
 818 RESULT eTSMPEGDecoder::setRadioPic(const std::string &filename)
 819 {
 820         m_radio_pic = filename;
 821         return 0;
 822 }
 823
 824 RESULT eTSMPEGDecoder::showSinglePic(const char *filename)
 825 {
 826         if (m_decoder == 0)
 827         {
 828                 FILE *f = fopen(filename, "r");
 829                 if (f)
 830                 {
 831                         int vfd = open("/dev/dvb/adapter0/video0", O_RDWR);
 832                         if (vfd > 0)
 833                         {
 834                                 fseek(f, 0, SEEK_END);
 835                                 int length = ftell(f);
 836                                 unsigned char *buffer = new unsigned char[length*2+9];
 837                                 if (ioctl(vfd, VIDEO_FAST_FORWARD, 1) < 0)
 838                                         eDebug("VIDEO_FAST_FORWARD failed (%m)");
 839                                 if (ioctl(vfd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_MEMORY) < 0)
 840                                         eDebug("VIDEO_SELECT_SOURCE MEMORY failed (%m)");
 841                                 if (ioctl(vfd, VIDEO_PLAY) < 0)
 842                                         eDebug("VIDEO_PLAY failed (%m)");
 843                                 int cnt=0;
 844                                 int pos=0;
 845                                 while(cnt<2)
 846                                 {
 847                                         int rd;
 848                                         fseek(f, 0, SEEK_SET);
 849                                         if (!cnt)
 850                                         {
 851                                                 buffer[pos++]=0;
 852                                                 buffer[pos++]=0;
 853                                                 buffer[pos++]=1;
 854                                                 buffer[pos++]=0xE0;
 855                                                 buffer[pos++]=(length*2)>>8;
 856                                                 buffer[pos++]=(length*2)&0xFF;
 857                                                 buffer[pos++]=0x80;
 858                                                 buffer[pos++]=0;
 859                                                 buffer[pos++]=0;
 860                                         }
 861                                         while(1)
 862                                         {
 863                                                 rd = fread(buffer+pos, 1, length, f);
 864                                                 if (rd > 0)
 865                                                         pos += rd;
 866                                                 else
 867                                                         break;
 868                                         }
 869                                         ++cnt;
 870                                 }
 871                                 write(vfd, buffer, pos);
 872                                 usleep(75000);  // i dont like this.. but i dont have a better solution :(
 873                                 if (ioctl(vfd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_DEMUX) < 0)
 874                                         eDebug("VIDEO_SELECT_SOURCE DEMUX failed (%m)");
 875                                 if (ioctl(vfd, VIDEO_FAST_FORWARD, 0) < 0)
 876                                         eDebug("VIDEO_FAST_FORWARD failed (%m)");
 877                                 close(vfd);
 878                                 delete [] buffer;
 879                         }
 880                         fclose(f);
 881                 }
 882                 else
 883                 {
 884                         eDebug("couldnt open %s", filename);
 885                         return -1;
 886                 }
 887         }
 888         else
 889         {
 890                 eDebug("only show single pics on first decoder");
 891                 return -1;
 892         }
 893         return 0;
 894 }
 895
 896 RESULT eTSMPEGDecoder::connectVideoEvent(const Slot1<void, struct videoEvent> &event, ePtr<eConnection> &conn)
 897 {
 898         conn = new eConnection(this, m_video_event.connect(event));
 899         return 0;
 900 }
 901
 902 void eTSMPEGDecoder::video_event(struct videoEvent event)
 903 {
 904         /* emit */ m_video_event(event);
 905 }