java_gen/templates/of_class.java - onos-loxi - Gitiles

 //:: # Copyright 2013, Big Switch Networks, Inc.
 //:: #
 //:: # LoxiGen is licensed under the Eclipse Public License, version 1.0 (EPL), with
 //:: # the following special exception:
 //:: #
 //:: # LOXI Exception
 //:: #
 //:: # As a special exception to the terms of the EPL, you may distribute libraries
 //:: # generated by LoxiGen (LoxiGen Libraries) under the terms of your choice, provided
 //:: # that copyright and licensing notices generated by LoxiGen are not altered or removed
 //:: # from the LoxiGen Libraries and the notice provided below is (i) included in
 //:: # the LoxiGen Libraries, if distributed in source code form and (ii) included in any
 //:: # documentation for the LoxiGen Libraries, if distributed in binary form.
 //:: #
 //:: # Notice: "Copyright 2013, Big Switch Networks, Inc. This library was generated by the LoxiGen Compiler."
 //:: #
 //:: # You may not use this file except in compliance with the EPL or LOXI Exception. You may obtain
 //:: # a copy of the EPL at:
 //:: #
 //:: # http::: #www.eclipse.org/legal/epl-v10.html
 //:: #
 //:: # Unless required by applicable law or agreed to in writing, software
 //:: # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 //:: # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 //:: # EPL for the specific language governing permissions and limitations
 //:: # under the EPL.
 //::
 //:: from loxi_ir import *
 //:: import os
 //:: import itertools
 //:: include('_copyright.java')

 //:: include('_autogen.java')

 package ${msg.package};

 //:: include("_imports.java", msg=msg)

 class ${impl_class} implements ${msg.interface.inherited_declaration()} {
 //:: if genopts.instrument:
     private static final Logger logger = LoggerFactory.getLogger(${impl_class}.class);
 //:: #endif
     // version: ${version}
     final static byte WIRE_VERSION = ${version.int_version};
 //:: if msg.is_fixed_length:
     final static int LENGTH = ${msg.length};
 //:: else:
     final static int MINIMUM_LENGTH = ${msg.min_length};
 //:: #endif

 //:: for prop in msg.data_members:
     //:: if prop.java_type.public_type != msg.interface.member_by_name(prop.name).java_type.public_type:
     //::    raise Exception("Interface and Class types do not match up: C: {} <-> I: {}".format(prop.java_type.public_type, msg.interface.member_by_name(prop.name).java_type.public_type))
     //:: #endif
     //:: if prop.default_value:
         private final static ${prop.java_type.public_type} ${prop.default_name} = ${prop.default_value};
     //:: #endif
 //:: #end

     // OF message fields
 //:: for prop in msg.data_members:
     private final ${prop.java_type.public_type} ${prop.name};
 //:: #endfor
 //
 //:: if all(prop.default_value for prop in msg.data_members):
     // Immutable default instance
     final static ${impl_class} DEFAULT = new ${impl_class}(
         ${", ".join(prop.default_name for prop in msg.data_members)}
     );
 //:: #endif

     //:: if msg.data_members:
     // package private constructor - used by readers, builders, and factory
     ${impl_class}(${
         ", ".join("%s %s" %(prop.java_type.public_type, prop.name) for prop in msg.data_members) }) {
 //:: for prop in msg.data_members:
         this.${prop.name} = ${prop.name};
 //:: #endfor
     }
     //:: else:
     final static ${impl_class} INSTANCE = new ${impl_class}();
     // private empty constructor - use shared instance!
     private ${impl_class}() {
     }
     //:: #endif

     // Accessors for OF message fields
     //:: include("_field_accessors.java", msg=msg, generate_setters=False, builder=False, has_parent=False)

     //:: if os.path.exists("%s/custom/%s.java" % (template_dir, msg.name)):
     //:: include("custom/%s.java" % msg.name, msg=msg)
     //:: #endif

     //:: if msg.data_members:
     public ${msg.interface.name}.Builder createBuilder() {
         return new BuilderWithParent(this);
     }

     static class BuilderWithParent implements ${msg.interface.name}.Builder {
         final ${impl_class} parentMessage;

         // OF message fields
 //:: for prop in msg.data_members:
         private boolean ${prop.name}Set;
         private ${prop.java_type.public_type} ${prop.name};
 //:: #endfor

         BuilderWithParent(${impl_class} parentMessage) {
             this.parentMessage = parentMessage;
         }

 //:: include("_field_accessors.java", msg=msg, generate_setters=True, builder=True, has_parent=True)


         @Override
         public ${msg.interface.name} build() {
                 //:: for prop in msg.data_members:
                 ${prop.java_type.public_type} ${prop.name} = this.${prop.name}Set ? this.${prop.name} : parentMessage.${prop.name};
                 //::    if not prop.is_nullable and not prop.java_type.is_primitive:
                 if(${prop.name} == null)
                     throw new NullPointerException("Property ${prop.name} must not be null");
                 //::    #endif
                 //:: #endfor

                 //
                 //:: if os.path.exists("%s/custom/%s.Builder_normalize_stanza.java" % (template_dir, msg.name)):
                 //:: include("custom/%s.Builder_normalize_stanza.java" % msg.name, msg=msg, has_parent=False)
                 //:: #endif
                 return new ${impl_class}(
                 //:: for i, prop in enumerate(msg.data_members):
                 //::    comma = "," if i < len(msg.data_members)-1 else ""
                     ${prop.name}${comma}
                 //:: #endfor
                 );
         }
         //:: if os.path.exists("%s/custom/%s.Builder.java" % (template_dir, msg.name)):
         //:: include("custom/%s.Builder.java" % msg.name, msg=msg, has_parent=True)
         //:: #endif

     }

     static class Builder implements ${msg.interface.name}.Builder {
         // OF message fields
 //:: for prop in msg.data_members:
         private boolean ${prop.name}Set;
         private ${prop.java_type.public_type} ${prop.name};
 //:: #endfor

 //:: include("_field_accessors.java", msg=msg, generate_setters=True, builder=True, has_parent=False)
 //
         @Override
         public ${msg.interface.name} build() {
             //:: for prop in msg.data_members:
             //::    if prop.default_value:
             ${prop.java_type.public_type} ${prop.name} = this.${prop.name}Set ? this.${prop.name} : ${prop.default_name};
             //:: else:
             if(!this.${prop.name}Set)
                 throw new IllegalStateException("Property ${prop.name} doesn't have default value -- must be set");
             //::    #endif
             //::    if not prop.is_nullable and not prop.java_type.is_primitive:
             if(${prop.name} == null)
                 throw new NullPointerException("Property ${prop.name} must not be null");
             //::    #endif
             //:: #endfor

             //:: if os.path.exists("%s/custom/%s.Builder_normalize_stanza.java" % (template_dir, msg.name)):
             //:: include("custom/%s.Builder_normalize_stanza.java" % msg.name, msg=msg, has_parent=False)
             //:: #endif

             return new ${impl_class}(
                 //:: for i, prop in enumerate(msg.data_members):
                 //::    comma = "," if i < len(msg.data_members)-1 else ""
                     ${prop.name}${comma}
                 //:: #endfor
                 );
         }
         //:: if os.path.exists("%s/custom/%s.Builder.java" % (template_dir, msg.name)):
         //:: include("custom/%s.Builder.java" % msg.name, msg=msg, has_parent=False)
         //:: #endif

     }
     //:: else:
     // no data members - do not support builder
     public ${msg.interface.name}.Builder createBuilder() {
         throw new UnsupportedOperationException("${impl_class} has no mutable properties -- builder unneeded");
     }
     //:: #endif


     final static Reader READER = new Reader();
     static class Reader implements OFMessageReader<${msg.interface.name}> {
         @Override
         public ${msg.interface.name} readFrom(ChannelBuffer bb) throws OFParseError {
 //:: for prop in msg.members:
 //:: if not prop.is_virtual and (prop.is_length_value or prop.is_field_length_value):
             int start = bb.readerIndex();
 //::     break
 //:: #endif
 //:: #endfor
 //:: fields_with_length_member = {}
 //:: for prop in msg.members:
 //:: if prop.is_virtual:
 //::    continue
 //:: elif prop.is_data:
             ${prop.java_type.public_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=True,
                     length=fields_with_length_member[prop.c_name] if prop.c_name in fields_with_length_member else None)};
 //:: elif prop.is_pad:
             // pad: ${prop.length} bytes
             bb.skipBytes(${prop.length});
 //:: elif prop.is_length_value:
             ${prop.java_type.public_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=True)};
             //:: if prop.is_fixed_value:
             if(${prop.name} != ${prop.value})
                 throw new OFParseError("Wrong ${prop.name}: Expected=${prop.enum_value}(${prop.value}), got="+${prop.name});
             //:: else:
             if(${prop.name} < MINIMUM_LENGTH)
                 throw new OFParseError("Wrong ${prop.name}: Expected to be >= " + MINIMUM_LENGTH + ", was: " + ${prop.name});
             //:: #endif
             if(bb.readableBytes() + (bb.readerIndex() - start) < ${prop.name}) {
                 // Buffer does not have all data yet
                 bb.readerIndex(start);
                 return null;
             }
             //:: if genopts.instrument:
             if(logger.isTraceEnabled())
                 logger.trace("readFrom - length={}", ${prop.name});
             //:: #endif
 //:: elif prop.is_fixed_value:
             // fixed value property ${prop.name} == ${prop.value}
             ${prop.java_type.priv_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=False)};
             if(${prop.name} != ${prop.priv_value})
                 throw new OFParseError("Wrong ${prop.name}: Expected=${prop.enum_value}(${prop.value}), got="+${prop.name});
 //:: elif prop.is_field_length_value:
 //::        fields_with_length_member[prop.member.field_name] = prop.name
             ${prop.java_type.public_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=True)};
 //:: else:
     // fixme: todo ${prop.name}
 //:: #endif
 //:: #endfor
             //:: if msg.align:
             //:: if msg.length_includes_align:
             // align message to ${msg.align} bytes (length contains aligned value)
             bb.skipBytes(length - (bb.readerIndex() - start));
             //:: else:
             // align message to ${msg.align} bytes (length does not contain alignment)
             bb.skipBytes(((length + ${msg.align-1})/${msg.align} * ${msg.align} ) - length );
             //:: #endif
             //:: #endif

             //:: if msg.data_members:
             //:: if os.path.exists("%s/custom/%s.Reader_normalize_stanza.java" % (template_dir, msg.name)):
             //:: include("custom/%s.Reader_normalize_stanza.java" % msg.name, msg=msg, has_parent=False)
             //:: #endif
             ${impl_class} ${msg.variable_name} = new ${impl_class}(
                     ${",\n                      ".join(
                          [ prop.name for prop in msg.data_members])}
                     );
             //:: if genopts.instrument:
             if(logger.isTraceEnabled())
                 logger.trace("readFrom - read={}", ${msg.variable_name});
             //:: #endif
             return ${msg.variable_name};
             //:: else:
             //:: if genopts.instrument:
             if(logger.isTraceEnabled())
                 logger.trace("readFrom - returning shared instance={}", INSTANCE);
             //:: #endif
             return INSTANCE;
             //:: #endif
         }
     }

     public void putTo(PrimitiveSink sink) {
         FUNNEL.funnel(this, sink);
     }

     final static ${impl_class}Funnel FUNNEL = new ${impl_class}Funnel();
     static class ${impl_class}Funnel implements Funnel<${impl_class}> {
         private static final long serialVersionUID = 1L;
         @Override
         public void funnel(${impl_class} message, PrimitiveSink sink) {
 //:: for prop in msg.members:
 //:: if prop.is_virtual:
 //::    continue
 //:: elif prop.is_data:
             ${prop.java_type.funnel_op(version, "message." + prop.name, pub_type=True)};
 //:: elif prop.is_pad:
             // skip pad (${prop.length} bytes)
 //:: elif prop.is_fixed_value:
             // fixed value property ${prop.name} = ${prop.value}
             ${prop.java_type.funnel_op(version, prop.priv_value, pub_type=False)};
 //:: else:
             // FIXME: skip funnel of ${prop.name}
 //:: #endif
 //:: #endfor
         }
     }


     public void writeTo(ChannelBuffer bb) {
         WRITER.write(bb, this);
     }

     final static Writer WRITER = new Writer();
     static class Writer implements OFMessageWriter<${impl_class}> {
         @Override
         public void write(ChannelBuffer bb, ${impl_class} message) {
 //:: if not msg.is_fixed_length:
             int startIndex = bb.writerIndex();
 //:: #endif
 //:: fields_with_length_member = {}
 //:: for prop in msg.members:
 //:: if prop.c_name in fields_with_length_member:
             int ${prop.name}StartIndex = bb.writerIndex();
 //:: #endif
 //:: if prop.is_virtual:
 //::    continue
 //:: elif prop.is_data:
             ${prop.java_type.write_op(version, "message." + prop.name, pub_type=True)};
 //:: elif prop.is_pad:
             // pad: ${prop.length} bytes
             bb.writeZero(${prop.length});
 //:: elif prop.is_fixed_value:
             // fixed value property ${prop.name} = ${prop.value}
             ${prop.java_type.write_op(version, prop.priv_value, pub_type=False)};
 //:: elif prop.is_length_value:
             // ${prop.name} is length of variable message, will be updated at the end
 //:: if not msg.is_fixed_length:
             int lengthIndex = bb.writerIndex();
 //:: #end
             ${prop.java_type.write_op(version, 0)};

 //:: elif prop.is_field_length_value:
 //::        fields_with_length_member[prop.member.field_name] = prop.name
             // ${prop.name} is length indicator for ${prop.member.field_name}, will be
             // udpated when ${prop.member.field_name} has been written
             int ${prop.name}Index = bb.writerIndex();
             ${prop.java_type.write_op(version, 0, pub_type=False)};
 //:: else:
             // FIXME: todo write ${prop.name}
 //:: #endif
 //:: if prop.c_name in fields_with_length_member:
 //::     length_member_name = fields_with_length_member[prop.c_name]
             // update field length member ${length_member_name}
             int ${prop.name}Length = bb.writerIndex() - ${prop.name}StartIndex;
             bb.setShort(${length_member_name}Index, ${prop.name}Length);
 //:: #endif
 //:: #endfor

 //:: if not msg.is_fixed_length:
             // update length field
             int length = bb.writerIndex() - startIndex;
             //:: if msg.align:
             int alignedLength = ((length + ${msg.align-1})/${msg.align} * ${msg.align});
             //:: #endif
             bb.setShort(lengthIndex, ${"alignedLength" if msg.length_includes_align else "length"});
             //:: if msg.align:
             // align message to ${msg.align} bytes
             bb.writeZero(alignedLength - length);
             //:: #endif
 //:: #end

         }
     }

     @Override
     public String toString() {
         StringBuilder b = new StringBuilder("${msg.name}(");
         //:: for i, prop in enumerate(msg.data_members):
         //:: if i > 0:
         b.append(", ");
         //:: #endif
         b.append("${prop.name}=").append(${ "Arrays.toString(%s)" % prop.name if prop.java_type.is_array else prop.name });
         //:: #endfor
         b.append(")");
         return b.toString();
     }


     @Override
     public boolean equals(Object obj) {
         if (this == obj)
             return true;
         if (obj == null)
             return false;
         if (getClass() != obj.getClass())
             return false;
         //:: if len(msg.data_members) > 0:
         ${msg.name} other = (${msg.name}) obj;
         //:: #endif

         //:: for prop in msg.data_members:
         //:: if prop.java_type.is_primitive:
         if( ${prop.name} != other.${prop.name})
             return false;
         //:: elif prop.java_type.is_array:
         if (!Arrays.equals(${prop.name}, other.${prop.name}))
                 return false;
         //:: else:
         if (${prop.name} == null) {
             if (other.${prop.name} != null)
                 return false;
         } else if (!${prop.name}.equals(other.${prop.name}))
             return false;
         //:: #endif
         //:: #endfor
         return true;
     }

     @Override
     public int hashCode() {
         //:: if len(msg.data_members) > 0:
         final int prime = 31;
         //:: #endif
         int result = 1;

         //:: for prop in msg.data_members:
         //:: if prop.java_type.pub_type == 'long':
         result = prime *  (int) (${prop.name} ^ (${prop.name} >>> 32));
         //:: elif prop.java_type.pub_type == 'boolean':
         result = prime * result + (${prop.name} ? 1231 : 1237);
         //:: elif prop.java_type.is_primitive:
         result = prime * result + ${prop.name};
         //:: elif prop.java_type.is_array:
         result = prime * result + Arrays.hashCode(${prop.name});
         //:: else:
         result = prime * result + ((${prop.name} == null) ? 0 : ${prop.name}.hashCode());
         //:: #endif
         //:: #endfor
         return result;
     }


 }
	//:: # Copyright 2013, Big Switch Networks, Inc.
	//:: #
	//:: # LoxiGen is licensed under the Eclipse Public License, version 1.0 (EPL), with
	//:: # the following special exception:
	//:: #
	//:: # LOXI Exception
	//:: #
	//:: # As a special exception to the terms of the EPL, you may distribute libraries
	//:: # generated by LoxiGen (LoxiGen Libraries) under the terms of your choice, provided
	//:: # that copyright and licensing notices generated by LoxiGen are not altered or removed
	//:: # from the LoxiGen Libraries and the notice provided below is (i) included in
	//:: # the LoxiGen Libraries, if distributed in source code form and (ii) included in any
	//:: # documentation for the LoxiGen Libraries, if distributed in binary form.
	//:: #
	//:: # Notice: "Copyright 2013, Big Switch Networks, Inc. This library was generated by the LoxiGen Compiler."
	//:: #
	//:: # You may not use this file except in compliance with the EPL or LOXI Exception. You may obtain
	//:: # a copy of the EPL at:
	//:: #
	//:: # http::: #www.eclipse.org/legal/epl-v10.html
	//:: #
	//:: # Unless required by applicable law or agreed to in writing, software
	//:: # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
	//:: # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
	//:: # EPL for the specific language governing permissions and limitations
	//:: # under the EPL.
	//::
	//:: from loxi_ir import *
	//:: import os
	//:: import itertools
	//:: include('_copyright.java')

	//:: include('_autogen.java')

	package ${msg.package};

	//:: include("_imports.java", msg=msg)

	class ${impl_class} implements ${msg.interface.inherited_declaration()} {
	//:: if genopts.instrument:
	private static final Logger logger = LoggerFactory.getLogger(${impl_class}.class);
	//:: #endif
	// version: ${version}
	final static byte WIRE_VERSION = ${version.int_version};
	//:: if msg.is_fixed_length:
	final static int LENGTH = ${msg.length};
	//:: else:
	final static int MINIMUM_LENGTH = ${msg.min_length};
	//:: #endif

	//:: for prop in msg.data_members:
	//:: if prop.java_type.public_type != msg.interface.member_by_name(prop.name).java_type.public_type:
	//:: raise Exception("Interface and Class types do not match up: C: {} <-> I: {}".format(prop.java_type.public_type, msg.interface.member_by_name(prop.name).java_type.public_type))
	//:: #endif
	//:: if prop.default_value:
	private final static ${prop.java_type.public_type} ${prop.default_name} = ${prop.default_value};
	//:: #endif
	//:: #end

	// OF message fields
	//:: for prop in msg.data_members:
	private final ${prop.java_type.public_type} ${prop.name};
	//:: #endfor
	//
	//:: if all(prop.default_value for prop in msg.data_members):
	// Immutable default instance
	final static ${impl_class} DEFAULT = new ${impl_class}(
	${", ".join(prop.default_name for prop in msg.data_members)}
	);
	//:: #endif

	//:: if msg.data_members:
	// package private constructor - used by readers, builders, and factory
	${impl_class}(${
	", ".join("%s %s" %(prop.java_type.public_type, prop.name) for prop in msg.data_members) }) {
	//:: for prop in msg.data_members:
	this.${prop.name} = ${prop.name};
	//:: #endfor
	}
	//:: else:
	final static ${impl_class} INSTANCE = new ${impl_class}();
	// private empty constructor - use shared instance!
	private ${impl_class}() {
	}
	//:: #endif

	// Accessors for OF message fields
	//:: include("_field_accessors.java", msg=msg, generate_setters=False, builder=False, has_parent=False)

	//:: if os.path.exists("%s/custom/%s.java" % (template_dir, msg.name)):
	//:: include("custom/%s.java" % msg.name, msg=msg)
	//:: #endif

	//:: if msg.data_members:
	public ${msg.interface.name}.Builder createBuilder() {
	return new BuilderWithParent(this);
	}

	static class BuilderWithParent implements ${msg.interface.name}.Builder {
	final ${impl_class} parentMessage;

	// OF message fields
	//:: for prop in msg.data_members:
	private boolean ${prop.name}Set;
	private ${prop.java_type.public_type} ${prop.name};
	//:: #endfor

	BuilderWithParent(${impl_class} parentMessage) {
	this.parentMessage = parentMessage;
	}

	//:: include("_field_accessors.java", msg=msg, generate_setters=True, builder=True, has_parent=True)


	@Override
	public ${msg.interface.name} build() {
	//:: for prop in msg.data_members:
	${prop.java_type.public_type} ${prop.name} = this.${prop.name}Set ? this.${prop.name} : parentMessage.${prop.name};
	//:: if not prop.is_nullable and not prop.java_type.is_primitive:
	if(${prop.name} == null)
	throw new NullPointerException("Property ${prop.name} must not be null");
	//:: #endif
	//:: #endfor

	//
	//:: if os.path.exists("%s/custom/%s.Builder_normalize_stanza.java" % (template_dir, msg.name)):
	//:: include("custom/%s.Builder_normalize_stanza.java" % msg.name, msg=msg, has_parent=False)
	//:: #endif
	return new ${impl_class}(
	//:: for i, prop in enumerate(msg.data_members):
	//:: comma = "," if i < len(msg.data_members)-1 else ""
	${prop.name}${comma}
	//:: #endfor
	);
	}
	//:: if os.path.exists("%s/custom/%s.Builder.java" % (template_dir, msg.name)):
	//:: include("custom/%s.Builder.java" % msg.name, msg=msg, has_parent=True)
	//:: #endif

	}

	static class Builder implements ${msg.interface.name}.Builder {
	// OF message fields
	//:: for prop in msg.data_members:
	private boolean ${prop.name}Set;
	private ${prop.java_type.public_type} ${prop.name};
	//:: #endfor

	//:: include("_field_accessors.java", msg=msg, generate_setters=True, builder=True, has_parent=False)
	//
	@Override
	public ${msg.interface.name} build() {
	//:: for prop in msg.data_members:
	//:: if prop.default_value:
	${prop.java_type.public_type} ${prop.name} = this.${prop.name}Set ? this.${prop.name} : ${prop.default_name};
	//:: else:
	if(!this.${prop.name}Set)
	throw new IllegalStateException("Property ${prop.name} doesn't have default value -- must be set");
	//:: #endif
	//:: if not prop.is_nullable and not prop.java_type.is_primitive:
	if(${prop.name} == null)
	throw new NullPointerException("Property ${prop.name} must not be null");
	//:: #endif
	//:: #endfor

	//:: if os.path.exists("%s/custom/%s.Builder_normalize_stanza.java" % (template_dir, msg.name)):
	//:: include("custom/%s.Builder_normalize_stanza.java" % msg.name, msg=msg, has_parent=False)
	//:: #endif

	return new ${impl_class}(
	//:: for i, prop in enumerate(msg.data_members):
	//:: comma = "," if i < len(msg.data_members)-1 else ""
	${prop.name}${comma}
	//:: #endfor
	);
	}
	//:: if os.path.exists("%s/custom/%s.Builder.java" % (template_dir, msg.name)):
	//:: include("custom/%s.Builder.java" % msg.name, msg=msg, has_parent=False)
	//:: #endif

	}
	//:: else:
	// no data members - do not support builder
	public ${msg.interface.name}.Builder createBuilder() {
	throw new UnsupportedOperationException("${impl_class} has no mutable properties -- builder unneeded");
	}
	//:: #endif


	final static Reader READER = new Reader();
	static class Reader implements OFMessageReader<${msg.interface.name}> {
	@Override
	public ${msg.interface.name} readFrom(ChannelBuffer bb) throws OFParseError {
	//:: for prop in msg.members:
	//:: if not prop.is_virtual and (prop.is_length_value or prop.is_field_length_value):
	int start = bb.readerIndex();
	//:: break
	//:: #endif
	//:: #endfor
	//:: fields_with_length_member = {}
	//:: for prop in msg.members:
	//:: if prop.is_virtual:
	//:: continue
	//:: elif prop.is_data:
	${prop.java_type.public_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=True,
	length=fields_with_length_member[prop.c_name] if prop.c_name in fields_with_length_member else None)};
	//:: elif prop.is_pad:
	// pad: ${prop.length} bytes
	bb.skipBytes(${prop.length});
	//:: elif prop.is_length_value:
	${prop.java_type.public_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=True)};
	//:: if prop.is_fixed_value:
	if(${prop.name} != ${prop.value})
	throw new OFParseError("Wrong ${prop.name}: Expected=${prop.enum_value}(${prop.value}), got="+${prop.name});
	//:: else:
	if(${prop.name} < MINIMUM_LENGTH)
	throw new OFParseError("Wrong ${prop.name}: Expected to be >= " + MINIMUM_LENGTH + ", was: " + ${prop.name});
	//:: #endif
	if(bb.readableBytes() + (bb.readerIndex() - start) < ${prop.name}) {
	// Buffer does not have all data yet
	bb.readerIndex(start);
	return null;
	}
	//:: if genopts.instrument:
	if(logger.isTraceEnabled())
	logger.trace("readFrom - length={}", ${prop.name});
	//:: #endif
	//:: elif prop.is_fixed_value:
	// fixed value property ${prop.name} == ${prop.value}
	${prop.java_type.priv_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=False)};
	if(${prop.name} != ${prop.priv_value})
	throw new OFParseError("Wrong ${prop.name}: Expected=${prop.enum_value}(${prop.value}), got="+${prop.name});
	//:: elif prop.is_field_length_value:
	//:: fields_with_length_member[prop.member.field_name] = prop.name
	${prop.java_type.public_type} ${prop.name} = ${prop.java_type.read_op(version, pub_type=True)};
	//:: else:
	// fixme: todo ${prop.name}
	//:: #endif
	//:: #endfor
	//:: if msg.align:
	//:: if msg.length_includes_align:
	// align message to ${msg.align} bytes (length contains aligned value)
	bb.skipBytes(length - (bb.readerIndex() - start));
	//:: else:
	// align message to ${msg.align} bytes (length does not contain alignment)
	bb.skipBytes(((length + ${msg.align-1})/${msg.align} * ${msg.align} ) - length );
	//:: #endif
	//:: #endif

	//:: if msg.data_members:
	//:: if os.path.exists("%s/custom/%s.Reader_normalize_stanza.java" % (template_dir, msg.name)):
	//:: include("custom/%s.Reader_normalize_stanza.java" % msg.name, msg=msg, has_parent=False)
	//:: #endif
	${impl_class} ${msg.variable_name} = new ${impl_class}(
	${",\n ".join(
	[ prop.name for prop in msg.data_members])}
	);
	//:: if genopts.instrument:
	if(logger.isTraceEnabled())
	logger.trace("readFrom - read={}", ${msg.variable_name});
	//:: #endif
	return ${msg.variable_name};
	//:: else:
	//:: if genopts.instrument:
	if(logger.isTraceEnabled())
	logger.trace("readFrom - returning shared instance={}", INSTANCE);
	//:: #endif
	return INSTANCE;
	//:: #endif
	}
	}

	public void putTo(PrimitiveSink sink) {
	FUNNEL.funnel(this, sink);
	}

	final static ${impl_class}Funnel FUNNEL = new ${impl_class}Funnel();
	static class ${impl_class}Funnel implements Funnel<${impl_class}> {
	private static final long serialVersionUID = 1L;
	@Override
	public void funnel(${impl_class} message, PrimitiveSink sink) {
	//:: for prop in msg.members:
	//:: if prop.is_virtual:
	//:: continue
	//:: elif prop.is_data:
	${prop.java_type.funnel_op(version, "message." + prop.name, pub_type=True)};
	//:: elif prop.is_pad:
	// skip pad (${prop.length} bytes)
	//:: elif prop.is_fixed_value:
	// fixed value property ${prop.name} = ${prop.value}
	${prop.java_type.funnel_op(version, prop.priv_value, pub_type=False)};
	//:: else:
	// FIXME: skip funnel of ${prop.name}
	//:: #endif
	//:: #endfor
	}
	}


	public void writeTo(ChannelBuffer bb) {
	WRITER.write(bb, this);
	}

	final static Writer WRITER = new Writer();
	static class Writer implements OFMessageWriter<${impl_class}> {
	@Override
	public void write(ChannelBuffer bb, ${impl_class} message) {
	//:: if not msg.is_fixed_length:
	int startIndex = bb.writerIndex();
	//:: #endif
	//:: fields_with_length_member = {}
	//:: for prop in msg.members:
	//:: if prop.c_name in fields_with_length_member:
	int ${prop.name}StartIndex = bb.writerIndex();
	//:: #endif
	//:: if prop.is_virtual:
	//:: continue
	//:: elif prop.is_data:
	${prop.java_type.write_op(version, "message." + prop.name, pub_type=True)};
	//:: elif prop.is_pad:
	// pad: ${prop.length} bytes
	bb.writeZero(${prop.length});
	//:: elif prop.is_fixed_value:
	// fixed value property ${prop.name} = ${prop.value}
	${prop.java_type.write_op(version, prop.priv_value, pub_type=False)};
	//:: elif prop.is_length_value:
	// ${prop.name} is length of variable message, will be updated at the end
	//:: if not msg.is_fixed_length:
	int lengthIndex = bb.writerIndex();
	//:: #end
	${prop.java_type.write_op(version, 0)};

	//:: elif prop.is_field_length_value:
	//:: fields_with_length_member[prop.member.field_name] = prop.name
	// ${prop.name} is length indicator for ${prop.member.field_name}, will be
	// udpated when ${prop.member.field_name} has been written
	int ${prop.name}Index = bb.writerIndex();
	${prop.java_type.write_op(version, 0, pub_type=False)};
	//:: else:
	// FIXME: todo write ${prop.name}
	//:: #endif
	//:: if prop.c_name in fields_with_length_member:
	//:: length_member_name = fields_with_length_member[prop.c_name]
	// update field length member ${length_member_name}
	int ${prop.name}Length = bb.writerIndex() - ${prop.name}StartIndex;
	bb.setShort(${length_member_name}Index, ${prop.name}Length);
	//:: #endif
	//:: #endfor

	//:: if not msg.is_fixed_length:
	// update length field
	int length = bb.writerIndex() - startIndex;
	//:: if msg.align:
	int alignedLength = ((length + ${msg.align-1})/${msg.align} * ${msg.align});
	//:: #endif
	bb.setShort(lengthIndex, ${"alignedLength" if msg.length_includes_align else "length"});
	//:: if msg.align:
	// align message to ${msg.align} bytes
	bb.writeZero(alignedLength - length);
	//:: #endif
	//:: #end

	}
	}

	@Override
	public String toString() {
	StringBuilder b = new StringBuilder("${msg.name}(");
	//:: for i, prop in enumerate(msg.data_members):
	//:: if i > 0:
	b.append(", ");
	//:: #endif
	b.append("${prop.name}=").append(${ "Arrays.toString(%s)" % prop.name if prop.java_type.is_array else prop.name });
	//:: #endfor
	b.append(")");
	return b.toString();
	}


	@Override
	public boolean equals(Object obj) {
	if (this == obj)
	return true;
	if (obj == null)
	return false;
	if (getClass() != obj.getClass())
	return false;
	//:: if len(msg.data_members) > 0:
	${msg.name} other = (${msg.name}) obj;
	//:: #endif

	//:: for prop in msg.data_members:
	//:: if prop.java_type.is_primitive:
	if( ${prop.name} != other.${prop.name})
	return false;
	//:: elif prop.java_type.is_array:
	if (!Arrays.equals(${prop.name}, other.${prop.name}))
	return false;
	//:: else:
	if (${prop.name} == null) {
	if (other.${prop.name} != null)
	return false;
	} else if (!${prop.name}.equals(other.${prop.name}))
	return false;
	//:: #endif
	//:: #endfor
	return true;
	}

	@Override
	public int hashCode() {
	//:: if len(msg.data_members) > 0:
	final int prime = 31;
	//:: #endif
	int result = 1;

	//:: for prop in msg.data_members:
	//:: if prop.java_type.pub_type == 'long':
	result = prime * (int) (${prop.name} ^ (${prop.name} >>> 32));
	//:: elif prop.java_type.pub_type == 'boolean':
	result = prime * result + (${prop.name} ? 1231 : 1237);
	//:: elif prop.java_type.is_primitive:
	result = prime * result + ${prop.name};
	//:: elif prop.java_type.is_array:
	result = prime * result + Arrays.hashCode(${prop.name});
	//:: else:
	result = prime * result + ((${prop.name} == null) ? 0 : ${prop.name}.hashCode());
	//:: #endif
	//:: #endfor
	return result;
	}


	}