5290fe3f31
git-svn-id: http://wiiusej.googlecode.com/svn/trunk@59 ae48ae66-6a45-0410-b38e-211266189506
468 lines
14 KiB
Java
468 lines
14 KiB
Java
package wiiusej;
|
|
|
|
import java.util.concurrent.ConcurrentLinkedQueue;
|
|
import java.util.concurrent.atomic.AtomicBoolean;
|
|
|
|
import javax.swing.event.EventListenerList;
|
|
|
|
import wiiusej.wiiuseapievents.EventsGatherer;
|
|
import wiiusej.wiiuseapievents.WiiUseApiEvent;
|
|
import wiiusej.wiiuseapievents.WiiUseApiListener;
|
|
import wiiusej.wiiuseapirequest.FloatValueRequest;
|
|
import wiiusej.wiiuseapirequest.IntValueRequest;
|
|
import wiiusej.wiiuseapirequest.LedsRequest;
|
|
import wiiusej.wiiuseapirequest.WiiUseApiRequest;
|
|
|
|
/**
|
|
* Class that manage the use of Wiiuse API.
|
|
*
|
|
* @author gduche
|
|
*
|
|
*/
|
|
public class WiiUseApiManager extends Thread {
|
|
|
|
private static WiiUseApiManager instance = new WiiUseApiManager();
|
|
|
|
private final EventListenerList listeners = new EventListenerList();
|
|
|
|
private Wiimote[] wiimotes;
|
|
|
|
private WiiUseApi wiiuse = WiiUseApi.getInstance();
|
|
|
|
private int connected = -1;
|
|
|
|
private int nbMaxWiimotes = -1;
|
|
|
|
private AtomicBoolean running = new AtomicBoolean(false);
|
|
|
|
private ConcurrentLinkedQueue<WiiUseApiRequest> requests = new ConcurrentLinkedQueue<WiiUseApiRequest>();
|
|
|
|
public static WiiUseApiManager getInstance() {
|
|
return instance;
|
|
}
|
|
|
|
/**
|
|
* Get wiimotes. Load library if necessary. Connect to wiimotes if
|
|
* necessary. Start polling if necessary. Return an array with the connected
|
|
* wiimotes.
|
|
*
|
|
* @param nb
|
|
* try to connect nb wiimotes
|
|
* @return an array with connected wiimotes or NULL.
|
|
*/
|
|
public static Wiimote[] getWiimotes(int nb) {
|
|
WiiUseApiManager manager = getInstance();
|
|
if (manager.connected < 0) {
|
|
int nbWiimotes = manager.connectWiimotes(nb);
|
|
manager.wiimotes = new Wiimote[nbWiimotes];
|
|
for (int i = 1; i <= nbWiimotes; i++) {
|
|
Wiimote wim = new Wiimote(i, manager);
|
|
manager.wiimotes[i-1] = wim;
|
|
manager.addWiiUseApiListener(wim);
|
|
}
|
|
}
|
|
|
|
if (manager.connected == 0) {
|
|
return new Wiimote[0];
|
|
}
|
|
|
|
if (!manager.isAlive())
|
|
manager.start();
|
|
|
|
return manager.wiimotes;
|
|
}
|
|
|
|
/**
|
|
* Connect wiimote and get the number of wiimotes connected. Supposed to be
|
|
* used once.
|
|
*
|
|
* @param nb
|
|
* try to connect nb wiimotes
|
|
* @return 0 if nothing connected or the number of wiimotes connected.
|
|
*/
|
|
public int connectWiimotes(int nb) {
|
|
nbMaxWiimotes = nb;
|
|
if (connected < 0) {
|
|
connected = wiiuse.doConnections(nb);
|
|
// @TODO
|
|
System.out.println(connected + " wiimote(s) connected !!!");
|
|
return connected;
|
|
} else {// library not loaded, no wiimotes connected
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Ask the thread to close a connection.
|
|
*
|
|
* @param id
|
|
* id of the wiimote to disconnect.
|
|
*/
|
|
public void closeConnection(int id) {
|
|
removeWiiUseApiListener(wiimotes[id-1]);
|
|
wiimotes[id-1] = null;
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_CLOSE_CONNECTION_REQUEST));
|
|
System.out.println("Wiimote " + id + " disconnected !");
|
|
}
|
|
|
|
/**
|
|
* Get the number of wiimotes connected.
|
|
*
|
|
* @return the number of wiimotes connected.
|
|
*/
|
|
public int getNbConnectedWiimotes() {
|
|
return connected;
|
|
}
|
|
|
|
/**
|
|
* Stop thread and shutdown wiiuse Api.
|
|
*/
|
|
public void shutdown() {
|
|
running.set(false);
|
|
wiiuse.shutdownApi();
|
|
}
|
|
|
|
/**
|
|
* Activate the rumble for the wiimote with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void activateRumble(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ACTIVATE_RUMBLE_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Deactivate the rumble for the wiimote with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void deactivateRumble(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_DEACTIVATE_RUMBLE_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Activate IR Tracking for the wiimote with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void activateIRTRacking(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ACTIVATE_IR_TRACKING_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Deactivate IR Tracking for the wiimote with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void deactivateIRTRacking(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_DEACTIVATE_IR_TRACKING_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Activate motion sensing for the wiimote with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void activateMotionSensing(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ACTIVATE_MOTION_SENSING_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Deactivate motion sensing for the wiimoter with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void deactivateMotionSensing(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_DEACTIVATE_MOTION_SENSING_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Activate smoothing the wiimotes with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void activateSmoothing(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ACTIVATE_SMOOTHING_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Deactivate smoothing the wiimotes with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void deactivateSmoothing(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_DEACTIVATE_SMOOTHING_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Activate continuous for the wiimotes with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote.
|
|
*/
|
|
public void activateContinuous(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ACTIVATE_CONTINUOUS_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Deactivate continuous for the wiimotes with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote
|
|
*/
|
|
public void deactivateContinuous(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_DEACTIVATE_CONTINUOUS_REQUEST));
|
|
}
|
|
|
|
/**
|
|
* Set leds for the wiimotes with the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote
|
|
* @param l1
|
|
* status of led1. True : ON, False : OFF
|
|
* @param l2
|
|
* status of led2. True : ON, False : OFF
|
|
* @param l3
|
|
* status of led3. True : ON, False : OFF
|
|
* @param l4
|
|
* status of led4. True : ON, False : OFF
|
|
*/
|
|
public void setLeds(int id, boolean l1, boolean l2, boolean l3, boolean l4) {
|
|
requests.add(new LedsRequest(id, WiiUseApiRequest.WIIUSE_LEDS_REQUEST,
|
|
l1, l2, l3, l4));
|
|
}
|
|
|
|
/**
|
|
* Set the orientation threshold for the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote
|
|
* @param th
|
|
* threshold in degrees
|
|
*/
|
|
public void setOrientationThreshold(int id, float th) {
|
|
requests.add(new FloatValueRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ORIENT_THRESHOLHD_REQUEST, th));
|
|
}
|
|
|
|
/**
|
|
* Set the acceleration threshold for the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote
|
|
* @param th
|
|
* threshold
|
|
*/
|
|
public void setAccelerationThreshold(int id, int th) {
|
|
requests.add(new IntValueRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ACCEL_THRESHOLHD_REQUEST, th));
|
|
}
|
|
|
|
/**
|
|
* Set alpha smoothing for the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote
|
|
* @param th
|
|
* threshold
|
|
*/
|
|
public void setAlphaSmoothing(int id, float th) {
|
|
requests.add(new FloatValueRequest(id,
|
|
WiiUseApiRequest.WIIUSE_ALPHA_SMOOTHING_REQUEST, th));
|
|
}
|
|
|
|
/**
|
|
* Try to resync with the wiimote by starting a new handshake.
|
|
* @TODO not used yet !!
|
|
* @param id
|
|
* id of the wiimote
|
|
*/
|
|
public void reSync(int id) {
|
|
requests.add(new WiiUseApiRequest(id, WiiUseApiRequest.WIIUSE_RESYNC));
|
|
}
|
|
|
|
/**
|
|
* Get Status for the wiimote for the given id.
|
|
*
|
|
* @param id
|
|
* id of the wiimote
|
|
*/
|
|
public void getStatus(int id) {
|
|
requests.add(new WiiUseApiRequest(id,
|
|
WiiUseApiRequest.WIIUSE_STATUS_REQUEST));
|
|
}
|
|
|
|
@Override
|
|
public void run() {
|
|
|
|
if (connected > 0) {
|
|
running.set(true);
|
|
|
|
EventsGatherer gather = new EventsGatherer(nbMaxWiimotes);
|
|
|
|
// Start polling and tell the observers when there Wiimote events
|
|
while (running.get()) {
|
|
WiiUseApiRequest req = requests.poll();
|
|
if (req != null) {// there is a request for the wiiuse api
|
|
int id = req.getId();
|
|
if (req.getRequestType() == WiiUseApiRequest.WIIUSE_CLOSE_CONNECTION_REQUEST) {
|
|
/* Close connections requests */
|
|
wiiuse.closeConnection(id);
|
|
|
|
connected--;
|
|
if (connected == 0) {// stop this thread if there is
|
|
// no more wiimotes connected.
|
|
System.out
|
|
.println("No more wiimotes connected !!!");
|
|
shutdown();
|
|
}
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_STATUS_REQUEST) {
|
|
/* Status requests */
|
|
wiiuse.getStatus(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ACTIVATE_RUMBLE_REQUEST) {
|
|
/* Activate Rumble requests */
|
|
wiiuse.activateRumble(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_DEACTIVATE_RUMBLE_REQUEST) {
|
|
/* Deactivate Rumble requests */
|
|
wiiuse.deactivateRumble(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ACTIVATE_IR_TRACKING_REQUEST) {
|
|
/* Activate IR Tracking requests */
|
|
wiiuse.activateIRTracking(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_DEACTIVATE_IR_TRACKING_REQUEST) {
|
|
/* Deactivate IR Tracking requests */
|
|
wiiuse.deactivateIRTracking(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ACTIVATE_MOTION_SENSING_REQUEST) {
|
|
/* Activate Motion sensing requests */
|
|
wiiuse.activateMotionSensing(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_DEACTIVATE_MOTION_SENSING_REQUEST) {
|
|
/* Deactivate Motion sensing requests */
|
|
wiiuse.deactivateMotionSensing(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_LEDS_REQUEST) {
|
|
/* leds requests */
|
|
LedsRequest reqLed = (LedsRequest) req;
|
|
wiiuse.setLeds(id, reqLed.isLed1(), reqLed.isLed2(),
|
|
reqLed.isLed3(), reqLed.isLed4());
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ACTIVATE_SMOOTHING_REQUEST) {
|
|
/* Activate smoothing requests */
|
|
wiiuse.activateSmoothing(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_DEACTIVATE_SMOOTHING_REQUEST) {
|
|
/* Deactivate smoothing requests */
|
|
wiiuse.deactivateSmoothing(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ACTIVATE_CONTINUOUS_REQUEST) {
|
|
/* Activate continuous requests */
|
|
wiiuse.activateContinuous(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_DEACTIVATE_CONTINUOUS_REQUEST) {
|
|
/* Deactivate continuous requests */
|
|
wiiuse.deactivateContinuous(id);
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ORIENT_THRESHOLHD_REQUEST) {
|
|
/* set orientation threshold request */
|
|
wiiuse.setOrientThreshold(req.getId(),
|
|
((FloatValueRequest) req).getFloatValue());
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ACCEL_THRESHOLHD_REQUEST) {
|
|
/* set acceleration threshold request */
|
|
wiiuse.setAccelThreshold(req.getId(),
|
|
((IntValueRequest) req).getIntValue());
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_ALPHA_SMOOTHING_REQUEST) {
|
|
/* set alpha smoothing request */
|
|
wiiuse.setAlphaSmoothing(req.getId(),
|
|
((FloatValueRequest) req).getFloatValue());
|
|
} else if (req.getRequestType() == WiiUseApiRequest.WIIUSE_RESYNC) {
|
|
/* set resync request */
|
|
wiiuse.reSync(req.getId());
|
|
} else {
|
|
System.out.println("Bad request to Wiiuse API !!!!!");
|
|
}
|
|
}
|
|
|
|
/* Polling */
|
|
wiiuse.specialPoll(gather);
|
|
|
|
/* deal with events gathered in Wiiuse API */
|
|
for (WiiUseApiEvent evt : gather.getEvents()) {
|
|
if (evt.getWiimoteId() != -1) {// event filled
|
|
// there is an event notify observers
|
|
notifyWiiUseApiListener(evt);
|
|
if (evt.getEventType() == WiiUseApiEvent.DISCONNECTION_EVENT) {
|
|
// check if it was a disconnection
|
|
// in this case disconnect the wiimote
|
|
closeConnection(evt.getWiimoteId());
|
|
}
|
|
} else {
|
|
System.out
|
|
.println("There is an event with id == -1 ??? there is a problem !!! : "
|
|
+ evt);
|
|
}
|
|
}
|
|
gather.clearEvents();
|
|
}
|
|
} else {
|
|
if (connected <= 0) {
|
|
System.out.println("No wiimotes connected !");
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* Add WiiUseApiListener to the listeners list.
|
|
*
|
|
* @param listener
|
|
* a WiiUseApiListener
|
|
*/
|
|
public void addWiiUseApiListener(WiiUseApiListener listener) {
|
|
listeners.add(WiiUseApiListener.class, listener);
|
|
}
|
|
|
|
/**
|
|
* Remove WiiUseApiListener from the listeners list.
|
|
*
|
|
* @param listener
|
|
* a WiiUseApiListener
|
|
*/
|
|
public void removeWiiUseApiListener(WiiUseApiListener listener) {
|
|
listeners.remove(WiiUseApiListener.class, listener);
|
|
}
|
|
|
|
/**
|
|
* Get the list of WiiUseApiListeners.
|
|
*
|
|
* @return the list of WiiUseApiListeners.
|
|
*/
|
|
public WiiUseApiListener[] getWiiUseApiListeners() {
|
|
return listeners.getListeners(WiiUseApiListener.class);
|
|
}
|
|
|
|
/**
|
|
* Notify WiiUseApiListeners that an event occured.
|
|
*
|
|
* @param evt
|
|
* WiimoteEvent occured
|
|
*/
|
|
private void notifyWiiUseApiListener(WiiUseApiEvent evt) {
|
|
for (WiiUseApiListener listener : getWiiUseApiListeners()) {
|
|
listener.wiiUseApiEvent(evt);
|
|
}
|
|
}
|
|
|
|
}
|