summaryrefslogtreecommitdiff
path: root/app/src/main/java/de/blinkt/openvpn/core/VpnStatus.java
diff options
context:
space:
mode:
Diffstat (limited to 'app/src/main/java/de/blinkt/openvpn/core/VpnStatus.java')
-rw-r--r--app/src/main/java/de/blinkt/openvpn/core/VpnStatus.java12
1 files changed, 5 insertions, 7 deletions
diff --git a/app/src/main/java/de/blinkt/openvpn/core/VpnStatus.java b/app/src/main/java/de/blinkt/openvpn/core/VpnStatus.java
index 5fbb440b..0fae6183 100644
--- a/app/src/main/java/de/blinkt/openvpn/core/VpnStatus.java
+++ b/app/src/main/java/de/blinkt/openvpn/core/VpnStatus.java
@@ -15,12 +15,10 @@ import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.LinkedList;
import java.util.Locale;
-import java.util.Queue;
import java.util.Vector;
-import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.concurrent.CopyOnWriteArrayList;
import se.leap.bitmaskclient.R;
-import de.blinkt.openvpn.VpnProfile;
public class VpnStatus {
@@ -28,7 +26,7 @@ public class VpnStatus {
private static final LinkedList<LogItem> logbuffer;
private static Vector<LogListener> logListener;
- private static Vector<StateListener> stateListener;
+ private static CopyOnWriteArrayList<StateListener> stateListener;
private static Vector<ByteCountListener> byteCountListener;
private static String mLaststatemsg = "";
@@ -200,7 +198,7 @@ public class VpnStatus {
static {
logbuffer = new LinkedList<>();
logListener = new Vector<>();
- stateListener = new Vector<>();
+ stateListener = new CopyOnWriteArrayList<>();
byteCountListener = new Vector<>();
trafficHistory = new TrafficHistory();
@@ -214,6 +212,7 @@ public class VpnStatus {
}
public interface StateListener {
+ String STATE_CONNECTRETRY = "CONNECTRETRY";
void updateState(String state, String logmessage, int localizedResId, ConnectionStatus level);
void setConnectedVPN(String uuid);
@@ -270,7 +269,7 @@ public class VpnStatus {
if (!stateListener.contains(sl)) {
stateListener.add(sl);
if (mLaststate != null)
- sl.updateState(mLaststate, mLaststatemsg, mLastStateresid, mLastLevel);
+ sl.updateState(mLaststate, mLaststatemsg, mLastStateresid, mLastLevel);
}
}
@@ -383,7 +382,6 @@ public class VpnStatus {
mLastStateresid = resid;
mLastLevel = level;
-
for (StateListener sl : stateListener) {
sl.updateState(state, msg, resid, level);
}