media-add-ons/dvb/DVBMediaNode.cpp

1500 		Packet *packet = new Packet(data, size, end_time);
1502 		err = fCardDataQueue->Insert(packet);
1504 			delete packet;
1517 		Packet *packet;
1518 		err = fCardDataQueue->Remove(&packet);
1524 		// packet->TimeStamp() is the end time of the capture
1525 		fDemux->AddData(packet);
1535 		Packet *packet;
1536 		err = fMpegTsQueue->Remove(&packet);
1542 //		TRACE("mpeg ts   packet, size %6ld, start_time %14Ld\n",
1543 //			packet->Size(), packet->TimeStamp());
1547 		write(fMpegTsFile, packet->Data(), packet->Size());
1551 		delete packet;
1561 		Packet *packet;
1562 		err = fEncAudioQueue->Remove(&packet);
1567 //		TRACE("enc audio packet, size %6ld, start_time %14Ld\n",
1568 //			packet->Size(), packet->TimeStamp());
1573 		if (B_OK != pes_extract(packet->Data(), packet->Size(), &data,
1576 			delete packet;
1585 			delete packet;
1592 		delete packet;
1602 		Packet *packet;
1603 		err = fEncVideoQueue->Remove(&packet);
1609 //		TRACE("enc video packet, size %6ld, start_time %14Ld\n",
1610 //			packet->Size(), packet->TimeStamp());
1616 		if (B_OK != pes_extract(packet->Data(), packet->Size(), &data,
1619 			delete packet;
1628 			delete packet;
1634 		delete packet;
1778 			printf("audio: decoded packet is %lldms too late, dropped\n",
1784 //			printf("audio: decoded packet is %lldms too late\n", -delay / 1000);
1787 			printf("audio: decoded packet is %lldms too early, dropped\n",
1793 //			printf("audio: decoded packet is %lldms too early\n", delay / 1000);
1799 				printf("audio: delay sem not timed out, dropped packet\n");
1998 			printf("video: decoded packet is %lldms too late, dropped\n",
2004 			printf("video: decoded packet is %lldms too early, dropped\n",
2013 				printf("video: delay sem not timed out, dropped packet\n");
2134 	Packet *packet;
2139 	// get copy of the first packet from queue, and determine format
2140 	status = queue->Peek(&packet);
2145 	status = pes_extract(packet->Data(), packet->Size(), &data, &size);
2150 	status = pes_stream_id(packet->Data(), packet->Size(), &stream_id);
2162 	delete packet;