Java 类org.projectfloodlight.openflow.protocol.OFRequest 实例源码

项目：fresco_floodlight 文件：OFConnection.java

@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;
}

项目：fresco_floodlight 文件：MockOFConnection.java

@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();
}

项目：iTAP-controller 文件：OFConnection.java

@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;
}

项目：iTAP-controller 文件：MockOFConnection.java

@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();
}

项目：SDN-Multicast 文件：OFConnection.java

@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;
}

项目：SDN-Multicast 文件：MockOFConnection.java

@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();
}

项目：arscheduler 文件：OFConnection.java

@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;
}

项目：arscheduler 文件：MockOFConnection.java

@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();
}

项目：floodlight1.2-delay 文件：OFConnection.java

@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;
}

项目：floodlight1.2-delay 文件：MockOFConnection.java

@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();
}

项目：floodlight-hardware 文件：OFConnection.java

@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;
}

项目：floodlight-hardware 文件：MockOFConnection.java

@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();
}

项目：ACAMPController 文件：OFConnection.java

@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;
}

项目：ACAMPController 文件：MockOFConnection.java

@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();
}

项目：fast-failover-demo 文件：OFConnection.java

@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;
}

项目：fast-failover-demo 文件：MockOFConnection.java

@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();
}

项目：floodlightLB 文件：OFConnection.java

@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;
}

项目：floodlightLB 文件：MockOFConnection.java

@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();
}

项目：DSC 文件：OFConnection.java

@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;
}

项目：DSC 文件：MockOFConnection.java

@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();
}

项目：floodlight 文件：OFConnection.java

@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;
}

项目：floodlight 文件：MockOFConnection.java

@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();
}

项目：fresco_floodlight 文件：OFSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request, LogicalOFMessageCategory category) {
    return getConnection(category).writeRequest(request);
}

项目：fresco_floodlight 文件：OFSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    return writeRequest(request, LogicalOFMessageCategory.MAIN);
}

项目：fresco_floodlight 文件：NullConnection.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    return Futures.immediateFailedFuture(new SwitchDisconnectedException(getDatapathId()));
}

项目：fresco_floodlight 文件：OFMessageDamperMockSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(
        OFRequest<R> request) {
    // TODO Auto-generated method stub
    return null;
}

项目：fresco_floodlight 文件：OFMessageDamperMockSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(
        OFRequest<R> request, LogicalOFMessageCategory category) {
    // TODO Auto-generated method stub
    return null;
}

项目：fresco_floodlight 文件：MockOFConnection.java

public RequestAndFuture(OFRequest<R> request) {
    this.request = request;
    this.replyFuture = SettableFuture.create();
}

项目：fresco_floodlight 文件：MockOFConnection.java

public OFRequest<R> getRequest() {
    return request;
}

项目：iTAP-controller 文件：OFSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request, LogicalOFMessageCategory category) {
    return getConnection(category).writeRequest(request);
}

项目：iTAP-controller 文件：OFSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    return connections.get(OFAuxId.MAIN).writeRequest(request);
}

项目：iTAP-controller 文件：NullConnection.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    return Futures.immediateFailedFuture(new SwitchDisconnectedException(getDatapathId()));
}

项目：iTAP-controller 文件：OFMessageDamperMockSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(
        OFRequest<R> request) {
    // TODO Auto-generated method stub
    return null;
}

项目：iTAP-controller 文件：OFMessageDamperMockSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(
        OFRequest<R> request, LogicalOFMessageCategory category) {
    // TODO Auto-generated method stub
    return null;
}

项目：iTAP-controller 文件：MockOFConnection.java

public RequestAndFuture(OFRequest<R> request) {
    this.request = request;
    this.replyFuture = SettableFuture.create();
}

项目：iTAP-controller 文件：MockOFConnection.java

public OFRequest<R> getRequest() {
    return request;
}

项目：SDN-Multicast 文件：OFSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request, LogicalOFMessageCategory category) {
    return getConnection(category).writeRequest(request);
}

项目：SDN-Multicast 文件：OFSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    return writeRequest(request, LogicalOFMessageCategory.MAIN);
}

项目：SDN-Multicast 文件：NullConnection.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(OFRequest<R> request) {
    return Futures.immediateFailedFuture(new SwitchDisconnectedException(getDatapathId()));
}

项目：SDN-Multicast 文件：OFMessageDamperMockSwitch.java

@Override
public <R extends OFMessage> ListenableFuture<R> writeRequest(
        OFRequest<R> request) {
    // TODO Auto-generated method stub
    return null;
}