From 9b89c303cc36b2ce8202b62fa88c9d8b849c6e6c Mon Sep 17 00:00:00 2001 From: Norman Maurer Date: Sun, 21 Apr 2013 13:41:34 +0200 Subject: [PATCH] Return correct type on retain(..) --- .../main/java/io/netty/channel/sctp/SctpMessage.java | 12 ++++++++++++ .../main/java/io/netty/channel/udt/UdtMessage.java | 11 +++++++++++ .../java/io/netty/channel/socket/DatagramPacket.java | 12 ++++++++++++ 3 files changed, 35 insertions(+) diff --git a/transport-sctp/src/main/java/io/netty/channel/sctp/SctpMessage.java b/transport-sctp/src/main/java/io/netty/channel/sctp/SctpMessage.java index f2f93b3ea2..268513e1a7 100644 --- a/transport-sctp/src/main/java/io/netty/channel/sctp/SctpMessage.java +++ b/transport-sctp/src/main/java/io/netty/channel/sctp/SctpMessage.java @@ -135,6 +135,18 @@ public final class SctpMessage extends DefaultByteBufHolder { } } + @Override + public SctpMessage retain() { + super.retain(); + return this; + } + + @Override + public SctpMessage retain(int increment) { + super.retain(increment); + return this; + } + @Override public String toString() { if (refCnt() == 0) { diff --git a/transport-udt/src/main/java/io/netty/channel/udt/UdtMessage.java b/transport-udt/src/main/java/io/netty/channel/udt/UdtMessage.java index 9a99dcd6a2..54fdd8d933 100644 --- a/transport-udt/src/main/java/io/netty/channel/udt/UdtMessage.java +++ b/transport-udt/src/main/java/io/netty/channel/udt/UdtMessage.java @@ -37,4 +37,15 @@ public final class UdtMessage extends DefaultByteBufHolder { return new UdtMessage(data().copy()); } + @Override + public UdtMessage retain() { + super.retain(); + return this; + } + + @Override + public UdtMessage retain(int increment) { + super.retain(increment); + return this; + } } diff --git a/transport/src/main/java/io/netty/channel/socket/DatagramPacket.java b/transport/src/main/java/io/netty/channel/socket/DatagramPacket.java index d8a7c44cbd..e0afd46935 100644 --- a/transport/src/main/java/io/netty/channel/socket/DatagramPacket.java +++ b/transport/src/main/java/io/netty/channel/socket/DatagramPacket.java @@ -55,6 +55,18 @@ public final class DatagramPacket extends DefaultByteBufHolder { return new DatagramPacket(data().copy(), remoteAddress()); } + @Override + public DatagramPacket retain() { + super.retain(); + return this; + } + + @Override + public DatagramPacket retain(int increment) { + super.retain(increment); + return this; + } + @Override public String toString() { if (refCnt() == 0) {