moonlight-stream/moonlight-common-c
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-common-c.git synced 2026-06-22 00:31:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Predictive RFI -> Speculative RFI

Browse Source
This commit is contained in:
Cameron Gutman
2022-10-06 20:46:25 -05:00
parent 9d25ebec40
commit 947d1b5aef
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/RtpVideoQueue.c
+4 -4
View File
@@ -104,10 +104,10 @@ static bool queuePacket(PRTP_VIDEO_QUEUE queue, PRTPV_QUEUE_ENTRY newEntry, PRTP
} }
else if (!isFecRecovery && isBefore16(packet->sequenceNumber, entry->packet->sequenceNumber)) { else if (!isFecRecovery && isBefore16(packet->sequenceNumber, entry->packet->sequenceNumber)) {
// This packet was received after a higher sequence number packet, so note that we // This packet was received after a higher sequence number packet, so note that we
// received an out of order packet to disable our predictive RFI recovery logic. // received an out of order packet to disable our speculative RFI recovery logic.
queue->lastOosSequenceNumber = packet->sequenceNumber; queue->lastOosSequenceNumber = packet->sequenceNumber;
if (!queue->receivedOosData) { if (!queue->receivedOosData) {
Limelog("Leaving predictive RFI mode after OOS video data (%u < %u)\n", Limelog("Leaving speculative RFI mode after OOS video data (%u < %u)\n",
packet->sequenceNumber, entry->packet->sequenceNumber); packet->sequenceNumber, entry->packet->sequenceNumber);
queue->receivedOosData = true; queue->receivedOosData = true;
} }
@@ -119,7 +119,7 @@ static bool queuePacket(PRTP_VIDEO_QUEUE queue, PRTPV_QUEUE_ENTRY newEntry, PRTP
// This is just a fancy way of determining if 32767 packets have passed since our last OOS data // This is just a fancy way of determining if 32767 packets have passed since our last OOS data
if (queue->receivedOosData && isBefore16(queue->bufferHighestSequenceNumber, queue->lastOosSequenceNumber)) { if (queue->receivedOosData && isBefore16(queue->bufferHighestSequenceNumber, queue->lastOosSequenceNumber)) {
Limelog("Entering predictive RFI mode after sequenced video data\n"); Limelog("Entering speculative RFI mode after sequenced video data\n");
queue->receivedOosData = false; queue->receivedOosData = false;
} }
@@ -600,7 +600,7 @@ int RtpvAddPacket(PRTP_VIDEO_QUEUE queue, PRTP_PACKET packet, int length, PRTPV_
LC_ASSERT(queue->currentFrameNumber < nvPacket->frameIndex); LC_ASSERT(queue->currentFrameNumber < nvPacket->frameIndex);
// If the frame immediately preceding this one was lost, we may have already // If the frame immediately preceding this one was lost, we may have already
// reported it using our predictive RFI logic. Don't report it again. // reported it using our speculative RFI logic. Don't report it again.
if (queue->currentFrameNumber + 1 != nvPacket->frameIndex || !queue->reportedLostFrame) { if (queue->currentFrameNumber + 1 != nvPacket->frameIndex || !queue->reportedLostFrame) {
// NB: We only have to notify for the most recent lost frame, since // NB: We only have to notify for the most recent lost frame, since
// the depacketizer will report the RFI range starting at the last // the depacketizer will report the RFI range starting at the last
src/VideoDepacketizer.c
+1 -1
View File
@@ -902,7 +902,7 @@ void notifyFrameLost(unsigned int frameNumber) {
// If RFI is enabled, we will notify the host PC now // If RFI is enabled, we will notify the host PC now
if (isReferenceFrameInvalidationEnabled()) { if (isReferenceFrameInvalidationEnabled()) {
Limelog("Sending predictive RFI request for probable loss of frame %d\n", frameNumber); Limelog("Sending speculative RFI request for predicted loss of frame %d\n", frameNumber);
// Advance the frame number since we won't be expecting this one anymore // Advance the frame number since we won't be expecting this one anymore
nextFrameNumber = frameNumber + 1; nextFrameNumber = frameNumber + 1;