org.apache.hadoop.hbase.regionserver.wal

Class FSHLog.RingBufferExceptionHandler

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.FSHLog.RingBufferExceptionHandler

All Implemented Interfaces:

com.lmax.disruptor.ExceptionHandler<RingBufferTruck>

Enclosing class:

FSHLog

static class FSHLog.RingBufferExceptionHandler
extends Object
implements com.lmax.disruptor.ExceptionHandler<RingBufferTruck>

Exception handler to pass the disruptor ringbuffer. Same as native implementation only it logs using our logger instead of java native logger.

Constructor Summary

Constructors

Constructor and Description
RingBufferExceptionHandler()

Method Summary

Modifier and Type	Method and Description
void	handleEventException(Throwable ex, long sequence, RingBufferTruck event)
void	handleOnShutdownException(Throwable ex)
void	handleOnStartException(Throwable ex)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RingBufferExceptionHandler

RingBufferExceptionHandler()

Method Detail

handleEventException

public void handleEventException(Throwable ex,
                                 long sequence,
                                 RingBufferTruck event)

Specified by:

handleEventException in interface com.lmax.disruptor.ExceptionHandler<RingBufferTruck>

handleOnStartException

public void handleOnStartException(Throwable ex)

Specified by:

handleOnStartException in interface com.lmax.disruptor.ExceptionHandler<RingBufferTruck>

handleOnShutdownException

public void handleOnShutdownException(Throwable ex)

Specified by:

handleOnShutdownException in interface com.lmax.disruptor.ExceptionHandler<RingBufferTruck>