blob: b2e66053653df04ee9ee9eaaaa5ebbc02f860b24 [file]
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* 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 License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.ignite.internal;
import org.apache.ignite.internal.TestMapMessage;
import org.apache.ignite.plugin.extensions.communication.MessageCollectionItemType;
import org.apache.ignite.plugin.extensions.communication.MessageCollectionType;
import org.apache.ignite.plugin.extensions.communication.MessageItemType;
import org.apache.ignite.plugin.extensions.communication.MessageMapType;
import org.apache.ignite.plugin.extensions.communication.MessageReader;
import org.apache.ignite.plugin.extensions.communication.MessageSerializer;
import org.apache.ignite.plugin.extensions.communication.MessageWriter;
/**
* This class is generated automatically.
*
* @see org.apache.ignite.internal.MessageProcessor
*/
public class TestMapMessageSerializer implements MessageSerializer<TestMapMessage> {
/** */
private final static MessageMapType affTopVersionIgniteUuidMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.AFFINITY_TOPOLOGY_VERSION), new MessageItemType(MessageCollectionItemType.IGNITE_UUID), false);
/** */
private final static MessageMapType bitSetUuidMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.BIT_SET), new MessageItemType(MessageCollectionItemType.UUID), false);
/** */
private final static MessageMapType booleanArrayBoxedLongMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.BOOLEAN_ARR), new MessageItemType(MessageCollectionItemType.LONG), false);
/** */
private final static MessageMapType boxedBooleanAffTopVersionMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.BOOLEAN), new MessageItemType(MessageCollectionItemType.AFFINITY_TOPOLOGY_VERSION), false);
/** */
private final static MessageMapType boxedByteBoxedBooleanMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.BYTE), new MessageItemType(MessageCollectionItemType.BOOLEAN), false);
/** */
private final static MessageMapType boxedCharBoxedLongMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.CHAR), new MessageItemType(MessageCollectionItemType.LONG), false);
/** */
private final static MessageMapType boxedDoubleBoxedFloatMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.DOUBLE), new MessageItemType(MessageCollectionItemType.FLOAT), false);
/** */
private final static MessageMapType boxedFloatBoxedCharMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.FLOAT), new MessageItemType(MessageCollectionItemType.CHAR), false);
/** */
private final static MessageMapType boxedIntBoxedShortMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.INT), new MessageItemType(MessageCollectionItemType.SHORT), false);
/** */
private final static MessageMapType boxedLongBoxedIntMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.LONG), new MessageItemType(MessageCollectionItemType.INT), false);
/** */
private final static MessageMapType boxedShortBoxedByteMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.SHORT), new MessageItemType(MessageCollectionItemType.BYTE), false);
/** */
private final static MessageMapType byteArrayBooleanArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.BYTE_ARR), new MessageItemType(MessageCollectionItemType.BOOLEAN_ARR), false);
/** */
private final static MessageMapType charArrayLongArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.CHAR_ARR), new MessageItemType(MessageCollectionItemType.LONG_ARR), false);
/** */
private final static MessageMapType doubleArrayFloatArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.DOUBLE_ARR), new MessageItemType(MessageCollectionItemType.FLOAT_ARR), false);
/** */
private final static MessageMapType floatArrayCharArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.FLOAT_ARR), new MessageItemType(MessageCollectionItemType.CHAR_ARR), false);
/** */
private final static MessageMapType gridLongListIntegerMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.GRID_LONG_LIST), new MessageItemType(MessageCollectionItemType.INT), false);
/** */
private final static MessageMapType gridlistDoubleMapUuidMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.GRID_LONG_LIST), new MessageMapType(new MessageItemType(MessageCollectionItemType.UUID), new MessageCollectionType(new MessageItemType(MessageCollectionItemType.DOUBLE), false), false), false);
/** */
private final static MessageMapType igniteUuidBitSetMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.IGNITE_UUID), new MessageItemType(MessageCollectionItemType.BIT_SET), false);
/** */
private final static MessageMapType intArrayShortArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.INT_ARR), new MessageItemType(MessageCollectionItemType.SHORT_ARR), false);
/** */
private final static MessageMapType integerGridLongListMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.INT), new MessageItemType(MessageCollectionItemType.GRID_LONG_LIST), false);
/** */
private final static MessageMapType longArrayIntArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.LONG_ARR), new MessageItemType(MessageCollectionItemType.INT_ARR), false);
/** */
private final static MessageMapType messageBoxedDoubleMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.MSG), new MessageItemType(MessageCollectionItemType.DOUBLE), false);
/** */
private final static MessageMapType shortArrayByteArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.SHORT_ARR), new MessageItemType(MessageCollectionItemType.BYTE_ARR), false);
/** */
private final static MessageMapType stringDoubleArrayMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.STRING), new MessageItemType(MessageCollectionItemType.DOUBLE_ARR), false);
/** */
private final static MessageMapType uuidStringMapCollDesc = new MessageMapType(new MessageItemType(MessageCollectionItemType.UUID), new MessageItemType(MessageCollectionItemType.STRING), false);
/** */
@Override public boolean writeTo(TestMapMessage msg, MessageWriter writer) {
if (!writer.isHeaderWritten()) {
if (!writer.writeHeader(msg.directType()))
return false;
writer.onHeaderWritten();
}
switch (writer.state()) {
case 0:
if (!writer.writeMap(msg.booleanArrayBoxedLongMap, booleanArrayBoxedLongMapCollDesc))
return false;
writer.incrementState();
case 1:
if (!writer.writeMap(msg.byteArrayBooleanArrayMap, byteArrayBooleanArrayMapCollDesc))
return false;
writer.incrementState();
case 2:
if (!writer.writeMap(msg.shortArrayByteArrayMap, shortArrayByteArrayMapCollDesc))
return false;
writer.incrementState();
case 3:
if (!writer.writeMap(msg.intArrayShortArrayMap, intArrayShortArrayMapCollDesc))
return false;
writer.incrementState();
case 4:
if (!writer.writeMap(msg.longArrayIntArrayMap, longArrayIntArrayMapCollDesc))
return false;
writer.incrementState();
case 5:
if (!writer.writeMap(msg.charArrayLongArrayMap, charArrayLongArrayMapCollDesc))
return false;
writer.incrementState();
case 6:
if (!writer.writeMap(msg.floatArrayCharArrayMap, floatArrayCharArrayMapCollDesc))
return false;
writer.incrementState();
case 7:
if (!writer.writeMap(msg.doubleArrayFloatArrayMap, doubleArrayFloatArrayMapCollDesc))
return false;
writer.incrementState();
case 8:
if (!writer.writeMap(msg.stringDoubleArrayMap, stringDoubleArrayMapCollDesc))
return false;
writer.incrementState();
case 9:
if (!writer.writeMap(msg.uuidStringMap, uuidStringMapCollDesc))
return false;
writer.incrementState();
case 10:
if (!writer.writeMap(msg.bitSetUuidMap, bitSetUuidMapCollDesc))
return false;
writer.incrementState();
case 11:
if (!writer.writeMap(msg.igniteUuidBitSetMap, igniteUuidBitSetMapCollDesc))
return false;
writer.incrementState();
case 12:
if (!writer.writeMap(msg.affTopVersionIgniteUuidMap, affTopVersionIgniteUuidMapCollDesc))
return false;
writer.incrementState();
case 13:
if (!writer.writeMap(msg.boxedBooleanAffTopVersionMap, boxedBooleanAffTopVersionMapCollDesc))
return false;
writer.incrementState();
case 14:
if (!writer.writeMap(msg.boxedByteBoxedBooleanMap, boxedByteBoxedBooleanMapCollDesc))
return false;
writer.incrementState();
case 15:
if (!writer.writeMap(msg.boxedShortBoxedByteMap, boxedShortBoxedByteMapCollDesc))
return false;
writer.incrementState();
case 16:
if (!writer.writeMap(msg.boxedIntBoxedShortMap, boxedIntBoxedShortMapCollDesc))
return false;
writer.incrementState();
case 17:
if (!writer.writeMap(msg.boxedLongBoxedIntMap, boxedLongBoxedIntMapCollDesc))
return false;
writer.incrementState();
case 18:
if (!writer.writeMap(msg.boxedCharBoxedLongMap, boxedCharBoxedLongMapCollDesc))
return false;
writer.incrementState();
case 19:
if (!writer.writeMap(msg.boxedFloatBoxedCharMap, boxedFloatBoxedCharMapCollDesc))
return false;
writer.incrementState();
case 20:
if (!writer.writeMap(msg.boxedDoubleBoxedFloatMap, boxedDoubleBoxedFloatMapCollDesc))
return false;
writer.incrementState();
case 21:
if (!writer.writeMap(msg.messageBoxedDoubleMap, messageBoxedDoubleMapCollDesc))
return false;
writer.incrementState();
case 22:
if (!writer.writeMap(msg.integerGridLongListMap, integerGridLongListMapCollDesc))
return false;
writer.incrementState();
case 23:
if (!writer.writeMap(msg.gridLongListIntegerMap, gridLongListIntegerMapCollDesc))
return false;
writer.incrementState();
case 24:
if (!writer.writeMap(msg.gridlistDoubleMapUuidMap, gridlistDoubleMapUuidMapCollDesc))
return false;
writer.incrementState();
}
return true;
}
/** */
@Override public boolean readFrom(TestMapMessage msg, MessageReader reader) {
switch (reader.state()) {
case 0:
msg.booleanArrayBoxedLongMap = reader.readMap(booleanArrayBoxedLongMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 1:
msg.byteArrayBooleanArrayMap = reader.readMap(byteArrayBooleanArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 2:
msg.shortArrayByteArrayMap = reader.readMap(shortArrayByteArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 3:
msg.intArrayShortArrayMap = reader.readMap(intArrayShortArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 4:
msg.longArrayIntArrayMap = reader.readMap(longArrayIntArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 5:
msg.charArrayLongArrayMap = reader.readMap(charArrayLongArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 6:
msg.floatArrayCharArrayMap = reader.readMap(floatArrayCharArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 7:
msg.doubleArrayFloatArrayMap = reader.readMap(doubleArrayFloatArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 8:
msg.stringDoubleArrayMap = reader.readMap(stringDoubleArrayMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 9:
msg.uuidStringMap = reader.readMap(uuidStringMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 10:
msg.bitSetUuidMap = reader.readMap(bitSetUuidMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 11:
msg.igniteUuidBitSetMap = reader.readMap(igniteUuidBitSetMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 12:
msg.affTopVersionIgniteUuidMap = reader.readMap(affTopVersionIgniteUuidMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 13:
msg.boxedBooleanAffTopVersionMap = reader.readMap(boxedBooleanAffTopVersionMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 14:
msg.boxedByteBoxedBooleanMap = reader.readMap(boxedByteBoxedBooleanMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 15:
msg.boxedShortBoxedByteMap = reader.readMap(boxedShortBoxedByteMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 16:
msg.boxedIntBoxedShortMap = reader.readMap(boxedIntBoxedShortMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 17:
msg.boxedLongBoxedIntMap = reader.readMap(boxedLongBoxedIntMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 18:
msg.boxedCharBoxedLongMap = reader.readMap(boxedCharBoxedLongMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 19:
msg.boxedFloatBoxedCharMap = reader.readMap(boxedFloatBoxedCharMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 20:
msg.boxedDoubleBoxedFloatMap = reader.readMap(boxedDoubleBoxedFloatMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 21:
msg.messageBoxedDoubleMap = reader.readMap(messageBoxedDoubleMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 22:
msg.integerGridLongListMap = reader.readMap(integerGridLongListMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 23:
msg.gridLongListIntegerMap = reader.readMap(gridLongListIntegerMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
case 24:
msg.gridlistDoubleMapUuidMap = reader.readMap(gridlistDoubleMapUuidMapCollDesc);
if (!reader.isLastRead())
return false;
reader.incrementState();
}
return true;
}
}