From ce81b2ee8be0c324739bb787fb0d4ec0fd34130b Mon Sep 17 00:00:00 2001
From: ascrutae <ascrutae@gmail.com>
Date: Thu, 8 Dec 2016 14:41:09 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4=E6=97=A0=E7=94=A8=E6=B5=8B?=
 =?UTF-8?q?=E8=AF=95=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../a/eye/skywalking/storage/TestFile.java    | 32 --------------
 .../a/eye/skywalking/storage/TestMain.java    | 44 -------------------
 2 files changed, 76 deletions(-)
 delete mode 100644 skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestFile.java
 delete mode 100644 skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestMain.java

diff --git a/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestFile.java b/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestFile.java
deleted file mode 100644
index bb92a0f0a..000000000
--- a/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestFile.java
+++ /dev/null
@@ -1,32 +0,0 @@
-package com.a.eye.skywalking.storage;
-
-import com.a.eye.skywalking.storage.data.file.DataFileNameDesc;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.text.SimpleDateFormat;
-
-/**
- * Created by xin on 2016/11/30.
- */
-public class TestFile {
-    public static void main(String[] args) throws IOException {
-//        File file = new File("/Users/xin/workbench/data/file", "2016_11_29_23_02_55_517_1000");
-//        System.out.println(file.length());
-//
-//        FileInputStream byteInputStream = new FileInputStream(file);
-//        byte[] bytes = new byte[1024];
-//        int count = 0;
-//        int length = 0;
-//        while ((count = byteInputStream.read(bytes)) != -1) {
-//            length += count;
-//        }
-//
-//        System.out.println(length);
-
-        long startTime = System.currentTimeMillis();
-        System.out.println(startTime);
-        System.out.println(new SimpleDateFormat("yyyy_MM_dd_HH_mm_ss_SSS").format(startTime));
-    }
-}
diff --git a/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestMain.java b/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestMain.java
deleted file mode 100644
index ecdc8502d..000000000
--- a/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/TestMain.java
+++ /dev/null
@@ -1,44 +0,0 @@
-package com.a.eye.skywalking.storage;
-
-import com.a.eye.skywalking.health.report.HealthCollector;
-import com.a.eye.skywalking.health.report.HeathReading;
-import com.a.eye.skywalking.storage.config.Config;
-import com.a.eye.skywalking.storage.data.spandata.RequestSpanData;
-import com.lmax.disruptor.EventHandler;
-import com.lmax.disruptor.RingBuffer;
-import com.lmax.disruptor.dsl.Disruptor;
-import com.lmax.disruptor.util.DaemonThreadFactory;
-
-/**
- * Created by xin on 2016/12/7.
- */
-public class TestMain {
-    public static void main(String[] args) throws InterruptedException {
-        Disruptor<StringBuilder> requestSpanDataDisruptor = null;
-        requestSpanDataDisruptor = new Disruptor<StringBuilder>(new StringBuilderFactory(), Config.Disruptor.BUFFER_SIZE, DaemonThreadFactory.INSTANCE);
-        requestSpanDataDisruptor.handleEventsWith(new EventHandler<StringBuilder>() {
-            @Override
-            public void onEvent(StringBuilder event, long sequence, boolean endOfBatch) throws Exception {
-                System.out.println("AA: " + event);
-            }
-        }, new EventHandler<StringBuilder>() {
-            @Override
-            public void onEvent(StringBuilder event, long sequence, boolean endOfBatch) throws Exception {
-                System.out.println("BB: " + event);
-            }
-        });
-        requestSpanDataDisruptor.start();
-        RingBuffer<StringBuilder> stringBuilderRingBuffer = requestSpanDataDisruptor.getRingBuffer();
-
-        long sequence = stringBuilderRingBuffer.next();  // Grab the next sequence
-        try {
-            StringBuilder data = stringBuilderRingBuffer.get(sequence);
-            data.append("A");
-        } catch (Exception e) {
-        } finally {
-            stringBuilderRingBuffer.publish(sequence);
-        }
-
-        Thread.sleep(1000);
-    }
-}