/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package org.apache.directory.server.dhcp.netty;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.socket.DatagramPacket;
import java.nio.ByteBuffer;
import javax.annotation.Nonnull;
import org.anarres.dhcp.common.address.InterfaceAddress;
import org.apache.directory.server.dhcp.io.DhcpMessageDecoder;
import org.apache.directory.server.dhcp.io.DhcpMessageEncoder;
import org.apache.directory.server.dhcp.messages.DhcpMessage;
import org.apache.directory.server.dhcp.service.DhcpService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 *
 * @author shevek
 */
public class DhcpHandler extends SimpleChannelInboundHandler<DatagramPacket> {

    private static final Logger LOG = LoggerFactory.getLogger(DhcpHandler.class);
    private final DhcpService dhcpService;
    private final DhcpMessageDecoder decoder = new DhcpMessageDecoder();
    private final DhcpMessageEncoder encoder = new DhcpMessageEncoder();

    public DhcpHandler(@Nonnull DhcpService dhcpService) {
        this.dhcpService = dhcpService;
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) throws Exception {
        DhcpMessage request = decoder.decode(msg.content().nioBuffer());
        InterfaceAddress localAddress = new InterfaceAddress(msg.recipient().getAddress(), 0);
        DhcpMessage reply = dhcpService.getReplyFor(
                localAddress,
                msg.sender(), request);
        if (reply != null) {
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            encoder.encode(buffer, reply);
            buffer.flip();
            ByteBuf buf = Unpooled.wrappedBuffer(buffer);
            DatagramPacket packet = new DatagramPacket(buf, msg.sender());
            ctx.write(packet, ctx.voidPromise());
        }
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        LOG.error("Error on channel: " + cause, cause);
        // ctx.close();
    }

}

@@ -263,41 +263,8 @@
 uf;%0A
-import io.netty.buffer.Unpooled;%0A
 impo
@@ -1773,45 +1773,125 @@
 eBuf
-fer buffer = ByteBuffer.allocate(1024
+ buf = ctx.alloc().buffer(1024);%0A            ByteBuffer buffer = buf.nioBuffer(buf.writerIndex(), buf.writableBytes()
 );%0A 
@@ -1975,51 +1975,62 @@
     
-ByteBuf buf = Unpooled.wrappedBuffer(buffer
+buf.writerIndex(buf.writerIndex() + buffer.remaining()
 );%0A 

Use ctx.alloc().