zhangkun83

class KeepAliveManager {
  ResettableTimer shutdownTimer = new ResettableTimer() {
      @Override
      void timerExpired(TimerState state) {
        synchronized (lock) {
          if (!state.isCancelled()) {
            transport.shutdownNow();
          }
        }
      }

zhangkun83

    Logger.getLogger("io.grpc").setLevel(Level.FINE);
    Handler[] handlers = Logger.getLogger( "" ).getHandlers();
    for ( int index = 0; index < handlers.length; index++ ) {
      handlers[index].setLevel( Level.FINE );
    }

zhangkun83

class LoadTest extends Test{
 private numberOfClients = 1000

 public FileTree getCandidateClassFiles() {
   FileTree candidateTimes = super.getCandidateClassFiles()
   for(int client = 1; client<numberOfClients;client++){
     candidateTimes = candidateTimes + super.getCandidateClassFiles()
   }
   return candidateTimes