import org.openflow.protocol.OFPacketQueue; //导入依赖的package包/类
/**
 * Read the queue message data from the ChannelBuffer
 * @param data the channel buffer from which we're deserializing
 * @param length the length to the end of the enclosing message
 */
public void readFrom(ChannelBuffer data, int length) {
    super.readFrom(data, length);
    portNumber = data.readShort();
    data.readInt();   // pad
    data.readShort(); // pad

    int availLength = (length - MINIMUM_LENGTH);
    this.queues.clear();

    while (availLength > 0) {
        OFPacketQueue queue = new OFPacketQueue();
        queue.readFrom(data);
        queues.add(queue);
        availLength -= queue.getLength();
    }
}
 

import org.openflow.protocol.OFPacketQueue; //导入依赖的package包/类
/**
 * @return the total length of the queue modify or delete msg
 */
@Override
public int getLength() {
    int queuesLength = 0;

    for (OFPacketQueue queue : queues) {
        queuesLength += queue.getLength();
    }

    return super.getLength() + MINIMUM_LENGTH + queuesLength;
}
 

import org.openflow.protocol.OFPacketQueue; //导入依赖的package包/类
/**
 * Write the queue message data to the ChannelBuffer
 * @param data the channel buffer to which we're serializing
 */
public void writeTo(ChannelBuffer data) {
    super.writeTo(data);
    data.writeShort(this.portNumber);
    data.writeInt(0);   // pad
    data.writeShort(0); // pad

    for (OFPacketQueue queue : queues) {
        queue.writeTo(data);
    }
}
 

import org.openflow.protocol.OFPacketQueue; //导入依赖的package包/类
/**
 * @return the queues
 */
public List<OFPacketQueue> getQueues() {
    return queues;
}
 

import org.openflow.protocol.OFPacketQueue; //导入依赖的package包/类
/**
 * @param queues the queues to modify or delete
 */
public void setQueues(List<OFPacketQueue> queues) {
    this.queues = queues;
}