import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
	if (!isConnected()) {
		return Futures.immediateFailedFuture(new SwitchDisconnectedException(getDatapathId()));
	}

	DeliverableListenableFuture<R> future = new DeliverableListenableFuture<R>();
	xidDeliverableMap.put(request.getXid(), future);
	listener.messageWritten(this, request);
	this.write(request);
	return future;
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
@Override
public <R extends OFMessage> ListenableFuture<R>
        writeRequest(OFRequest<R> request) {
    RequestAndFuture<R> raf = new RequestAndFuture<>(request);
    messages.add(request);
    requests.put(request.getXid(), raf);
    return raf.getReplyFuture();
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    if (!isConnected())
        return Futures.immediateFailedFuture(new SwitchDisconnectedException(getDatapathId()));

    DeliverableListenableFuture<R> future = new DeliverableListenableFuture<R>();
    xidDeliverableMap.put(request.getXid(), future);
    listener.messageWritten(this, request);
    write(request);
    return future;
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    if (!isConnected())
        return Futures.immediateFailedFuture(new SwitchDisconnectedException(getDatapathId()));

    DeliverableListenableFuture<R> future = new DeliverableListenableFuture<R>();
    xidDeliverableMap.put(request.getXid(), future);
    write(request);
    return future;
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request, LogicalOFMessageCategory category) {
	return getConnection(category).writeRequest(request);
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    return Futures.immediateFailedFuture(new SwitchDisconnectedException(getDatapathId()));
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(
		OFRequest<R> request) {
	// TODO Auto-generated method stub
	return null;
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
public RequestAndFuture(OFRequest<R> request) {
    this.request = request;
    this.replyFuture = SettableFuture.create();
}
 

import org.projectfloodlight.openflow.protocol.OFRequest; //导入依赖的package包/类
public OFRequest<R> getRequest() {
    return request;
}