Skip to content

Commit c9e31e2

Browse files
committed
Changes for Netty 4.0 compat
1 parent fa0b84e commit c9e31e2

24 files changed

+618
-304
lines changed

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/AbstractDnsMessage.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -349,19 +349,6 @@ private void clear(int section) {
349349
}
350350
}
351351

352-
@Override
353-
public DnsMessage touch() {
354-
return (DnsMessage) super.touch();
355-
}
356-
357-
@Override
358-
public DnsMessage touch(Object hint) {
359-
if (leak != null) {
360-
leak.record(hint);
361-
}
362-
return this;
363-
}
364-
365352
@Override
366353
public DnsMessage retain() {
367354
return (DnsMessage) super.retain();

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DatagramDnsQuery.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -121,16 +121,6 @@ public DatagramDnsQuery clear() {
121121
return (DatagramDnsQuery) super.clear();
122122
}
123123

124-
@Override
125-
public DatagramDnsQuery touch() {
126-
return (DatagramDnsQuery) super.touch();
127-
}
128-
129-
@Override
130-
public DatagramDnsQuery touch(Object hint) {
131-
return (DatagramDnsQuery) super.touch(hint);
132-
}
133-
134124
@Override
135125
public DatagramDnsQuery retain() {
136126
return (DatagramDnsQuery) super.retain();

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DatagramDnsResponse.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -155,16 +155,6 @@ public DatagramDnsResponse clear() {
155155
return (DatagramDnsResponse) super.clear();
156156
}
157157

158-
@Override
159-
public DatagramDnsResponse touch() {
160-
return (DatagramDnsResponse) super.touch();
161-
}
162-
163-
@Override
164-
public DatagramDnsResponse touch(Object hint) {
165-
return (DatagramDnsResponse) super.touch(hint);
166-
}
167-
168158
@Override
169159
public DatagramDnsResponse retain() {
170160
return (DatagramDnsResponse) super.retain();

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DefaultDnsQuery.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -84,16 +84,6 @@ public DnsQuery clear() {
8484
return (DnsQuery) super.clear();
8585
}
8686

87-
@Override
88-
public DnsQuery touch() {
89-
return (DnsQuery) super.touch();
90-
}
91-
92-
@Override
93-
public DnsQuery touch(Object hint) {
94-
return (DnsQuery) super.touch(hint);
95-
}
96-
9787
@Override
9888
public DnsQuery retain() {
9989
return (DnsQuery) super.retain();

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DefaultDnsRawRecord.java

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -102,18 +102,6 @@ public boolean release(int decrement) {
102102
return content().release(decrement);
103103
}
104104

105-
@Override
106-
public DnsRawRecord touch() {
107-
content().touch();
108-
return this;
109-
}
110-
111-
@Override
112-
public DnsRawRecord touch(Object hint) {
113-
content().touch(hint);
114-
return this;
115-
}
116-
117105
@Override
118106
public String toString() {
119107
final StringBuilder buf = new StringBuilder(64).append(StringUtil.simpleClassName(this)).append('(');

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DefaultDnsResponse.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -148,16 +148,6 @@ public DnsResponse clear() {
148148
return (DnsResponse) super.clear();
149149
}
150150

151-
@Override
152-
public DnsResponse touch() {
153-
return (DnsResponse) super.touch();
154-
}
155-
156-
@Override
157-
public DnsResponse touch(Object hint) {
158-
return (DnsResponse) super.touch(hint);
159-
}
160-
161151
@Override
162152
public DnsResponse retain() {
163153
return (DnsResponse) super.retain();

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DnsMessage.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -142,12 +142,6 @@ public interface DnsMessage extends ReferenceCounted {
142142
*/
143143
DnsMessage clear();
144144

145-
@Override
146-
DnsMessage touch();
147-
148-
@Override
149-
DnsMessage touch(Object hint);
150-
151145
@Override
152146
DnsMessage retain();
153147

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DnsMessageUtil.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -172,8 +172,8 @@ private static void appendRecords(StringBuilder buf, DnsMessage message, DnsSect
172172
final int count = message.count(section);
173173
for (int i = 0; i < count; i ++) {
174174
buf.append(StringUtil.NEWLINE)
175-
.append(StringUtil.TAB)
176-
.append(message.recordAt(section, i));
175+
.append('\t')
176+
.append(message.recordAt(section, i).toString());
177177
}
178178
}
179179

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DnsQuery.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -46,12 +46,6 @@ public interface DnsQuery extends DnsMessage {
4646
@Override
4747
DnsQuery clear();
4848

49-
@Override
50-
DnsQuery touch();
51-
52-
@Override
53-
DnsQuery touch(Object hint);
54-
5549
@Override
5650
DnsQuery retain();
5751

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DnsRawRecord.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,4 @@ public interface DnsRawRecord extends DnsRecord, ByteBufHolder {
3232

3333
@Override
3434
DnsRawRecord retain(int increment);
35-
36-
@Override
37-
DnsRawRecord touch();
38-
39-
@Override
40-
DnsRawRecord touch(Object hint);
4135
}

netty-bp/codec-dns/src/main/java/io/netty/handler/codec/dns/DnsResponse.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -99,12 +99,6 @@ public interface DnsResponse extends DnsMessage {
9999
@Override
100100
DnsResponse clear();
101101

102-
@Override
103-
DnsResponse touch();
104-
105-
@Override
106-
DnsResponse touch(Object hint);
107-
108102
@Override
109103
DnsResponse retain();
110104

netty-bp/codec-dns/src/test/java/io/netty/handler/codec/dns/DnsQueryTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ public void writeQueryTest() throws Exception {
5959

6060
embedder.writeOutbound(query);
6161

62-
DatagramPacket packet = embedder.readOutbound();
62+
DatagramPacket packet = (DatagramPacket) embedder.readOutbound();
6363
Assert.assertTrue(packet.content().isReadable());
6464
packet.release();
6565
Assert.assertNull(embedder.readOutbound());

netty-bp/codec-dns/src/test/java/io/netty/handler/codec/dns/DnsResponseTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public void readResponseTest() throws Exception {
7676
for (byte[] p: packets) {
7777
ByteBuf packet = embedder.alloc().buffer(512).writeBytes(p);
7878
embedder.writeInbound(new DatagramPacket(packet, null, new InetSocketAddress(0)));
79-
AddressedEnvelope<DnsResponse, InetSocketAddress> envelope = embedder.readInbound();
79+
AddressedEnvelope<DnsResponse, InetSocketAddress> envelope = (AddressedEnvelope<DnsResponse, InetSocketAddress>) embedder.readInbound();
8080
assertThat(envelope, is(instanceOf(DatagramDnsResponse.class)));
8181
DnsResponse response = envelope.content();
8282
assertThat(response, is(sameInstance((Object) envelope)));
Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
/*
2+
* Copyright 2014 The Netty Project
3+
*
4+
* The Netty Project licenses this file to you under the Apache License,
5+
* version 2.0 (the "License"); you may not use this file except in compliance
6+
* with the License. You may obtain a copy of the License at:
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12+
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13+
* License for the specific language governing permissions and limitations
14+
* under the License.
15+
*/
16+
17+
package io.netty.channel;
18+
19+
import io.netty.bootstrap.ChannelFactory;
20+
import io.netty.util.internal.StringUtil;
21+
22+
/**
23+
* A {@link ChannelFactory} that instantiates a new {@link Channel} by invoking its default constructor reflectively.
24+
*/
25+
public class ReflectiveChannelFactory<T extends Channel> implements ChannelFactory<T> {
26+
27+
private final Class<? extends T> clazz;
28+
29+
public ReflectiveChannelFactory(Class<? extends T> clazz) {
30+
if (clazz == null) {
31+
throw new NullPointerException("clazz");
32+
}
33+
this.clazz = clazz;
34+
}
35+
36+
@Override
37+
public T newChannel() {
38+
try {
39+
return clazz.newInstance();
40+
} catch (Throwable t) {
41+
throw new ChannelException("Unable to create Channel from class " + clazz, t);
42+
}
43+
}
44+
45+
@Override
46+
public String toString() {
47+
return StringUtil.simpleClassName(clazz) + ".class";
48+
}
49+
}

0 commit comments

Comments
 (0)