question: protected void halt ( final Throwable cause ) { halt = true ; final boolean isFirstCause = firstCause . compareAndSet ( null , cause ) ; if ( WARN ) try { if ( ! InnerCause . isInnerCause ( cause , InterruptedException . class ) && ! InnerCause . isInnerCause ( cause , CancellationException . class ) && ! InnerCause . isInnerCause ( cause , ClosedByInterruptException . class ) && ! InnerCause . isInnerCause ( cause , RejectedExecutionException . class ) && ! InnerCause . isInnerCause ( cause , BufferClosedException . class ) ) { log . warn ( "orderIndex=" + orderIndex + ", partitionId=" + partitionId + ", isFirstCause=" + isFirstCause + " : " + cause . getLocalizedMessage ( ) , cause ) ; } } catch ( Throwable ex ) { } }
target:  Indicate that join processing should halt.  This method is written defensively and will not throw anything.