+++ /dev/null
-package org.openflow.codec.protocol.statistics;
-
-import java.lang.reflect.Constructor;
-import java.util.HashMap;
-import java.util.Map;
-
-import org.openflow.codec.protocol.Instantiable;
-import org.openflow.codec.protocol.OFPType;
-import org.openflow.codec.util.U16;
-
-/**
- * Represents an ofp_multipart_types enum
- *
- * @author AnilGujele
- *
- */
-public enum OFPMultipartTypes {
- DESC(0, OFPDescriptionStatistics.class, OFPDescriptionStatistics.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPDescriptionStatistics();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPDescriptionStatistics();
- }
- }), FLOW(1, OFPFlowStatisticsRequest.class, OFPFlowStatisticsReply.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPFlowStatisticsRequest();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPFlowStatisticsReply();
- }
- }), AGGREGATE(2, OFPAggregateStatisticsRequest.class, OFPAggregateStatisticsReply.class,
- new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPAggregateStatisticsRequest();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPAggregateStatisticsReply();
- }
- }), TABLE(3, OFPTableStatistics.class, OFPTableStatistics.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPTableStatistics();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPTableStatistics();
- }
- }), PORT_STATS(4, OFPPortStatisticsRequest.class, OFPPortStatisticsReply.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPPortStatisticsRequest();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPPortStatisticsReply();
- }
- }), QUEUE(5, OFPQueueStatisticsRequest.class, OFPQueueStatisticsReply.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPQueueStatisticsRequest();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPQueueStatisticsReply();
- }
- }), GROUP_DESC(7, OFPGroupDescription.class, OFPGroupDescription.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPGroupDescription();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPGroupDescription();
- }
- }), GROUP_FEATURES(8, OFPGroupFeatures.class, OFPGroupFeatures.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPGroupFeatures();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPGroupFeatures();
- }
- }), TABLE_FEATURES(12, OFPTableFeatures.class, OFPTableFeatures.class, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPTableFeatures();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPTableFeatures();
- }
- }), PORT_DESC(13, OFPPortDescriptionStatistics.class, OFPPortDescriptionStatistics.class,
- new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPPortDescriptionStatistics();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPPortDescriptionStatistics();
- }
- }),
-
- EXPERIMENTER(0xffff, OFPExperimenterMultipartHeader.class, OFPExperimenterMultipartHeader.class,
- new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPExperimenterMultipartHeader();
- }
- }, new Instantiable<OFPStatistics>() {
- @Override
- public OFPStatistics instantiate() {
- return new OFPExperimenterMultipartHeader();
- }
- });
-
- private static Map<Integer, OFPMultipartTypes> requestMapping;
- private static Map<Integer, OFPMultipartTypes> replyMapping;
-
- private Class<? extends OFPStatistics> requestClass;
- private Constructor<? extends OFPStatistics> requestConstructor;
- private Instantiable<OFPStatistics> requestInstantiable;
- private Class<? extends OFPStatistics> replyClass;
- private Constructor<? extends OFPStatistics> replyConstructor;
- private Instantiable<OFPStatistics> replyInstantiable;
- private int type;
-
- /**
- * Store some information about the OpenFlow Statistic type, including wire
- * protocol type number, and derived class
- *
- * @param type
- * Wire protocol number associated with this OFPMultipartType
- * @param requestClass
- * The Multipart Java class to return when the containing OFPType
- * is MULTIPART_REQUEST
- * @param replyClass
- * The Multipart Java class to return when the containing OFPType
- * is MULTIPART_REPLY
- */
- OFPMultipartTypes(int type, Class<? extends OFPStatistics> requestClass, Class<? extends OFPStatistics> replyClass,
- Instantiable<OFPStatistics> requestInstantiable, Instantiable<OFPStatistics> replyInstantiable) {
- this.type = type;
- this.requestClass = requestClass;
- try {
- this.requestConstructor = requestClass.getConstructor(new Class[] {});
- } catch (Exception e) {
- throw new RuntimeException("Failure getting constructor for class: " + requestClass, e);
- }
-
- this.replyClass = replyClass;
- try {
- this.replyConstructor = replyClass.getConstructor(new Class[] {});
- } catch (Exception e) {
- throw new RuntimeException("Failure getting constructor for class: " + replyClass, e);
- }
- this.requestInstantiable = requestInstantiable;
- this.replyInstantiable = replyInstantiable;
- OFPMultipartTypes.addMapping(this.type, OFPType.MULTIPART_REQUEST, this);
- OFPMultipartTypes.addMapping(this.type, OFPType.MULTIPART_REPLY, this);
- }
-
- /**
- * Adds a mapping from type value to OFStatisticsType enum
- *
- * @param i
- * OpenFlow wire protocol type
- * @param t
- * type of containing OFPMessage, only accepts MULTIPART_REQUEST
- * or MULTIPART_REPLY
- * @param st
- * type
- */
- public static void addMapping(int i, OFPType t, OFPMultipartTypes st) {
-
- if (t == OFPType.MULTIPART_REQUEST) {
- if (requestMapping == null)
- requestMapping = new HashMap<Integer, OFPMultipartTypes>();
- OFPMultipartTypes.requestMapping.put(i, st);
- } else if (t == OFPType.MULTIPART_REPLY) {
- if (replyMapping == null)
- replyMapping = new HashMap<Integer, OFPMultipartTypes>();
- OFPMultipartTypes.replyMapping.put(i, st);
- } else {
- throw new RuntimeException(t.toString() + " is an invalid OFPType");
- }
- }
-
- /**
- * Remove a mapping from type value to OFPMultipartType enum
- *
- * @param i
- * OpenFlow wire protocol type
- * @param t
- * type of containing OFPMessage, only accepts MULTIPART_REQUEST
- * or MULTIPART_REPLY
- */
- public static void removeMapping(int i, OFPType t) {
- if (t == OFPType.MULTIPART_REQUEST) {
- requestMapping.remove(i);
- } else if (t == OFPType.MULTIPART_REPLY) {
- replyMapping.remove(i);
- } else {
- throw new RuntimeException(t.toString() + " is an invalid OFPType");
- }
- }
-
- /**
- * Given a wire protocol OpenFlow type number, return the OFPMultipartType
- * associated with it
- *
- * @param i
- * wire protocol number
- * @param t
- * type of containing OFPMessage, only accepts MULTIPART_REQUEST
- * or MULTIPART_REPLY
- * @return OFPMultipartType enum type
- */
- public static OFPMultipartTypes valueOf(short i, OFPType t) {
- if (t == OFPType.MULTIPART_REQUEST) {
- return requestMapping.get(U16.f(i));
- } else if (t == OFPType.MULTIPART_REPLY) {
- return replyMapping.get(U16.f(i));
- } else {
- throw new RuntimeException(t.toString() + " is an invalid OFPType");
- }
- }
-
- /**
- * @return Returns the wire protocol value corresponding to this
- * OFPMultipartType
- */
- public short getTypeValue() {
- return U16.t(this.type);
- }
-
- /**
- * @return Returns the wire protocol unsigned value corresponding to this
- * OFPMultipartType
- */
- public int getTypeValueU() {
- return this.type;
- }
-
- /**
- * @param t
- * type of containing OFPMessage, only accepts MULTIPART_REQUEST
- * or MULTIPART_REPLY
- * @return return the OFPMessage subclass corresponding to this
- * OFPMultipartType
- */
- public Class<? extends OFPStatistics> toClass(OFPType t) {
- if (t == OFPType.MULTIPART_REQUEST) {
- return requestClass;
- } else if (t == OFPType.MULTIPART_REPLY) {
- return replyClass;
- } else {
- throw new RuntimeException(t.toString() + " is an invalid OFPType");
- }
- }
-
- /**
- * Returns the no-argument Constructor of the implementation class for this
- * OFPMultipartType, either request or reply based on the supplied OFPType
- *
- * @param t
- * @return
- */
- public Constructor<? extends OFPStatistics> getConstructor(OFPType t) {
- if (t == OFPType.MULTIPART_REQUEST) {
- return requestConstructor;
- } else if (t == OFPType.MULTIPART_REPLY) {
- return replyConstructor;
- } else {
- throw new RuntimeException(t.toString() + " is an invalid OFPType");
- }
- }
-
- /**
- * @return the requestInstantiable
- */
- public Instantiable<OFPStatistics> getRequestInstantiable() {
- return requestInstantiable;
- }
-
- /**
- * @param requestInstantiable
- * the requestInstantiable to set
- */
- public void setRequestInstantiable(Instantiable<OFPStatistics> requestInstantiable) {
- this.requestInstantiable = requestInstantiable;
- }
-
- /**
- * @return the replyInstantiable
- */
- public Instantiable<OFPStatistics> getReplyInstantiable() {
- return replyInstantiable;
- }
-
- /**
- * @param replyInstantiable
- * the replyInstantiable to set
- */
- public void setReplyInstantiable(Instantiable<OFPStatistics> replyInstantiable) {
- this.replyInstantiable = replyInstantiable;
- }
-
- /**
- * Returns a new instance of the implementation class for this
- * OFPMultipartType, either request or reply based on the supplied OFPType
- *
- * @param t
- * @return
- */
- public OFPStatistics newInstance(OFPType t) {
- if (t == OFPType.MULTIPART_REQUEST) {
- return requestInstantiable.instantiate();
- } else if (t == OFPType.MULTIPART_REPLY) {
- return replyInstantiable.instantiate();
- } else {
- throw new RuntimeException(t.toString() + " is an invalid OFPType");
- }
- }
-}
Code Review / openflowjava.git / blobdiff