Function added that allows to update VPN state via JNI
This commit is contained in:
@@ -90,6 +90,30 @@ static void dbg_android(debug_t group, level_t level, char *fmt, ...)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
METHOD(charonservice_t, update_status, bool,
|
||||||
|
private_charonservice_t *this, android_vpn_state_t code)
|
||||||
|
{
|
||||||
|
JNIEnv *env;
|
||||||
|
jmethodID method_id;
|
||||||
|
bool success = FALSE;
|
||||||
|
|
||||||
|
androidjni_attach_thread(&env);
|
||||||
|
|
||||||
|
method_id = (*env)->GetMethodID(env, android_charonvpnservice_class,
|
||||||
|
"updateStatus", "(I)V");
|
||||||
|
if (!method_id)
|
||||||
|
{
|
||||||
|
goto failed;
|
||||||
|
}
|
||||||
|
(*env)->CallVoidMethod(env, this->vpn_service, method_id, (jint)code);
|
||||||
|
success = !androidjni_exception_occurred(env);
|
||||||
|
|
||||||
|
failed:
|
||||||
|
androidjni_exception_occurred(env);
|
||||||
|
androidjni_detach_thread();
|
||||||
|
return success;
|
||||||
|
}
|
||||||
|
|
||||||
METHOD(charonservice_t, bypass_socket, bool,
|
METHOD(charonservice_t, bypass_socket, bool,
|
||||||
private_charonservice_t *this, int fd, int family)
|
private_charonservice_t *this, int fd, int family)
|
||||||
{
|
{
|
||||||
@@ -133,6 +157,7 @@ static void charonservice_init(JNIEnv *env, jobject service)
|
|||||||
|
|
||||||
INIT(this,
|
INIT(this,
|
||||||
.public = {
|
.public = {
|
||||||
|
.update_status = _update_status,
|
||||||
.bypass_socket = _bypass_socket,
|
.bypass_socket = _bypass_socket,
|
||||||
},
|
},
|
||||||
.vpn_service = (*env)->NewGlobalRef(env, service),
|
.vpn_service = (*env)->NewGlobalRef(env, service),
|
||||||
|
|||||||
@@ -30,8 +30,22 @@
|
|||||||
|
|
||||||
#include <library.h>
|
#include <library.h>
|
||||||
|
|
||||||
|
typedef enum android_vpn_state_t android_vpn_state_t;
|
||||||
typedef struct charonservice_t charonservice_t;
|
typedef struct charonservice_t charonservice_t;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* VPN status codes. As defined in CharonVpnService.java
|
||||||
|
*/
|
||||||
|
enum android_vpn_state_t {
|
||||||
|
CHARONSERVICE_CHILD_STATE_UP = 1,
|
||||||
|
CHARONSERVICE_CHILD_STATE_DOWN,
|
||||||
|
CHARONSERVICE_AUTH_ERROR,
|
||||||
|
CHARONSERVICE_PEER_AUTH_ERROR,
|
||||||
|
CHARONSERVICE_LOOKUP_ERROR,
|
||||||
|
CHARONSERVICE_UNREACHABLE_ERROR,
|
||||||
|
CHARONSERVICE_GENERIC_ERROR,
|
||||||
|
};
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Public interface of charonservice.
|
* Public interface of charonservice.
|
||||||
*
|
*
|
||||||
@@ -39,6 +53,14 @@ typedef struct charonservice_t charonservice_t;
|
|||||||
*/
|
*/
|
||||||
struct charonservice_t {
|
struct charonservice_t {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Update the status in the Java domain (UI)
|
||||||
|
*
|
||||||
|
* @param code status code
|
||||||
|
* @return TRUE on success
|
||||||
|
*/
|
||||||
|
bool (*update_status)(charonservice_t *this, android_vpn_state_t code);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Install a bypass policy for the given socket using the protect() Method
|
* Install a bypass policy for the given socket using the protect() Method
|
||||||
* of the Android VpnService interface
|
* of the Android VpnService interface
|
||||||
|
|||||||
@@ -64,6 +64,17 @@ public class CharonVpnService extends VpnService implements Runnable
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* as defined in charonservice.h
|
||||||
|
*/
|
||||||
|
static final int STATE_CHILD_SA_UP = 1;
|
||||||
|
static final int STATE_CHILD_SA_DOWN = 2;
|
||||||
|
static final int STATE_AUTH_ERROR = 3;
|
||||||
|
static final int STATE_PEER_AUTH_ERROR = 4;
|
||||||
|
static final int STATE_LOOKUP_ERROR = 5;
|
||||||
|
static final int STATE_UNREACHABLE_ERROR = 6;
|
||||||
|
static final int STATE_GENERIC_ERROR = 7;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public int onStartCommand(Intent intent, int flags, int startId)
|
public int onStartCommand(Intent intent, int flags, int startId)
|
||||||
{
|
{
|
||||||
@@ -253,6 +264,70 @@ public class CharonVpnService extends VpnService implements Runnable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Set an error on the state service and disconnect the current connection.
|
||||||
|
* This is not done by calling stopCurrentConnection() above, but instead
|
||||||
|
* is done asynchronously via state service.
|
||||||
|
*
|
||||||
|
* @param error error state
|
||||||
|
*/
|
||||||
|
private void setErrorDisconnect(ErrorState error)
|
||||||
|
{
|
||||||
|
synchronized (mServiceLock)
|
||||||
|
{
|
||||||
|
if (mService != null)
|
||||||
|
{
|
||||||
|
mService.setError(error);
|
||||||
|
mService.disconnect();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Updates the state of the current connection.
|
||||||
|
* Called via JNI by different threads (but not concurrently).
|
||||||
|
*
|
||||||
|
* @param status new state
|
||||||
|
*/
|
||||||
|
public void updateStatus(int status)
|
||||||
|
{
|
||||||
|
switch (status)
|
||||||
|
{
|
||||||
|
case STATE_CHILD_SA_DOWN:
|
||||||
|
synchronized (mServiceLock)
|
||||||
|
{
|
||||||
|
/* since this state is also reached when the SA is closed remotely,
|
||||||
|
* we call disconnect() to make sure charon is properly deinitialized */
|
||||||
|
if (mService != null)
|
||||||
|
{
|
||||||
|
mService.disconnect();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case STATE_CHILD_SA_UP:
|
||||||
|
setState(State.CONNECTED);
|
||||||
|
break;
|
||||||
|
case STATE_AUTH_ERROR:
|
||||||
|
setErrorDisconnect(ErrorState.AUTH_FAILED);
|
||||||
|
break;
|
||||||
|
case STATE_PEER_AUTH_ERROR:
|
||||||
|
setErrorDisconnect(ErrorState.PEER_AUTH_FAILED);
|
||||||
|
break;
|
||||||
|
case STATE_LOOKUP_ERROR:
|
||||||
|
setErrorDisconnect(ErrorState.LOOKUP_FAILED);
|
||||||
|
break;
|
||||||
|
case STATE_UNREACHABLE_ERROR:
|
||||||
|
setErrorDisconnect(ErrorState.UNREACHABLE);
|
||||||
|
break;
|
||||||
|
case STATE_GENERIC_ERROR:
|
||||||
|
setErrorDisconnect(ErrorState.GENERIC_ERROR);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
Log.e(TAG, "Unknown status code received");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Initialization of charon, provided by libandroidbridge.so
|
* Initialization of charon, provided by libandroidbridge.so
|
||||||
*/
|
*/
|
||||||
|
|||||||
Reference in New Issue
Block a user