public void close(){
  while (subChannel.size() > 0) {
    subs.addSample(subChannel.poll());
  }
  while (pubChannel.size() > 0) {
    pubs.addSample(pubChannel.poll());
  }
  if (subs.hasSamples()) {
    start=subs.start;
    end=subs.end;
  }
 else {
    start=pubs.start;
    end=pubs.end;
  }
  end=Math.min(end,subs.end);
  end=Math.min(end,pubs.end);
  msgBytes=pubs.msgBytes + subs.msgBytes;
  ioBytes=pubs.ioBytes + subs.ioBytes;
  msgCnt=pubs.msgCnt + subs.msgCnt;
  jobMsgCnt=pubs.jobMsgCnt + subs.jobMsgCnt;
}

public void close ( ) { while ( subChannel . size ( ) > 0 ) { subs . addSample ( subChannel . poll ( ) ) ; } while ( pubChannel . size ( ) > 0 ) { pubs . addSample ( pubChannel . poll ( ) ) ; } if ( subs . hasSamples ( ) ) { start = subs . start ; end = subs . end ; } else { start = pubs . start ; end = pubs . end ; } end = Math . min ( end , subs . end ) ; end = Math . min ( end , pubs . end ) ; msgBytes = pubs . msgBytes + subs . msgBytes ; ioBytes = pubs . ioBytes + subs . ioBytes ; msgCnt = pubs . msgCnt + subs . msgCnt ; jobMsgCnt = pubs . jobMsgCnt + subs . jobMsgCnt ; }
closes this benchmark and calculates totals and times .
