Skip to content

Commit

Permalink
[netty#4327] Ensure toString() will not throw IllegalReferenceCountEx…
Browse files Browse the repository at this point in the history
…ception

Motivation:

As toString() is often used while logging we need to ensure this produces no exception.

Modifications:

Ensure we never throw an IllegalReferenceCountException.

Result:

Be able to log without produce exceptions.
  • Loading branch information
normanmaurer committed Oct 10, 2015
1 parent f2a3e77 commit 9faf4c9
Show file tree
Hide file tree
Showing 4 changed files with 45 additions and 12 deletions.
10 changes: 9 additions & 1 deletion buffer/src/main/java/io/netty/buffer/DefaultByteBufHolder.java
Original file line number Diff line number Diff line change
Expand Up @@ -90,8 +90,16 @@ public boolean release(int decrement) {
return data.release(decrement);
}

/**
* Return {@link ByteBuf#toString()} without checking the reference count first. This is useful to implemement
* {@link #toString()}.
*/
protected final String contentToString() {
return data.toString();
}

@Override
public String toString() {
return StringUtil.simpleClassName(this) + '(' + content().toString() + ')';
return StringUtil.simpleClassName(this) + '(' + contentToString() + ')';
}
}
32 changes: 32 additions & 0 deletions buffer/src/test/java/io/netty/buffer/DefaultByteBufHolderTest.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,32 @@
/*
* Copyright 2015 The Netty Project
*
* The Netty Project licenses this file to you under the Apache License,
* version 2.0 (the "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations
* under the License.
*/
package io.netty.buffer;

import org.junit.Test;

import static org.junit.Assert.*;

public class DefaultByteBufHolderTest {

@Test
public void testToString() {
ByteBufHolder holder = new DefaultByteBufHolder(Unpooled.buffer());
assertEquals(1, holder.refCnt());
assertNotNull(holder.toString());
assertTrue(holder.release());
assertNotNull(holder.toString());
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ public int rsv() {

@Override
public String toString() {
return StringUtil.simpleClassName(this) + "(data: " + content() + ')';
return StringUtil.simpleClassName(this) + "(data: " + contentToString() + ')';
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

import com.sun.nio.sctp.MessageInfo;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufUtil;
import io.netty.buffer.DefaultByteBufHolder;

/**
Expand Down Expand Up @@ -191,15 +190,9 @@ public SctpMessage touch(Object hint) {

@Override
public String toString() {
if (refCnt() == 0) {
return "SctpFrame{" +
"streamIdentifier=" + streamIdentifier + ", protocolIdentifier=" + protocolIdentifier +
", unordered=" + unordered +
", data=(FREED)}";
}
return "SctpFrame{" +
"streamIdentifier=" + streamIdentifier + ", protocolIdentifier=" + protocolIdentifier +
", unordered=" + unordered +
", data=" + ByteBufUtil.hexDump(content()) + '}';
"streamIdentifier=" + streamIdentifier + ", protocolIdentifier=" + protocolIdentifier +
", unordered=" + unordered +
", data=" + contentToString() + '}';
}
}

0 comments on commit 9faf4c9

Please sign in to comment.