Merge branch 'master' into #66_remove_loggers_and_recorders_between_channel_restarts

This commit is contained in:
Denny
2017-01-08 04:44:53 -05:00
3 changed files with 36 additions and 9 deletions

View File

@@ -243,9 +243,18 @@ public class IcecastTCPAudioBroadcaster extends IcecastAudioBroadcaster
{
if(cause instanceof IOException && ((IOException)cause).getMessage().startsWith("Connection reset"))
{
mLog.info("Streaming connection reset by remote server - reestablishing connection");
disconnect();
connect();
IOException ioe = (IOException)cause;
if(ioe.getMessage() != null && ioe.getMessage().startsWith("Connection reset"))
{
mLog.info("Streaming connection reset by remote server - reestablishing connection");
disconnect();
connect();
}
else
{
mLog.error("IO Exception", ioe);
}
}
else
{

View File

@@ -244,9 +244,18 @@ public class ShoutcastV1AudioBroadcaster extends AudioBroadcaster
{
if(cause instanceof IOException && ((IOException)cause).getMessage().startsWith("Connection reset"))
{
mLog.info("Streaming connection reset by remote server - reestablishing connection");
disconnect();
connect();
IOException ioe = (IOException)cause;
if(ioe.getMessage() != null && ioe.getMessage().startsWith("Connection reset"))
{
mLog.info("Streaming connection reset by remote server - reestablishing connection");
disconnect();
connect();
}
else
{
mLog.error("IO Exception", ioe);
}
}
else
{

View File

@@ -370,9 +370,18 @@ public class ShoutcastV2AudioBroadcaster extends AudioBroadcaster implements IBr
{
if(cause instanceof IOException && ((IOException)cause).getMessage().startsWith("Connection reset"))
{
mLog.info("Streaming connection reset by remote server - reestablishing connection");
disconnect();
connect();
IOException ioe = (IOException)cause;
if(ioe.getMessage() != null && ioe.getMessage().startsWith("Connection reset"))
{
mLog.info("Streaming connection reset by remote server - reestablishing connection");
disconnect();
connect();
}
else
{
mLog.error("IO Exception", ioe);
}
}
else
{