Team2890/allwpilib
4
0
Fork 0
mirror of https://github.com/wpilibsuite/allwpilib synced 2026-06-23 01:21:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Adds connection listeners that can be called statically (#111)

Browse Source 
This way you can have a connection listener before initializing NetworkTables.
This commit is contained in:
Thad House
2016-09-06 21:30:59 -07:00
committed by Peter Johnson
parent fc48944b47
commit 3888d7726a
1 changed files with 37 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
java/src/edu/wpi/first/wpilibj/networktables/NetworkTable.java
View File

@@ -223,11 +223,11 @@ public class NetworkTable implements ITable, IRemote {
return !client;
}
private class ListenerBase {
private static class ListenerBase {
public int uid;
}
private class ConnectionListenerAdapter extends ListenerBase implements NetworkTablesJNI.ConnectionListenerFunction {
private static class ConnectionListenerAdapter extends ListenerBase implements NetworkTablesJNI.ConnectionListenerFunction {
private final IRemote targetSource;
private final IRemoteConnectionListener targetListener;
@@ -243,6 +243,41 @@ public class NetworkTable implements ITable, IRemote {
targetListener.disconnectedEx(targetSource, conn);
}
}
private static IRemote staticRemote = new IRemote() {
public void addConnectionListener(IRemoteConnectionListener listener, boolean immediateNotify) {
NetworkTable.addGlobalConnectionListener(listener, immediateNotify);
}
public void removeConnectionListener(IRemoteConnectionListener listener) {
NetworkTable.removeGlobalConnectionListener(listener);
}
public boolean isConnected() {
ConnectionInfo[] conns = NetworkTablesJNI.getConnections();
return conns.length > 0;
}
public boolean isServer() {
return !client;
}
};
private static final Hashtable<IRemoteConnectionListener,ConnectionListenerAdapter> globalConnectionListenerMap = new Hashtable<IRemoteConnectionListener,ConnectionListenerAdapter>();
public static synchronized void addGlobalConnectionListener(IRemoteConnectionListener listener,
boolean immediateNotify) {
ConnectionListenerAdapter adapter = globalConnectionListenerMap.get(listener);
if (adapter != null)
throw new IllegalStateException("Cannot add the same listener twice");
adapter = new ConnectionListenerAdapter(staticRemote, listener);
adapter.uid = NetworkTablesJNI.addConnectionListener(adapter, immediateNotify);
globalConnectionListenerMap.put(listener, adapter);
}
public static synchronized void removeGlobalConnectionListener(IRemoteConnectionListener listener) {
ConnectionListenerAdapter adapter = globalConnectionListenerMap.get(listener);
if (adapter != null) {
NetworkTablesJNI.removeConnectionListener(adapter.uid);
globalConnectionListenerMap.remove(listener);
}
}
private final Hashtable<IRemoteConnectionListener,ConnectionListenerAdapter> connectionListenerMap = new Hashtable<IRemoteConnectionListener,ConnectionListenerAdapter>();
public synchronized void addConnectionListener(IRemoteConnectionListener listener,