From 19519c347abbd80c338ecc12eb9ad9d8628019f9 Mon Sep 17 00:00:00 2001 From: leventov Date: Fri, 18 Sep 2015 15:36:46 +0300 Subject: [PATCH] #43 add test --- .../openhft/chronicle/map/Issue43Test.java | 71 +++++++++++++++++++ 1 file changed, 71 insertions(+) create mode 100644 src/test/java/net/openhft/chronicle/map/Issue43Test.java diff --git a/src/test/java/net/openhft/chronicle/map/Issue43Test.java b/src/test/java/net/openhft/chronicle/map/Issue43Test.java new file mode 100644 index 000000000..084f4d9ab --- /dev/null +++ b/src/test/java/net/openhft/chronicle/map/Issue43Test.java @@ -0,0 +1,71 @@ +/* + * Copyright (C) 2015 higherfrequencytrading.com + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License as published by + * the Free Software Foundation, either version 3 of the License. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public License + * along with this program. If not, see . + */ + +package net.openhft.chronicle.map; + +import net.openhft.lang.io.Bytes; +import net.openhft.lang.io.serialization.BytesMarshaller; +import org.junit.Test; + +public class Issue43Test { + + @Test + public void testIssue43() { + try { + ChronicleMap map = ChronicleMapBuilder + .of(Long.class, ValueWrapper.class) + .entries(512) + .valueMarshaller(new ArrayMarshaller()) + .constantValueSizeBySample(new ValueWrapper(new double[128])) + .createPersistedTo(Builder.getPersistenceFile()); + System.out.println("Created the monkey map ValueWrapper 128"); + } catch (Throwable ex) { + System.out.println(ex); + } + } + + + private static class ValueWrapper { + private final double values[]; + + public ValueWrapper(double[] values) { + this.values = values; + } + } + + private static class ArrayMarshaller implements BytesMarshaller { + + @Override + public void write(Bytes bytes, ValueWrapper vw) { + bytes.writeInt(vw.values.length); + + for (int i = 0; i < vw.values.length; i ++) { + bytes.writeDouble(vw.values[i]); + } + } + + @Override + public ValueWrapper read(Bytes bytes) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public ValueWrapper read(Bytes arg0, ValueWrapper arg1) { + throw new UnsupportedOperationException("Not supported yet."); + } + + } +}