19 #ifndef DATVVIDEOPLAYER_H 20 #define DATVVIDEOPLAYER_H 45 int size =
in.readable() *
sizeof(T);
56 fatal(
"leansdr::datvvideoplayer::run: pipe");
62 fatal(
"leansdr::datvvideoplayer::run: write");
68 fatal(
"leansdr::datvvideoplayer::run: partial write");
73 fprintf(stderr,
"leansdr::datvvideoplayer::run: nw: %d size: %d\n", nw, size);
76 in.read(nw /
sizeof(T));
87 #endif // DATVVIDEOPLAYER_H DATVideostream * m_objVideoStream
DATVUDPStream * m_udpStream
int pushData(const char *chrData, int intSize)
void fatal(const char *s)
void pushData(const char *chrData, int nbTSBlocks)
datvvideoplayer(scheduler *sch, pipebuf< T > &_in, DATVideostream *objVideoStream, DATVUDPStream *udpStream)