import tachyon.worker.tiered.StorageDir;
@ChannelHandler.Sharable
public final class DataServerHandler extends ChannelInboundHandlerAdapter {
private static final Logger LOG = LoggerFactory.getLogger(Constants.LOGGER_TYPE);
private final BlocksLocker mLocker;
<BUG>public DataServerHandler(final BlocksLocker locker, final TachyonConf tachyonConf) {
mLocker = locker;</BUG>
}
@Override
public void channelRead(final ChannelHandlerContext ctx, final Object msg) throws Exception {

import tachyon.worker.tiered.StorageDir;
@ChannelHandler.Sharable
public final class DataServerHandler extends ChannelInboundHandlerAdapter {
private static final Logger LOG = LoggerFactory.getLogger(Constants.LOGGER_TYPE);
private final BlocksLocker mLocker;
public DataServerHandler(final BlocksLocker locker) {
mLocker = locker;
}
@Override
public void channelRead(final ChannelHandlerContext ctx, final Object msg) throws Exception {
