@Override
public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
        CallOptions callOptions, Channel next) {
    return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) {

        @Override
        public void start(Listener<RespT> responseListener, Metadata headers) {
            super.start(
                    new ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(responseListener) {

                        @Override
                        protected Listener<RespT> delegate() {
                            callTime = System.nanoTime();
                            return super.delegate();
                        }
                    }, headers);
        }
    };
}
 

@Override
public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
        CallOptions callOptions, Channel next) {
    return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) {

        @Override
        public void start(Listener<RespT> responseListener, Metadata headers) {
            super.start(
                    new ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(responseListener) {

                        @Override
                        protected Listener<RespT> delegate() {
                            callTime = System.nanoTime();
                            return super.delegate();
                        }
                    }, headers);
        }
    };
}
 

@Override
public void start(Listener<RespT> responseListener, Metadata headers) {
  entryBuilder.setStartTime(getCurrentTimestamp());
  RequestMetadata metadata = TracingMetadataUtils.requestMetadataFromHeaders(headers);
  if (metadata != null) {
    entryBuilder.setMetadata(metadata);
  }
  super.start(
      new ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(
          responseListener) {
        @Override
        public void onMessage(RespT message) {
          handler.handleResp(message);
          super.onMessage(message);
        }

        @Override
        public void onClose(Status status, Metadata trailers) {
          entryBuilder.setEndTime(getCurrentTimestamp());
          entryBuilder.setStatus(makeStatusProto(status));
          entryBuilder.setDetails(handler.getDetails());
          rpcLogFile.write(entryBuilder.build());
          super.onClose(status, trailers);
        }
      },
      headers);
}
 

@Override
public void start(Listener<RespT> responseListener, Metadata headers) {
  super.start(
      new ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(
          responseListener) {

        @Override
        public void onClose(Status status, Metadata trailers) {
          networkTime.stop();
          super.onClose(status, trailers);
        }
      },
      headers);
}