blob: 76e361d767a56b6c73fe454225da974949b43516 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
package se.leap.bitmaskclient.pluggableTransports;
import android.util.Log;
import java.util.Observable;
import java.util.Observer;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import client.Client_;
import de.blinkt.openvpn.core.ConnectionStatus;
import de.blinkt.openvpn.core.VpnStatus;
import se.leap.bitmaskclient.eip.EipStatus;
public class ObfsVpnClient implements Observer, client.EventLogger {
public static final AtomicInteger SOCKS_PORT = new AtomicInteger(4430);
public static final String SOCKS_IP = "127.0.0.1";
private static final String ERR_BIND = "bind: address already in use";
private static final String TAG = ObfsVpnClient.class.getSimpleName();
private volatile boolean noNetwork;
private final AtomicBoolean isErrorHandling = new AtomicBoolean(false);
private final AtomicInteger reconnectRetry = new AtomicInteger(0);
private static final int MAX_RETRY = 5;
private final client.Client_ obfsVpnClient;
private final Object LOCK = new Object();
public ObfsVpnClient(Obfs4Options options) {
obfsVpnClient = new Client_(options.udp, SOCKS_IP+":"+SOCKS_PORT.get(), options.cert);
obfsVpnClient.setEventLogger(this);
}
/**
* starts the client
* @return the port ObfsVpn is running on
*/
public int start() {
synchronized (LOCK) {
Log.d(TAG, "aquired LOCK");
new Thread(this::startSync).start();
waitUntilStarted();
Log.d(TAG, "returning LOCK after " + (reconnectRetry.get() + 1) * 200 +" ms");
}
return SOCKS_PORT.get();
}
private void waitUntilStarted() {
int count = -1;
try {
while (count < reconnectRetry.get() && reconnectRetry.get() < MAX_RETRY) {
Thread.sleep(200);
count++;
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
private void startSync() {
try {
obfsVpnClient.start();
} catch (Exception e) {
Log.e(TAG, "[obfsvpn] exception: " + e.getLocalizedMessage());
VpnStatus.logError("[obfsvpn] " + e.getLocalizedMessage());
if (e.getLocalizedMessage() != null && e.getLocalizedMessage().contains(ERR_BIND) && reconnectRetry.get() < MAX_RETRY) {
reconnectRetry.addAndGet(1);
SOCKS_PORT.addAndGet(1);
obfsVpnClient.setSocksAddr(SOCKS_IP+":"+SOCKS_PORT.get());
Log.d(TAG, "[obfsvpn] reconnecting on different port... " + SOCKS_PORT.get());
VpnStatus.logDebug("[obfsvpn] reconnecting on different port... " + SOCKS_PORT.get());
startSync();
} else if (noNetwork) {
isErrorHandling.set(true);
}
}
}
public void stop() {
synchronized (LOCK) {
Log.d(TAG, "stopping obfsVpnClient...");
try {
obfsVpnClient.stop();
reconnectRetry.set(0);
SOCKS_PORT.set(4430);
Thread.sleep(100);
} catch (Exception e) {
e.printStackTrace();
VpnStatus.logError("[obfsvpn] " + e.getLocalizedMessage());
}
isErrorHandling.set(false);
Log.d(TAG, "stopping obfsVpnClient releasing LOCK ...");
}
}
public boolean isStarted() {
return obfsVpnClient.isStarted();
}
@Override
public void update(Observable observable, Object arg) {
if (observable instanceof EipStatus) {
EipStatus status = (EipStatus) observable;
if (status.getLevel() == ConnectionStatus.LEVEL_NONETWORK) {
noNetwork = true;
} else {
noNetwork = false;
if (isErrorHandling.getAndSet(false)) {
stop();
start();
}
}
}
}
@Override
public void error(String s) {
VpnStatus.logError("[obfsvpn] " + s);
}
@Override
public void log(String state, String message) {
VpnStatus.logDebug("[obfsvpn] " + state + " " + message);
}
}
|
