moonlight-stream/moonlight-common-c
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-common-c.git synced 2025-08-17 17:05:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add support for handling alternate max packet sizes

Browse Source
This commit is contained in:
Cameron Gutman 2014-06-29 00:06:29 -07:00
parent a38e1f37eb
commit 8c8fcc7cbe
3 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
limelight-common/Limelight-internal.h
View File

@ -17,7 +17,7 @@ void connectionDetectedFrameLoss(int startFrame, int endFrame);
void connectionReceivedFrame(int frameIndex);
void connectionLostPackets(int lastReceivedPacket, int nextReceivedPacket);
void initializeVideoDepacketizer(void);
void initializeVideoDepacketizer(int pktSize);
void destroyVideoDepacketizer(void);
void processRtpPayload(PNV_VIDEO_PACKET videoPacket, int length);
int getNextDecodeUnit(PDECODE_UNIT *du);

10
limelight-common/VideoDepacketizer.c
View File

@ -15,17 +15,19 @@ static int gotNextFrameStart;
static int lastPacketInStream = 0;
static LINKED_BLOCKING_QUEUE decodeUnitQueue;
static int packetSize;
static unsigned short lastSequenceNumber;
typedef struct _BUFFER_DESC {
char* data;
int offset;
int length;
unsigned int offset;
unsigned int length;
} BUFFER_DESC, *PBUFFER_DESC;
void initializeVideoDepacketizer(void) {
void initializeVideoDepacketizer(int pktSize) {
LbqInitializeLinkedBlockingQueue(&decodeUnitQueue, 15);
packetSize = pktSize;
}
static void clearAvcNalState(void) {
@ -243,7 +245,7 @@ void processRtpPayload(PNV_VIDEO_PACKET videoPacket, int length) {
currentPos.offset = 0;
currentPos.length = length - sizeof(*videoPacket);
if (currentPos.length < 968) {
if (currentPos.length < packetSize - sizeof(NV_VIDEO_PACKET)) {
processRtpPayloadSlow(videoPacket, &currentPos);
return;
}

2
limelight-common/VideoStream.c
View File

@ -32,7 +32,7 @@ void initializeVideoStream(IP_ADDRESS host, PSTREAM_CONFIGURATION streamConfig,
LbqInitializeLinkedBlockingQueue(&packetQueue, 30);
initializeVideoDepacketizer();
initializeVideoDepacketizer(configuration.packetSize);
}
void destroyVideoStream(void) {