Modify all plugins to include a rescanControllers method.

main
sigonasr2, Sig, Sigo 3 years ago
parent b374f106c7
commit 243fb16c45
  1. 30
      src/core/net/java/games/input/ControllerEnvironment.java
  2. 160
      src/core/net/java/games/input/DefaultControllerEnvironment.java
  3. 4
      src/plugins/linux/net/java/games/input/LinuxEnvironmentPlugin.java
  4. 5
      src/plugins/windows/net/java/games/input/DirectAndRawInputEnvironmentPlugin.java
  5. 4
      src/plugins/windows/net/java/games/input/DirectInputEnvironmentPlugin.java
  6. 5
      src/plugins/windows/net/java/games/input/RawInputEnvironmentPlugin.java
  7. 11
      src/plugins/wintab/net/java/games/input/WinTabEnvironmentPlugin.java

@ -37,13 +37,8 @@
*
*****************************************************************************/
package net.java.games.input;
import java.io.File;
import java.security.AccessController;
import java.security.PrivilegedAction;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
@ -71,6 +66,9 @@ import java.util.logging.Logger;
*
*/
public abstract class ControllerEnvironment {
static void logln(String msg) {
log(msg + "\n");
}
static void log(String msg) {
Logger.getLogger(ControllerEnvironment.class.getName()).info(msg);
@ -85,17 +83,12 @@ public abstract class ControllerEnvironment {
/**
* List of controller listeners
*/
protected final ArrayList<ControllerListener> controllerListeners = new ArrayList<>();
protected final ArrayList controllerListeners = new ArrayList();
/**
* Protected constructor for subclassing.
*/
protected ControllerEnvironment() {
if(System.getProperty("jinput.loglevel") != null) {
String loggerName = ControllerEnvironment.class.getPackage().getName();
Level level = Level.parse(System.getProperty("jinput.loglevel"));
Logger.getLogger(loggerName).setLevel(level);
}
}
/**
@ -103,6 +96,11 @@ public abstract class ControllerEnvironment {
* or an empty array if there are no controllers in this environment.
*/
public abstract Controller[] getControllers();
/**
* Rescans the devices and provides a list of new controllers.
* @return a list of all controllers available to this environment.
*/
public abstract Controller[] rescanControllers();
/**
* Adds a listener for controller state change events.
@ -133,9 +131,9 @@ public abstract class ControllerEnvironment {
*/
protected void fireControllerAdded(Controller c) {
ControllerEvent ev = new ControllerEvent(c);
Iterator<ControllerListener> it = controllerListeners.iterator();
Iterator it = controllerListeners.iterator();
while (it.hasNext()) {
it.next().controllerAdded(ev);
((ControllerListener)it.next()).controllerAdded(ev);
}
}
@ -145,9 +143,9 @@ public abstract class ControllerEnvironment {
*/
protected void fireControllerRemoved(Controller c) {
ControllerEvent ev = new ControllerEvent(c);
Iterator<ControllerListener> it = controllerListeners.iterator();
Iterator it = controllerListeners.iterator();
while (it.hasNext()) {
it.next().controllerRemoved(ev);
((ControllerListener)it.next()).controllerRemoved(ev);
}
}
@ -158,4 +156,4 @@ public abstract class ControllerEnvironment {
public static ControllerEnvironment getDefaultEnvironment() {
return defaultEnvironment;
}
}
} // ControllerEnvironment

@ -1,4 +1,10 @@
/*
* %W% %E%
*
* Copyright 2002 Sun Microsystems, Inc. All rights reserved.
* SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
*/
/*****************************************************************************
* Copyright (c) 2003 Sun Microsystems, Inc. All Rights Reserved.
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
@ -29,20 +35,24 @@
* You acknowledge that this software is not designed or intended for us in
* the design, construction, operation or maintenance of any nuclear facility
*
*/
*****************************************************************************/
package net.java.games.input;
import net.java.games.util.plugins.Plugins;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.lang.reflect.Method;
import java.security.AccessController;
import java.security.PrivilegedAction;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.Properties;
import java.util.StringTokenizer;
import java.util.logging.Logger;
import net.java.games.util.plugins.*;
/**
* The default controller environment.
*
@ -62,23 +72,34 @@ class DefaultControllerEnvironment extends ControllerEnvironment {
*
*/
static void loadLibrary(final String lib_name) {
AccessController.doPrivileged((PrivilegedAction<String>) () -> {
AccessController.doPrivileged(
new PrivilegedAction() {
public final Object run() {
String lib_path = System.getProperty("net.java.games.input.librarypath");
if (lib_path != null)
System.load(lib_path + File.separator + System.mapLibraryName(lib_name));
else
System.loadLibrary(lib_name);
return null;
}
});
}
static String getPrivilegedProperty(final String property) {
return AccessController.doPrivileged((PrivilegedAction<String>) () -> System.getProperty(property));
return (String)AccessController.doPrivileged(new PrivilegedAction() {
public Object run() {
return System.getProperty(property);
}
});
}
static String getPrivilegedProperty(final String property, final String default_value) {
return AccessController.doPrivileged((PrivilegedAction<String>) () -> System.getProperty(property, default_value));
return (String)AccessController.doPrivileged(new PrivilegedAction() {
public Object run() {
return System.getProperty(property, default_value);
}
});
}
/**
@ -86,7 +107,8 @@ class DefaultControllerEnvironment extends ControllerEnvironment {
*/
private ArrayList<Controller> controllers;
private Collection<String> loadedPluginNames = new ArrayList<>();
private Collection loadedPlugins = new ArrayList();
private ArrayList<ControllerEnvironment> environments = new ArrayList<ControllerEnvironment>();
/**
* Public no-arg constructor.
@ -98,25 +120,16 @@ class DefaultControllerEnvironment extends ControllerEnvironment {
* Returns a list of all controllers available to this environment,
* or an empty array if there are no controllers in this environment.
*/
public Controller[] getControllers()
{
reloadControllers();
Controller[] ret = new Controller[controllers.size()];
Iterator<Controller> it = controllers.iterator();
int i = 0;
while (it.hasNext())
{
ret[i] = it.next();
i++;
}
return ret;
public Controller[] getControllers() {
if (controllers == null) {
// Controller list has not been scanned.
controllers = new ArrayList<Controller>();
AccessController.doPrivileged(new PrivilegedAction() {
public Object run() {
scanControllers();
return null;
}
private void reloadControllers()
{
controllers = new ArrayList<>();
AccessController.doPrivileged((PrivilegedAction<Void>) () -> scanControllers());
});
//Check the properties for specified controller classes
String pluginClasses = getPrivilegedProperty("jinput.plugins", "") + " " + getPrivilegedProperty("net.java.games.input.plugins", "");
if(!getPrivilegedProperty("jinput.useDefaultPlugin", "true").toLowerCase().trim().equals("false") && !getPrivilegedProperty("net.java.games.input.useDefaultPlugin", "true").toLowerCase().trim().equals("false")) {
@ -125,7 +138,7 @@ class DefaultControllerEnvironment extends ControllerEnvironment {
pluginClasses = pluginClasses + " net.java.games.input.LinuxEnvironmentPlugin";
} else if(osName.equals("Mac OS X")) {
pluginClasses = pluginClasses + " net.java.games.input.OSXEnvironmentPlugin";
} else if(osName.equals("Windows XP") || osName.equals("Windows Vista") || osName.equals("Windows 7") || osName.equals("Windows 8") || osName.equals("Windows 8.1") || osName.equals("Windows 10")) {
} else if(osName.equals("Windows XP") || osName.equals("Windows Vista") || osName.equals("Windows 7")) {
pluginClasses = pluginClasses + " net.java.games.input.DirectAndRawInputEnvironmentPlugin";
} else if(osName.equals("Windows 98") || osName.equals("Windows 2000")) {
pluginClasses = pluginClasses + " net.java.games.input.DirectInputEnvironmentPlugin";
@ -142,23 +155,94 @@ class DefaultControllerEnvironment extends ControllerEnvironment {
while(pluginClassTok.hasMoreTokens()) {
String className = pluginClassTok.nextToken();
try {
if(!loadedPlugins.contains(className)) {
log.fine("Loading: " + className);
Class<?> ceClass = Class.forName(className);
ControllerEnvironment ce = (ControllerEnvironment) ceClass.getDeclaredConstructor().newInstance();
Class ceClass = Class.forName(className);
ControllerEnvironment ce = (ControllerEnvironment) ceClass.newInstance();
if(ce.isSupported()) {
environments.add(ce);
addControllers(ce.getControllers());
loadedPluginNames.add(ce.getClass().getName());
loadedPlugins.add(ce.getClass().getName());
} else {
log(ceClass.getName() + " is not supported");
logln(ceClass.getName() + " is not supported");
}
}
} catch (Throwable e) {
e.printStackTrace();
}
}
}
if(!environments.isEmpty()){
Controller[] newScanControllers = environments.get(0).getControllers();
Controller[] ret = new Controller[newScanControllers.length];
for(int i = 0; i < newScanControllers.length; i++){
ret[i] = newScanControllers[i];
}
return ret;
}
Controller[] ret = new Controller[controllers.size()];
Iterator<Controller> it = controllers.iterator();
int i = 0;
while (it.hasNext()) {
ret[i] = (Controller)it.next();
i++;
}
return ret;
}
/**
* Returns a list of all controllers available to this environment,
* or an empty array if there are no controllers in this environment.
*/
public Controller[] rescanControllers() {
if(!environments.isEmpty()){
Controller[] newScanControllers = environments.get(0).rescanControllers();
// need to add controllers that were connected
for(int i = 0; i < newScanControllers.length; i++){
boolean controllerExist = false;
for(Controller controller:controllers){
if(newScanControllers[i] == controller){
controllerExist = true;
break;
}
}
if(!controllerExist){
controllers.add(newScanControllers[i]);
}
}
ArrayList<Controller> removeControllers = new ArrayList<Controller>();
// need to remove controllers that have disconnected
for(Controller controller:controllers){
boolean controllerExist = false;
for(int i = 0; i < newScanControllers.length; i++){
if(controller == newScanControllers[i]){
controllerExist = true;
break;
}
}
if(!controllerExist){
//controllers.remove(controller);
removeControllers.add(controller);
}
}
for(Controller controller: removeControllers){
controllers.remove(controller);
}
}
Controller[] ret = new Controller[controllers.size()];
Iterator<Controller> it = controllers.iterator();
int i = 0;
while (it.hasNext()) {
ret[i] = (Controller)it.next();
i++;
}
return ret;
}
/* This is jeff's new plugin code using Jeff's Plugin manager */
private Void scanControllers() {
private void scanControllers() {
String pluginPathName = getPrivilegedProperty("jinput.controllerPluginPath");
if(pluginPathName == null) {
pluginPathName = "controller";
@ -168,8 +252,6 @@ class DefaultControllerEnvironment extends ControllerEnvironment {
File.separator + "lib"+File.separator + pluginPathName);
scanControllersAt(getPrivilegedProperty("user.dir")+
File.separator + pluginPathName);
return null;
}
private void scanControllersAt(String path) {
@ -179,19 +261,19 @@ class DefaultControllerEnvironment extends ControllerEnvironment {
}
try {
Plugins plugins = new Plugins(file);
@SuppressWarnings("unchecked")
Class<ControllerEnvironment>[] envClasses = plugins.getExtends(ControllerEnvironment.class);
Class[] envClasses = plugins.getExtends(ControllerEnvironment.class);
for(int i=0;i<envClasses.length;i++){
try {
ControllerEnvironment.log("ControllerEnvironment "+
ControllerEnvironment.logln("ControllerEnvironment "+
envClasses[i].getName()
+" loaded by "+envClasses[i].getClassLoader());
ControllerEnvironment ce = envClasses[i].getDeclaredConstructor().newInstance();
ControllerEnvironment ce = (ControllerEnvironment)
envClasses[i].newInstance();
if(ce.isSupported()) {
addControllers(ce.getControllers());
loadedPluginNames.add(ce.getClass().getName());
loadedPlugins.add(ce.getClass().getName());
} else {
log(envClasses[i].getName() + " is not supported");
logln(envClasses[i].getName() + " is not supported");
}
} catch (Throwable e) {
e.printStackTrace();

@ -121,6 +121,10 @@ public final class LinuxEnvironmentPlugin extends ControllerEnvironment implemen
return controllers;
}
public final Controller[] rescanControllers() {
return enumerateControllers();
}
private final static Component[] createComponents(List<LinuxEventComponent> event_components, LinuxEventDevice device) {
LinuxEventComponent[][] povs = new LinuxEventComponent[4][2];
List<LinuxComponent> components = new ArrayList<>();

@ -84,6 +84,11 @@ public class DirectAndRawInputEnvironmentPlugin extends ControllerEnvironment {
return controllers;
}
public final Controller[] rescanControllers() {
controllers=null;
return getControllers();
}
/**
* @see net.java.games.input.ControllerEnvironment#isSupported()
*/

@ -138,6 +138,10 @@ public final class DirectInputEnvironmentPlugin extends ControllerEnvironment im
return controllers;
}
public Controller[] rescanControllers() {
return enumControllers(window);
}
private final Component[] createComponents(IDirectInputDevice device, boolean map_mouse_buttons) {
List<DIDeviceObject> device_objects = device.getObjects();
List<DIComponent> controller_components = new ArrayList<>();

@ -121,6 +121,11 @@ public final class RawInputEnvironmentPlugin extends ControllerEnvironment imple
return controllers;
}
public Controller[] rescanControllers() {
RawInputEventQueue queue = new RawInputEventQueue();
return enumControllers(queue);
}
private final static SetupAPIDevice lookupSetupAPIDevice(String device_name, List<SetupAPIDevice> setupapi_devices) {
/* First, replace # with / in the device name, since that
* seems to be the format in raw input device name

@ -120,12 +120,19 @@ public class WinTabEnvironmentPlugin extends ControllerEnvironment implements Pl
return controllers;
}
public Controller[] rescanControllers() {
winTabContext.close();
winTabContext = new WinTabContext(window);
winTabContext.open();
return winTabContext.getControllers();
}
private final class ShutdownHook extends Thread {
public final void run() {
/* Release the devices to kill off active force feedback effects */
for (int i = 0; i < active_devices.size(); i++) {
/*for (int i = 0; i < active_devices.size(); i++) {
// TODO free the devices
}
}*/
//Close the context
winTabContext.close();
/* We won't release the window since it is

Loading…
Cancel
Save