* Factory class is designed for easy producing a MultipartRequestInput. Class should help * to understand a relationship between {@link MultipartType} and {@link MultipartRequestInput} * without touch OF specification 1.3.2 - a section 7.3.5. Multipart Messages * see also OpenFlow 1.3.2 * * @author Vaclav Demcak *
* Created: Mar 27, 2015 */ public final class MultipartRequestInputFactory { private MultipartRequestInputFactory() { throw new UnsupportedOperationException("Factory class"); } /** * Method validate input and makes {@link MultipartRequestInput} from input values. Method set * a moreRequest marker to false and it creates default empty {@link MultipartRequestBody} * by {@link MultipartType} * * @param xid * @param type * @param ofVersion * @return */ public static MultipartRequestInput makeMultipartRequestInput(final long xid, final short ofVersion, @Nonnull final MultipartType type) { return maker(xid, type, ofVersion, false, makeDefaultEmptyRequestBody(type, ofVersion)); } /** * Method build {@link MultipartRequestInput} from input values. It is private because we would like * to validate only what is really need to be validate. * * @param xid * @param type * @param ofVersion * @param moreRequests * @param body * @return */ private static MultipartRequestInput maker(final long xid, final MultipartType type, final short ofVersion, final boolean moreRequests, final MultipartRequestBody body) { final MultipartRequestInputBuilder builder = new MultipartRequestInputBuilder(); builder.setFlags(new MultipartRequestFlags(moreRequests)); builder.setMultipartRequestBody(body); builder.setVersion(ofVersion); builder.setType(type); builder.setXid(xid); return builder.build(); } private static MultipartRequestBody makeDefaultEmptyRequestBody(@CheckForNull final MultipartType type, @CheckForNull final short version) { Preconditions.checkArgument(type != null, "Multipart Request can not by build without type!"); switch (type) { case OFPMPDESC: return new MultipartRequestDescCaseBuilder().build(); case OFPMPFLOW: MultipartRequestFlowCaseBuilder multipartRequestFlowCaseBuilder = new MultipartRequestFlowCaseBuilder(); MultipartRequestFlowBuilder multipartRequestFlowBuilder = new MultipartRequestFlowBuilder(); multipartRequestFlowBuilder.setTableId(OFConstants.OFPTT_ALL); multipartRequestFlowBuilder.setOutPort(OFConstants.OFPP_ANY); multipartRequestFlowBuilder.setOutGroup(OFConstants.OFPG_ANY); multipartRequestFlowBuilder.setCookie(BigInteger.ZERO); multipartRequestFlowBuilder.setCookieMask(BigInteger.ZERO); switch (version) { case OFConstants.OFP_VERSION_1_0: MatchV10Builder matchV10Builder = MatchUtil.createEmptyV10Match(); multipartRequestFlowBuilder.setMatchV10(matchV10Builder.build()); break; case OFConstants.OFP_VERSION_1_3: multipartRequestFlowBuilder.setMatch(new MatchBuilder().setType(OxmMatchType.class).build()); break; default: throw new IllegalArgumentException("Unknown version " + version); } multipartRequestFlowCaseBuilder.setMultipartRequestFlow(multipartRequestFlowBuilder.build()); return multipartRequestFlowCaseBuilder.build(); case OFPMPAGGREGATE: return new MultipartRequestAggregateCaseBuilder().build(); case OFPMPTABLE: return new MultipartRequestTableCaseBuilder().build(); case OFPMPPORTSTATS: MultipartRequestPortStatsCaseBuilder multipartRequestPortStatsCaseBuilder = new MultipartRequestPortStatsCaseBuilder(); MultipartRequestPortStatsBuilder multipartRequestPortStatsBuilder = new MultipartRequestPortStatsBuilder(); multipartRequestPortStatsBuilder.setPortNo(OFConstants.OFPP_ANY); multipartRequestPortStatsCaseBuilder.setMultipartRequestPortStats(multipartRequestPortStatsBuilder.build()); return multipartRequestPortStatsCaseBuilder.build(); case OFPMPQUEUE: MultipartRequestQueueCaseBuilder multipartRequestQueueCaseBuilder = new MultipartRequestQueueCaseBuilder(); MultipartRequestQueueBuilder multipartRequestQueueBuilder = new MultipartRequestQueueBuilder(); multipartRequestQueueBuilder.setPortNo(OFConstants.OFPP_ANY); multipartRequestQueueBuilder.setQueueId(OFConstants.OFPQ_ALL); multipartRequestQueueCaseBuilder.setMultipartRequestQueue(multipartRequestQueueBuilder.build()); return multipartRequestQueueCaseBuilder.build(); case OFPMPGROUP: MultipartRequestGroupCaseBuilder multipartRequestGroupCaseBuilder = new MultipartRequestGroupCaseBuilder(); MultipartRequestGroupBuilder multipartRequestGroupBuilder = new MultipartRequestGroupBuilder(); GroupId groupId = new GroupId(OFConstants.OFPG_ALL); multipartRequestGroupBuilder.setGroupId(groupId); multipartRequestGroupCaseBuilder.setMultipartRequestGroup(multipartRequestGroupBuilder.build()); return multipartRequestGroupCaseBuilder.build(); case OFPMPGROUPDESC: return new MultipartRequestGroupDescCaseBuilder().build(); case OFPMPGROUPFEATURES: return new MultipartRequestGroupFeaturesCaseBuilder().build(); case OFPMPMETER: MultipartRequestMeterCaseBuilder multipartRequestMeterCaseBuilder = new MultipartRequestMeterCaseBuilder(); MultipartRequestMeterBuilder multipartRequestMeterBuilder = new MultipartRequestMeterBuilder(); MeterId meterId = new MeterId(OFConstants.OFPM_ALL); multipartRequestMeterBuilder.setMeterId(meterId); multipartRequestMeterCaseBuilder.setMultipartRequestMeter(multipartRequestMeterBuilder.build()); return multipartRequestMeterCaseBuilder.build(); case OFPMPMETERCONFIG: MultipartRequestMeterConfigCaseBuilder multipartRequestMeterConfigCaseBuilder = new MultipartRequestMeterConfigCaseBuilder(); MultipartRequestMeterConfigBuilder multipartRequestMeterConfigBuilder = new MultipartRequestMeterConfigBuilder(); MeterId configMeterId = new MeterId(OFConstants.OFPM_ALL); multipartRequestMeterConfigBuilder.setMeterId(configMeterId); multipartRequestMeterConfigCaseBuilder.setMultipartRequestMeterConfig(multipartRequestMeterConfigBuilder.build()); return multipartRequestMeterConfigCaseBuilder.build(); case OFPMPMETERFEATURES: return new MultipartRequestMeterFeaturesCaseBuilder().build(); case OFPMPTABLEFEATURES: MultipartRequestTableFeaturesCaseBuilder tableFeaturesCaseBuilder = new MultipartRequestTableFeaturesCaseBuilder(); tableFeaturesCaseBuilder.setMultipartRequestTableFeatures(new MultipartRequestTableFeaturesBuilder().build()); return tableFeaturesCaseBuilder.build(); case OFPMPPORTDESC: return new MultipartRequestPortDescCaseBuilder().build(); case OFPMPEXPERIMENTER: return new MultipartRequestExperimenterCaseBuilder().build(); default: throw new IllegalArgumentException("Unknown MultipartType " + type); } } }