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

Pass the correct socket error to connectionTerminated()

Browse Source
This commit is contained in:
Cameron Gutman
2014-03-29 21:55:05 -04:00
committed by Michelle Bergeron
parent 761f324465
commit 61909b373f
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
limelight-common/AudioStream.c
+2 -2
View File
@@ -54,7 +54,7 @@ static void UdpPingThreadProc(void *context) {
err = sendto(rtpSocket, pingData, sizeof(pingData), 0, (struct sockaddr*)&saddr, sizeof(saddr)); err = sendto(rtpSocket, pingData, sizeof(pingData), 0, (struct sockaddr*)&saddr, sizeof(saddr));
if (err != sizeof(pingData)) { if (err != sizeof(pingData)) {
Limelog("UDP ping thread terminating #1\n"); Limelog("UDP ping thread terminating #1\n");
listenerCallbacks->connectionTerminated(err); listenerCallbacks->connectionTerminated(LastSocketError());
return; return;
} }
@@ -77,7 +77,7 @@ static void ReceiveThreadProc(void* context) {
if (err <= 0) { if (err <= 0) {
Limelog("Receive thread terminating #2\n"); Limelog("Receive thread terminating #2\n");
free(buffer); free(buffer);
listenerCallbacks->connectionTerminated(err); listenerCallbacks->connectionTerminated(LastSocketError());
return; return;
} }
limelight-common/VideoStream.c
+2 -2
View File
@@ -66,7 +66,7 @@ static void UdpPingThreadProc(void *context) {
err = sendto(rtpSocket, pingData, sizeof(pingData), 0, (struct sockaddr*)&saddr, sizeof(saddr)); err = sendto(rtpSocket, pingData, sizeof(pingData), 0, (struct sockaddr*)&saddr, sizeof(saddr));
if (err != sizeof(pingData)) { if (err != sizeof(pingData)) {
Limelog("UDP ping thread terminating #1\n"); Limelog("UDP ping thread terminating #1\n");
listenerCallbacks->connectionTerminated(err); listenerCallbacks->connectionTerminated(LastSocketError());
return; return;
} }
@@ -89,7 +89,7 @@ static void ReceiveThreadProc(void* context) {
if (err <= 0) { if (err <= 0) {
Limelog("Receive thread terminating #2\n"); Limelog("Receive thread terminating #2\n");
free(buffer); free(buffer);
listenerCallbacks->connectionTerminated(err); listenerCallbacks->connectionTerminated(LastSocketError());
return; return;
} }