andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge pull request #51 from motlin/master

Browse Source 
Fixes from static-analysis tools.
This commit is contained in:
Norman Maurer 2011-11-12 01:03:02 -08:00
commit 0b3a685f95
32 changed files with 183 additions and 100 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/jboss/netty/channel/local/DefaultLocalChannel.java
View File

@ -104,7 +104,7 @@ final class DefaultLocalChannel extends AbstractChannel implements LocalChannel
return state.get() == ST_CONNECTED; return state.get() == ST_CONNECTED;
} }
final void setBound() throws ClosedChannelException { void setBound() throws ClosedChannelException {
if (!state.compareAndSet(ST_OPEN, ST_BOUND)) { if (!state.compareAndSet(ST_OPEN, ST_BOUND)) {
switch (state.get()) { switch (state.get()) {
case ST_CLOSED: case ST_CLOSED:
@ -115,7 +115,7 @@ final class DefaultLocalChannel extends AbstractChannel implements LocalChannel
} }
} }
final void setConnected() { void setConnected() {
if (state.get() != ST_CLOSED) { if (state.get() != ST_CLOSED) {
state.set(ST_CONNECTED); state.set(ST_CONNECTED);
} }

12
src/main/java/org/jboss/netty/channel/rxtx/RXTXChannelConfig.java
View File

@ -28,7 +28,7 @@ import org.jboss.netty.util.internal.ConversionUtil;
*/ */
public class RXTXChannelConfig extends DefaultChannelConfig { public class RXTXChannelConfig extends DefaultChannelConfig {
public static enum Stopbits { public enum Stopbits {
STOPBITS_1(SerialPort.STOPBITS_1), STOPBITS_1(SerialPort.STOPBITS_1),
STOPBITS_2(SerialPort.STOPBITS_2), STOPBITS_2(SerialPort.STOPBITS_2),
@ -36,7 +36,7 @@ public class RXTXChannelConfig extends DefaultChannelConfig {
private final int value; private final int value;
private Stopbits(int value) { Stopbits(int value) {
this.value = value; this.value = value;
} }
@ -54,7 +54,7 @@ public class RXTXChannelConfig extends DefaultChannelConfig {
} }
} }
public static enum Databits { public enum Databits {
DATABITS_5(SerialPort.DATABITS_5), DATABITS_5(SerialPort.DATABITS_5),
DATABITS_6(SerialPort.DATABITS_6), DATABITS_6(SerialPort.DATABITS_6),
@ -63,7 +63,7 @@ public class RXTXChannelConfig extends DefaultChannelConfig {
private final int value; private final int value;
private Databits(int value) { Databits(int value) {
this.value = value; this.value = value;
} }
@ -81,7 +81,7 @@ public class RXTXChannelConfig extends DefaultChannelConfig {
} }
} }
public static enum Paritybit { public enum Paritybit {
NONE(SerialPort.PARITY_NONE), NONE(SerialPort.PARITY_NONE),
ODD(SerialPort.PARITY_ODD), ODD(SerialPort.PARITY_ODD),
@ -91,7 +91,7 @@ public class RXTXChannelConfig extends DefaultChannelConfig {
private final int value; private final int value;
private Paritybit(int value) { Paritybit(int value) {
this.value = value; this.value = value;
} }

2
src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelClientChannel.java
View File

@ -288,7 +288,7 @@ public class HttpTunnelClientChannel extends AbstractChannel implements
Channels.fireChannelInterestChanged(this); Channels.fireChannelInterestChanged(this);
} }
private class ConsolidatingFutureListener implements ChannelFutureListener { private static class ConsolidatingFutureListener implements ChannelFutureListener {
private final ChannelFuture completionFuture; private final ChannelFuture completionFuture;

2
src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelServerChannelSink.java
View File

@ -61,7 +61,7 @@ class HttpTunnelServerChannelSink extends AbstractChannelSink {
} }
} }
private final class ChannelFutureProxy implements ChannelFutureListener { private static final class ChannelFutureProxy implements ChannelFutureListener {
private final ChannelFuture upstreamFuture; private final ChannelFuture upstreamFuture;
ChannelFutureProxy(ChannelFuture upstreamFuture) { ChannelFutureProxy(ChannelFuture upstreamFuture) {

2
src/main/java/org/jboss/netty/channel/socket/http/ServerMessageSwitch.java
View File

@ -238,7 +238,7 @@ class ServerMessageSwitch implements ServerMessageSwitchUpstreamInterface,
/** /**
* Used to pass the result received from one ChannelFutureListener to another verbatim. * Used to pass the result received from one ChannelFutureListener to another verbatim.
*/ */
private final class RelayedChannelFutureListener implements private static final class RelayedChannelFutureListener implements
ChannelFutureListener { ChannelFutureListener {
private final ChannelFuture originalFuture; private final ChannelFuture originalFuture;

4
src/main/java/org/jboss/netty/channel/socket/nio/SocketReceiveBufferPool.java
View File

@ -30,7 +30,7 @@ final class SocketReceiveBufferPool {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
private final SoftReference<ByteBuffer>[] pool = new SoftReference[POOL_SIZE]; private final SoftReference<ByteBuffer>[] pool = new SoftReference[POOL_SIZE];
final ByteBuffer acquire(int size) { ByteBuffer acquire(int size) {
final SoftReference<ByteBuffer>[] pool = this.pool; final SoftReference<ByteBuffer>[] pool = this.pool;
for (int i = 0; i < POOL_SIZE; i ++) { for (int i = 0; i < POOL_SIZE; i ++) {
SoftReference<ByteBuffer> ref = pool[i]; SoftReference<ByteBuffer> ref = pool[i];
@ -59,7 +59,7 @@ final class SocketReceiveBufferPool {
return buf; return buf;
} }
final void release(ByteBuffer buffer) { void release(ByteBuffer buffer) {
final SoftReference<ByteBuffer>[] pool = this.pool; final SoftReference<ByteBuffer>[] pool = this.pool;
for (int i = 0; i < POOL_SIZE; i ++) { for (int i = 0; i < POOL_SIZE; i ++) {
SoftReference<ByteBuffer> ref = pool[i]; SoftReference<ByteBuffer> ref = pool[i];

18
src/main/java/org/jboss/netty/channel/socket/nio/SocketSendBufferPool.java
View File

@ -45,7 +45,7 @@ final class SocketSendBufferPool {
super(); super();
} }
final SendBuffer acquire(Object message) { SendBuffer acquire(Object message) {
if (message instanceof ChannelBuffer) { if (message instanceof ChannelBuffer) {
return acquire((ChannelBuffer) message); return acquire((ChannelBuffer) message);
} else if (message instanceof FileRegion) { } else if (message instanceof FileRegion) {
@ -147,7 +147,7 @@ final class SocketSendBufferPool {
return q << ALIGN_SHIFT; return q << ALIGN_SHIFT;
} }
private final class Preallocation { private static final class Preallocation {
final ByteBuffer buffer; final ByteBuffer buffer;
int refCnt; int refCnt;
@ -176,7 +176,7 @@ final class SocketSendBufferPool {
void release(); void release();
} }
class UnpooledSendBuffer implements SendBuffer { static class UnpooledSendBuffer implements SendBuffer {
final ByteBuffer buffer; final ByteBuffer buffer;
final int initialPos; final int initialPos;
@ -266,7 +266,7 @@ final class SocketSendBufferPool {
} }
} }
final class FileSendBuffer implements SendBuffer { static final class FileSendBuffer implements SendBuffer {
private final FileRegion file; private final FileRegion file;
private long writtenBytes; private long writtenBytes;
@ -320,27 +320,27 @@ final class SocketSendBufferPool {
} }
@Override @Override
public final boolean finished() { public boolean finished() {
return true; return true;
} }
@Override @Override
public final long writtenBytes() { public long writtenBytes() {
return 0; return 0;
} }
@Override @Override
public final long totalBytes() { public long totalBytes() {
return 0; return 0;
} }
@Override @Override
public final long transferTo(WritableByteChannel ch) throws IOException { public long transferTo(WritableByteChannel ch) throws IOException {
return 0; return 0;
} }
@Override @Override
public final long transferTo(DatagramChannel ch, SocketAddress raddr) throws IOException { public long transferTo(DatagramChannel ch, SocketAddress raddr) throws IOException {
return 0; return 0;
} }

1
src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientFactory.java
View File

@ -72,6 +72,7 @@ public class WebSocketClientFactory {
bootstrap.setPipelineFactory(new ChannelPipelineFactory() { bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
@Override
public ChannelPipeline getPipeline() throws Exception { public ChannelPipeline getPipeline() throws Exception {
ChannelPipeline pipeline = Channels.pipeline(); ChannelPipeline pipeline = Channels.pipeline();
pipeline.addLast("decoder", new WebSocketHttpResponseDecoder()); pipeline.addLast("decoder", new WebSocketHttpResponseDecoder());

3
src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientHandler.java
View File

@ -102,14 +102,17 @@ public class WebSocketClientHandler extends SimpleChannelUpstreamHandler impleme
e.getChannel().close(); e.getChannel().close();
} }
@Override
public ChannelFuture connect() { public ChannelFuture connect() {
return bootstrap.connect(new InetSocketAddress(url.getHost(), url.getPort())); return bootstrap.connect(new InetSocketAddress(url.getHost(), url.getPort()));
} }
@Override
public ChannelFuture disconnect() { public ChannelFuture disconnect() {
return channel.close(); return channel.close();
} }
@Override
public ChannelFuture send(WebSocketFrame frame) { public ChannelFuture send(WebSocketFrame frame) {
return channel.write(frame); return channel.write(frame);
} }

1
src/main/java/org/jboss/netty/example/iostream/IOStream.java
View File

@ -44,6 +44,7 @@ public class IOStream {
// Configure the event pipeline factory. // Configure the event pipeline factory.
bootstrap.setPipelineFactory(new ChannelPipelineFactory() { bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
@Override
public ChannelPipeline getPipeline() throws Exception { public ChannelPipeline getPipeline() throws Exception {
DefaultChannelPipeline pipeline = new DefaultChannelPipeline(); DefaultChannelPipeline pipeline = new DefaultChannelPipeline();
pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter())); pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));

101
src/main/java/org/jboss/netty/example/localtime/LocalTimeProtocol.java
View File

@ -25,6 +25,7 @@ public final class LocalTimeProtocol {
; ;
@Override
public final int getNumber() { return value; } public final int getNumber() { return value; }
public static Continent valueOf(int value) { public static Continent valueOf(int value) {
@ -51,20 +52,23 @@ public final class LocalTimeProtocol {
private static final com.google.protobuf.Internal.EnumLiteMap<Continent> private static final com.google.protobuf.Internal.EnumLiteMap<Continent>
internalValueMap = internalValueMap =
new com.google.protobuf.Internal.EnumLiteMap<Continent>() { new com.google.protobuf.Internal.EnumLiteMap<Continent>() {
@Override
public Continent findValueByNumber(int number) { public Continent findValueByNumber(int number) {
return Continent.valueOf(number) return Continent.valueOf(number)
; } ; }
}; };
@Override
public final com.google.protobuf.Descriptors.EnumValueDescriptor public final com.google.protobuf.Descriptors.EnumValueDescriptor
getValueDescriptor() { getValueDescriptor() {
return getDescriptor().getValues().get(index); return getDescriptor().getValues().get(index);
} }
@Override
public final com.google.protobuf.Descriptors.EnumDescriptor public final com.google.protobuf.Descriptors.EnumDescriptor
getDescriptorForType() { getDescriptorForType() {
return getDescriptor(); return getDescriptor();
} }
public static final com.google.protobuf.Descriptors.EnumDescriptor public static com.google.protobuf.Descriptors.EnumDescriptor
getDescriptor() { getDescriptor() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.getDescriptor().getEnumTypes().get(0); return org.jboss.netty.example.localtime.LocalTimeProtocol.getDescriptor().getEnumTypes().get(0);
} }
@ -82,7 +86,7 @@ public final class LocalTimeProtocol {
} }
private final int index; private final int index;
private final int value; private final int value;
private Continent(int index, int value) { Continent(int index, int value) {
this.index = index; this.index = index;
this.value = value; this.value = value;
} }
@ -106,6 +110,7 @@ public final class LocalTimeProtocol {
; ;
@Override
public final int getNumber() { return value; } public final int getNumber() { return value; }
public static DayOfWeek valueOf(int value) { public static DayOfWeek valueOf(int value) {
@ -128,20 +133,23 @@ public final class LocalTimeProtocol {
private static final com.google.protobuf.Internal.EnumLiteMap<DayOfWeek> private static final com.google.protobuf.Internal.EnumLiteMap<DayOfWeek>
internalValueMap = internalValueMap =
new com.google.protobuf.Internal.EnumLiteMap<DayOfWeek>() { new com.google.protobuf.Internal.EnumLiteMap<DayOfWeek>() {
@Override
public DayOfWeek findValueByNumber(int number) { public DayOfWeek findValueByNumber(int number) {
return DayOfWeek.valueOf(number) return DayOfWeek.valueOf(number)
; } ; }
}; };
@Override
public final com.google.protobuf.Descriptors.EnumValueDescriptor public final com.google.protobuf.Descriptors.EnumValueDescriptor
getValueDescriptor() { getValueDescriptor() {
return getDescriptor().getValues().get(index); return getDescriptor().getValues().get(index);
} }
@Override
public final com.google.protobuf.Descriptors.EnumDescriptor public final com.google.protobuf.Descriptors.EnumDescriptor
getDescriptorForType() { getDescriptorForType() {
return getDescriptor(); return getDescriptor();
} }
public static final com.google.protobuf.Descriptors.EnumDescriptor public static com.google.protobuf.Descriptors.EnumDescriptor
getDescriptor() { getDescriptor() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.getDescriptor().getEnumTypes().get(1); return org.jboss.netty.example.localtime.LocalTimeProtocol.getDescriptor().getEnumTypes().get(1);
} }
@ -159,7 +167,7 @@ public final class LocalTimeProtocol {
} }
private final int index; private final int index;
private final int value; private final int value;
private DayOfWeek(int index, int value) { DayOfWeek(int index, int value) {
this.index = index; this.index = index;
this.value = value; this.value = value;
} }
@ -184,15 +192,17 @@ public final class LocalTimeProtocol {
return defaultInstance; return defaultInstance;
} }
@Override
public Location getDefaultInstanceForType() { public Location getDefaultInstanceForType() {
return defaultInstance; return defaultInstance;
} }
public static final com.google.protobuf.Descriptors.Descriptor public static com.google.protobuf.Descriptors.Descriptor
getDescriptor() { getDescriptor() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Location_descriptor; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Location_descriptor;
} }
@Override
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Location_fieldAccessorTable; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Location_fieldAccessorTable;
@ -215,7 +225,8 @@ public final class LocalTimeProtocol {
private void initFields() { private void initFields() {
continent_ = org.jboss.netty.example.localtime.LocalTimeProtocol.Continent.AFRICA; continent_ = org.jboss.netty.example.localtime.LocalTimeProtocol.Continent.AFRICA;
} }
public final boolean isInitialized() { @Override
public boolean isInitialized() {
if (!hasContinent) { if (!hasContinent) {
return false; return false;
} }
@ -225,6 +236,7 @@ public final class LocalTimeProtocol {
return true; return true;
} }
@Override
public void writeTo(com.google.protobuf.CodedOutputStream output) public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException { throws java.io.IOException {
getSerializedSize(); getSerializedSize();
@ -238,6 +250,7 @@ public final class LocalTimeProtocol {
} }
private int memoizedSerializedSize = -1; private int memoizedSerializedSize = -1;
@Override
public int getSerializedSize() { public int getSerializedSize() {
int size = memoizedSerializedSize; int size = memoizedSerializedSize;
if (size != -1) { if (size != -1) {
@ -326,10 +339,12 @@ public final class LocalTimeProtocol {
} }
public static Builder newBuilder() { return Builder.create(); } public static Builder newBuilder() { return Builder.create(); }
@Override
public Builder newBuilderForType() { return newBuilder(); } public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.Location prototype) { public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.Location prototype) {
return newBuilder().mergeFrom(prototype); return newBuilder().mergeFrom(prototype);
} }
@Override
public Builder toBuilder() { return newBuilder(this); } public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends public static final class Builder extends
@ -345,10 +360,12 @@ public final class LocalTimeProtocol {
return builder; return builder;
} }
@Override
protected org.jboss.netty.example.localtime.LocalTimeProtocol.Location internalGetResult() { protected org.jboss.netty.example.localtime.LocalTimeProtocol.Location internalGetResult() {
return result; return result;
} }
@Override
public Builder clear() { public Builder clear() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -358,22 +375,27 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder clone() { public Builder clone() {
return create().mergeFrom(result); return create().mergeFrom(result);
} }
@Override
public com.google.protobuf.Descriptors.Descriptor public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() { getDescriptorForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.Location.getDescriptor(); return org.jboss.netty.example.localtime.LocalTimeProtocol.Location.getDescriptor();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.Location getDefaultInstanceForType() { public org.jboss.netty.example.localtime.LocalTimeProtocol.Location getDefaultInstanceForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.Location.getDefaultInstance(); return org.jboss.netty.example.localtime.LocalTimeProtocol.Location.getDefaultInstance();
} }
@Override
public boolean isInitialized() { public boolean isInitialized() {
return result.isInitialized(); return result.isInitialized();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.Location build() { public org.jboss.netty.example.localtime.LocalTimeProtocol.Location build() {
if (result != null && !isInitialized()) { if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result); throw newUninitializedMessageException(result);
@ -390,6 +412,7 @@ public final class LocalTimeProtocol {
return buildPartial(); return buildPartial();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.Location buildPartial() { public org.jboss.netty.example.localtime.LocalTimeProtocol.Location buildPartial() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -400,6 +423,7 @@ public final class LocalTimeProtocol {
return returnMe; return returnMe;
} }
@Override
public Builder mergeFrom(com.google.protobuf.Message other) { public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.Location) { if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.Location) {
return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.Location)other); return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.Location)other);
@ -423,6 +447,7 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder mergeFrom( public Builder mergeFrom(
com.google.protobuf.CodedInputStream input, com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@ -530,15 +555,17 @@ public final class LocalTimeProtocol {
return defaultInstance; return defaultInstance;
} }
@Override
public Locations getDefaultInstanceForType() { public Locations getDefaultInstanceForType() {
return defaultInstance; return defaultInstance;
} }
public static final com.google.protobuf.Descriptors.Descriptor public static com.google.protobuf.Descriptors.Descriptor
getDescriptor() { getDescriptor() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Locations_descriptor; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Locations_descriptor;
} }
@Override
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Locations_fieldAccessorTable; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_Locations_fieldAccessorTable;
@ -558,7 +585,8 @@ public final class LocalTimeProtocol {
private void initFields() { private void initFields() {
} }
public final boolean isInitialized() { @Override
public boolean isInitialized() {
for (org.jboss.netty.example.localtime.LocalTimeProtocol.Location element : getLocationList()) { for (org.jboss.netty.example.localtime.LocalTimeProtocol.Location element : getLocationList()) {
if (!element.isInitialized()) { if (!element.isInitialized()) {
return false; return false;
@ -567,6 +595,7 @@ public final class LocalTimeProtocol {
return true; return true;
} }
@Override
public void writeTo(com.google.protobuf.CodedOutputStream output) public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException { throws java.io.IOException {
getSerializedSize(); getSerializedSize();
@ -577,6 +606,7 @@ public final class LocalTimeProtocol {
} }
private int memoizedSerializedSize = -1; private int memoizedSerializedSize = -1;
@Override
public int getSerializedSize() { public int getSerializedSize() {
int size = memoizedSerializedSize; int size = memoizedSerializedSize;
if (size != -1) { if (size != -1) {
@ -661,10 +691,12 @@ public final class LocalTimeProtocol {
} }
public static Builder newBuilder() { return Builder.create(); } public static Builder newBuilder() { return Builder.create(); }
@Override
public Builder newBuilderForType() { return newBuilder(); } public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.Locations prototype) { public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.Locations prototype) {
return newBuilder().mergeFrom(prototype); return newBuilder().mergeFrom(prototype);
} }
@Override
public Builder toBuilder() { return newBuilder(this); } public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends public static final class Builder extends
@ -680,10 +712,12 @@ public final class LocalTimeProtocol {
return builder; return builder;
} }
@Override
protected org.jboss.netty.example.localtime.LocalTimeProtocol.Locations internalGetResult() { protected org.jboss.netty.example.localtime.LocalTimeProtocol.Locations internalGetResult() {
return result; return result;
} }
@Override
public Builder clear() { public Builder clear() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -693,22 +727,27 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder clone() { public Builder clone() {
return create().mergeFrom(result); return create().mergeFrom(result);
} }
@Override
public com.google.protobuf.Descriptors.Descriptor public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() { getDescriptorForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.Locations.getDescriptor(); return org.jboss.netty.example.localtime.LocalTimeProtocol.Locations.getDescriptor();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.Locations getDefaultInstanceForType() { public org.jboss.netty.example.localtime.LocalTimeProtocol.Locations getDefaultInstanceForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.Locations.getDefaultInstance(); return org.jboss.netty.example.localtime.LocalTimeProtocol.Locations.getDefaultInstance();
} }
@Override
public boolean isInitialized() { public boolean isInitialized() {
return result.isInitialized(); return result.isInitialized();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.Locations build() { public org.jboss.netty.example.localtime.LocalTimeProtocol.Locations build() {
if (result != null && !isInitialized()) { if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result); throw newUninitializedMessageException(result);
@ -725,6 +764,7 @@ public final class LocalTimeProtocol {
return buildPartial(); return buildPartial();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.Locations buildPartial() { public org.jboss.netty.example.localtime.LocalTimeProtocol.Locations buildPartial() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -739,6 +779,7 @@ public final class LocalTimeProtocol {
return returnMe; return returnMe;
} }
@Override
public Builder mergeFrom(com.google.protobuf.Message other) { public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.Locations) { if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.Locations) {
return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.Locations)other); return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.Locations)other);
@ -762,6 +803,7 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder mergeFrom( public Builder mergeFrom(
com.google.protobuf.CodedInputStream input, com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@ -870,15 +912,17 @@ public final class LocalTimeProtocol {
return defaultInstance; return defaultInstance;
} }
@Override
public LocalTime getDefaultInstanceForType() { public LocalTime getDefaultInstanceForType() {
return defaultInstance; return defaultInstance;
} }
public static final com.google.protobuf.Descriptors.Descriptor public static com.google.protobuf.Descriptors.Descriptor
getDescriptor() { getDescriptor() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTime_descriptor; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTime_descriptor;
} }
@Override
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTime_fieldAccessorTable; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTime_fieldAccessorTable;
@ -936,7 +980,8 @@ public final class LocalTimeProtocol {
private void initFields() { private void initFields() {
dayOfWeek_ = org.jboss.netty.example.localtime.LocalTimeProtocol.DayOfWeek.SUNDAY; dayOfWeek_ = org.jboss.netty.example.localtime.LocalTimeProtocol.DayOfWeek.SUNDAY;
} }
public final boolean isInitialized() { @Override
public boolean isInitialized() {
if (!hasYear) { if (!hasYear) {
return false; return false;
} }
@ -961,6 +1006,7 @@ public final class LocalTimeProtocol {
return true; return true;
} }
@Override
public void writeTo(com.google.protobuf.CodedOutputStream output) public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException { throws java.io.IOException {
getSerializedSize(); getSerializedSize();
@ -989,6 +1035,7 @@ public final class LocalTimeProtocol {
} }
private int memoizedSerializedSize = -1; private int memoizedSerializedSize = -1;
@Override
public int getSerializedSize() { public int getSerializedSize() {
int size = memoizedSerializedSize; int size = memoizedSerializedSize;
if (size != -1) { if (size != -1) {
@ -1097,10 +1144,12 @@ public final class LocalTimeProtocol {
} }
public static Builder newBuilder() { return Builder.create(); } public static Builder newBuilder() { return Builder.create(); }
@Override
public Builder newBuilderForType() { return newBuilder(); } public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime prototype) { public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime prototype) {
return newBuilder().mergeFrom(prototype); return newBuilder().mergeFrom(prototype);
} }
@Override
public Builder toBuilder() { return newBuilder(this); } public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends public static final class Builder extends
@ -1116,10 +1165,12 @@ public final class LocalTimeProtocol {
return builder; return builder;
} }
@Override
protected org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime internalGetResult() { protected org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime internalGetResult() {
return result; return result;
} }
@Override
public Builder clear() { public Builder clear() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -1129,22 +1180,27 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder clone() { public Builder clone() {
return create().mergeFrom(result); return create().mergeFrom(result);
} }
@Override
public com.google.protobuf.Descriptors.Descriptor public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() { getDescriptorForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime.getDescriptor(); return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime.getDescriptor();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime getDefaultInstanceForType() { public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime getDefaultInstanceForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime.getDefaultInstance(); return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime.getDefaultInstance();
} }
@Override
public boolean isInitialized() { public boolean isInitialized() {
return result.isInitialized(); return result.isInitialized();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime build() { public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime build() {
if (result != null && !isInitialized()) { if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result); throw newUninitializedMessageException(result);
@ -1161,6 +1217,7 @@ public final class LocalTimeProtocol {
return buildPartial(); return buildPartial();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime buildPartial() { public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime buildPartial() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -1171,6 +1228,7 @@ public final class LocalTimeProtocol {
return returnMe; return returnMe;
} }
@Override
public Builder mergeFrom(com.google.protobuf.Message other) { public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime) { if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime) {
return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime)other); return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime)other);
@ -1209,6 +1267,7 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder mergeFrom( public Builder mergeFrom(
com.google.protobuf.CodedInputStream input, com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@ -1423,15 +1482,17 @@ public final class LocalTimeProtocol {
return defaultInstance; return defaultInstance;
} }
@Override
public LocalTimes getDefaultInstanceForType() { public LocalTimes getDefaultInstanceForType() {
return defaultInstance; return defaultInstance;
} }
public static final com.google.protobuf.Descriptors.Descriptor public static com.google.protobuf.Descriptors.Descriptor
getDescriptor() { getDescriptor() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTimes_descriptor; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTimes_descriptor;
} }
@Override
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTimes_fieldAccessorTable; return org.jboss.netty.example.localtime.LocalTimeProtocol.internal_static_org_jboss_netty_example_localtime_LocalTimes_fieldAccessorTable;
@ -1451,7 +1512,8 @@ public final class LocalTimeProtocol {
private void initFields() { private void initFields() {
} }
public final boolean isInitialized() { @Override
public boolean isInitialized() {
for (org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime element : getLocalTimeList()) { for (org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTime element : getLocalTimeList()) {
if (!element.isInitialized()) { if (!element.isInitialized()) {
return false; return false;
@ -1460,6 +1522,7 @@ public final class LocalTimeProtocol {
return true; return true;
} }
@Override
public void writeTo(com.google.protobuf.CodedOutputStream output) public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException { throws java.io.IOException {
getSerializedSize(); getSerializedSize();
@ -1470,6 +1533,7 @@ public final class LocalTimeProtocol {
} }
private int memoizedSerializedSize = -1; private int memoizedSerializedSize = -1;
@Override
public int getSerializedSize() { public int getSerializedSize() {
int size = memoizedSerializedSize; int size = memoizedSerializedSize;
if (size != -1) { if (size != -1) {
@ -1554,10 +1618,12 @@ public final class LocalTimeProtocol {
} }
public static Builder newBuilder() { return Builder.create(); } public static Builder newBuilder() { return Builder.create(); }
@Override
public Builder newBuilderForType() { return newBuilder(); } public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes prototype) { public static Builder newBuilder(org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes prototype) {
return newBuilder().mergeFrom(prototype); return newBuilder().mergeFrom(prototype);
} }
@Override
public Builder toBuilder() { return newBuilder(this); } public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends public static final class Builder extends
@ -1573,10 +1639,12 @@ public final class LocalTimeProtocol {
return builder; return builder;
} }
@Override
protected org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes internalGetResult() { protected org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes internalGetResult() {
return result; return result;
} }
@Override
public Builder clear() { public Builder clear() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -1586,22 +1654,27 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder clone() { public Builder clone() {
return create().mergeFrom(result); return create().mergeFrom(result);
} }
@Override
public com.google.protobuf.Descriptors.Descriptor public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() { getDescriptorForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes.getDescriptor(); return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes.getDescriptor();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes getDefaultInstanceForType() { public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes getDefaultInstanceForType() {
return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes.getDefaultInstance(); return org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes.getDefaultInstance();
} }
@Override
public boolean isInitialized() { public boolean isInitialized() {
return result.isInitialized(); return result.isInitialized();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes build() { public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes build() {
if (result != null && !isInitialized()) { if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result); throw newUninitializedMessageException(result);
@ -1618,6 +1691,7 @@ public final class LocalTimeProtocol {
return buildPartial(); return buildPartial();
} }
@Override
public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes buildPartial() { public org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes buildPartial() {
if (result == null) { if (result == null) {
throw new IllegalStateException( throw new IllegalStateException(
@ -1632,6 +1706,7 @@ public final class LocalTimeProtocol {
return returnMe; return returnMe;
} }
@Override
public Builder mergeFrom(com.google.protobuf.Message other) { public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes) { if (other instanceof org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes) {
return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes)other); return mergeFrom((org.jboss.netty.example.localtime.LocalTimeProtocol.LocalTimes)other);
@ -1655,6 +1730,7 @@ public final class LocalTimeProtocol {
return this; return this;
} }
@Override
public Builder mergeFrom( public Builder mergeFrom(
com.google.protobuf.CodedInputStream input, com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@ -1801,6 +1877,7 @@ public final class LocalTimeProtocol {
}; };
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
@Override
public com.google.protobuf.ExtensionRegistry assignDescriptors( public com.google.protobuf.ExtensionRegistry assignDescriptors(
com.google.protobuf.Descriptors.FileDescriptor root) { com.google.protobuf.Descriptors.FileDescriptor root) {
descriptor = root; descriptor = root;

2
src/main/java/org/jboss/netty/handler/codec/base64/Base64Dialect.java
View File

@ -203,7 +203,7 @@ public enum Base64Dialect {
final byte[] decodabet; final byte[] decodabet;
final boolean breakLinesByDefault; final boolean breakLinesByDefault;
private Base64Dialect(byte[] alphabet, byte[] decodabet, boolean breakLinesByDefault) { Base64Dialect(byte[] alphabet, byte[] decodabet, boolean breakLinesByDefault) {
this.alphabet = alphabet; this.alphabet = alphabet;
this.decodabet = decodabet; this.decodabet = decodabet;
this.breakLinesByDefault = breakLinesByDefault; this.breakLinesByDefault = breakLinesByDefault;

4
src/main/java/org/jboss/netty/handler/codec/http/HttpHeaderDateFormat.java
View File

@ -67,7 +67,7 @@ final class HttpHeaderDateFormat extends SimpleDateFormat {
* First obsolete format<p> * First obsolete format<p>
* Sunday, 06-Nov-94 08:49:37 GMT -> E, d-MMM-y HH:mm:ss z * Sunday, 06-Nov-94 08:49:37 GMT -> E, d-MMM-y HH:mm:ss z
*/ */
private final class HttpHeaderDateFormatObsolete1 extends SimpleDateFormat { private static final class HttpHeaderDateFormatObsolete1 extends SimpleDateFormat {
private static final long serialVersionUID = -3178072504225114298L; private static final long serialVersionUID = -3178072504225114298L;
HttpHeaderDateFormatObsolete1() { HttpHeaderDateFormatObsolete1() {
@ -81,7 +81,7 @@ final class HttpHeaderDateFormat extends SimpleDateFormat {
* <p> * <p>
* Sun Nov 6 08:49:37 1994 -> EEE, MMM d HH:mm:ss yyyy * Sun Nov 6 08:49:37 1994 -> EEE, MMM d HH:mm:ss yyyy
*/ */
private final class HttpHeaderDateFormatObsolete2 extends SimpleDateFormat { private static final class HttpHeaderDateFormatObsolete2 extends SimpleDateFormat {
private static final long serialVersionUID = 3010674519968303714L; private static final long serialVersionUID = 3010674519968303714L;
HttpHeaderDateFormatObsolete2() { HttpHeaderDateFormatObsolete2() {

2
src/main/java/org/jboss/netty/handler/codec/http/HttpMessageDecoder.java
View File

@ -124,7 +124,7 @@ public abstract class HttpMessageDecoder extends ReplayingDecoder<HttpMessageDec
* *
* @apiviz.exclude * @apiviz.exclude
*/ */
protected static enum State { protected enum State {
SKIP_CONTROL_CHARS, SKIP_CONTROL_CHARS,
READ_INITIAL, READ_INITIAL,
READ_HEADER, READ_HEADER,

6
src/main/java/org/jboss/netty/handler/codec/http/HttpPostBodyUtil.java
View File

@ -88,7 +88,7 @@ public class HttpPostBodyUtil {
Not allowed: "quoted-printable" Not allowed: "quoted-printable"
/ "base64" / "base64"
*/ */
public static enum TransferEncodingMechanism { public enum TransferEncodingMechanism {
/** /**
* Default encoding * Default encoding
*/ */
@ -104,11 +104,11 @@ public class HttpPostBodyUtil {
public String value; public String value;
private TransferEncodingMechanism(String value) { TransferEncodingMechanism(String value) {
this.value = value; this.value = value;
} }
private TransferEncodingMechanism() { TransferEncodingMechanism() {
value = name(); value = name();
} }

4
src/main/java/org/jboss/netty/handler/codec/http/HttpPostRequestDecoder.java
View File

@ -232,7 +232,7 @@ public class HttpPostRequestDecoder {
* @author frederic bregier * @author frederic bregier
* *
*/ */
private static enum MultiPartStatus { private enum MultiPartStatus {
NOTSTARTED, NOTSTARTED,
PREAMBLE, PREAMBLE,
HEADERDELIMITER, HEADERDELIMITER,
@ -1485,7 +1485,7 @@ public class HttpPostRequestDecoder {
* @author frederic bregier * @author frederic bregier
* *
*/ */
public class IncompatibleDataDecoderException extends Exception { public static class IncompatibleDataDecoderException extends Exception {
/** /**
* *
*/ */

1
src/main/java/org/jboss/netty/handler/codec/http/websocketx/UTF8Output.java
View File

@ -67,6 +67,7 @@ public class UTF8Output {
} }
} }
@Override
public String toString() { public String toString() {
if (state != UTF8_ACCEPT) { if (state != UTF8_ACCEPT) {
throw new UTF8Exception("bytes are not UTF-8"); throw new UTF8Exception("bytes are not UTF-8");

2
src/main/java/org/jboss/netty/handler/codec/http/websocketx/WebSocket08FrameDecoder.java
View File

@ -83,7 +83,7 @@ public class WebSocket08FrameDecoder extends ReplayingDecoder<WebSocket08FrameDe
private boolean maskedPayload = false; private boolean maskedPayload = false;
private boolean receivedClosingHandshake = false; private boolean receivedClosingHandshake = false;
public static enum State { public enum State {
FRAME_START, MASKING_KEY, PAYLOAD, CORRUPT FRAME_START, MASKING_KEY, PAYLOAD, CORRUPT
} }

2
src/main/java/org/jboss/netty/handler/codec/http/websocketx/WebSocketClientHandshaker10.java
View File

@ -49,7 +49,7 @@ public class WebSocketClientHandshaker10 extends WebSocketClientHandshaker {
private String expectedChallengeResponseString = null; private String expectedChallengeResponseString = null;
private final String protocol = null; private static final String protocol = null;
private boolean allowExtensions = false; private boolean allowExtensions = false;

12
src/main/java/org/jboss/netty/util/internal/ConcurrentHashMap.java
View File

@ -138,7 +138,7 @@ public final class ConcurrentHashMap<K, V> extends AbstractMap<K, V>
* @param hash the hash code for the key * @param hash the hash code for the key
* @return the segment * @return the segment
*/ */
final Segment<K, V> segmentFor(int hash) { Segment<K, V> segmentFor(int hash) {
return segments[hash >>> segmentShift & segmentMask]; return segments[hash >>> segmentShift & segmentMask];
} }
@ -173,21 +173,21 @@ public final class ConcurrentHashMap<K, V> extends AbstractMap<K, V>
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final K key() { K key() {
return (K) key; return (K) key;
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final V value() { V value() {
return (V) value; return (V) value;
} }
final void setValue(V value) { void setValue(V value) {
this.value = value; this.value = value;
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> HashEntry<K, V>[] newArray(int i) { static <K, V> HashEntry<K, V>[] newArray(int i) {
return new HashEntry[i]; return new HashEntry[i];
} }
} }
@ -273,7 +273,7 @@ public final class ConcurrentHashMap<K, V> extends AbstractMap<K, V>
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> Segment<K, V>[] newArray(int i) { static <K, V> Segment<K, V>[] newArray(int i) {
return new Segment[i]; return new Segment[i];
} }

12
src/main/java/org/jboss/netty/util/internal/ConcurrentIdentityHashMap.java
View File

@ -138,7 +138,7 @@ public final class ConcurrentIdentityHashMap<K, V> extends AbstractMap<K, V>
* @param hash the hash code for the key * @param hash the hash code for the key
* @return the segment * @return the segment
*/ */
final Segment<K, V> segmentFor(int hash) { Segment<K, V> segmentFor(int hash) {
return segments[hash >>> segmentShift & segmentMask]; return segments[hash >>> segmentShift & segmentMask];
} }
@ -173,21 +173,21 @@ public final class ConcurrentIdentityHashMap<K, V> extends AbstractMap<K, V>
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final K key() { K key() {
return (K) key; return (K) key;
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final V value() { V value() {
return (V) value; return (V) value;
} }
final void setValue(V value) { void setValue(V value) {
this.value = value; this.value = value;
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> HashEntry<K, V>[] newArray(int i) { static <K, V> HashEntry<K, V>[] newArray(int i) {
return new HashEntry[i]; return new HashEntry[i];
} }
} }
@ -273,7 +273,7 @@ public final class ConcurrentIdentityHashMap<K, V> extends AbstractMap<K, V>
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> Segment<K, V>[] newArray(int i) { static <K, V> Segment<K, V>[] newArray(int i) {
return new Segment[i]; return new Segment[i];
} }

20
src/main/java/org/jboss/netty/util/internal/ConcurrentIdentityWeakKeyHashMap.java
View File

@ -145,7 +145,7 @@ public final class ConcurrentIdentityWeakKeyHashMap<K, V> extends AbstractMap<K,
* @param hash the hash code for the key * @param hash the hash code for the key
* @return the segment * @return the segment
*/ */
final Segment<K, V> segmentFor(int hash) { Segment<K, V> segmentFor(int hash) {
return segments[hash >>> segmentShift & segmentMask]; return segments[hash >>> segmentShift & segmentMask];
} }
@ -167,11 +167,11 @@ public final class ConcurrentIdentityWeakKeyHashMap<K, V> extends AbstractMap<K,
this.hash = hash; this.hash = hash;
} }
public final int keyHash() { public int keyHash() {
return hash; return hash;
} }
public final Object keyRef() { public Object keyRef() {
return this; return this;
} }
} }
@ -204,16 +204,16 @@ public final class ConcurrentIdentityWeakKeyHashMap<K, V> extends AbstractMap<K,
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final K key() { K key() {
return ((WeakReference<K>) keyRef).get(); return ((WeakReference<K>) keyRef).get();
} }
final V value() { V value() {
return dereferenceValue(valueRef); return dereferenceValue(valueRef);
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final V dereferenceValue(Object value) { V dereferenceValue(Object value) {
if (value instanceof WeakKeyReference) { if (value instanceof WeakKeyReference) {
return ((Reference<V>) value).get(); return ((Reference<V>) value).get();
} }
@ -221,12 +221,12 @@ public final class ConcurrentIdentityWeakKeyHashMap<K, V> extends AbstractMap<K,
return (V) value; return (V) value;
} }
final void setValue(V value) { void setValue(V value) {
this.valueRef = value; this.valueRef = value;
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> HashEntry<K, V>[] newArray(int i) { static <K, V> HashEntry<K, V>[] newArray(int i) {
return new HashEntry[i]; return new HashEntry[i];
} }
} }
@ -318,7 +318,7 @@ public final class ConcurrentIdentityWeakKeyHashMap<K, V> extends AbstractMap<K,
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> Segment<K, V>[] newArray(int i) { static <K, V> Segment<K, V>[] newArray(int i) {
return new Segment[i]; return new Segment[i];
} }
@ -618,7 +618,7 @@ public final class ConcurrentIdentityWeakKeyHashMap<K, V> extends AbstractMap<K,
} }
@SuppressWarnings("rawtypes") @SuppressWarnings("rawtypes")
final void removeStale() { void removeStale() {
WeakKeyReference ref; WeakKeyReference ref;
while ((ref = (WeakKeyReference) refQueue.poll()) != null) { while ((ref = (WeakKeyReference) refQueue.poll()) != null) {
remove(ref.keyRef(), ref.keyHash(), null, true); remove(ref.keyRef(), ref.keyHash(), null, true);

20
src/main/java/org/jboss/netty/util/internal/ConcurrentWeakKeyHashMap.java
View File

@ -145,7 +145,7 @@ public final class ConcurrentWeakKeyHashMap<K, V> extends AbstractMap<K, V> impl
* @param hash the hash code for the key * @param hash the hash code for the key
* @return the segment * @return the segment
*/ */
final Segment<K, V> segmentFor(int hash) { Segment<K, V> segmentFor(int hash) {
return segments[hash >>> segmentShift & segmentMask]; return segments[hash >>> segmentShift & segmentMask];
} }
@ -167,11 +167,11 @@ public final class ConcurrentWeakKeyHashMap<K, V> extends AbstractMap<K, V> impl
this.hash = hash; this.hash = hash;
} }
public final int keyHash() { public int keyHash() {
return hash; return hash;
} }
public final Object keyRef() { public Object keyRef() {
return this; return this;
} }
} }
@ -204,16 +204,16 @@ public final class ConcurrentWeakKeyHashMap<K, V> extends AbstractMap<K, V> impl
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final K key() { K key() {
return ((WeakReference<K>) keyRef).get(); return ((WeakReference<K>) keyRef).get();
} }
final V value() { V value() {
return dereferenceValue(valueRef); return dereferenceValue(valueRef);
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
final V dereferenceValue(Object value) { V dereferenceValue(Object value) {
if (value instanceof WeakKeyReference) { if (value instanceof WeakKeyReference) {
return ((Reference<V>) value).get(); return ((Reference<V>) value).get();
} }
@ -221,12 +221,12 @@ public final class ConcurrentWeakKeyHashMap<K, V> extends AbstractMap<K, V> impl
return (V) value; return (V) value;
} }
final void setValue(V value) { void setValue(V value) {
this.valueRef = value; this.valueRef = value;
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> HashEntry<K, V>[] newArray(int i) { static <K, V> HashEntry<K, V>[] newArray(int i) {
return new HashEntry[i]; return new HashEntry[i];
} }
} }
@ -318,7 +318,7 @@ public final class ConcurrentWeakKeyHashMap<K, V> extends AbstractMap<K, V> impl
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
static final <K, V> Segment<K, V>[] newArray(int i) { static <K, V> Segment<K, V>[] newArray(int i) {
return new Segment[i]; return new Segment[i];
} }
@ -618,7 +618,7 @@ public final class ConcurrentWeakKeyHashMap<K, V> extends AbstractMap<K, V> impl
} }
@SuppressWarnings("rawtypes") @SuppressWarnings("rawtypes")
final void removeStale() { void removeStale() {
WeakKeyReference ref; WeakKeyReference ref;
while ((ref = (WeakKeyReference) refQueue.poll()) != null) { while ((ref = (WeakKeyReference) refQueue.poll()) != null) {
remove(ref.keyRef(), ref.keyHash(), null, true); remove(ref.keyRef(), ref.keyHash(), null, true);

22
src/main/java/org/jboss/netty/util/internal/LinkedTransferQueue.java
View File

@ -437,7 +437,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
volatile Thread waiter; // null until waiting volatile Thread waiter; // null until waiting
// CAS methods for fields // CAS methods for fields
final boolean casNext(Node cmp, Node val) { boolean casNext(Node cmp, Node val) {
if (AtomicFieldUpdaterUtil.isAvailable()) { if (AtomicFieldUpdaterUtil.isAvailable()) {
return nextUpdater.compareAndSet(this, cmp, val); return nextUpdater.compareAndSet(this, cmp, val);
} else { } else {
@ -452,7 +452,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
} }
} }
final boolean casItem(Object cmp, Object val) { boolean casItem(Object cmp, Object val) {
// assert cmp == null || cmp.getClass() != Node.class; // assert cmp == null || cmp.getClass() != Node.class;
if (AtomicFieldUpdaterUtil.isAvailable()) { if (AtomicFieldUpdaterUtil.isAvailable()) {
return itemUpdater.compareAndSet(this, cmp, val); return itemUpdater.compareAndSet(this, cmp, val);
@ -481,7 +481,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
* Links node to itself to avoid garbage retention. Called * Links node to itself to avoid garbage retention. Called
* only after CASing head field, so uses relaxed write. * only after CASing head field, so uses relaxed write.
*/ */
final void forgetNext() { void forgetNext() {
this.next = this; this.next = this;
} }
@ -494,7 +494,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
* follows either CAS or return from park (if ever parked; * follows either CAS or return from park (if ever parked;
* else we don't care). * else we don't care).
*/ */
final void forgetContents() { void forgetContents() {
this.item = this; this.item = this;
this.waiter = null; this.waiter = null;
} }
@ -503,7 +503,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
* Returns true if this node has been matched, including the * Returns true if this node has been matched, including the
* case of artificial matches due to cancellation. * case of artificial matches due to cancellation.
*/ */
final boolean isMatched() { boolean isMatched() {
Object x = item; Object x = item;
return x == this || x == null == isData; return x == this || x == null == isData;
} }
@ -511,7 +511,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
/** /**
* Returns true if this is an unmatched request node. * Returns true if this is an unmatched request node.
*/ */
final boolean isUnmatchedRequest() { boolean isUnmatchedRequest() {
return !isData && item == null; return !isData && item == null;
} }
@ -520,7 +520,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
* appended to this node because this node is unmatched and * appended to this node because this node is unmatched and
* has opposite data mode. * has opposite data mode.
*/ */
final boolean cannotPrecede(boolean haveData) { boolean cannotPrecede(boolean haveData) {
boolean d = isData; boolean d = isData;
Object x; Object x;
return d != haveData && (x = item) != this && x != null == d; return d != haveData && (x = item) != this && x != null == d;
@ -529,7 +529,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
/** /**
* Tries to artificially match a data node -- used by remove. * Tries to artificially match a data node -- used by remove.
*/ */
final boolean tryMatchData() { boolean tryMatchData() {
// assert isData; // assert isData;
Object x = item; Object x = item;
if (x != null && x != this && casItem(x, null)) { if (x != null && x != this && casItem(x, null)) {
@ -895,12 +895,12 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
} }
@Override @Override
public final boolean hasNext() { public boolean hasNext() {
return nextNode != null; return nextNode != null;
} }
@Override @Override
public final E next() { public E next() {
Node p = nextNode; Node p = nextNode;
if (p == null) { if (p == null) {
throw new NoSuchElementException(); throw new NoSuchElementException();
@ -911,7 +911,7 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
} }
@Override @Override
public final void remove() { public void remove() {
Node p = lastRet; Node p = lastRet;
if (p == null) { if (p == null) {
throw new IllegalStateException(); throw new IllegalStateException();

6
src/main/java/org/jboss/netty/util/internal/NonReentrantLock.java
View File

@ -68,7 +68,7 @@ public final class NonReentrantLock extends AbstractQueuedSynchronizer
} }
@Override @Override
protected final boolean tryAcquire(int acquires) { protected boolean tryAcquire(int acquires) {
if (compareAndSetState(0, 1)) { if (compareAndSetState(0, 1)) {
owner = Thread.currentThread(); owner = Thread.currentThread();
return true; return true;
@ -77,7 +77,7 @@ public final class NonReentrantLock extends AbstractQueuedSynchronizer
} }
@Override @Override
protected final boolean tryRelease(int releases) { protected boolean tryRelease(int releases) {
if (Thread.currentThread() != owner) { if (Thread.currentThread() != owner) {
throw new IllegalMonitorStateException(); throw new IllegalMonitorStateException();
} }
@ -87,7 +87,7 @@ public final class NonReentrantLock extends AbstractQueuedSynchronizer
} }
@Override @Override
protected final boolean isHeldExclusively() { protected boolean isHeldExclusively() {
return getState() != 0 && owner == Thread.currentThread(); return getState() != 0 && owner == Thread.currentThread();
} }
} }

2
src/main/java/org/jboss/netty/util/internal/jzlib/JZlib.java
View File

@ -103,7 +103,7 @@ public final class JZlib {
// Bit length codes must not exceed MAX_BL_BITS bits // Bit length codes must not exceed MAX_BL_BITS bits
static final int MAX_BL_BITS = 7; static final int MAX_BL_BITS = 7;
static enum WrapperType { enum WrapperType {
NONE, ZLIB, GZIP, ZLIB_OR_NONE; NONE, ZLIB, GZIP, ZLIB_OR_NONE;
} }
} }

2
src/test/java/org/jboss/netty/channel/socket/AbstractSocketEchoTest.java
View File

@ -147,7 +147,7 @@ public abstract class AbstractSocketEchoTest {
} }
} }
private class EchoHandler extends SimpleChannelUpstreamHandler { private static class EchoHandler extends SimpleChannelUpstreamHandler {
volatile Channel channel; volatile Channel channel;
final AtomicReference<Throwable> exception = new AtomicReference<Throwable>(); final AtomicReference<Throwable> exception = new AtomicReference<Throwable>();
volatile int counter; volatile int counter;

2
src/test/java/org/jboss/netty/handler/codec/frame/AbstractSocketFixedLengthEchoTest.java
View File

@ -149,7 +149,7 @@ public abstract class AbstractSocketFixedLengthEchoTest {
} }
} }
private class EchoHandler extends SimpleChannelUpstreamHandler { private static class EchoHandler extends SimpleChannelUpstreamHandler {
volatile Channel channel; volatile Channel channel;
final AtomicReference<Throwable> exception = new AtomicReference<Throwable>(); final AtomicReference<Throwable> exception = new AtomicReference<Throwable>();
volatile int counter; volatile int counter;

2
src/test/java/org/jboss/netty/handler/codec/serialization/AbstractSocketCompatibleObjectStreamEchoTest.java
View File

@ -157,7 +157,7 @@ public abstract class AbstractSocketCompatibleObjectStreamEchoTest {
} }
} }
private class EchoHandler extends SimpleChannelUpstreamHandler { private static class EchoHandler extends SimpleChannelUpstreamHandler {
volatile Channel channel; volatile Channel channel;
final AtomicReference<Throwable> exception = new AtomicReference<Throwable>(); final AtomicReference<Throwable> exception = new AtomicReference<Throwable>();
volatile int counter; volatile int counter;

2
src/test/java/org/jboss/netty/handler/codec/serialization/AbstractSocketObjectStreamEchoTest.java
View File

@ -156,7 +156,7 @@ public abstract class AbstractSocketObjectStreamEchoTest {
} }
} }
private class EchoHandler extends SimpleChannelUpstreamHandler { private static class EchoHandler extends SimpleChannelUpstreamHandler {
volatile Channel channel; volatile Channel channel;
final AtomicReference<Throwable> exception = new AtomicReference<Throwable>(); final AtomicReference<Throwable> exception = new AtomicReference<Throwable>();
volatile int counter; volatile int counter;

2
src/test/java/org/jboss/netty/handler/codec/string/AbstractSocketStringEchoTest.java
View File

@ -162,7 +162,7 @@ public abstract class AbstractSocketStringEchoTest {
} }
} }
private class EchoHandler extends SimpleChannelUpstreamHandler { private static class EchoHandler extends SimpleChannelUpstreamHandler {
volatile Channel channel; volatile Channel channel;
final AtomicReference<Throwable> exception = new AtomicReference<Throwable>(); final AtomicReference<Throwable> exception = new AtomicReference<Throwable>();
volatile int counter; volatile int counter;

2
src/test/java/org/jboss/netty/handler/ssl/AbstractSocketSslEchoTest.java
View File

@ -194,7 +194,7 @@ public abstract class AbstractSocketSslEchoTest {
} }
} }
private class EchoHandler extends SimpleChannelUpstreamHandler { private static class EchoHandler extends SimpleChannelUpstreamHandler {
volatile Channel channel; volatile Channel channel;
final AtomicReference<Throwable> exception = new AtomicReference<Throwable>(); final AtomicReference<Throwable> exception = new AtomicReference<Throwable>();
volatile int counter; volatile int counter;