private OFRpcTaskFactory() {
// hiding implicit constructor
}
-
+
/**
* @param taskContext
* @param input
createGetAllNodeConnectorsStatisticsTask(
final OFRpcTaskContext taskContext, final GetAllNodeConnectorsStatisticsInput input,
SwitchConnectionDistinguisher cookie) {
- class OFRpcTaskImpl extends OFRpcTask<GetAllNodeConnectorsStatisticsInput, RpcResult<GetAllNodeConnectorsStatisticsOutput>> {
+ class OFRpcTaskImpl extends OFRpcTask<GetAllNodeConnectorsStatisticsInput, RpcResult<GetAllNodeConnectorsStatisticsOutput>> {
public OFRpcTaskImpl(OFRpcTaskContext taskContext, SwitchConnectionDistinguisher cookie,
GetAllNodeConnectorsStatisticsInput input) {
MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
// Select all ports
mprQueueBuilder.setPortNo(OFConstants.OFPP_ANY);
- // Select all the ports
- mprQueueBuilder.setQueueId(OFConstants.OFPQ_ANY);
+ // Select all the queues
+ mprQueueBuilder.setQueueId(OFConstants.OFPQ_ALL);
caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
// Set request body to main multipart request
MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
// Select all queues
- mprQueueBuilder.setQueueId(OFConstants.OFPQ_ANY);
+ mprQueueBuilder.setQueueId(OFConstants.OFPQ_ALL);
// Select specific port
mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
OpenflowVersion.get(taskContext.getSession().getFeatures().getVersion()),