@Benchmark
  public void createCallLatency(OutputStreamWriter results) throws Exception {
    results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
      private int i = 0;

      @Override
      public void callTimed() throws Exception {
        proxyTClientProxyProtocol.create(new CreateRequest(metaInfo, ROOT + "newfilea-" + i++,
            metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true,
            (short) 1, 1024));
      }
    }, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
    results.write("  |  ");

    results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
      private int i = 0;

      @Override
      public void callTimed() throws Exception {
        proxyClientProxyProtocol.create(new CreateRequest(metaInfo, ROOT + "newfileb-" + i++,
            metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true,
            (short) 1, 1024));
      }
    }, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
    results.write("  |  ");

    results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
      private int i = 0;

      @Override
      public void callTimed() throws Exception {
        directClientProxyProtocol.create(new CreateRequest(metaInfo, ROOT + "newfilec-" + i++,
            metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true,
            (short) 1, 1024));
      }
    }, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
    results.write("  |  ");

    results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
      private int i = 0;

      @Override
      public void callTimed() throws Exception {
        directClientProtocol.create(ROOT + "newfiled-" + i++, FsPermission.getDefault(),
            metaInfo.getOrigCaller().getUserName(), true, true, (short) 1, 1024);
      }
    }, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
  }
@ Benchmark public void createCallLatency ( OutputStreamWriter results ) throws Exception { results . write ( new MeanDevAccumulator ( ) . addResults ( new TimedCallable ( ) { private int i = 0 ; @ Override public void callTimed ( ) throws Exception { proxyTClientProxyProtocol . create ( new CreateRequest ( metaInfo , ROOT + "newfilea-" + i ++ , metaInfo . getOrigCaller ( ) . getUserName ( ) , FsPermission . getDefault ( ) , true , true , ( short ) 1 , 1024 ) ) ; } } , WARMUP_SAMPLES , MEASURED_SAMPLES ) . report ( ) ) ; results . write ( "  |  " ) ; results . write ( new MeanDevAccumulator ( ) . addResults ( new TimedCallable ( ) { private int i = 0 ; @ Override public void callTimed ( ) throws Exception { proxyClientProxyProtocol . create ( new CreateRequest ( metaInfo , ROOT + "newfileb-" + i ++ , metaInfo . getOrigCaller ( ) . getUserName ( ) , FsPermission . getDefault ( ) , true , true , ( short ) 1 , 1024 ) ) ; } } , WARMUP_SAMPLES , MEASURED_SAMPLES ) . report ( ) ) ; results . write ( "  |  " ) ; results . write ( new MeanDevAccumulator ( ) . addResults ( new TimedCallable ( ) { private int i = 0 ; @ Override public void callTimed ( ) throws Exception { directClientProxyProtocol . create ( new CreateRequest ( metaInfo , ROOT + "newfilec-" + i ++ , metaInfo . getOrigCaller ( ) . getUserName ( ) , FsPermission . getDefault ( ) , true , true , ( short ) 1 , 1024 ) ) ; } } , WARMUP_SAMPLES , MEASURED_SAMPLES ) . report ( ) ) ; results . write ( "  |  " ) ; results . write ( new MeanDevAccumulator ( ) . addResults ( new TimedCallable ( ) { private int i = 0 ; @ Override public void callTimed ( ) throws Exception { directClientProtocol . create ( ROOT + "newfiled-" + i ++ , FsPermission . getDefault ( ) , metaInfo . getOrigCaller ( ) . getUserName ( ) , true , true , ( short ) 1 , 1024 ) ; } } , WARMUP_SAMPLES , MEASURED_SAMPLES ) . report ( ) ) ; }
//////////////////////////////////////