MVPReceiver::~MVPReceiver()
{
- Detach();
- threadStop();
-
numMVPReceivers--;
Log::getInstance()->log("MVPReceiver", Log::DEBUG, "num mvp receivers now down to %i", numMVPReceivers);
}
return vdrActivated;
}
+void MVPReceiver::detachMVPReceiver()
+{
+ threadStop();
+ Detach();
+}
+
void MVPReceiver::Receive(UCHAR* data, int length)
{
pthread_mutex_lock(&processedRingLock);
destpids++;
*destpids=0;
return mergedSpidsTpid;
-}
+}
+
virtual ~MVPReceiver();
int init(TCP* tcp, ULONG streamID);
bool isVdrActivated();
+ void detachMVPReceiver();
private:
MVPReceiver(cChannel* channel, cDevice* device);