20#define PTSINDEX_ENTRIES 1024
37 void Put(uint32_t Pts,
int Index,
bool Independent);
64 pi[
w].independent = Independent;
74 if (
w ==
r || Pts == 0 && !Still)
76 uint32_t Delta = 0xFFFFFFFF;
78 for (
int i =
w; i !=
r; ) {
81 uint32_t d =
pi[i].pts < Pts ? Pts -
pi[i].pts :
pi[i].pts - Pts;
98 if (
w ==
r || Pts == 0 && !Still)
102 int UnplayedIFrame = 2;
103 for (
int i =
r; i !=
w && UnplayedIFrame; ) {
104 int32_t d = int32_t(Pts -
pi[i].pts);
106 if (
pi[i].independent) {
107 FrameNumber =
pi[i].index;
115 else if (
pi[i].independent)
151:
cThread(
"non blocking file reader")
237#define PLAYERBUFSIZE (MAXFRAMESIZE * 5)
239#define RESUMEBACKUP 10
240#define MAXSTUCKATEOF 3
270 bool NextFile(uint16_t FileNumber = 0, off_t FileOffset = -1);
274 virtual void Activate(
bool On)
override;
275 virtual void Action(
void)
override;
277 cDvbPlayer(
const char *FileName,
bool PauseLive);
287 void Goto(
int Position,
bool Still =
false);
291 virtual bool GetIndex(
int &Current,
int &Total,
bool SnapToIFrame =
false)
override;
296#define MAX_VIDEO_SLOWMOTION 63
297#define NORMAL_SPEED 4
324 isyslog(
"replay %s", FileName);
333 esyslog(
"ERROR: can't allocate index");
334 else if (!
index->Ok()) {
408 int Index =
index->GetResume();
412 if (
index->Get(Index, &FileNumber, &FileOffset) &&
NextFile(FileNumber, FileOffset))
426 marks->Lock(StateKey);
433 Index =
index->GetNextIFrame(Index,
false);
437 return index->StoreResume(Index);
463 marks->Lock(StateKey);
465 int Index =
marks->First()->Position();
468 if (
index->Get(Index, &FileNumber, &FileOffset) &&
NextFile(FileNumber, FileOffset)) {
481 bool WaitingForData =
false;
482 time_t StuckAtEof = 0;
483 uint32_t LastStc = 0;
484 int LastReadFrame = -1;
485 int SwitchToPlayFrame = 0;
487 bool AtLastMark =
false;
512 bool TimeShiftMode =
index->IsStillRecording();
524 if (NewIndex <= 0 && readIndex > 0)
534 if (!
NextFile(FileNumber, FileOffset))
547 marks->Lock(StateKey);
549 if (m && (m->
Index() & 0x01) != 0) {
550 m =
marks->GetNextBegin(m);
554 else if (
Setup.PauseAtLastMark)
556 else if (
index->IsStillRecording())
587 WaitingForData =
false;
594 WaitingForData =
true;
663 w =
PlayTs(p, pc, VideoOnly);
681 if (
Setup.PauseAtLastMark) {
694 if (
eof || SwitchToPlayFrame) {
695 bool SwitchToPlay =
false;
699 else if (!StuckAtEof)
700 StuckAtEof = time(NULL);
709 if (Index >= LastReadFrame)
712 else if (Index <= 0 || SwitchToPlayFrame && Index >= SwitchToPlayFrame)
715 if (!SwitchToPlayFrame)
720 SwitchToPlayFrame = 0;
771 if (
Setup.MultiSpeedMode) {
793 if (
Setup.MultiSpeedMode) {
813 default:
esyslog(
"ERROR: unknown playMode %d (%s)",
playMode, __FUNCTION__);
823 if (
Setup.MultiSpeedMode) {
845 if (
Setup.MultiSpeedMode) {
865 default:
esyslog(
"ERROR: unknown playMode %d (%s)",
playMode, __FUNCTION__);
872 if (
index && Frames) {
875 int OldCurrent = Current;
879 Current =
index->GetNextIFrame(Current + Frames + (Frames > 0 ? -1 : 1), Frames > 0);
880 return Current >= 0 ? Current : OldCurrent;
887 if (
index && Seconds) {
894 Index =
index->GetNextIFrame(Index,
false, NULL, NULL, NULL);
912 Index =
index->GetNextIFrame(Index,
false, &FileNumber, &FileOffset, &Length);
915 if (
NextFile(FileNumber, FileOffset)) {
954 return index->GetErrors();
963 int i1 =
index->GetNextIFrame(Current + 1,
false);
964 int i2 =
index->GetNextIFrame(Current,
true);
965 Current = (abs(Current - i1) <= abs(Current - i2)) ? i1 : i2;
967 Total =
index->Last();
970 Current = Total = -1;
978 Total =
index->Last();
981 Current = Total = -1;
1055 player->SkipSeconds(Seconds);
1061 return player->SkipFrames(Frames);
1068 return player->GetErrors();
1075 player->GetIndex(Current, Total, SnapToIFrame);
1084 player->GetFrameNumber(Current, Total);
1098 player->Goto(Position, Still);
static void SleepMs(int TimeoutMs)
Creates a cCondWait object and uses it to sleep for TimeoutMs milliseconds, immediately giving up the...
void SetPlayer(cPlayer *Player)
cControl(cPlayer *Player, bool Hidden=false)
void SetMarks(const cMarks *Marks)
virtual ~cDvbPlayerControl() override
bool GetIndex(int &Current, int &Total, bool SnapToIFrame=false)
const cErrors * GetErrors(void)
void SkipSeconds(int Seconds)
cDvbPlayerControl(const char *FileName, bool PauseLive=false)
bool GetReplayMode(bool &Play, bool &Forward, int &Speed)
int SkipFrames(int Frames)
void Goto(int Index, bool Still=false)
bool GetFrameNumber(int &Current, int &Total)
virtual const cErrors * GetErrors(void) override
cRingBufferFrame * ringBuffer
void SetMarks(const cMarks *Marks)
virtual void Action(void) override
A derived cThread class must implement the code it wants to execute as a separate thread in this func...
virtual bool GetReplayMode(bool &Play, bool &Forward, int &Speed) override
virtual void Activate(bool On) override
void SkipSeconds(int Seconds)
virtual double FramesPerSecond(void)
cDvbPlayer(const char *FileName, bool PauseLive)
cNonBlockingFileReader * nonBlockingFileReader
cUnbufferedFile * replayFile
virtual void SetAudioTrack(eTrackType Type, const tTrackId *TrackId) override
void Goto(int Position, bool Still=false)
bool NextFile(uint16_t FileNumber=0, off_t FileOffset=-1)
virtual ~cDvbPlayer() override
virtual bool GetFrameNumber(int &Current, int &Total) override
void TrickSpeed(int Increment)
int SkipFrames(int Frames)
virtual bool GetIndex(int &Current, int &Total, bool SnapToIFrame=false) override
void Request(cUnbufferedFile *File, int Length)
cNonBlockingFileReader(void)
void Action(void)
A derived cThread class must implement the code it wants to execute as a separate thread in this func...
bool WaitForDataMs(int msToWait)
int Result(uchar **Buffer)
~cNonBlockingFileReader()
void DeviceStillPicture(const uchar *Data, int Length)
uint64_t DeviceGetSTC(void)
int PlayTs(const uchar *Data, int Length, bool VideoOnly=false)
int PlayPes(const uchar *Data, int Length, bool VideoOnly=false)
bool DevicePoll(cPoller &Poller, int TimeoutMs=0)
void DeviceSetTempSubtitles(void)
bool DeviceHasIBPTrickSpeed(void)
cPlayer(ePlayMode PlayMode=pmAudioVideo)
bool DeviceIsPlayingVideo(void)
void DeviceTrickSpeed(int Speed, bool Forward)
int FindIndex(uint32_t Pts, bool Still)
int FindFrameNumber(uint32_t Pts, bool Forward, bool Still)
tPtsIndex pi[PTSINDEX_ENTRIES]
void Put(uint32_t Pts, int Index, bool Independent)
double FramesPerSecond(void) const
bool IsPesRecording(void) const
static void SetBrokenLink(uchar *Data, int Length)
void Remove(bool IncState=true)
Removes this key from the lock it was previously used with.
void bool Start(void)
Sets the description of this thread, which will be used when logging starting or stopping of the thre...
bool Running(void)
Returns false if a derived cThread object shall leave its Action() function.
cThread(const char *Description=NULL, bool LowPriority=false)
Creates a new thread.
void Cancel(int WaitSeconds=0)
Cancels the thread by first setting 'running' to false, so that the Action() loop can finish in an or...
static tThreadId IsMainThread(void)
cUnbufferedFile is used for large files that are mainly written or read in a streaming manner,...
#define MAX_VIDEO_SLOWMOTION
cString IndexToHMSF(int Index, bool WithFrame, double FramesPerSecond)
int SecondsToFrames(int Seconds, double FramesPerSecond)
int ReadFrame(cUnbufferedFile *f, uchar *b, int Length, int Max)
int64_t TsGetPts(const uchar *p, int l)
bool PesHasPts(const uchar *p)
int64_t PesGetPts(const uchar *p)