moonlight-stream/moonlight-common-c
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-common-c.git synced 2025-07-02 07:46:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add support for sunshine host latency

Browse Source
This commit is contained in:
ns6089 2023-04-18 20:56:12 +03:00 committed by Cameron Gutman
parent 169078d0a9
commit 284840bde7
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Limelight.h
View File

@ -151,6 +151,12 @@ typedef struct _DECODE_UNIT {
// Frame type // Frame type
int frameType; int frameType;
// Optional host processing latency of the frame, in 1/10 ms units.
// Zero when the host doesn't provide the latency data
// or frame processing latency is not applicable to the current frame
// (happens when the frame is repeated).
uint16_t frameHostProcessingLatency;
// Receive time of first buffer. This value uses an implementation-defined epoch, // Receive time of first buffer. This value uses an implementation-defined epoch,
// but the same epoch as enqueueTimeMs and LiGetMillis(). // but the same epoch as enqueueTimeMs and LiGetMillis().
uint64_t receiveTimeMs; uint64_t receiveTimeMs;

10
src/VideoDepacketizer.c
View File

@ -16,6 +16,7 @@ static unsigned int lastPacketInStream;
static bool decodingFrame; static bool decodingFrame;
static bool strictIdrFrameWait; static bool strictIdrFrameWait;
static uint64_t syntheticPtsBase; static uint64_t syntheticPtsBase;
static uint16_t frameHostProcessingLatency;
static uint64_t firstPacketReceiveTime; static uint64_t firstPacketReceiveTime;
static unsigned int firstPacketPresentationTime; static unsigned int firstPacketPresentationTime;
static bool dropStatePending; static bool dropStatePending;
@ -64,6 +65,7 @@ void initializeVideoDepacketizer(int pktSize) {
lastPacketInStream = UINT32_MAX; lastPacketInStream = UINT32_MAX;
decodingFrame = false; decodingFrame = false;
syntheticPtsBase = 0; syntheticPtsBase = 0;
frameHostProcessingLatency = 0;
firstPacketReceiveTime = 0; firstPacketReceiveTime = 0;
firstPacketPresentationTime = 0; firstPacketPresentationTime = 0;
dropStatePending = false; dropStatePending = false;
@ -449,6 +451,7 @@ static void reassembleFrame(int frameNumber) {
qdu->decodeUnit.bufferList = nalChainHead; qdu->decodeUnit.bufferList = nalChainHead;
qdu->decodeUnit.fullLength = nalChainDataLength; qdu->decodeUnit.fullLength = nalChainDataLength;
qdu->decodeUnit.frameNumber = frameNumber; qdu->decodeUnit.frameNumber = frameNumber;
qdu->decodeUnit.frameHostProcessingLatency = frameHostProcessingLatency;
qdu->decodeUnit.receiveTimeMs = firstPacketReceiveTime; qdu->decodeUnit.receiveTimeMs = firstPacketReceiveTime;
qdu->decodeUnit.presentationTimeMs = firstPacketPresentationTime; qdu->decodeUnit.presentationTimeMs = firstPacketPresentationTime;
qdu->decodeUnit.enqueueTimeMs = LiGetMillis(); qdu->decodeUnit.enqueueTimeMs = LiGetMillis();
@ -834,6 +837,13 @@ static void processRtpPayload(PNV_VIDEO_PACKET videoPacket, int length,
} }
} }
// Sunshine can provide host processing latency of the frame
if (IS_SUNSHINE()) {
BYTE_BUFFER bb;
BbInitializeWrappedBuffer(&bb, currentPos.data, currentPos.offset + 1, 2, BYTE_ORDER_LITTLE);
BbGet16(&bb, &frameHostProcessingLatency);
}
if (APP_VERSION_AT_LEAST(7, 1, 450)) { if (APP_VERSION_AT_LEAST(7, 1, 450)) {
// >= 7.1.450 uses 2 different header lengths based on the first byte: // >= 7.1.450 uses 2 different header lengths based on the first byte:
// 0x01 indicates an 8 byte header // 0x01 indicates an 8 byte header