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

Only allow input packets to be queued between start and stop

Browse Source
This commit is contained in:
Cameron Gutman 2020-08-06 19:12:29 -07:00
parent f6927475cf
commit 6010367637
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/InputStream.c
View File

@ -49,7 +49,6 @@ int initializeInputStream(void) {
LbqInitializeLinkedBlockingQueue(&packetQueue, 30); LbqInitializeLinkedBlockingQueue(&packetQueue, 30);
initialized = 1;
return 0; return 0;
} }
@ -72,8 +71,6 @@ void destroyInputStream(void) {
entry = nextEntry; entry = nextEntry;
} }
initialized = 0;
} }
static int addPkcs7PaddingInPlace(unsigned char* plaintext, int plaintextLen) { static int addPkcs7PaddingInPlace(unsigned char* plaintext, int plaintextLen) {
@ -423,6 +420,9 @@ int startInputStream(void) {
return err; return err;
} }
// Allow input packets to be queued now
initialized = 1;
// GFE will not send haptics events without this magic packet first // GFE will not send haptics events without this magic packet first
sendEnableHaptics(); sendEnableHaptics();
@ -431,6 +431,9 @@ int startInputStream(void) {
// Stops the input stream // Stops the input stream
int stopInputStream(void) { int stopInputStream(void) {
// No more packets should be queued now
initialized = 0;
// Signal the input send thread // Signal the input send thread
LbqSignalQueueShutdown(&packetQueue); LbqSignalQueueShutdown(&packetQueue);
PltInterruptThread(&inputSendThread); PltInterruptThread(&inputSendThread);