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

reset flag when network fail.

This commit is contained in:
wusheng 2016-12-02 11:34:40 +08:00
parent e845ee024a
commit b73e0366d1
1 changed files with 2 additions and 2 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

@ -23,7 +23,7 @@ public class StorageThread extends Thread {
StorageThread(long count, CountDownLatch countDownLatch, int index) {
listener = new MyStorageClientListener();
client = new Client("10.128.7.241", 34000).newSpanStorageClient(listener);
client = new Client("10.128.6.79", 23000).newSpanStorageClient(listener);
this.count = count;
this.countDownLatch = countDownLatch;
this.index = index;
@ -78,7 +78,7 @@ public class StorageThread extends Thread {
@Override
public void onError(Throwable throwable) {
isCompleted = true;
}
@Override