<commit_before>import com.a.eye.skywalking.network.dependencies.io.grpc.ManagedChannel;
import com.a.eye.skywalking.network.dependencies.io.grpc.ManagedChannelBuilder;
import com.a.eye.skywalking.network.dependencies.io.grpc.stub.StreamObserver;
import com.a.eye.skywalking.network.grpc.AckSpan;
import com.a.eye.skywalking.network.grpc.RequestSpan;
import com.a.eye.skywalking.network.grpc.SendResult;
import com.a.eye.skywalking.network.grpc.SpanStorageServiceGrpc;

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

    private static SpanStorageServiceGrpc.SpanStorageServiceStub spanStorageServiceStub = newStub(channel);

    private static StreamObserver<AckSpan> ackSpanStreamObserver =
            spanStorageServiceStub.storageACKSpan(new StreamObserver<SendResult>() {
                @Override
                public void onNext(SendResult sendResult) {
                    System.out.println(sendResult.getResult());
                }

                @Override
                public void onError(Throwable throwable) {
                    throwable.printStackTrace();
                }

                @Override
                public void onCompleted() {
                    System.out.println("Success!!");
                }
            });


    private static StreamObserver<RequestSpan> requestSpanStreamObserver =
            spanStorageServiceStub.storageRequestSpan(new StreamObserver<SendResult>() {
                @Override
                public void onNext(SendResult sendResult) {
                    System.out.println(sendResult.getResult());
                }

                @Override
                public void onError(Throwable throwable) {
                    throwable.printStackTrace();
                }

                @Override
                public void onCompleted() {
                    System.out.println("Success!!");
                }
            });


    public static void main(String[] args) throws InterruptedException {
        RequestSpan requestSpan =
                RequestSpan.newBuilder().setSpanType(1).setAddress("127.0.0.1").setApplicationId("1").setCallType("1")
                        .setLevelId(0).setProcessNo("19287").setStartDate(System.currentTimeMillis())
                        .setTraceId("1.0Final.1478661327960.8504828.2277.53.3").setUserId("1")
                        .setViewPointId("http://localhost:8080/wwww/test/helloWorld").build();
        AckSpan ackSpan =
                AckSpan.newBuilder().setLevelId(0).setCost(10).setTraceId("1.0Final.1478661327960.8504828.2277.53.3")
                        .setStatusCode(0).setViewpointId("http://localhost:8080/wwww/test/helloWorld").build();

        for (int i = 0; i < 100000; i++) {
            requestSpanStreamObserver.onNext(requestSpan);
            ackSpanStreamObserver.onNext(ackSpan);
            Thread.sleep(100);
        }


        ackSpanStreamObserver.onCompleted();
        requestSpanStreamObserver.onCompleted();

        Thread.sleep(10000);

    }
}<commit_msg>change test case of StorageClient.<commit_after>import com.a.eye.skywalking.network.dependencies.io.grpc.ManagedChannel;
import com.a.eye.skywalking.network.dependencies.io.grpc.ManagedChannelBuilder;
import com.a.eye.skywalking.network.dependencies.io.grpc.stub.ClientCallStreamObserver;
import com.a.eye.skywalking.network.dependencies.io.grpc.stub.ServerCallStreamObserver;
import com.a.eye.skywalking.network.dependencies.io.grpc.stub.StreamObserver;
import com.a.eye.skywalking.network.grpc.AckSpan;
import com.a.eye.skywalking.network.grpc.RequestSpan;
import com.a.eye.skywalking.network.grpc.SendResult;
import com.a.eye.skywalking.network.grpc.SpanStorageServiceGrpc;

import static com.a.eye.skywalking.network.grpc.SpanStorageServiceGrpc.newStub;

public class StorageClient {
    private static ManagedChannel channel =
            ManagedChannelBuilder.forAddress("10.128.35.79", 34000).usePlaintext(true).build();

    private static SpanStorageServiceGrpc.SpanStorageServiceStub spanStorageServiceStub = newStub(channel);

    private static long endTime1 = 0;

    private static long endTime2 = 0;


    public static void main(String[] args) throws InterruptedException {
        RequestSpan requestSpan =
                RequestSpan.newBuilder().setSpanType(1).setAddress("127.0.0.1").setApplicationId("1").setCallType("1")
                        .setLevelId(0).setProcessNo("19287").setStartDate(System.currentTimeMillis())
                        .setTraceId("1.0Final.1478661327960.8504828.2277.53.3").setUserId("1")
                        .setViewPointId("http://localhost:8080/wwww/test/helloWorld").build();
        AckSpan ackSpan =
                AckSpan.newBuilder().setLevelId(0).setCost(10).setTraceId("1.0Final.1478661327960.8504828.2277.53.3")
                        .setStatusCode(0).setViewpointId("http://localhost:8080/wwww/test/helloWorld").build();

        long startTime = System.currentTimeMillis();


        for(int i = 0; i < 1000; i++){
            StreamObserver<AckSpan> ackSpanStreamObserver =
                    spanStorageServiceStub.storageACKSpan(new StreamObserver<SendResult>() {
                        @Override
                        public void onNext(SendResult sendResult) {

                        }

                        @Override
                        public void onError(Throwable throwable) {
                            throwable.printStackTrace();
                        }

                        @Override
                        public void onCompleted() {
                            endTime1 = System.currentTimeMillis();
                        }
                    });
            StreamObserver<RequestSpan> requestSpanStreamObserver =
                    spanStorageServiceStub.storageRequestSpan(new StreamObserver<SendResult>() {
                        @Override
                        public void onNext(SendResult sendResult) {

                        }

                        @Override
                        public void onError(Throwable throwable) {
                            throwable.printStackTrace();
                        }

                        @Override
                        public void onCompleted() {
                            endTime2 = System.currentTimeMillis();
                        }
                    });
            for(int j = 0; j < 10000; j++){
                requestSpanStreamObserver.onNext(requestSpan);
                ackSpanStreamObserver.onNext(ackSpan);

                ClientCallStreamObserver<RequestSpan> newRequestSpanStreamObserver =  (ClientCallStreamObserver<RequestSpan>)requestSpanStreamObserver;
                while(!newRequestSpanStreamObserver.isReady()){
                    Thread.sleep(1);
                }
            }

            ackSpanStreamObserver.onCompleted();
            requestSpanStreamObserver.onCompleted();


        }

        Thread.sleep(1000L);

        System.out.println("save execute in " + (endTime1 - startTime) + "ms");
        System.out.println("save execute2 in " + (endTime2 - startTime) + "ms");


        Thread.sleep(10000);

    }
}
{'fraction_non_alphanumeric': 0.10118319053447572, 'fraction_numerical': 0.03291173670610635, 'mean_word_length': 2.0744147157190636, 'pattern_counts': {'":': 0, '<': 16, '<?xml version=': 0, '>': 13, 'https://': 0, 'lorem ipsum': 0, 'www.': 4, 'xml': 0}, 'pii_count': 4, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3318944', 'n_tokens_mistral': 2097, 'n_tokens_neox': 1878, 'n_words': 253}