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

Add Video/Audio prefix to ThreadProc names

Browse Source 
It's easier to find them in stack traces that way.
This commit is contained in:
Cameron Gutman 2021-06-20 10:36:05 -05:00
parent eff97414bf
commit 75999a6e07
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/AudioStream.c
View File

@ -41,7 +41,7 @@ typedef struct _QUEUED_AUDIO_PACKET {
char data[MAX_PACKET_SIZE]; char data[MAX_PACKET_SIZE];
} QUEUED_AUDIO_PACKET, *PQUEUED_AUDIO_PACKET; } QUEUED_AUDIO_PACKET, *PQUEUED_AUDIO_PACKET;
static void UdpPingThreadProc(void* context) { static void AudioPingThreadProc(void* context) {
// Ping in ASCII // Ping in ASCII
char pingData[] = { 0x50, 0x49, 0x4E, 0x47 }; char pingData[] = { 0x50, 0x49, 0x4E, 0x47 };
LC_SOCKADDR saddr; LC_SOCKADDR saddr;
@ -93,7 +93,7 @@ int initializeAudioStream(void) {
// We may receive audio before our threads are started, but that's okay. We'll // We may receive audio before our threads are started, but that's okay. We'll
// drop the first 1 second of audio packets to catch up with the backlog. // drop the first 1 second of audio packets to catch up with the backlog.
int err = PltCreateThread("AudioPing", UdpPingThreadProc, NULL, &udpPingThread); int err = PltCreateThread("AudioPing", AudioPingThreadProc, NULL, &udpPingThread);
if (err != 0) { if (err != 0) {
closeSocket(rtpSocket); closeSocket(rtpSocket);
rtpSocket = INVALID_SOCKET; rtpSocket = INVALID_SOCKET;
@ -225,7 +225,7 @@ static void decodeInputData(PQUEUED_AUDIO_PACKET packet) {
} }
} }
static void ReceiveThreadProc(void* context) { static void AudioReceiveThreadProc(void* context) {
PRTP_PACKET rtp; PRTP_PACKET rtp;
PQUEUED_AUDIO_PACKET packet; PQUEUED_AUDIO_PACKET packet;
int queueStatus; int queueStatus;
@ -369,7 +369,7 @@ static void ReceiveThreadProc(void* context) {
} }
} }
static void DecoderThreadProc(void* context) { static void AudioDecoderThreadProc(void* context) {
int err; int err;
PQUEUED_AUDIO_PACKET packet; PQUEUED_AUDIO_PACKET packet;
@ -438,7 +438,7 @@ int startAudioStream(void* audioContext, int arFlags) {
AudioCallbacks.start(); AudioCallbacks.start();
err = PltCreateThread("AudioRecv", ReceiveThreadProc, NULL, &receiveThread); err = PltCreateThread("AudioRecv", AudioReceiveThreadProc, NULL, &receiveThread);
if (err != 0) { if (err != 0) {
AudioCallbacks.stop(); AudioCallbacks.stop();
closeSocket(rtpSocket); closeSocket(rtpSocket);
@ -447,7 +447,7 @@ int startAudioStream(void* audioContext, int arFlags) {
} }
if ((AudioCallbacks.capabilities & CAPABILITY_DIRECT_SUBMIT) == 0) { if ((AudioCallbacks.capabilities & CAPABILITY_DIRECT_SUBMIT) == 0) {
err = PltCreateThread("AudioDec", DecoderThreadProc, NULL, &decoderThread); err = PltCreateThread("AudioDec", AudioDecoderThreadProc, NULL, &decoderThread);
if (err != 0) { if (err != 0) {
AudioCallbacks.stop(); AudioCallbacks.stop();
PltInterruptThread(&receiveThread); PltInterruptThread(&receiveThread);

12
src/VideoStream.c
View File

@ -43,7 +43,7 @@ void destroyVideoStream(void) {
} }
// UDP Ping proc // UDP Ping proc
static void UdpPingThreadProc(void* context) { static void VideoPingThreadProc(void* context) {
char pingData[] = { 0x50, 0x49, 0x4E, 0x47 }; char pingData[] = { 0x50, 0x49, 0x4E, 0x47 };
LC_SOCKADDR saddr; LC_SOCKADDR saddr;
@ -62,7 +62,7 @@ static void UdpPingThreadProc(void* context) {
} }
// Receive thread proc // Receive thread proc
static void ReceiveThreadProc(void* context) { static void VideoReceiveThreadProc(void* context) {
int err; int err;
int bufferSize, receiveSize; int bufferSize, receiveSize;
char* buffer; char* buffer;
@ -160,7 +160,7 @@ void notifyKeyFrameReceived(void) {
} }
// Decoder thread proc // Decoder thread proc
static void DecoderThreadProc(void* context) { static void VideoDecoderThreadProc(void* context) {
while (!PltIsThreadInterrupted(&decoderThread)) { while (!PltIsThreadInterrupted(&decoderThread)) {
VIDEO_FRAME_HANDLE frameHandle; VIDEO_FRAME_HANDLE frameHandle;
PDECODE_UNIT decodeUnit; PDECODE_UNIT decodeUnit;
@ -252,7 +252,7 @@ int startVideoStream(void* rendererContext, int drFlags) {
VideoCallbacks.start(); VideoCallbacks.start();
err = PltCreateThread("VideoRecv", ReceiveThreadProc, NULL, &receiveThread); err = PltCreateThread("VideoRecv", VideoReceiveThreadProc, NULL, &receiveThread);
if (err != 0) { if (err != 0) {
VideoCallbacks.stop(); VideoCallbacks.stop();
closeSocket(rtpSocket); closeSocket(rtpSocket);
@ -261,7 +261,7 @@ int startVideoStream(void* rendererContext, int drFlags) {
} }
if ((VideoCallbacks.capabilities & (CAPABILITY_DIRECT_SUBMIT | CAPABILITY_PULL_RENDERER)) == 0) { if ((VideoCallbacks.capabilities & (CAPABILITY_DIRECT_SUBMIT | CAPABILITY_PULL_RENDERER)) == 0) {
err = PltCreateThread("VideoDec", DecoderThreadProc, NULL, &decoderThread); err = PltCreateThread("VideoDec", VideoDecoderThreadProc, NULL, &decoderThread);
if (err != 0) { if (err != 0) {
VideoCallbacks.stop(); VideoCallbacks.stop();
PltInterruptThread(&receiveThread); PltInterruptThread(&receiveThread);
@ -300,7 +300,7 @@ int startVideoStream(void* rendererContext, int drFlags) {
// Start pinging before reading the first frame so GFE knows where // Start pinging before reading the first frame so GFE knows where
// to send UDP data // to send UDP data
err = PltCreateThread("VideoPing", UdpPingThreadProc, NULL, &udpPingThread); err = PltCreateThread("VideoPing", VideoPingThreadProc, NULL, &udpPingThread);
if (err != 0) { if (err != 0) {
VideoCallbacks.stop(); VideoCallbacks.stop();
stopVideoDepacketizer(); stopVideoDepacketizer();