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

update test case

This commit is contained in:
wusheng 2016-11-15 20:10:05 +08:00
parent e8eef8e0a8
commit 82251c2db5
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
skywalking-storage-center/skywalking-storage/src/test/java/StorageClient.java
View File

@ -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);