You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/12/09 13:03:21 UTC
[1/9] ignite git commit: IGNITE-2099: WIP.
Repository: ignite
Updated Branches:
refs/heads/ignite-2099 [created] 9ff351b50
IGNITE-2099: WIP.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/86f4892d
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/86f4892d
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/86f4892d
Branch: refs/heads/ignite-2099
Commit: 86f4892dced3f4ed6b3dcfb59f639aaa9cc53f77
Parents: 0adee3a
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 12:53:00 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 12:53:00 2015 +0300
----------------------------------------------------------------------
.../ignite/binary/BinaryCollectionFactory.java | 33 ++++++++
.../apache/ignite/binary/BinaryMapFactory.java | 33 ++++++++
.../apache/ignite/binary/BinaryRawReader.java | 8 +-
.../org/apache/ignite/binary/BinaryReader.java | 9 +--
.../internal/portable/BinaryReaderExImpl.java | 83 ++++++++++++++------
.../internal/portable/PortableContext.java | 12 ---
.../ignite/internal/portable/PortableUtils.java | 74 +++++++++--------
.../portable/BinaryMarshallerSelfTest.java | 4 +-
.../BinaryObjectBuilderAdditionalSelfTest.java | 71 ++++++++++-------
.../mutabletest/GridPortableTestClasses.java | 77 +++++++++++++-----
10 files changed, 269 insertions(+), 135 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/main/java/org/apache/ignite/binary/BinaryCollectionFactory.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/binary/BinaryCollectionFactory.java b/modules/core/src/main/java/org/apache/ignite/binary/BinaryCollectionFactory.java
new file mode 100644
index 0000000..0e5bf83
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/binary/BinaryCollectionFactory.java
@@ -0,0 +1,33 @@
+/*
+ * 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.binary;
+
+import java.util.Collection;
+
+/**
+ * Collection factory.
+ */
+public interface BinaryCollectionFactory<K> {
+ /**
+ * Create collection.
+ *
+ * @param size Amount of elements in collection.
+ * @return Collection.
+ */
+ public Collection<K> create(int size);
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/main/java/org/apache/ignite/binary/BinaryMapFactory.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/binary/BinaryMapFactory.java b/modules/core/src/main/java/org/apache/ignite/binary/BinaryMapFactory.java
new file mode 100644
index 0000000..d514bf9
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/binary/BinaryMapFactory.java
@@ -0,0 +1,33 @@
+/*
+ * 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.binary;
+
+import java.util.Map;
+
+/**
+ * Map factory.
+ */
+public interface BinaryMapFactory<K, V> {
+ /**
+ * Create collection.
+ *
+ * @param size Amount of elements in collection.
+ * @return Collection.
+ */
+ public Map<K, V> create(int size);
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/main/java/org/apache/ignite/binary/BinaryRawReader.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/binary/BinaryRawReader.java b/modules/core/src/main/java/org/apache/ignite/binary/BinaryRawReader.java
index 7ff515a..ce059d1 100644
--- a/modules/core/src/main/java/org/apache/ignite/binary/BinaryRawReader.java
+++ b/modules/core/src/main/java/org/apache/ignite/binary/BinaryRawReader.java
@@ -206,11 +206,11 @@ public interface BinaryRawReader {
@Nullable public <T> Collection<T> readCollection() throws BinaryObjectException;
/**
- * @param colCls Collection class.
+ * @param factory Collection factory.
* @return Collection.
* @throws BinaryObjectException In case of error.
*/
- @Nullable public <T> Collection<T> readCollection(Class<? extends Collection<T>> colCls)
+ @Nullable public <T> Collection<T> readCollection(BinaryCollectionFactory<T> factory)
throws BinaryObjectException;
/**
@@ -220,11 +220,11 @@ public interface BinaryRawReader {
@Nullable public <K, V> Map<K, V> readMap() throws BinaryObjectException;
/**
- * @param mapCls Map class.
+ * @param factory Map factory.
* @return Map.
* @throws BinaryObjectException In case of error.
*/
- @Nullable public <K, V> Map<K, V> readMap(Class<? extends Map<K, V>> mapCls) throws BinaryObjectException;
+ @Nullable public <K, V> Map<K, V> readMap(BinaryMapFactory<K, V> factory) throws BinaryObjectException;
/**
* @return Value.
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/main/java/org/apache/ignite/binary/BinaryReader.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/binary/BinaryReader.java b/modules/core/src/main/java/org/apache/ignite/binary/BinaryReader.java
index b8183a2..be7a156 100644
--- a/modules/core/src/main/java/org/apache/ignite/binary/BinaryReader.java
+++ b/modules/core/src/main/java/org/apache/ignite/binary/BinaryReader.java
@@ -242,11 +242,11 @@ public interface BinaryReader {
/**
* @param fieldName Field name.
- * @param colCls Collection class.
+ * @param factory Collection factory.
* @return Collection.
* @throws BinaryObjectException In case of error.
*/
- public <T> Collection<T> readCollection(String fieldName, Class<? extends Collection<T>> colCls)
+ public <T> Collection<T> readCollection(String fieldName, BinaryCollectionFactory<T> factory)
throws BinaryObjectException;
/**
@@ -258,12 +258,11 @@ public interface BinaryReader {
/**
* @param fieldName Field name.
- * @param mapCls Map class.
+ * @param factory Map factory.
* @return Map.
* @throws BinaryObjectException In case of error.
*/
- public <K, V> Map<K, V> readMap(String fieldName, Class<? extends Map<K, V>> mapCls)
- throws BinaryObjectException;
+ public <K, V> Map<K, V> readMap(String fieldName, BinaryMapFactory<K, V> factory) throws BinaryObjectException;
/**
* @param fieldName Field name.
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
index a0aa2e5..e2d098b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
@@ -26,8 +26,11 @@ import java.util.Collection;
import java.util.Date;
import java.util.Map;
import java.util.UUID;
+
+import org.apache.ignite.binary.BinaryCollectionFactory;
import org.apache.ignite.binary.BinaryIdMapper;
import org.apache.ignite.binary.BinaryInvalidTypeException;
+import org.apache.ignite.binary.BinaryMapFactory;
import org.apache.ignite.binary.BinaryObject;
import org.apache.ignite.binary.BinaryObjectException;
import org.apache.ignite.binary.BinaryRawReader;
@@ -1236,20 +1239,20 @@ public class BinaryReaderExImpl implements BinaryReader, BinaryRawReaderEx, Bina
}
/** {@inheritDoc} */
- @Nullable @Override public <T> Collection<T> readCollection(String fieldName,
- Class<? extends Collection<T>> colCls) throws BinaryObjectException {
- return findFieldByName(fieldName) ? readCollection0(colCls) : null;
+ @Nullable @Override public <T> Collection<T> readCollection(String fieldName, BinaryCollectionFactory<T> factory)
+ throws BinaryObjectException {
+ return findFieldByName(fieldName) ? readCollection0(factory) : null;
}
/**
* @param fieldId Field ID.
- * @param colCls Collection class.
+ * @param factory Collection factory.
* @return Value.
* @throws BinaryObjectException In case of error.
*/
- @Nullable <T> Collection<T> readCollection(int fieldId, @Nullable Class<? extends Collection> colCls)
+ @Nullable <T> Collection<T> readCollection(int fieldId, @Nullable BinaryCollectionFactory<T> factory)
throws BinaryObjectException {
- return findFieldById(fieldId) ? (Collection<T>)readCollection0(colCls) : null;
+ return findFieldById(fieldId) ? (Collection<T>)readCollection0(factory) : null;
}
/** {@inheritDoc} */
@@ -1258,26 +1261,41 @@ public class BinaryReaderExImpl implements BinaryReader, BinaryRawReaderEx, Bina
}
/** {@inheritDoc} */
- @Nullable @Override public <T> Collection<T> readCollection(Class<? extends Collection<T>> colCls)
+ @Nullable @Override public <T> Collection<T> readCollection(BinaryCollectionFactory<T> factory)
throws BinaryObjectException {
- return readCollection0(colCls);
+ return readCollection0(factory);
}
/**
* Internal read collection routine.
*
- * @param cls Collection class.
+ * @param factory Collection factory.
* @return Value.
* @throws BinaryObjectException If failed.
*/
- private Collection readCollection0(@Nullable Class<? extends Collection> cls)
+ private Collection readCollection0(@Nullable BinaryCollectionFactory factory)
throws BinaryObjectException {
switch (checkFlag(COL)) {
case NORMAL:
- return (Collection)PortableUtils.doReadCollection(in, ctx, ldr, this, true, cls);
+ return (Collection)PortableUtils.doReadCollection(in, ctx, ldr, this, true, factory);
- case HANDLE:
- return readHandleField();
+ case HANDLE: {
+ int handlePos = PortableUtils.positionForHandle(in) - in.readInt();
+
+ Object obj = getHandle(handlePos);
+
+ if (obj == null) {
+ int retPos = in.position();
+
+ streamPosition(handlePos);
+
+ obj = readCollection0(factory);
+
+ streamPosition(retPos);
+ }
+
+ return (Collection)obj;
+ }
default:
return null;
@@ -1290,19 +1308,19 @@ public class BinaryReaderExImpl implements BinaryReader, BinaryRawReaderEx, Bina
}
/** {@inheritDoc} */
- @Nullable @Override public <K, V> Map<K, V> readMap(String fieldName, Class<? extends Map<K, V>> mapCls)
+ @Nullable @Override public <K, V> Map<K, V> readMap(String fieldName, BinaryMapFactory<K, V> factory)
throws BinaryObjectException {
- return findFieldByName(fieldName) ? readMap0(mapCls) : null;
+ return findFieldByName(fieldName) ? readMap0(factory) : null;
}
/**
* @param fieldId Field ID.
- * @param mapCls Map class.
+ * @param factory Factory.
* @return Value.
* @throws BinaryObjectException In case of error.
*/
- @Nullable Map<?, ?> readMap(int fieldId, @Nullable Class<? extends Map> mapCls) throws BinaryObjectException {
- return findFieldById(fieldId) ? readMap0(mapCls) : null;
+ @Nullable Map<?, ?> readMap(int fieldId, @Nullable BinaryMapFactory factory) throws BinaryObjectException {
+ return findFieldById(fieldId) ? readMap0(factory) : null;
}
/** {@inheritDoc} */
@@ -1311,25 +1329,40 @@ public class BinaryReaderExImpl implements BinaryReader, BinaryRawReaderEx, Bina
}
/** {@inheritDoc} */
- @Nullable @Override public <K, V> Map<K, V> readMap(Class<? extends Map<K, V>> mapCls)
+ @Nullable @Override public <K, V> Map<K, V> readMap(BinaryMapFactory<K, V> factory)
throws BinaryObjectException {
- return readMap0(mapCls);
+ return readMap0(factory);
}
/**
* Internal read map routine.
*
- * @param cls Map class.
+ * @param factory Factory.
* @return Value.
* @throws BinaryObjectException If failed.
*/
- private Map readMap0(@Nullable Class<? extends Map> cls) throws BinaryObjectException {
+ private Map readMap0(@Nullable BinaryMapFactory factory) throws BinaryObjectException {
switch (checkFlag(MAP)) {
case NORMAL:
- return (Map)PortableUtils.doReadMap(in, ctx, ldr, this, true, cls);
+ return (Map)PortableUtils.doReadMap(in, ctx, ldr, this, true, factory);
- case HANDLE:
- return readHandleField();
+ case HANDLE: {
+ int handlePos = PortableUtils.positionForHandle(in) - in.readInt();
+
+ Object obj = getHandle(handlePos);
+
+ if (obj == null) {
+ int retPos = in.position();
+
+ streamPosition(handlePos);
+
+ obj = readMap0(factory);
+
+ streamPosition(retPos);
+ }
+
+ return (Map)obj;
+ }
default:
return null;
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
index 8bad737..7449863 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
@@ -164,16 +164,9 @@ public class PortableContext implements Externalizable {
colTypes.put(LinkedList.class, GridPortableMarshaller.LINKED_LIST);
colTypes.put(HashSet.class, GridPortableMarshaller.HASH_SET);
colTypes.put(LinkedHashSet.class, GridPortableMarshaller.LINKED_HASH_SET);
- colTypes.put(TreeSet.class, GridPortableMarshaller.TREE_SET);
- colTypes.put(ConcurrentSkipListSet.class, GridPortableMarshaller.CONC_SKIP_LIST_SET);
- colTypes.put(ConcurrentLinkedQueue.class, GridPortableMarshaller.CONC_LINKED_QUEUE);
mapTypes.put(HashMap.class, GridPortableMarshaller.HASH_MAP);
mapTypes.put(LinkedHashMap.class, GridPortableMarshaller.LINKED_HASH_MAP);
- mapTypes.put(TreeMap.class, GridPortableMarshaller.TREE_MAP);
- mapTypes.put(ConcurrentHashMap.class, GridPortableMarshaller.CONC_HASH_MAP);
- mapTypes.put(ConcurrentHashMap8.class, GridPortableMarshaller.CONC_HASH_MAP);
- mapTypes.put(Properties.class, GridPortableMarshaller.PROPERTIES_MAP);
// IDs range from [0..200] is used by Java SDK API and GridGain legacy API
@@ -210,14 +203,9 @@ public class PortableContext implements Externalizable {
registerPredefinedType(LinkedList.class, 0);
registerPredefinedType(HashSet.class, 0);
registerPredefinedType(LinkedHashSet.class, 0);
- registerPredefinedType(TreeSet.class, 0);
- registerPredefinedType(ConcurrentSkipListSet.class, 0);
registerPredefinedType(HashMap.class, 0);
registerPredefinedType(LinkedHashMap.class, 0);
- registerPredefinedType(TreeMap.class, 0);
- registerPredefinedType(ConcurrentHashMap.class, 0);
- registerPredefinedType(ConcurrentHashMap8.class, 0);
registerPredefinedType(GridMapEntry.class, 60);
registerPredefinedType(IgniteBiTuple.class, 61);
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
index 5d794ca..42d9d85 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
@@ -17,9 +17,10 @@
package org.apache.ignite.internal.portable;
-import java.util.concurrent.ConcurrentLinkedQueue;
import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.binary.BinaryCollectionFactory;
import org.apache.ignite.binary.BinaryInvalidTypeException;
+import org.apache.ignite.binary.BinaryMapFactory;
import org.apache.ignite.binary.BinaryObject;
import org.apache.ignite.binary.BinaryObjectException;
import org.apache.ignite.binary.Binarylizable;
@@ -35,8 +36,6 @@ import org.jsr166.ConcurrentHashMap8;
import java.io.ByteArrayInputStream;
import java.io.Externalizable;
import java.lang.reflect.Array;
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.sql.Timestamp;
@@ -56,6 +55,7 @@ import java.util.TreeMap;
import java.util.TreeSet;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ConcurrentSkipListSet;
import static java.nio.charset.StandardCharsets.UTF_8;
@@ -1004,8 +1004,7 @@ public class PortableUtils {
else if (cls == Timestamp[].class)
return BinaryWriteMode.TIMESTAMP_ARR;
else if (cls.isArray())
- return cls.getComponentType().isEnum() ?
- BinaryWriteMode.ENUM_ARR : BinaryWriteMode.OBJECT_ARR;
+ return cls.getComponentType().isEnum() ? BinaryWriteMode.ENUM_ARR : BinaryWriteMode.OBJECT_ARR;
else if (cls == BinaryObjectImpl.class)
return BinaryWriteMode.PORTABLE_OBJ;
else if (Binarylizable.class.isAssignableFrom(cls))
@@ -1014,9 +1013,9 @@ public class PortableUtils {
return BinaryWriteMode.EXTERNALIZABLE;
else if (Map.Entry.class.isAssignableFrom(cls))
return BinaryWriteMode.MAP_ENTRY;
- else if (Collection.class.isAssignableFrom(cls))
+ else if (isSpecialCollection(cls))
return BinaryWriteMode.COL;
- else if (Map.class.isAssignableFrom(cls))
+ else if (isSpecialMap(cls))
return BinaryWriteMode.MAP;
else if (cls.isEnum())
return BinaryWriteMode.ENUM;
@@ -1027,6 +1026,27 @@ public class PortableUtils {
}
/**
+ * Check if class represents a collection which must be treated specially.
+ *
+ * @param cls Class.
+ * @return {@code True} if this is a special collection class.
+ */
+ private static boolean isSpecialCollection(Class cls) {
+ return ArrayList.class.equals(cls) || LinkedList.class.equals(cls) ||
+ HashSet.class.equals(cls) || LinkedHashSet.class.equals(cls);
+ }
+
+ /**
+ * Check if class represents a map which must be treated specially.
+ *
+ * @param cls Class.
+ * @return {@code True} if this is a special map class.
+ */
+ private static boolean isSpecialMap(Class cls) {
+ return HashMap.class.equals(cls) || LinkedHashMap.class.equals(cls);
+ }
+
+ /**
* @return Value.
*/
public static byte[] doReadByteArray(PortableInputStream in) {
@@ -1738,13 +1758,13 @@ public class PortableUtils {
/**
* @param deserialize Deep flag.
- * @param cls Collection class.
+ * @param factory Collection factory.
* @return Value.
* @throws BinaryObjectException In case of error.
*/
@SuppressWarnings("unchecked")
public static Collection<?> doReadCollection(PortableInputStream in, PortableContext ctx, ClassLoader ldr,
- BinaryReaderHandlesHolder handles, boolean deserialize, @Nullable Class<? extends Collection> cls)
+ BinaryReaderHandlesHolder handles, boolean deserialize, BinaryCollectionFactory factory)
throws BinaryObjectException {
int hPos = positionForHandle(in);
@@ -1756,20 +1776,8 @@ public class PortableUtils {
Collection<Object> col;
- if (cls != null) {
- try {
- Constructor<? extends Collection> cons = cls.getConstructor();
-
- col = cons.newInstance();
- }
- catch (NoSuchMethodException ignored) {
- throw new BinaryObjectException("Collection class doesn't have public default constructor: " +
- cls.getName());
- }
- catch (InvocationTargetException | InstantiationException | IllegalAccessException e) {
- throw new BinaryObjectException("Failed to instantiate collection: " + cls.getName(), e);
- }
- }
+ if (factory != null)
+ col = factory.create(size);
else {
switch (colType) {
case ARR_LIST:
@@ -1832,13 +1840,13 @@ public class PortableUtils {
/**
* @param deserialize Deep flag.
- * @param cls Map class.
+ * @param factory Map factory.
* @return Value.
* @throws BinaryObjectException In case of error.
*/
@SuppressWarnings("unchecked")
public static Map<?, ?> doReadMap(PortableInputStream in, PortableContext ctx, ClassLoader ldr,
- BinaryReaderHandlesHolder handles, boolean deserialize, @Nullable Class<? extends Map> cls)
+ BinaryReaderHandlesHolder handles, boolean deserialize, BinaryMapFactory factory)
throws BinaryObjectException {
int hPos = positionForHandle(in);
@@ -1850,20 +1858,8 @@ public class PortableUtils {
Map<Object, Object> map;
- if (cls != null) {
- try {
- Constructor<? extends Map> cons = cls.getConstructor();
-
- map = cons.newInstance();
- }
- catch (NoSuchMethodException ignored) {
- throw new BinaryObjectException("Map class doesn't have public default constructor: " +
- cls.getName());
- }
- catch (InvocationTargetException | InstantiationException | IllegalAccessException e) {
- throw new BinaryObjectException("Failed to instantiate map: " + cls.getName(), e);
- }
- }
+ if (factory != null)
+ map = factory.create(size);
else {
switch (mapType) {
case HASH_MAP:
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryMarshallerSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryMarshallerSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryMarshallerSelfTest.java
index a06e6c3..64093e7 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryMarshallerSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryMarshallerSelfTest.java
@@ -1141,8 +1141,8 @@ public class BinaryMarshallerSelfTest extends GridCommonAbstractTest {
));
Object[] arr = new Object[] {new Value(1), new Value(2), new Value(3)};
- Collection<Value> col = Arrays.asList(new Value(4), new Value(5), new Value(6));
- Map<Key, Value> map = F.asMap(new Key(10), new Value(10), new Key(20), new Value(20), new Key(30), new Value(30));
+ Collection<Value> col = new ArrayList<>(Arrays.asList(new Value(4), new Value(5), new Value(6)));
+ Map<Key, Value> map = new HashMap<>(F.asMap(new Key(10), new Value(10), new Key(20), new Value(20), new Key(30), new Value(30)));
CollectionFieldsObject obj = new CollectionFieldsObject(arr, col, map);
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
index cfeb714..119500a 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
@@ -21,6 +21,24 @@ import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
+import org.apache.ignite.IgniteBinary;
+import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.binary.BinaryObject;
+import org.apache.ignite.binary.BinaryObjectBuilder;
+import org.apache.ignite.binary.BinaryType;
+import org.apache.ignite.configuration.BinaryConfiguration;
+import org.apache.ignite.configuration.CacheConfiguration;
+import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.internal.portable.builder.BinaryObjectBuilderImpl;
+import org.apache.ignite.internal.portable.builder.PortableBuilderEnum;
+import org.apache.ignite.internal.portable.mutabletest.GridBinaryMarshalerAwareTestClass;
+import org.apache.ignite.internal.processors.cache.portable.CacheObjectBinaryProcessorImpl;
+import org.apache.ignite.internal.processors.cache.portable.IgniteBinaryImpl;
+import org.apache.ignite.internal.util.lang.GridMapEntry;
+import org.apache.ignite.testframework.GridTestUtils;
+import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Assert;
+
import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.sql.Timestamp;
@@ -35,27 +53,11 @@ import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.UUID;
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteBinary;
-import org.apache.ignite.configuration.BinaryConfiguration;
-import org.apache.ignite.configuration.CacheConfiguration;
-import org.apache.ignite.configuration.IgniteConfiguration;
-import org.apache.ignite.internal.portable.builder.PortableBuilderEnum;
-import org.apache.ignite.internal.portable.builder.BinaryObjectBuilderImpl;
-import org.apache.ignite.internal.portable.mutabletest.GridBinaryMarshalerAwareTestClass;
-import org.apache.ignite.internal.processors.cache.portable.CacheObjectBinaryProcessorImpl;
-import org.apache.ignite.internal.processors.cache.portable.IgniteBinaryImpl;
-import org.apache.ignite.internal.util.lang.GridMapEntry;
-import org.apache.ignite.binary.BinaryObjectBuilder;
-import org.apache.ignite.binary.BinaryType;
-import org.apache.ignite.binary.BinaryObject;
-import org.apache.ignite.testframework.GridTestUtils;
-import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
-import org.junit.Assert;
import static org.apache.ignite.cache.CacheMode.REPLICATED;
import static org.apache.ignite.internal.portable.mutabletest.GridPortableTestClasses.Address;
-import static org.apache.ignite.internal.portable.mutabletest.GridPortableTestClasses.AddressBook;
+import static org.apache.ignite.internal.portable.mutabletest.GridPortableTestClasses.Addresses;
+import static org.apache.ignite.internal.portable.mutabletest.GridPortableTestClasses.Companies;
import static org.apache.ignite.internal.portable.mutabletest.GridPortableTestClasses.Company;
import static org.apache.ignite.internal.portable.mutabletest.GridPortableTestClasses.TestObjectAllTypes;
import static org.apache.ignite.internal.portable.mutabletest.GridPortableTestClasses.TestObjectArrayList;
@@ -1116,30 +1118,39 @@ public class BinaryObjectBuilderAdditionalSelfTest extends GridCommonAbstractTes
*
*/
public void testChangeMap() {
- AddressBook addrBook = new AddressBook();
+ Addresses addrs = new Addresses();
+
+ addrs.addCompany(new Company(1, "Google inc", 100,
+ new Address("Saint-Petersburg", "Torzhkovskya", 1, 53), "occupation"));
+
+ addrs.addCompany(new Company(2, "Apple inc", 100,
+ new Address("Saint-Petersburg", "Torzhkovskya", 1, 54), "occupation"));
+
+ addrs.addCompany(new Company(3, "Microsoft", 100,
+ new Address("Saint-Petersburg", "Torzhkovskya", 1, 55), "occupation"));
+
+ addrs.addCompany(new Company(4, "Oracle", 100,
+ new Address("Saint-Petersburg", "Nevskiy", 1, 1), "occupation"));
- addrBook.addCompany(new Company(1, "Google inc", 100, new Address("Saint-Petersburg", "Torzhkovskya", 1, 53), "occupation"));
- addrBook.addCompany(new Company(2, "Apple inc", 100, new Address("Saint-Petersburg", "Torzhkovskya", 1, 54), "occupation"));
- addrBook.addCompany(new Company(3, "Microsoft", 100, new Address("Saint-Petersburg", "Torzhkovskya", 1, 55), "occupation"));
- addrBook.addCompany(new Company(4, "Oracle", 100, new Address("Saint-Petersburg", "Nevskiy", 1, 1), "occupation"));
+ BinaryObjectBuilderImpl binaryAddres = wrap(addrs);
- BinaryObjectBuilderImpl mutableObj = wrap(addrBook);
+ Map<String, BinaryObjectBuilderImpl> map = binaryAddres.getField("companyByStreet");
- Map<String, List<BinaryObjectBuilderImpl>> map = mutableObj.getField("companyByStreet");
+ BinaryObjectBuilderImpl binaryCompanies = map.get("Torzhkovskya");
- List<BinaryObjectBuilderImpl> list = map.get("Torzhkovskya");
+ List<BinaryObjectBuilderImpl> binaryCompaniesList = binaryCompanies.getField("companies");
- BinaryObjectBuilderImpl company = list.get(0);
+ BinaryObjectBuilderImpl company = binaryCompaniesList.get(0);
assert "Google inc".equals(company.<String>getField("name"));
- list.remove(0);
+ binaryCompaniesList.remove(0);
- AddressBook res = mutableObj.build().deserialize();
+ Addresses res = binaryAddres.build().deserialize();
assertEquals(Arrays.asList("Nevskiy", "Torzhkovskya"), new ArrayList<>(res.getCompanyByStreet().keySet()));
- List<Company> torzhkovskyaCompanies = res.getCompanyByStreet().get("Torzhkovskya");
+ Companies torzhkovskyaCompanies = res.getCompanyByStreet().get("Torzhkovskya");
assertEquals(2, torzhkovskyaCompanies.size());
assertEquals("Apple inc", torzhkovskyaCompanies.get(0).name);
http://git-wip-us.apache.org/repos/asf/ignite/blob/86f4892d/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java b/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
index 69687ab..3aaa0d0 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
@@ -31,6 +31,12 @@ import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.UUID;
+
+import org.apache.ignite.binary.BinaryMapFactory;
+import org.apache.ignite.binary.BinaryObjectException;
+import org.apache.ignite.binary.BinaryReader;
+import org.apache.ignite.binary.BinaryWriter;
+import org.apache.ignite.binary.Binarylizable;
import org.apache.ignite.internal.util.lang.GridMapEntry;
import org.apache.ignite.binary.BinaryObject;
@@ -315,7 +321,10 @@ public class GridPortableTestClasses {
/**
*
*/
- public static class Address {
+ public static class Address implements Serializable {
+ /** SUID. */
+ private static final long serialVersionUID = 0L;
+
/** City. */
public String city;
@@ -354,7 +363,10 @@ public class GridPortableTestClasses {
/**
*
*/
- public static class Company {
+ public static class Company implements Serializable {
+ /** SUID. */
+ private static final long serialVersionUID = 0L;
+
/** ID. */
public int id;
@@ -396,28 +408,50 @@ public class GridPortableTestClasses {
}
/**
- *
+ * Companies.
*/
- public static class AddressBook {
- /** */
- private Map<String, List<Company>> companyByStreet = new TreeMap<>();
+ public static class Companies {
+ /** Companies. */
+ private ArrayList<Company> companies = new ArrayList<>();
/**
- * @param street Street.
+ * @param idx Index.
* @return Company.
*/
- public List<Company> findCompany(String street) {
- return companyByStreet.get(street);
+ public Company get(int idx) {
+ return companies.get(idx);
+ }
+
+ /**
+ * @param company Company.
+ */
+ public void add(Company company) {
+ companies.add(company);
+ }
+
+ /**
+ * @return Size.
+ */
+ public int size() {
+ return companies.size();
}
+ }
+
+ /**
+ *
+ */
+ public static class Addresses implements Binarylizable {
+ /** */
+ private Map<String, Companies> companyByStreet = new TreeMap<>();
/**
* @param company Company.
*/
public void addCompany(Company company) {
- List<Company> list = companyByStreet.get(company.address.street);
+ Companies list = companyByStreet.get(company.address.street);
if (list == null) {
- list = new ArrayList<>();
+ list = new Companies();
companyByStreet.put(company.address.street, list);
}
@@ -428,16 +462,23 @@ public class GridPortableTestClasses {
/**
* @return map
*/
- public Map<String, List<Company>> getCompanyByStreet() {
+ public Map<String, Companies> getCompanyByStreet() {
return companyByStreet;
}
- /**
- * @param companyByStreet map
- */
- public void setCompanyByStreet(Map<String, List<Company>> companyByStreet) {
- this.companyByStreet = companyByStreet;
+ /** {@inheritDoc} */
+ @Override public void writeBinary(BinaryWriter writer) throws BinaryObjectException {
+ writer.writeMap("companyByStreet", companyByStreet);
}
- }
+ /** {@inheritDoc} */
+ @SuppressWarnings("unchecked")
+ @Override public void readBinary(BinaryReader reader) throws BinaryObjectException {
+ companyByStreet = reader.readMap("companyByStreet", new BinaryMapFactory<String, Companies>() {
+ @Override public Map<String, Companies> create(int size) {
+ return new TreeMap<>();
+ }
+ });
+ }
+ }
}
\ No newline at end of file
[9/9] ignite git commit: Merge branch 'ignite-1.5' into ignite-2099
Posted by vo...@apache.org.
Merge branch 'ignite-1.5' into ignite-2099
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9ff351b5
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9ff351b5
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9ff351b5
Branch: refs/heads/ignite-2099
Commit: 9ff351b50b481c85460c4c95f9c3aad93a5a9a6f
Parents: d72d846 afbb0dc
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 15:03:59 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 15:03:59 2015 +0300
----------------------------------------------------------------------
.../configuration/CacheConfiguration.java | 4 +-
.../configuration/TransactionConfiguration.java | 47 +++-
.../portable/PortableClassDescriptor.java | 46 ++--
.../cache/jta/CacheJtaManagerAdapter.java | 4 +-
.../portable/BinaryMarshallerSelfTest.java | 14 +-
.../HibernateTransactionalDataRegion.java | 18 +-
.../HibernateL2CacheTransactionalSelfTest.java | 23 +-
modules/jta/pom.xml | 9 +-
.../cache/jta/jndi/CacheJndiTmFactory.java | 132 +++++++++++
.../processors/cache/jta/CacheJtaManager.java | 41 +++-
.../cache/AbstarctCacheJtaSelfTest.java | 183 +++++++++++++++
.../cache/CacheJndiTmFactorySelfTest.java | 166 ++++++++++++++
...CacheJtaConfigurationValidationSelfTest.java | 4 +-
...CacheJtaFactoryConfigValidationSelfTest.java | 142 ++++++++++++
.../processors/cache/GridCacheJtaSelfTest.java | 221 -------------------
.../cache/GridCacheReplicatedJtaSelfTest.java | 32 ---
.../cache/GridJtaLifecycleAwareSelfTest.java | 191 ++++++++++++++++
.../GridPartitionedCacheJtaFactorySelfTest.java | 41 ++++
...titionedCacheJtaLookupClassNameSelfTest.java | 83 +++++++
.../GridReplicatedCacheJtaFactorySelfTest.java | 32 +++
...plicatedCacheJtaLookupClassNameSelfTest.java | 32 +++
.../GridTmLookupLifecycleAwareSelfTest.java | 122 ----------
.../ignite/testsuites/IgniteJtaTestSuite.java | 26 ++-
23 files changed, 1186 insertions(+), 427 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/9ff351b5/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableClassDescriptor.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/9ff351b5/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryMarshallerSelfTest.java
----------------------------------------------------------------------
[5/9] ignite git commit: IGNITE-2099: Minor fix.
Posted by vo...@apache.org.
IGNITE-2099: Minor fix.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/755fe6dd
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/755fe6dd
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/755fe6dd
Branch: refs/heads/ignite-2099
Commit: 755fe6dd80c4d3c846bea35f8232fc4650b5e966
Parents: 75d5874
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 13:21:04 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 13:21:04 2015 +0300
----------------------------------------------------------------------
.../ignite/internal/portable/builder/PortableBuilderReader.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/755fe6dd/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
index 1e6ef91..985d200 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
@@ -732,6 +732,7 @@ public class PortableBuilderReader implements PortablePositionReadable {
case GridPortableMarshaller.HASH_SET:
case GridPortableMarshaller.LINKED_HASH_SET:
+ return new PortableLazySet(this, size);
}
throw new BinaryObjectException("Unknown collection type: " + colType);
[7/9] ignite git commit: IGNITE-2099: Fixing tests.
Posted by vo...@apache.org.
IGNITE-2099: Fixing tests.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6172ce1c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6172ce1c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6172ce1c
Branch: refs/heads/ignite-2099
Commit: 6172ce1c3dfc7266cd22fdb1cc29eb64ca795041
Parents: e799232
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 13:25:53 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 13:25:53 2015 +0300
----------------------------------------------------------------------
.../BinaryObjectBuilderAdditionalSelfTest.java | 30 --------------------
1 file changed, 30 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/6172ce1c/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
index 119500a..06535d2 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/portable/BinaryObjectBuilderAdditionalSelfTest.java
@@ -150,15 +150,6 @@ public class BinaryObjectBuilderAdditionalSelfTest extends GridCommonAbstractTes
break;
}
-
- case "entry":
- assertEquals(((Map.Entry)expVal).getKey(), ((Map.Entry)actVal).getKey());
- assertEquals(((Map.Entry)expVal).getValue(), ((Map.Entry)actVal).getValue());
- break;
-
- default:
- assertTrue(field.getName(), Objects.deepEquals(expVal, actVal));
- break;
}
}
}
@@ -925,27 +916,6 @@ public class BinaryObjectBuilderAdditionalSelfTest extends GridCommonAbstractTes
/**
*
*/
- public void testMapEntryModification() {
- TestObjectContainer obj = new TestObjectContainer();
- obj.foo = ImmutableMap.of(1, "a").entrySet().iterator().next();
-
- BinaryObjectBuilderImpl mutableObj = wrap(obj);
-
- Map.Entry<Object, Object> entry = mutableObj.getField("foo");
-
- assertEquals(1, entry.getKey());
- assertEquals("a", entry.getValue());
-
- entry.setValue("b");
-
- TestObjectContainer res = mutableObj.build().deserialize();
-
- assertEquals(new GridMapEntry<>(1, "b"), res.foo);
- }
-
- /**
- *
- */
public void testMapEntryOverride() {
TestObjectContainer obj = new TestObjectContainer();
[6/9] ignite git commit: Merge branch 'ignite-2099' into
ignite-2099-noentry
Posted by vo...@apache.org.
Merge branch 'ignite-2099' into ignite-2099-noentry
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e7992323
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e7992323
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e7992323
Branch: refs/heads/ignite-2099
Commit: e7992323d1c7ab435173282f590f277e76bfaa3b
Parents: d53472e 755fe6d
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 13:21:11 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 13:21:11 2015 +0300
----------------------------------------------------------------------
.../ignite/internal/portable/builder/PortableBuilderReader.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/e7992323/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
----------------------------------------------------------------------
[4/9] ignite git commit: IGNITE-2099: Removed entries handling.
Posted by vo...@apache.org.
IGNITE-2099: Removed entries handling.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d53472e5
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d53472e5
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d53472e5
Branch: refs/heads/ignite-2099
Commit: d53472e5de989c994cd534e21ce10d54db4cd277
Parents: 75d5874
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 13:11:42 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 13:11:42 2015 +0300
----------------------------------------------------------------------
.../internal/portable/BinaryFieldAccessor.java | 19 ++----
.../internal/portable/BinaryReaderExImpl.java | 24 -------
.../internal/portable/BinaryWriteMode.java | 3 -
.../internal/portable/BinaryWriterExImpl.java | 45 +++----------
.../portable/GridPortableMarshaller.java | 3 -
.../portable/PortableClassDescriptor.java | 6 --
.../ignite/internal/portable/PortableUtils.java | 30 ---------
.../portable/builder/PortableBuilderReader.java | 10 ---
.../portable/builder/PortableLazyMapEntry.java | 68 --------------------
9 files changed, 15 insertions(+), 193 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryFieldAccessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryFieldAccessor.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryFieldAccessor.java
index 2f6b73c..7701fb5 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryFieldAccessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryFieldAccessor.java
@@ -17,6 +17,11 @@
package org.apache.ignite.internal.portable;
+import org.apache.ignite.binary.BinaryObjectException;
+import org.apache.ignite.internal.util.GridUnsafe;
+import org.apache.ignite.internal.util.typedef.internal.U;
+import sun.misc.Unsafe;
+
import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.sql.Timestamp;
@@ -24,10 +29,6 @@ import java.util.Collection;
import java.util.Date;
import java.util.Map;
import java.util.UUID;
-import org.apache.ignite.binary.BinaryObjectException;
-import org.apache.ignite.internal.util.GridUnsafe;
-import org.apache.ignite.internal.util.typedef.internal.U;
-import sun.misc.Unsafe;
/**
* Field accessor to speedup access.
@@ -607,11 +608,6 @@ public abstract class BinaryFieldAccessor {
break;
- case MAP_ENTRY:
- writer.writeMapEntryField((Map.Entry<?, ?>)val);
-
- break;
-
case PORTABLE_OBJ:
writer.writePortableObjectField((BinaryObjectImpl)val);
@@ -813,11 +809,6 @@ public abstract class BinaryFieldAccessor {
break;
- case MAP_ENTRY:
- val = reader.readMapEntry(id);
-
- break;
-
case PORTABLE_OBJ:
val = reader.readPortableObject(id);
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
index e2d098b..6a8091f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryReaderExImpl.java
@@ -65,7 +65,6 @@ import static org.apache.ignite.internal.portable.GridPortableMarshaller.INT_ARR
import static org.apache.ignite.internal.portable.GridPortableMarshaller.LONG;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.LONG_ARR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.MAP;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.MAP_ENTRY;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.NULL;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJ;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJ_ARR;
@@ -313,24 +312,6 @@ public class BinaryReaderExImpl implements BinaryReader, BinaryRawReaderEx, Bina
/**
* @param fieldId Field ID.
- * @return Value.
- * @throws BinaryObjectException On case of error.
- */
- @Nullable Map.Entry<?, ?> readMapEntry(int fieldId) throws BinaryObjectException {
- if (findFieldById(fieldId)) {
- Flag flag = checkFlag(MAP_ENTRY);
-
- if (flag == Flag.NORMAL)
- return PortableUtils.doReadMapEntry(in, ctx, ldr, this, true);
- else if (flag == Flag.HANDLE)
- return readHandleField();
- }
-
- return null;
- }
-
- /**
- * @param fieldId Field ID.
* @return Portable object.
* @throws BinaryObjectException In case of error.
*/
@@ -1617,11 +1598,6 @@ public class BinaryReaderExImpl implements BinaryReader, BinaryRawReaderEx, Bina
break;
- case MAP_ENTRY:
- obj = PortableUtils.doReadMapEntry(in, ctx, ldr, this, true);
-
- break;
-
case PORTABLE_OBJ:
obj = PortableUtils.doReadPortableObject(in, ctx);
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriteMode.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriteMode.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriteMode.java
index bd73ad0..3e0bf69 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriteMode.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriteMode.java
@@ -133,9 +133,6 @@ public enum BinaryWriteMode {
MAP(GridPortableMarshaller.MAP),
/** */
- MAP_ENTRY(GridPortableMarshaller.MAP_ENTRY),
-
- /** */
PORTABLE_OBJ(GridPortableMarshaller.OBJ),
/** */
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriterExImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriterExImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriterExImpl.java
index 6bb493e..4139b8f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriterExImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/BinaryWriterExImpl.java
@@ -17,6 +17,16 @@
package org.apache.ignite.internal.portable;
+import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.binary.BinaryIdMapper;
+import org.apache.ignite.binary.BinaryObjectException;
+import org.apache.ignite.binary.BinaryRawWriter;
+import org.apache.ignite.binary.BinaryWriter;
+import org.apache.ignite.internal.portable.streams.PortableHeapOutputStream;
+import org.apache.ignite.internal.portable.streams.PortableOutputStream;
+import org.apache.ignite.internal.util.typedef.internal.A;
+import org.jetbrains.annotations.Nullable;
+
import java.io.IOException;
import java.io.ObjectOutput;
import java.lang.reflect.InvocationTargetException;
@@ -27,15 +37,6 @@ import java.util.Collection;
import java.util.Date;
import java.util.Map;
import java.util.UUID;
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.binary.BinaryIdMapper;
-import org.apache.ignite.binary.BinaryObjectException;
-import org.apache.ignite.binary.BinaryRawWriter;
-import org.apache.ignite.binary.BinaryWriter;
-import org.apache.ignite.internal.portable.streams.PortableHeapOutputStream;
-import org.apache.ignite.internal.portable.streams.PortableOutputStream;
-import org.apache.ignite.internal.util.typedef.internal.A;
-import org.jetbrains.annotations.Nullable;
import static java.nio.charset.StandardCharsets.UTF_8;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.BOOLEAN;
@@ -62,7 +63,6 @@ import static org.apache.ignite.internal.portable.GridPortableMarshaller.INT_ARR
import static org.apache.ignite.internal.portable.GridPortableMarshaller.LONG;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.LONG_ARR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.MAP;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.MAP_ENTRY;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.NULL;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJ;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJ_ARR;
@@ -761,23 +761,6 @@ public class BinaryWriterExImpl implements BinaryWriter, BinaryRawWriterEx, Obje
}
/**
- * @param e Map entry.
- * @throws org.apache.ignite.binary.BinaryObjectException In case of error.
- */
- void doWriteMapEntry(@Nullable Map.Entry<?, ?> e) throws BinaryObjectException {
- if (e == null)
- out.writeByte(NULL);
- else {
- if (tryWriteAsHandle(e))
- return;
-
- out.writeByte(MAP_ENTRY);
- doWriteObject(e.getKey());
- doWriteObject(e.getValue());
- }
- }
-
- /**
* @param val Value.
*/
void doWriteEnum(@Nullable Enum<?> val) {
@@ -1218,14 +1201,6 @@ public class BinaryWriterExImpl implements BinaryWriter, BinaryRawWriterEx, Obje
}
/**
- * @param e Map entry.
- * @throws org.apache.ignite.binary.BinaryObjectException In case of error.
- */
- void writeMapEntryField(@Nullable Map.Entry<?, ?> e) throws BinaryObjectException {
- doWriteMapEntry(e);
- }
-
- /**
* @param val Value.
*/
void writeEnumField(@Nullable Enum<?> val) {
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
index a9df27d..5063a1e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
@@ -119,9 +119,6 @@ public class GridPortableMarshaller {
public static final byte MAP = 25;
/** */
- public static final byte MAP_ENTRY = 26;
-
- /** */
public static final byte PORTABLE_OBJ = 27;
/** */
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableClassDescriptor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableClassDescriptor.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableClassDescriptor.java
index 984f7c9..620b16a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableClassDescriptor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableClassDescriptor.java
@@ -206,7 +206,6 @@ public class PortableClassDescriptor {
case OBJECT_ARR:
case COL:
case MAP:
- case MAP_ENTRY:
case PORTABLE_OBJ:
case ENUM:
case PORTABLE_ENUM:
@@ -537,11 +536,6 @@ public class PortableClassDescriptor {
break;
- case MAP_ENTRY:
- writer.doWriteMapEntry((Map.Entry<?, ?>)obj);
-
- break;
-
case ENUM:
writer.doWriteEnum((Enum<?>)obj);
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
index 62d2e9a..e4ae77c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
@@ -26,7 +26,6 @@ import org.apache.ignite.binary.BinaryObjectException;
import org.apache.ignite.binary.Binarylizable;
import org.apache.ignite.internal.portable.builder.PortableLazyValue;
import org.apache.ignite.internal.portable.streams.PortableInputStream;
-import org.apache.ignite.internal.util.lang.GridMapEntry;
import org.apache.ignite.internal.util.typedef.F;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteBiTuple;
@@ -87,7 +86,6 @@ import static org.apache.ignite.internal.portable.GridPortableMarshaller.LINKED_
import static org.apache.ignite.internal.portable.GridPortableMarshaller.LONG;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.LONG_ARR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.MAP;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.MAP_ENTRY;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.NULL;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJ;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJECT_TYPE_ID;
@@ -263,7 +261,6 @@ public class PortableUtils {
FIELD_TYPE_NAMES[PORTABLE_OBJ] = "Object";
FIELD_TYPE_NAMES[COL] = "Collection";
FIELD_TYPE_NAMES[MAP] = "Map";
- FIELD_TYPE_NAMES[MAP_ENTRY] = "Entry";
FIELD_TYPE_NAMES[CLASS] = "Class";
FIELD_TYPE_NAMES[BYTE_ARR] = "byte[]";
FIELD_TYPE_NAMES[SHORT_ARR] = "short[]";
@@ -618,9 +615,6 @@ public class PortableUtils {
if (Map.class.isAssignableFrom(cls))
return MAP;
- if (Map.Entry.class.isAssignableFrom(cls))
- return MAP_ENTRY;
-
return OBJ;
}
@@ -1003,8 +997,6 @@ public class PortableUtils {
return BinaryWriteMode.PORTABLE;
else if (Externalizable.class.isAssignableFrom(cls))
return BinaryWriteMode.EXTERNALIZABLE;
- else if (Map.Entry.class.isAssignableFrom(cls))
- return BinaryWriteMode.MAP_ENTRY;
else if (isSpecialCollection(cls))
return BinaryWriteMode.COL;
else if (isSpecialMap(cls))
@@ -1700,9 +1692,6 @@ public class PortableUtils {
case MAP:
return doReadMap(in, ctx, ldr, handles, false, null);
- case MAP_ENTRY:
- return doReadMapEntry(in, ctx, ldr, handles, false);
-
case PORTABLE_OBJ:
return doReadPortableObject(in, ctx);
@@ -1872,25 +1861,6 @@ public class PortableUtils {
}
/**
- * @param deserialize Deserialize flag flag.
- * @return Value.
- * @throws BinaryObjectException In case of error.
- */
- public static Map.Entry<?, ?> doReadMapEntry(PortableInputStream in, PortableContext ctx, ClassLoader ldr,
- BinaryReaderHandlesHolder handles, boolean deserialize) throws BinaryObjectException {
- int hPos = positionForHandle(in);
-
- Object val1 = deserializeOrUnmarshal(in, ctx, ldr, handles, deserialize);
- Object val2 = deserializeOrUnmarshal(in, ctx, ldr, handles, deserialize);
-
- GridMapEntry entry = new GridMapEntry<>(val1, val2);
-
- handles.setHandle(entry, hPos);
-
- return entry;
- }
-
- /**
* Deserialize or unmarshal the object.
*
* @param deserialize Deserialize.
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
index 1e6ef91..29840eb 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
@@ -344,12 +344,6 @@ public class PortableBuilderReader implements PortablePositionReadable {
return;
}
- case GridPortableMarshaller.MAP_ENTRY:
- skipValue();
- skipValue();
-
- return;
-
case GridPortableMarshaller.PORTABLE_OBJ:
len = readInt() + 4;
@@ -448,7 +442,6 @@ public class PortableBuilderReader implements PortablePositionReadable {
case GridPortableMarshaller.OBJ_ARR:
case GridPortableMarshaller.COL:
case GridPortableMarshaller.MAP:
- case GridPortableMarshaller.MAP_ENTRY:
return new LazyCollection(pos);
case GridPortableMarshaller.ENUM: {
@@ -746,9 +739,6 @@ public class PortableBuilderReader implements PortablePositionReadable {
case GridPortableMarshaller.ENUM_ARR:
return new PortableEnumArrayLazyValue(this);
- case GridPortableMarshaller.MAP_ENTRY:
- return new PortableLazyMapEntry(this);
-
case GridPortableMarshaller.PORTABLE_OBJ: {
int size = readInt();
http://git-wip-us.apache.org/repos/asf/ignite/blob/d53472e5/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableLazyMapEntry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableLazyMapEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableLazyMapEntry.java
deleted file mode 100644
index 5ebb223..0000000
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableLazyMapEntry.java
+++ /dev/null
@@ -1,68 +0,0 @@
-/*
- * 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.portable.builder;
-
-import org.apache.ignite.internal.portable.*;
-
-import java.util.Map;
-
-/**
- *
- */
-class PortableLazyMapEntry implements Map.Entry<Object, Object>, PortableBuilderSerializationAware {
- /** */
- private final Object key;
-
- /** */
- private Object val;
-
- /**
- * @param reader GridMutablePortableReader
- */
- PortableLazyMapEntry(PortableBuilderReader reader) {
- key = reader.parseValue();
- val = reader.parseValue();
- }
-
- /** {@inheritDoc} */
- @Override public Object getKey() {
- return PortableUtils.unwrapLazy(key);
- }
-
- /** {@inheritDoc} */
- @Override public Object getValue() {
- return PortableUtils.unwrapLazy(val);
- }
-
- /** {@inheritDoc} */
- @Override public Object setValue(Object val) {
- Object res = getValue();
-
- this.val = val;
-
- return res;
- }
-
- /** {@inheritDoc} */
- @Override public void writeTo(BinaryWriterExImpl writer, PortableBuilderSerializer ctx) {
- writer.writeByte(GridPortableMarshaller.MAP_ENTRY);
-
- ctx.writeValue(writer, key);
- ctx.writeValue(writer, val);
- }
-}
[8/9] ignite git commit: IGNITE-2099: Minor fix.
Posted by vo...@apache.org.
IGNITE-2099: Minor fix.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d72d8462
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d72d8462
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d72d8462
Branch: refs/heads/ignite-2099
Commit: d72d8462030b5610a5c7b5cd6469e25bef1f5fcc
Parents: 6172ce1
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 13:34:27 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 13:34:27 2015 +0300
----------------------------------------------------------------------
.../java/org/apache/ignite/internal/portable/PortableUtils.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/d72d8462/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
index e4ae77c..125bb25 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
@@ -609,10 +609,10 @@ public class PortableUtils {
if (cls.isArray())
return cls.getComponentType().isEnum() || cls.getComponentType() == Enum.class ? ENUM_ARR : OBJ_ARR;
- if (Collection.class.isAssignableFrom(cls))
+ if (isSpecialCollection(cls))
return COL;
- if (Map.class.isAssignableFrom(cls))
+ if (isSpecialMap(cls))
return MAP;
return OBJ;
[3/9] ignite git commit: IGNITE-2099: Removed collection types which
are no longer used.
Posted by vo...@apache.org.
IGNITE-2099: Removed collection types which are no longer used.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/75d5874c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/75d5874c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/75d5874c
Branch: refs/heads/ignite-2099
Commit: 75d5874cb89722152de009c1581831bf6b2bc0e4
Parents: 5c41396
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 13:05:07 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 13:05:07 2015 +0300
----------------------------------------------------------------------
.../portable/GridPortableMarshaller.java | 18 ------
.../internal/portable/PortableContext.java | 59 +++++++++-----------
.../ignite/internal/portable/PortableUtils.java | 38 -------------
.../portable/builder/PortableBuilderReader.java | 3 -
.../builder/PortableBuilderSerializer.java | 8 +--
5 files changed, 28 insertions(+), 98 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/75d5874c/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
index 5244da8..a9df27d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/GridPortableMarshaller.java
@@ -167,30 +167,12 @@ public class GridPortableMarshaller {
public static final byte LINKED_HASH_SET = 4;
/** */
- public static final byte TREE_SET = 5;
-
- /** */
- public static final byte CONC_SKIP_LIST_SET = 6;
-
- /** */
- public static final byte CONC_LINKED_QUEUE = 7;
-
- /** */
public static final byte HASH_MAP = 1;
/** */
public static final byte LINKED_HASH_MAP = 2;
/** */
- public static final byte TREE_MAP = 3;
-
- /** */
- public static final byte CONC_HASH_MAP = 4;
-
- /** */
- public static final byte PROPERTIES_MAP = 5;
-
- /** */
public static final int OBJECT_TYPE_ID = -1;
/** */
http://git-wip-us.apache.org/repos/asf/ignite/blob/75d5874c/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
index 7449863..1f129cd 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableContext.java
@@ -17,6 +17,33 @@
package org.apache.ignite.internal.portable;
+import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.binary.BinaryIdMapper;
+import org.apache.ignite.binary.BinaryInvalidTypeException;
+import org.apache.ignite.binary.BinaryObjectException;
+import org.apache.ignite.binary.BinarySerializer;
+import org.apache.ignite.binary.BinaryType;
+import org.apache.ignite.binary.BinaryTypeConfiguration;
+import org.apache.ignite.cache.CacheKeyConfiguration;
+import org.apache.ignite.cache.affinity.AffinityKeyMapped;
+import org.apache.ignite.configuration.BinaryConfiguration;
+import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.internal.IgniteKernal;
+import org.apache.ignite.internal.IgnitionEx;
+import org.apache.ignite.internal.processors.cache.portable.CacheObjectBinaryProcessorImpl;
+import org.apache.ignite.internal.processors.datastructures.CollocatedQueueItemKey;
+import org.apache.ignite.internal.processors.datastructures.CollocatedSetItemKey;
+import org.apache.ignite.internal.util.IgniteUtils;
+import org.apache.ignite.internal.util.lang.GridMapEntry;
+import org.apache.ignite.internal.util.typedef.F;
+import org.apache.ignite.internal.util.typedef.T2;
+import org.apache.ignite.internal.util.typedef.internal.U;
+import org.apache.ignite.lang.IgniteBiTuple;
+import org.apache.ignite.marshaller.MarshallerContext;
+import org.apache.ignite.marshaller.optimized.OptimizedMarshaller;
+import org.jetbrains.annotations.Nullable;
+import org.jsr166.ConcurrentHashMap8;
+
import java.io.Externalizable;
import java.io.File;
import java.io.IOException;
@@ -41,43 +68,11 @@ import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.LinkedList;
import java.util.Map;
-import java.util.Properties;
import java.util.Set;
-import java.util.TreeMap;
-import java.util.TreeSet;
import java.util.UUID;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ConcurrentMap;
-import java.util.concurrent.ConcurrentSkipListSet;
import java.util.jar.JarEntry;
import java.util.jar.JarFile;
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.binary.BinaryIdMapper;
-import org.apache.ignite.binary.BinaryInvalidTypeException;
-import org.apache.ignite.binary.BinaryObjectException;
-import org.apache.ignite.binary.BinarySerializer;
-import org.apache.ignite.binary.BinaryType;
-import org.apache.ignite.binary.BinaryTypeConfiguration;
-import org.apache.ignite.cache.CacheKeyConfiguration;
-import org.apache.ignite.cache.affinity.AffinityKeyMapped;
-import org.apache.ignite.configuration.BinaryConfiguration;
-import org.apache.ignite.configuration.IgniteConfiguration;
-import org.apache.ignite.internal.IgniteKernal;
-import org.apache.ignite.internal.IgnitionEx;
-import org.apache.ignite.internal.processors.cache.portable.CacheObjectBinaryProcessorImpl;
-import org.apache.ignite.internal.processors.datastructures.CollocatedQueueItemKey;
-import org.apache.ignite.internal.processors.datastructures.CollocatedSetItemKey;
-import org.apache.ignite.internal.util.IgniteUtils;
-import org.apache.ignite.internal.util.lang.GridMapEntry;
-import org.apache.ignite.internal.util.typedef.F;
-import org.apache.ignite.internal.util.typedef.T2;
-import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.lang.IgniteBiTuple;
-import org.apache.ignite.marshaller.MarshallerContext;
-import org.apache.ignite.marshaller.optimized.OptimizedMarshaller;
-import org.jetbrains.annotations.Nullable;
-import org.jsr166.ConcurrentHashMap8;
/**
* Portable context.
http://git-wip-us.apache.org/repos/asf/ignite/blob/75d5874c/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
index 42d9d85..62d2e9a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableUtils.java
@@ -49,13 +49,11 @@ import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.LinkedList;
import java.util.Map;
-import java.util.Properties;
import java.util.Set;
import java.util.TreeMap;
import java.util.TreeSet;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ConcurrentSkipListSet;
import static java.nio.charset.StandardCharsets.UTF_8;
@@ -68,9 +66,6 @@ import static org.apache.ignite.internal.portable.GridPortableMarshaller.CHAR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.CHAR_ARR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.CLASS;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.COL;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.CONC_HASH_MAP;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.CONC_LINKED_QUEUE;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.CONC_SKIP_LIST_SET;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.DATE;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.DATE_ARR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.DECIMAL;
@@ -99,7 +94,6 @@ import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJECT_
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OBJ_ARR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.OPTM_MARSH;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.PORTABLE_OBJ;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.PROPERTIES_MAP;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.PROTO_VER;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.SHORT;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.SHORT_ARR;
@@ -107,8 +101,6 @@ import static org.apache.ignite.internal.portable.GridPortableMarshaller.STRING;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.STRING_ARR;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.TIMESTAMP;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.TIMESTAMP_ARR;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.TREE_MAP;
-import static org.apache.ignite.internal.portable.GridPortableMarshaller.TREE_SET;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.UNREGISTERED_TYPE_ID;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.USER_COL;
import static org.apache.ignite.internal.portable.GridPortableMarshaller.USER_SET;
@@ -1800,21 +1792,6 @@ public class PortableUtils {
break;
- case TREE_SET:
- col = new TreeSet<>();
-
- break;
-
- case CONC_SKIP_LIST_SET:
- col = new ConcurrentSkipListSet<>();
-
- break;
-
- case CONC_LINKED_QUEUE:
- col = new ConcurrentLinkedQueue<>();
-
- break;
-
case USER_SET:
col = U.newHashSet(size);
@@ -1872,26 +1849,11 @@ public class PortableUtils {
break;
- case TREE_MAP:
- map = new TreeMap<>();
-
- break;
-
- case CONC_HASH_MAP:
- map = new ConcurrentHashMap<>(size);
-
- break;
-
case USER_COL:
map = U.newHashMap(size);
break;
- case PROPERTIES_MAP:
- map = new Properties();
-
- break;
-
default:
throw new BinaryObjectException("Invalid map type: " + mapType);
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/75d5874c/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
index cf27da4..1e6ef91 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderReader.java
@@ -732,9 +732,6 @@ public class PortableBuilderReader implements PortablePositionReadable {
case GridPortableMarshaller.HASH_SET:
case GridPortableMarshaller.LINKED_HASH_SET:
- case GridPortableMarshaller.TREE_SET:
- case GridPortableMarshaller.CONC_SKIP_LIST_SET:
- return new PortableLazySet(this, size);
}
throw new BinaryObjectException("Unknown collection type: " + colType);
http://git-wip-us.apache.org/repos/asf/ignite/blob/75d5874c/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderSerializer.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderSerializer.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderSerializer.java
index 52f84c6..ee35ab2 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderSerializer.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/builder/PortableBuilderSerializer.java
@@ -118,13 +118,7 @@ class PortableBuilderSerializer {
writer.writeByte(GridPortableMarshaller.COL);
writer.writeInt(c.size());
- byte colType;
-
- if (c instanceof GridConcurrentSkipListSet)
- colType = GridPortableMarshaller.CONC_SKIP_LIST_SET;
- else
- colType = writer.context().collectionType(c.getClass());
-
+ byte colType = writer.context().collectionType(c.getClass());
writer.writeByte(colType);
[2/9] ignite git commit: IGNITE-2099: Enhanced test,
all is fine for now.
Posted by vo...@apache.org.
IGNITE-2099: Enhanced test, all is fine for now.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5c413968
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5c413968
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5c413968
Branch: refs/heads/ignite-2099
Commit: 5c41396817b9d8b208d4107edf805865220b9172
Parents: 86f4892
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Dec 9 13:00:43 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Dec 9 13:00:43 2015 +0300
----------------------------------------------------------------------
.../internal/portable/mutabletest/GridPortableTestClasses.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5c413968/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java b/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
index 3aaa0d0..b568cb5 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/portable/mutabletest/GridPortableTestClasses.java
@@ -412,7 +412,7 @@ public class GridPortableTestClasses {
*/
public static class Companies {
/** Companies. */
- private ArrayList<Company> companies = new ArrayList<>();
+ private List<Company> companies = new ArrayList<>();
/**
* @param idx Index.