diff --git a/libspark/record.cpp b/libspark/record.cpp index 2d269eb..74ce89f 100644 --- a/libspark/record.cpp +++ b/libspark/record.cpp @@ -67,7 +67,7 @@ void cRecord::Close(void) } #endif -bool cRecord::Start(int fd, unsigned short vpid, unsigned short * apids, int numpids) +bool cRecord::Start(int fd, unsigned short vpid, unsigned short *apids, int numpids, uint64_t) { lt_info("%s: fd %d, vpid 0x%03x\n", __func__, fd, vpid); int i; @@ -404,3 +404,13 @@ void cRecord::RecordThread() pthread_exit(NULL); } +int cRecord::GetStatus() +{ + /* dummy for now */ + return REC_STATUS_OK; +} + +void cRecord::ResetStatus() +{ + return; +} diff --git a/libspark/record_lib.h b/libspark/record_lib.h index 5dc548b..e77f9b8 100644 --- a/libspark/record_lib.h +++ b/libspark/record_lib.h @@ -4,6 +4,10 @@ #include #include "dmx_lib.h" +#define REC_STATUS_OK 0 +#define REC_STATUS_SLOW 1 +#define REC_STATUS_OVERFLOW 2 + typedef enum { RECORD_RUNNING, RECORD_STOPPED, @@ -22,6 +26,7 @@ class cRecord pthread_t record_thread; bool record_thread_running; record_state_t exit_flag; + int state; #ifdef MARTII int bufsize; int bufsize_dmx; @@ -38,9 +43,11 @@ class cRecord ~cRecord(); bool Open(); - bool Start(int fd, unsigned short vpid, unsigned short *apids, int numapids); + bool Start(int fd, unsigned short vpid, unsigned short *apids, int numapids, uint64_t ch = 0); bool Stop(void); bool AddPid(unsigned short pid); + int GetStatus(); + void ResetStatus(); bool ChangePids(unsigned short vpid, unsigned short *apids, int numapids); void RecordThread(); diff --git a/libtriple/record_td.cpp b/libtriple/record_td.cpp index 32c1a01..584aba7 100644 --- a/libtriple/record_td.cpp +++ b/libtriple/record_td.cpp @@ -50,7 +50,7 @@ void cRecord::Close(void) } #endif -bool cRecord::Start(int fd, unsigned short vpid, unsigned short * apids, int numpids) +bool cRecord::Start(int fd, unsigned short vpid, unsigned short *apids, int numpids, uint64_t) { lt_info("%s: fd %d, vpid 0x%03x\n", __func__, fd, vpid); int i; @@ -259,3 +259,13 @@ void cRecord::RecordThread() pthread_exit(NULL); } +int cRecord::GetStatus() +{ + /* dummy for now */ + return REC_STATUS_OK; +} + +void cRecord::ResetStatus() +{ + return; +} diff --git a/libtriple/record_td.h b/libtriple/record_td.h index 75099f7..c2f60ea 100644 --- a/libtriple/record_td.h +++ b/libtriple/record_td.h @@ -4,6 +4,10 @@ #include #include "dmx_td.h" +#define REC_STATUS_OK 0 +#define REC_STATUS_SLOW 1 +#define REC_STATUS_OVERFLOW 2 + typedef enum { RECORD_RUNNING, RECORD_STOPPED, @@ -21,14 +25,17 @@ class cRecord pthread_t record_thread; bool record_thread_running; record_state_t exit_flag; + int state; public: cRecord(int num = 0); ~cRecord(); bool Open(); - bool Start(int fd, unsigned short vpid, unsigned short *apids, int numapids); + bool Start(int fd, unsigned short vpid, unsigned short *apids, int numapids, uint64_t ch = 0); bool Stop(void); bool AddPid(unsigned short pid); + int GetStatus(); + void ResetStatus(); bool ChangePids(unsigned short vpid, unsigned short *apids, int numapids); void RecordThread();