GitHub/sdrtrunk
1
0
Fork 0
mirror of https://github.com/DSheirer/sdrtrunk.git synced 2026-11-14 17:47:32 -05:00
Code Issues Packages Projects Releases 2 Wiki Activity

#808 Improves broadcastify calls socket reset exception handling. (#810)

Browse Source 
Co-authored-by: Denny <denny@denny-desktop>
This commit is contained in:
Denny Sheirer
2020-05-09 15:20:33 +00:00
committed by GitHub
parent af0dbf1566
commit 0d51b39604
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/io/github/dsheirer/audio/broadcast/broadcastify/BroadcastifyCallBroadcaster.java
View File

@@ -48,6 +48,7 @@ import java.net.http.HttpResponse;
import java.time.Duration; import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.Queue; import java.util.Queue;
import java.util.concurrent.CompletionException;
import java.util.concurrent.LinkedTransferQueue; import java.util.concurrent.LinkedTransferQueue;
import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@@ -240,14 +241,14 @@ public class BroadcastifyCallBroadcaster extends AbstractAudioBroadcaster<Broadc
.whenComplete((stringHttpResponse, throwable) -> { .whenComplete((stringHttpResponse, throwable) -> {
if(throwable != null || stringHttpResponse.statusCode() != 200) if(throwable != null || stringHttpResponse.statusCode() != 200)
{ {
if(throwable instanceof IOException) if(throwable instanceof IOException || throwable instanceof CompletionException)
{ {
//We get socket reset exceptions occasionally when the remote server doesn't //We get socket reset exceptions occasionally when the remote server doesn't
//fully read our request and immediately responds. //fully read our request and immediately responds.
} }
else else
{ {
mLog.error("Error while sending upload URL request", throwable); mLog.error("Error while sending upload URL request" + throwable.getLocalizedMessage());
setBroadcastState(BroadcastState.TEMPORARY_BROADCAST_ERROR); setBroadcastState(BroadcastState.TEMPORARY_BROADCAST_ERROR);
} }
incrementErrorAudioCount(); incrementErrorAudioCount();
@@ -284,7 +285,7 @@ public class BroadcastifyCallBroadcaster extends AbstractAudioBroadcaster<Broadc
.whenComplete((fileResponse, throwable1) -> { .whenComplete((fileResponse, throwable1) -> {
if(throwable1 != null || fileResponse.statusCode() != 200) if(throwable1 != null || fileResponse.statusCode() != 200)
{ {
if(throwable1 instanceof IOException) if(throwable1 instanceof IOException || throwable1 instanceof CompletionException)
{ {
//We get socket reset exceptions occasionally when the remote server doesn't //We get socket reset exceptions occasionally when the remote server doesn't
//fully read our request and immediately responds. //fully read our request and immediately responds.