From e3df9ac2a7f1cecf68b95327dc8f076cdcdba9f3 Mon Sep 17 00:00:00 2001 From: wusheng Date: Wed, 30 Nov 2016 09:37:31 +0800 Subject: [PATCH] add a test case for DataFile write and read --- .../storage/data/file/DataFileTest.java | 33 +++++++++++++++++++ 1 file changed, 33 insertions(+) create mode 100644 skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/file/DataFileTest.java diff --git a/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/file/DataFileTest.java b/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/file/DataFileTest.java new file mode 100644 index 000000000..469af8e12 --- /dev/null +++ b/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/file/DataFileTest.java @@ -0,0 +1,33 @@ +package com.a.eye.skywalking.storage.data.file; + +import com.a.eye.skywalking.network.grpc.RequestSpan; +import com.a.eye.skywalking.storage.data.index.IndexMetaInfo; +import com.a.eye.skywalking.storage.data.spandata.RequestSpanData; +import com.a.eye.skywalking.storage.data.spandata.SpanDataBuilder; +import org.junit.Assert; +import org.junit.Test; + +/** + * Created by wusheng on 2016/11/29. + */ +public class DataFileTest { + @Test + public void testWriteFile(){ + DataFile dataFile = new DataFile(); + + IndexMetaInfo info = null; + for (int i = 0; i < 100; i++) { + RequestSpan span = RequestSpan.newBuilder().setUserId("1").setApplicationId("app").build(); + + try { + info = dataFile.write(new RequestSpanData(span)); + } finally { + dataFile.flush(); + } + + RequestSpan newSpan = SpanDataBuilder.buildRequestSpan(dataFile.read(info.getOffset(), info.getLength())); + + Assert.assertEquals("1", newSpan.getUserId()); + } + } +} -- GitLab