-
-
-
- private MultipartRequestInputFactory() {
- // singleton
- }
-
- /**
- * @return singleton factory
- */
- public static synchronized MultipartRequestInputFactory getInstance() {
- if (instance == null) {
- instance = new MultipartRequestInputFactory();
- }
- return instance;
- }
-
- @Override
- public void messageToBuffer(short version, ByteBuf out,
- MultipartRequestInput message) {
- ByteBufUtils.writeOFHeader(instance, message, out);
- out.writeShort(message.getType().getIntValue());
- out.writeShort(createMultipartRequestFlagsBitmask(message.getFlags()));
- ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_MESSAGE, out);
-
- if (message.getMultipartRequestBody() instanceof MultipartRequestDesc ){
- encodeDescBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestFlow) {
- encodeFlowBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestAggregate) {
- encodeAggregateBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestTable) {
- encodeTableBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortStats) {
- encodePortStatsBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestQueue) {
- encodeQueueBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestGroup) {
- encodeGroupStatsBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestGroupDesc) {
- encodeGroupDescBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestGroupFeatures) {
- encodeGroupFeaturesBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestMeter) {
- encodeMeterBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestMeterConfig) {
- encodeMeterConfigBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestMeterFeatures) {
- encodeMeterFeaturesBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestTableFeatures) {
- encodeTableFeaturesBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortDesc) {
- encodePortDescBody(message.getMultipartRequestBody(), out);
- } else if (message.getMultipartRequestBody() instanceof MultipartRequestExperimenter) {
- encodeExperimenterBody(message.getMultipartRequestBody(), out);
- }
- }