import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.RoleRequestInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.RoleRequestOutput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SendMultipartRequestMessageInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetAsyncInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.TableModInput;
protected List<Exception> occuredExceptions = new ArrayList<>();
private ConnectionReadyListener connectionReadyListener;
-
+
private int planItemCounter;
/**
private boolean checkRpc(OfHeader rpcInput, String rpcName) {
String msg = null;
boolean finished = true;
-
+
if (eventPlan.isEmpty()) {
throw new IllegalStateException("eventPlan already depleted");
}
-
+
LOG.debug("checking rpc: name={}, ver={}, xid={}", rpcName, rpcInput.getVersion(), rpcInput.getXid());
- if (!(eventPlan.peek() instanceof SwitchTestWaitForRpcEvent)
+ if (!(eventPlan.peek() instanceof SwitchTestWaitForRpcEvent)
&& !(eventPlan.peek() instanceof SwitchTestWaitForAllEvent)) {
if (eventPlan.peek() instanceof SwitchTestNotificationEvent) {
SwitchTestNotificationEvent notifEvent = (SwitchTestNotificationEvent) (eventPlan.peek());
.peek();
Set<SwitchTestWaitForRpcEvent> eventBag = switchTestWaitForAll.getWaitEventBag();
List<String> msgLot = new ArrayList<>();
-
+
if (eventBag == null || eventBag.isEmpty()) {
msg = "no wait events in bag";
} else {
finished = false;
for (SwitchTestWaitForRpcEvent switchTestWaitForRpc : eventBag) {
- String msgPart = checkSingleRpcContent(rpcInput, rpcName, switchTestWaitForRpc);
-
+ String msgPart = checkSingleRpcContent(rpcInput, rpcName, switchTestWaitForRpc);
+
if (msgPart != null) {
msgLot.add(msgPart);
} else {
}
}
}
-
+
if (!msgLot.isEmpty()) {
msg = Joiner.on(" | ").join(msgLot);
}
} else if (eventPlan.peek() instanceof SwitchTestWaitForRpcEvent) {
SwitchTestWaitForRpcEvent switchTestRpcEvent = (SwitchTestWaitForRpcEvent) eventPlan
.peek();
- msg = checkSingleRpcContent(rpcInput, rpcName, switchTestRpcEvent);
+ msg = checkSingleRpcContent(rpcInput, rpcName, switchTestRpcEvent);
}
}
* @param rpcName
* @param msgTmp
* @param switchTestWaitForRpc
- * @return
+ * @return
*/
private static String checkSingleRpcContent(OfHeader rpcInput, String rpcName,
SwitchTestWaitForRpcEvent switchTestWaitForRpc) {
} else if (!rpcInput.getXid().equals(switchTestWaitForRpc.getXid())) {
failureMsg = "expected "+rpcName+".xid [" + switchTestWaitForRpc.getXid()
+ "], got [" + rpcInput.getXid() + "]";
- }
-
+ }
+
return failureMsg;
}
-
+
/**
* @param rpcInput
* rpc call parameter
ConnectionReadyListener connectionReadyListener) {
this.connectionReadyListener = connectionReadyListener;
}
+
+ @Override
+ public Future<RpcResult<Void>> sendMultipartRequestMessage(
+ SendMultipartRequestMessageInput arg0) {
+ checkRpcAndNext(arg0, "sendMultipartRequestMessage");
+ SettableFuture<RpcResult<Void>> result = createOneWayRpcResult();
+ return result;
+ }
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatus;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.RoleRequestInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.RoleRequestOutput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SendMultipartRequestMessageInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetAsyncInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.TableModInput;
this.connectionReadyListener = connectionReadyListener;
}
+ @Override
+ public Future<RpcResult<Void>> sendMultipartRequestMessage(
+ SendMultipartRequestMessageInput input) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
}