kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

no message

This commit is contained in:
ascrutae 2016-11-27 18:53:47 +08:00
parent c3ae98b1e4
commit f3539eae7f
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
skywalking-storage-center/skywalking-storage/src/test/java/StorageThread.java
View File

@ -22,7 +22,7 @@ public class StorageThread extends Thread {
StorageThread(long count, CountDownLatch countDownLatch) {
listener = new MyStorageClientListener();
client = new Client("10.128.7.241", 34000).newSpanStorageClient(listener);
client = new Client("127.0.0.1", 34000).newSpanStorageClient(listener);
this.count = count;
this.countDownLatch = countDownLatch;
}
@ -53,6 +53,8 @@ public class StorageThread extends Thread {
LockSupport.parkNanos(1);
}
listener.begin();
ackSpanList.clear();
requestSpanList.clear();
}
requestSpanList.add(requestSpan);