Hello
I still try to write a Plugin which a background receiving of data.
For example I have 3 devices.
I want the last device to receive data only from "Transponder A" with
"PID X". This should be a very high prio.
The user should tune as he likes.
Now I want to receive "Transponder B" with "PID Y", but with a low Prio.
So the user don't observe it.
The low prio receiver should be detached if a user need the device.
The Problem is that the user action don't detach the receiver.
How can I implement it?
Patrick
So I have written this code:
#define PRIORECEIVER 59
struct sReceiverID{
cDevice *device;
cPTSReceiver *receiver;
int originalNetworkId;
int transportStreamId;
int serviceId;
int vpid;
};
/**
* Start listening for PTS values on the given service.
*
* Step1. create the channel for the values
* Step2. get next free receiver position in array
* Step3. test if allready a receiver is listen to the values, if exist
return
* Step4. test if allready a receiver is listen on same transponder. if
exist create a new receiver and add to same device. return
* Step5. test if static device can receive data. If it could, create a
device and add to static device and return
* Step6. test all other devices and add the first fit device. return
* Step7. return with false. No device can handel a receiver with this
valuse.
*/
bool ctuner::addPTSStream(int originalNetworkId, int transportStreamId,
int serviceId){
//DEBUG
/* for (int b=0;b<MAXRECEIVERS;b++){
if (receiverID[b].originalNetworkId){
dsyslog("receiverID[%d].",b);
dsyslog(" %d) ONID: %d",b,receiverID[b].originalNetworkId);
dsyslog(" %d) TSID: %d",b,receiverID[b].transportStreamId);
dsyslog(" %d) SID: %d \n",b,receiverID[b].serviceId);
dsyslog(" lisen on
device[%d]",receiverID[b].device->DeviceNumber());
}
}; */
//DEBUG END
//create the fitting channel for the originalNetworkId,
transportStreamId and serviceId
cChannel *channel =
GetChannelBy_ONID_TID_SID(originalNetworkId,transportStreamId,serviceId);
if(!channel)return false;//can't read channel from file
else{
// dsyslog("channels with originalNetworkId = %d,
transportStreamId = %d and serviceId = %d was found and has
VPID=%d",originalNetworkId,transportStreamId,serviceId,channel->Vpid());
}
//create a receiver for the VPID
cPTSReceiver *receiver = NULL;
int a;
for (a=0;((receiverID[a].receiver!=NULL) &&
(a<MAXRECEIVERS));a++){};
if (receiverID[a].receiver){
esyslog("MAXRECEIVER reached");
return false;//max receivers was reached
}
//check if already a receiver is set to the originalNetworkId,
transportStreamId and serviceId.
// if a receiver with the same originalNetworkId, transportStreamId
and serviceId were found,
// no new receiver was needed.
for(int i=0;i < MAXRECEIVER;i++){
if ((receiverID[i].originalNetworkId == originalNetworkId) &&
(receiverID[i].transportStreamId == transportStreamId) &&
(receiverID[i].serviceId == serviceId)){
//there is already a receiver set to this IDs
//dsyslog("There is already a receiver listen to the
IDS: %d, %d ,%d",originalNetworkId, transportStreamId, serviceId);
return true;//not need to attach new receiver
}
}//no receiver found for this IDs lets create a new receiver
//dsyslog("VPID from channel is: %d",channel->Vpid()),
receiver = new cPTSReceiver(channel->Vpid());
if(!receiver){
dsyslog("receiver failed");
return false;
}
receiverID[a].receiver = receiver;
receiverID[a].originalNetworkId =0;//will be set later
receiverID[a].transportStreamId =0;//will be set later
receiverID[a].serviceId =serviceId;
receiverID[a].device = NULL;//will be set later if device was known
receiverID[a].vpid = channel->Vpid();
//dsyslog("new PTSReceiver was created for VPID=%d",channel->Vpid());
// If a receiver with the same originalNetworkId and transportStreamId
// were found, the device of this receiver is tuned to the same
originalNetworkId, transportStreamId
// the new receiver need, so I can attach the new receiver to the
same device
for(int i=0;i < MAXRECEIVER;i++){
if ((receiverID[i].originalNetworkId == originalNetworkId) &&
(receiverID[i].transportStreamId == transportStreamId)){
//there is already a receiver on the same transponder
//dsyslog("There is already a receiver on the same
transponder IDS: %d, %d, added ",originalNetworkId, transportStreamId);
if (!receiverID[i].device->AttachReceiver(receiver)){
esyslog("ERROR could not attach receiver to same
transponder. reason unknown");
delete receiver;
receiverID[a].receiver = NULL;
receiverID[a].originalNetworkId = 0;
receiverID[a].transportStreamId = 0;
receiverID[a].serviceId = 0;
receiverID[a].device = NULL;
receiverID[a].vpid = 0;
return false;//could not attach receiver, reason unknown
}
receiverID[a].device = receiverID[i].device;
receiverID[a].originalNetworkId =originalNetworkId;
receiverID[a].transportStreamId =transportStreamId;
dsyslog("added to
device[%d]",receiverID[a].device->DeviceNumber());
return true;//new receiver was added to same device
}
}
//not I need to test all other devices to receive the data
cDevice *device;
//check the last device first, because it is static tuned on a
transponder and will not change
device = cDevice::GetDevice(cDevice::NumDevices()-2);//TODO in case
of xine the last one is the xine device so use -2 else -1
if(device->ProvidesChannel(channel,PRIORECEIVER)){
//dsyslog(" static device can receive PTSStream");
device->SwitchChannel(channel,false);
if (!device->AttachReceiver(receiver)){
esyslog("ERROR could not attach receiver to static
device.");
}else{
receiverID[a].device = device;
receiverID[a].originalNetworkId =originalNetworkId;
receiverID[a].transportStreamId =transportStreamId;
dsyslog("added to
device[%d]",receiverID[a].device->DeviceNumber());
return true;//successful added
}
}
else {
//dsyslog(" static device can't receive PTSStream");
}
//check all other devices if the receiver can be added
for (int i= cDevice::NumDevices()-2; i>=0 ;i--){
device = cDevice::GetDevice(i);
if(device->ProvidesChannel(channel,PRIORECEIVER)){
//dsyslog(" device[%d] can receive PTSStream",i);
device->SwitchChannel(channel,false);
if (!device->AttachReceiver(receiver)){
esyslog("ERROR could not attach receiver to device[%d].",i);
}else{
// dsyslog("successful added receiver to device[%d]",i);
receiverID[a].originalNetworkId =originalNetworkId;
receiverID[a].transportStreamId =transportStreamId;
receiverID[a].device = device;
dsyslog("added to
device[%d]",receiverID[a].device->DeviceNumber());
return true;//successful added
}
}
else{
// dsyslog(" device[%d] can't receive PTSStream",i);
}
}
//no device can handel the originalNetworkId, transportStreamId and
serviceId
// so clean up and exit with false
// dsyslog("no device found for VPID=%d",receiverID[a].vpid);
delete receiver;
receiverID[a].receiver = NULL;
//not needed but make it clean
receiverID[a].originalNetworkId =0;
receiverID[a].transportStreamId =0;
receiverID[a].serviceId =0;
receiverID[a].receiver = NULL;
receiverID[a].vpid = 0;
return false;
}
