import javax.usb.UsbPipe; //导入依赖的package包/类
/**
 * Sends an ADB Message.
 * 
 * @param message
 *            The message to send.
 * @throws UsbException
 *             When USB communication failed.
 */
public void sendMessage(Message message) throws UsbException
{
    UsbEndpoint outEndpoint =
        this.iface.getUsbEndpoint(this.outEndpoint);
    UsbPipe outPipe = outEndpoint.getUsbPipe();
    MessageHeader header = message.getHeader();
    outPipe.open();
    try
    {
        int sent = outPipe.syncSubmit(header.getBytes());
        if (sent != MessageHeader.SIZE)
            throw new InvalidMessageException(
                "Invalid ADB message header size sent: " + sent);
        sent = outPipe.syncSubmit(message.getData());
        if (sent != header.getDataLength())
            throw new InvalidMessageException(
                "Data size mismatch in sent ADB message. Should be "
                    + header.getDataLength() + " but is " + sent);
    }
    finally
    {
        outPipe.close();
    }
}
 

import javax.usb.UsbPipe; //导入依赖的package包/类
private int sendBulkTransfer(UsbEndpoint usbEndpoint, byte[] data) throws UsbException{
        int returnCode = -1;

        if(UsbConst.ENDPOINT_DIRECTION_OUT == usbEndpoint.getDirection()){
            mLogger.debug("sendBulkTransfer - direction: OUT,  byteString: {}", getByteString(data));
        }

        UsbPipe usbPipe = usbEndpoint.getUsbPipe();
        if (usbPipe != null) {
            if(!usbPipe.isOpen()){
                usbPipe.open();
            }
            if (usbPipe.isOpen()) {
                UsbIrp usbIrp = usbPipe.createUsbIrp();
                usbIrp.setData(data);
                //TODO: data length does not need to be set explicitly
//                int dataLength = (data == null) ? 0 : data.length;
//                usbIrp.setLength(dataLength);
                usbPipe.syncSubmit(usbIrp);
                if (!usbIrp.isUsbException()) {
                    returnCode = usbIrp.getActualLength();
                } else {
                    // throw usbControlIrp.getUsbException();
                    usbIrp.getUsbException().printStackTrace();
                }
            } else {
            	mLogger.error("usbPipe open ERROR");
            }
        } else {
        	mLogger.error("usbPipe is NULL");
        }

        if(UsbConst.ENDPOINT_DIRECTION_IN == usbEndpoint.getDirection()){
        	//TODO: show type of packet in debug log
            mLogger.debug("sendBulkTransfer - direction: IN,  byteString: {}", getByteString(data));
        }

        return returnCode;
    }
 

import javax.usb.UsbPipe; //导入依赖的package包/类
/**
 * Tests the data event.
 */
@Test
public void testDataEvent()
{
    final UsbPipeDataEvent event =
        new UsbPipeDataEvent(mock(UsbPipe.class), null);
    final UsbPipeListener a = mock(UsbPipeListener.class);
    final UsbPipeListener b = mock(UsbPipeListener.class);
    this.list.add(a);
    this.list.add(b);
    this.list.dataEventOccurred(event);
    verify(a).dataEventOccurred(event);
    verify(b).dataEventOccurred(event);
}
 

import javax.usb.UsbPipe; //导入依赖的package包/类
/**
 * Tests the error event.
 */
@Test
public void testErrorEvent()
{
    final UsbPipeErrorEvent event =
        new UsbPipeErrorEvent(mock(UsbPipe.class), new UsbException());
    final UsbPipeListener a = mock(UsbPipeListener.class);
    final UsbPipeListener b = mock(UsbPipeListener.class);
    this.list.add(a);
    this.list.add(b);
    this.list.errorEventOccurred(event);
    verify(a).errorEventOccurred(event);
    verify(b).errorEventOccurred(event);
}
 

import javax.usb.UsbPipe; //导入依赖的package包/类
/**
 * Receives an ADB message.
 * 
 * @return The received ADB message.
 * @throws UsbException
 *             When USB communication failed.
 */
public Message receiveMessage() throws UsbException
{
    UsbEndpoint inEndpoint =
        this.iface.getUsbEndpoint(this.inEndpoint);
    UsbPipe inPipe = inEndpoint.getUsbPipe();
    inPipe.open();
    try
    {
        byte[] headerBytes = new byte[MessageHeader.SIZE];
        int received = inPipe.syncSubmit(headerBytes);
        if (received != MessageHeader.SIZE)
            throw new InvalidMessageException(
                "Invalid ADB message header size: " + received);
        MessageHeader header = new MessageHeader(headerBytes);
        if (!header.isValid())
            throw new InvalidMessageException(
                "ADB message header checksum failure");
        byte[] data = new byte[header.getDataLength()];
        received = inPipe.syncSubmit(data);
        if (received != header.getDataLength())
            throw new InvalidMessageException(
                "ADB message data size mismatch. Should be "
                    + header.getDataLength() + " but is " + received);
        Message message = Message.create(header, data);
        if (!message.isValid())
            throw new InvalidMessageException(
                "ADB message data checksum failure");
        return message;
    }
    finally
    {
        inPipe.close();
    }
}
 

import javax.usb.UsbPipe; //导入依赖的package包/类
@Override
public UsbPipe getUsbPipe()
{
    return this.pipe;
}