From 82251c2db57923967b24c3c0c0799df682073e73 Mon Sep 17 00:00:00 2001
From: wusheng <wu.sheng@foxmail.com>
Date: Tue, 15 Nov 2016 20:10:05 +0800
Subject: [PATCH] update test case

---
 .../src/test/java/StorageClient.java          | 22 ++++++++++++-------
 1 file changed, 14 insertions(+), 8 deletions(-)

diff --git a/skywalking-storage-center/skywalking-storage/src/test/java/StorageClient.java b/skywalking-storage-center/skywalking-storage/src/test/java/StorageClient.java
index 0139fd2d3..07252cb9f 100644
--- a/skywalking-storage-center/skywalking-storage/src/test/java/StorageClient.java
+++ b/skywalking-storage-center/skywalking-storage/src/test/java/StorageClient.java
@@ -9,7 +9,7 @@ import static com.a.eye.skywalking.network.grpc.SpanStorageServiceGrpc.newStub;
 
 public class StorageClient {
     private static ManagedChannel channel =
-            ManagedChannelBuilder.forAddress("127.0.0.1", 34000).usePlaintext(true).build();
+            ManagedChannelBuilder.forAddress("10.128.35.79", 34000).usePlaintext(true).build();
 
     private static SpanStorageServiceGrpc.SpanStorageServiceStub spanStorageServiceStub = newStub(channel);
 
@@ -34,7 +34,7 @@ public class StorageClient {
         long startTime = System.currentTimeMillis();
 
 
-        for (int i = 0; i < 1; i++) {
+        for (int i = 0; i < 1000000; i++) {
             StreamObserver<AckSpan> ackSpanStreamObserver =
                     spanStorageServiceStub.storageACKSpan(new StreamObserver<SendResult>() {
                         @Override
@@ -69,21 +69,27 @@ public class StorageClient {
                             endTime2 = System.currentTimeMillis();
                         }
                     });
-            for (int j = 0; j < 1; j++) {
+            for (int j = 0; j < 10; j++) {
                 requestSpanStreamObserver.onNext(requestSpan);
                 ackSpanStreamObserver.onNext(ackSpan);
 
-                ClientCallStreamObserver<RequestSpan> newRequestSpanStreamObserver =
-                        (ClientCallStreamObserver<RequestSpan>) requestSpanStreamObserver;
-                while (!newRequestSpanStreamObserver.isReady()) {
-                    Thread.sleep(1);
-                }
+            }
+
+            ClientCallStreamObserver<RequestSpan> newRequestSpanStreamObserver =
+                    (ClientCallStreamObserver<RequestSpan>) requestSpanStreamObserver;
+
+            while (!newRequestSpanStreamObserver.isReady()) {
+                Thread.sleep(1);
             }
 
             ackSpanStreamObserver.onCompleted();
             requestSpanStreamObserver.onCompleted();
 
 
+            if(i % 500_000 == 0){
+                System.out.println(i);
+            }
+
         }
 
         Thread.sleep(1000L);