mirrors/neutrino
1
0
Fork 0
mirror of https://github.com/tuxbox-neutrino/neutrino.git synced 2025-08-30 17:01:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

pic max10<max_10@gmx.de> code from commit f480ad018c72d40a9d2d2fb4006cfca1c262234d

Browse Source
This commit is contained in:
Jacek Jendrzej
2017-08-29 16:35:32 +02:00
parent 4700523643
commit 2d4f52ae62
1 changed files with 41 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
src/driver/radiotext.cpp
View File

@@ -2375,7 +2375,13 @@ void CRadioText::run()
uint current_pid = 0;
printf("CRadioText::run: ###################### Starting thread ######################\n");
#if HAVE_SPARK_HARDWARE || HAVE_DUCKBOX_HARDWARE || HAVE_GENERIC_HARDWARE
int buflen = 0;
unsigned char *buf = NULL;
audioDemux = new cDemux(0); // live demux
#else
audioDemux = new cDemux(1);
#endif
audioDemux->Open(DMX_PES_CHANNEL,0,128*1024);
while(running) {
@@ -2400,11 +2406,41 @@ void CRadioText::run()
}
mutex.unlock();
if (pid) {
#if HAVE_SPARK_HARDWARE || HAVE_DUCKBOX_HARDWARE || HAVE_GENERIC_HARDWARE
int n;
unsigned char tmp[6];
n = audioDemux->Read(tmp, 6, 500);
if (n != 6) {
usleep(10000); /* save CPU if nothing read */
continue;
}
if (memcmp(tmp, "\000\000\001\300", 4))
continue;
int packlen = ((tmp[4] << 8) | tmp[5]) + 6;
if (buflen < packlen) {
if (buf)
free(buf);
buf = (unsigned char *) calloc(1, packlen);
buflen = packlen;
}
if (!buf)
break;
memcpy(buf, tmp, 6);
while ((n < packlen) && running) {
int len = audioDemux->Read(buf + n, packlen - n, 500);
if (len < 0)
break;
n += len;
}
#else
int n;
unsigned char buf[0x1FFFF];
n = audioDemux->Read(buf, sizeof(buf), 500 /*5000*/);
#endif
if (n > 0) {
//printf("."); fflush(stdout);
mutex.lock();
@@ -2413,6 +2449,10 @@ void CRadioText::run()
}
}
}
#if HAVE_SPARK_HARDWARE || HAVE_DUCKBOX_HARDWARE || HAVE_GENERIC_HARDWARE
if (buf)
free(buf);
#endif
delete audioDemux;
audioDemux = NULL;
printf("CRadioText::run: ###################### exit ######################\n");