private void internalFlush ( NextFilter nextFilter , IoSession session , IoBuffer buf ) throws Exception { IoBuffer tmp ; synchronized ( buf ) { buf . flip ( ) ; tmp = buf . duplicate ( ) ; buf . clear ( ) ; } logger . debug ( "Flushing buffer: {}" , tmp ) ; nextFilter . filterWrite ( session , new DefaultWriteRequest ( tmp ) ) ; }
Internal method that actually flushes the buffered data .