Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/quite/humla.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDaniel Lublin <daniel@lublin.se>2020-04-23 16:36:31 +0300
committerDaniel Lublin <daniel@lublin.se>2020-04-23 16:36:31 +0300
commitd6103a3c40c38c805f949b9922fd1cf1be0ea64c (patch)
tree633d7fbd051ed9388531505d20c3849f647e9247
parentbd8d7e1ac5d15c4d9e9f609372a0e750a52f4944 (diff)
Catch some possible crashes
-rw-r--r--src/main/java/se/lublin/humla/net/HumlaConnection.java7
-rw-r--r--src/main/java/se/lublin/humla/protocol/AudioHandler.java5
2 files changed, 11 insertions, 1 deletions
diff --git a/src/main/java/se/lublin/humla/net/HumlaConnection.java b/src/main/java/se/lublin/humla/net/HumlaConnection.java
index 15e007c..57ff570 100644
--- a/src/main/java/se/lublin/humla/net/HumlaConnection.java
+++ b/src/main/java/se/lublin/humla/net/HumlaConnection.java
@@ -46,6 +46,7 @@ import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Executors;
+import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
@@ -136,7 +137,11 @@ public class HumlaConnection implements HumlaTCP.TCPConnectionListener, HumlaUDP
}
// Start TCP/UDP ping thread. FIXME is this the right place?
- mPingTask = mPingExecutorService.scheduleAtFixedRate(mPingRunnable, 0, 5, TimeUnit.SECONDS);
+ try {
+ mPingTask = mPingExecutorService.scheduleAtFixedRate(mPingRunnable, 0, 5, TimeUnit.SECONDS);
+ } catch(RejectedExecutionException e) {
+ Log.w(Constants.TAG, "HumlaConnection fail to start ping thread, in \"shutdown\"? ", e);
+ }
mSession = msg.getSession();
mMaxBandwidth = msg.hasMaxBandwidth() ? msg.getMaxBandwidth() : -1;
diff --git a/src/main/java/se/lublin/humla/protocol/AudioHandler.java b/src/main/java/se/lublin/humla/protocol/AudioHandler.java
index 3d6268c..716211b 100644
--- a/src/main/java/se/lublin/humla/protocol/AudioHandler.java
+++ b/src/main/java/se/lublin/humla/protocol/AudioHandler.java
@@ -206,6 +206,11 @@ public class AudioHandler extends HumlaNetworkListener implements AudioInput.Aud
mEncoder = null;
}
+ if (codec == null) {
+ Log.w(Constants.TAG, "AudioHandler setCodec(null) Input disabled.");
+ return;
+ }
+
IEncoder encoder;
switch (codec) {
case UDPVoiceCELTAlpha: