protected void shutdown ( ) throws InterruptedException { if ( m_deadConnectionFuture != null ) { m_deadConnectionFuture . cancel ( false ) ; try { m_deadConnectionFuture . get ( ) ; } catch ( Throwable t ) { } } if ( m_topologyCheckFuture != null ) { m_topologyCheckFuture . cancel ( false ) ; try { m_topologyCheckFuture . get ( ) ; } catch ( Throwable t ) { } } if ( m_maxConnectionUpdater != null ) { m_maxConnectionUpdater . cancel ( false ) ; } if ( m_acceptor != null ) { m_acceptor . shutdown ( ) ; } if ( m_adminAcceptor != null ) { m_adminAcceptor . shutdown ( ) ; } if ( m_snapshotDaemon != null ) { m_snapshotDaemon . shutdown ( ) ; } if ( m_migratePartitionLeaderExecutor != null ) { m_migratePartitionLeaderExecutor . shutdown ( ) ; } m_notifier . shutdown ( ) ; }
all your read buffers events .. or something ..