import javax.usb.UsbDevice; //导入依赖的package包/类
protected void initialize() throws SecurityException, UsbException {
	UsbServices services = UsbHostManager.getUsbServices();
	UsbHub usbHub = services.getRootUsbHub();

	UsbDevice theDevice = findDevice(usbHub, targetVendor, targetProduct);

	if (theDevice == null) {
		logger.warn("Could not find the device. The driver is not operable.");
		return;
	}
	
	for (Object i : theDevice.getActiveUsbConfiguration().getUsbInterfaces()) {
		UsbInterface intf = (UsbInterface) i;
		for (Object e : intf.getUsbEndpoints()) {
			UsbEndpoint endp = (UsbEndpoint) e;
			if (endp.getDirection() == UsbConst.ENDPOINT_DIRECTION_IN) {
				this.pipe = endp.getUsbPipe();
			}
		}
	}
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Find the device with vendorId and productId
 * 
 * @param hub
 * @param vendorId
 * @param productId
 * @return USB device or null if not found.
 */
private static UsbDevice find(UsbHub hub, short vendorId, short productId) {
	UsbDevice launcher = null;

	for (UsbDevice device : (List<UsbDevice>) hub.getAttachedUsbDevices()) {
		if (device.isUsbHub()) {
			launcher = find((UsbHub) device, vendorId, productId);
			if (launcher != null)
				return launcher;
		} else {
			UsbDeviceDescriptor desc = device.getUsbDeviceDescriptor();
			if (desc.idVendor() == vendorId && desc.idProduct() == productId)
				return device;
		}
	}
	return null;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Send the UsbControlIrp to the UsbDevice on the DCP.
 *
 * @param usbDevice
 *            The UsbDevice.
 * @param usbControlIrp
 *            The UsbControlIrp.
 * @return If the submission was successful.
 */
public static boolean sendUsbControlIrp(UsbDevice usbDevice, UsbControlIrp usbControlIrp) {
    try {
        /*
         * This will block until the submission is complete.
         * Note that submissions (except interrupt and bulk in-direction)
         * will not block indefinitely, they will complete or fail within a finite
         * amount of time. See MouseDriver.HidMouseRunnable for more details.
         */
        usbDevice.syncSubmit(usbControlIrp);
        return true;
    } catch (UsbException uE) {
        mLogger.error("DCP submission failed : " + uE.getMessage());
        return false;
    }
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public static List<UsbDevice> findUsbDevices(UsbHub hub, short vendorId, short productId) {
    List<UsbDevice> usbDeviceList = new ArrayList<UsbDevice>();
    if (hub != null) {
        for (UsbDevice device : (List<UsbDevice>) hub.getAttachedUsbDevices()) {
            UsbDeviceDescriptor desc = device.getUsbDeviceDescriptor();
            if (desc.idVendor() == vendorId && desc.idProduct() == productId){
                mLogger.debug("Found USB device!");
                usbDeviceList.add(device);
            }
            if (device.isUsbHub()) {
                usbDeviceList.addAll(findUsbDevices((UsbHub) device, vendorId, productId));
            }
        }
    }
    return usbDeviceList;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
private static UsbDevice findUsb(UsbHub hub) {
	UsbDevice launcher = null;

	for (UsbDevice device: (List<UsbDevice>) hub.getAttachedUsbDevices()) {
		if (device.isUsbHub()) {
			launcher = findUsb((UsbHub) device);
			if (launcher != null) return launcher;
		} else {
			UsbDeviceDescriptor desc = device.getUsbDeviceDescriptor();
			System.out.println("Found on USB: idVendor: "+desc.idVendor()+", idProduct: "+desc.idProduct());
			if (desc.idVendor() == VENDOR_ID && desc.idProduct() == product_id) {
				System.out.println("Got our printer.");
				return device;
			}
		}
	}
	return null;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
public static Scale findScale() {
  try {
    UsbServices services = UsbHostManager.getUsbServices();
    UsbHub rootHub = services.getRootUsbHub();
    // Dymo M10 Scale:
    UsbDevice device = findDevice(rootHub, (short) 0x0922, (short) 0x8003);
    // Dymo M25 Scale:
    if (device == null) {
      device = findDevice(rootHub, (short) 0x0922, (short) 0x8004);
    }
    if (device == null) {
      return null;
    }
    return new UsbScale(device);
  } catch (UsbException ex) {
    throw new IllegalStateException("Unable to find devices", ex);
  }
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 *
 *
 * @param device
 */
public static void dump(UsbDevice device)
{
    UsbDeviceDescriptor desc = device.getUsbDeviceDescriptor();
    System.out.format("%04x:%04x%n", desc.idVendor() & 0xffff,
            desc.idProduct() & 0xffff);

    if (device.isUsbHub())
    {
        UsbHub hub = (UsbHub) device;

        for (UsbDevice child : (List<UsbDevice>) hub.getAttachedUsbDevices())
        {
            dump(child);
        }
    }
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
private List<Controller> retrieveKnownDevices() throws UsbException {
	List<Controller> controllers = new ArrayList<Controller>();
	Module[] knownDevices = Module.values();
	UsbHub retrieveUsbHub = this.usbServiceProvider.retrieveUsbHub();
	for (Module knownDevice : knownDevices) {
		LOGGER.info("inspecting USB bus for device {}", knownDevice);
		try {
			UsbDevice device = this.findDevice(retrieveUsbHub, knownDevice);
			if (null != device) {
				LOGGER.debug("found connected device for {}", knownDevice);
				controllers.add(Module.buildControllerFor(device));
			}
		} catch (Exception e) {
			LOGGER.warn("exception looking for device {} message {}", knownDevice, e.getMessage());
		}
	}
	return controllers;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private UsbDevice findDevice(UsbHub usbHub, Module definition) throws UsbException {
	List<UsbDevice> attachedUsbDevices = usbHub.getAttachedUsbDevices();
	for (UsbDevice usbDevice : attachedUsbDevices) {
		UsbDeviceDescriptor desc = usbDevice.getUsbDeviceDescriptor();
		if (definition.isBasedOn(desc.idVendor(), desc.idProduct())) {
			LOGGER.info("found device: {}", definition);
			return usbDevice;
		}
		if (usbDevice.isUsbHub()) {
			usbDevice = findDevice((UsbHub) usbDevice, definition);
			if (usbDevice != null) {
				return usbDevice;
			}
		}
	}
	return null;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
@Test
public void testProvideControllerFromDefinition() throws UsbException {
	Module expectedControllerDefinition = Module.CM15;
	// setup
	UsbServices usbServices = mock(UsbServices.class);
	UsbHub usbHub = mock(UsbHub.class);
	UsbDevice usbDevice = mock(UsbDevice.class);
	UsbDeviceDescriptor usbDeviceDescriptor = mock(UsbDeviceDescriptor.class);
	when(usbDeviceDescriptor.idVendor()).thenReturn(expectedControllerDefinition.getVendorId());
	when(usbDeviceDescriptor.idProduct()).thenReturn(expectedControllerDefinition.getProductId());
	when(usbDevice.getUsbDeviceDescriptor()).thenReturn(usbDeviceDescriptor);
	List<UsbDevice> attachedDevices = Arrays.asList(usbDevice);
	when(usbHub.getAttachedUsbDevices()).thenReturn(attachedDevices);
	when(usbServices.getRootUsbHub()).thenReturn(usbHub);
	when(this.usbServicesProvider.retrieveUsbHub()).thenReturn(usbHub);
	// act
	X10Controller actual = testObj.provideControllerBy(expectedControllerDefinition);
	// assert
	assertNotNull(actual);
	assertEquals(expectedControllerDefinition.getProductId(), actual.productId());
	assertEquals(expectedControllerDefinition.getVendorId(), actual.vendorId());
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Recursively searches for the missile launcher device on the specified USB
 * hub and returns it. If there are multiple missile launchers attached then
 * this simple demo only returns the first one.
 * 
 * @param hub
 *            The USB hub to search on.
 * @return The missile launcher USB device or null if not found.
 */
public static UsbDevice findMissileLauncher(UsbHub hub)
{
    UsbDevice launcher = null;

    for (UsbDevice device: (List<UsbDevice>) hub.getAttachedUsbDevices())
    {
        if (device.isUsbHub())
        {
            launcher = findMissileLauncher((UsbHub) device);
            if (launcher != null) return launcher;
        }
        else
        {
            UsbDeviceDescriptor desc = device.getUsbDeviceDescriptor();
            if (desc.idVendor() == VENDOR_ID &&
                desc.idProduct() == PRODUCT_ID) return device;
        }
    }
    return null;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Sends a message to the missile launcher.
 * 
 * @param device
 *            The USB device handle.
 * @param message
 *            The message to send.
 * @throws UsbException
 *             When sending the message failed.
 */
public static void sendMessage(UsbDevice device, byte[] message)
    throws UsbException
{
    UsbControlIrp irp = device.createUsbControlIrp(
        (byte) (UsbConst.REQUESTTYPE_TYPE_CLASS |
        UsbConst.REQUESTTYPE_RECIPIENT_INTERFACE), (byte) 0x09,
        (short) 2, (short) 1);
    irp.setData(message);
    device.syncSubmit(irp);
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Sends a command to the missile launcher.
 * 
 * @param device
 *            The USB device handle.
 * @param command
 *            The command to send.
 * @throws UsbException
 *             When USB communication failed.
 */
public static void sendCommand(UsbDevice device, int command)
    throws UsbException
{
    byte[] message = new byte[64];
    message[1] = (byte) ((command & CMD_LEFT) > 0 ? 1 : 0);
    message[2] = (byte) ((command & CMD_RIGHT) > 0 ? 1 : 0);
    message[3] = (byte) ((command & CMD_UP) > 0 ? 1 : 0);
    message[4] = (byte) ((command & CMD_DOWN) > 0 ? 1 : 0);
    message[5] = (byte) ((command & CMD_FIRE) > 0 ? 1 : 0);
    message[6] = 8;
    message[7] = 8;
    sendMessage(device, INIT_A);
    sendMessage(device, INIT_B);
    sendMessage(device, message);
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
private UsbDevice findDevice(UsbHub usbHub, short defaultVendorId2, short defaultProductId2) {
	UsbDevice result = null;
	for (Object d : usbHub.getAttachedUsbDevices()) {
		if (d instanceof UsbHub) {
			result = findDevice((UsbHub) d, defaultVendorId2, defaultProductId2);
			if (result != null) {
				return result;
			}
		}
		else if (d instanceof UsbDevice) {
			UsbDevice device = (UsbDevice) d;
			if (device.getUsbDeviceDescriptor().idProduct() == defaultProductId2
					&& device.getUsbDeviceDescriptor().idVendor() == defaultVendorId2) {
				return device;
			}
		}
	}
	return null;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Recursively traverses the USB bus, adding any labjacks to a list.
 * @param device the device to begin traversing through.
 * @param list the list of UsbDevices to add matching devices to.
 */
private void traverse(UsbDevice device, List<UsbDevice> list)
{
    if (device.isUsbHub())
    {
        // This is a USB Hub, traverse through the hub.
        List attachedDevices = ((UsbHub) device).getAttachedUsbDevices();
        for (int i=0; i<attachedDevices.size(); i++)
        {
            traverse((UsbDevice) attachedDevices.get(i), list);
        }
    }
    else
    {
        /** If the device is a Labjack, add it to the list */
        if (device.getUsbDeviceDescriptor().idVendor() == USB_VENDOR_ID 
                && device.getUsbDeviceDescriptor().idProduct() == USB_PRODUCT_ID)
        {
            list.add(device);
        }
    }
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Scroll the text string on the device led matrix from Right to Left
 * 
 * @param device
 * @param text
 * @throws UsbException
 */
private void scrollTextLeft(UsbDevice device, String text, int delay) throws UsbException {
	byte[][] matrix = new byte[LED_MATRIX_HEIGHT][text.length() * LED_MATRIX_HEIGHT];
	matrix = MatrixUtils.write(text, matrix, trimSpace);

	for (int i = 0; i < matrix[0].length-LED_MATRIX_WIDTH; ++i) {
		byte[][] window = MatrixUtils.slice(matrix, i);
		sendMatrix(device, window);
		wait(delay);
	}
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Scroll the text string on the device led matrix from Left to Right
 * 
 * @param device
 * @param text
 * @throws UsbException
 */
private void scrollTextRight(UsbDevice device, String text, int delay) throws UsbException {
	byte[][] matrix = new byte[LED_MATRIX_HEIGHT][text.length() * LED_MATRIX_HEIGHT];
	matrix = MatrixUtils.write(text, matrix, trimSpace);

	for (int i = matrix[0].length - LED_MATRIX_WIDTH; i >= 0; --i) {
		byte[][] window = MatrixUtils.slice(matrix, i);
		sendMatrix(device, window);
		wait(delay);
	}
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Returns a List of currently connected usb devices
 */
public static List<UsbDevice> getDevices() 
		throws SecurityException, UsbException, UnsupportedEncodingException
{
	ArrayList<UsbDevice> devices = new ArrayList<UsbDevice>();
	
	UsbServices services = UsbHostManager.getUsbServices();

	UsbHub root = services.getRootUsbHub();
	
	devices.addAll( getHubDevices( root ) );

	return devices;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
/**
 * Returns a list of devices attached to the hub
 */
public static List<UsbDevice> getHubDevices( UsbHub hub ) 
					throws UnsupportedEncodingException, UsbException
{
	ArrayList<UsbDevice> devices = new ArrayList<UsbDevice>();
	
	@SuppressWarnings( "unchecked" )
	List<UsbDevice> children = hub.getAttachedUsbDevices();
	
	Iterator<UsbDevice> it = children.iterator();
	
	while( it.hasNext() )
	{
		UsbDevice child = it.next();
		
		if( child.isUsbHub() )
		{
			devices.addAll( getHubDevices( (UsbHub)child ) );
		}
		else
		{
			devices.add( child );
		}
	}
			
	return devices;
}
 

import javax.usb.UsbDevice; //导入依赖的package包/类
public static String getDeviceDetails( UsbDevice device ) 
	throws UsbException, UnsupportedEncodingException, UsbDisconnectedException
{
	StringBuilder sb = new StringBuilder();

	sb.append( device.getUsbDeviceDescriptor().toString() + "\n\n" );
	
	for( Object configObject: device.getUsbConfigurations() )
	{
		UsbConfiguration config = (UsbConfiguration)configObject;
		
		sb.append( config.getUsbConfigurationDescriptor().toString() + "\n\n" );
		
		for( Object interfaceObject: config.getUsbInterfaces() )
		{
			UsbInterface iface = (UsbInterface)interfaceObject;
			
			sb.append( iface.getUsbInterfaceDescriptor().toString() + "\n\n" );
			
			for( Object endpointObject: iface.getUsbEndpoints() )
			{
				UsbEndpoint endpoint = (UsbEndpoint)endpointObject;
				
				sb.append( endpoint.getUsbEndpointDescriptor().toString() + "\n\n" );
			}
		}
	}

	return sb.toString();
}