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

Remove the usage of AtomicLong as this only confuse users. The Handler

Browse Source 
is not suited for re-use anyway. See #93
This commit is contained in:
norman 2011-12-01 09:39:48 +01:00
parent 47af6bc9e8
commit 2a0a63e1bb
2 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/jboss/netty/example/discard/DiscardClientHandler.java
View File

@ -15,7 +15,6 @@
*/
package org.jboss.netty.example.discard;
import java.util.concurrent.atomic.AtomicLong;
import java.util.logging.Level;
import java.util.logging.Logger;
@ -44,7 +43,7 @@ public class DiscardClientHandler extends SimpleChannelUpstreamHandler {
private static final Logger logger = Logger.getLogger(
DiscardClientHandler.class.getName());
private final AtomicLong transferredBytes = new AtomicLong();
private long transferredBytes = 0;
private final byte[] content;
public DiscardClientHandler(int messageSize) {
@ -56,7 +55,7 @@ public class DiscardClientHandler extends SimpleChannelUpstreamHandler {
}
public long getTransferredBytes() {
return transferredBytes.get();
return transferredBytes;
}
@Override
@ -90,7 +89,7 @@ public class DiscardClientHandler extends SimpleChannelUpstreamHandler {
@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) {
transferredBytes.addAndGet(e.getWrittenAmount());
transferredBytes =+e.getWrittenAmount();
}
@Override

7
src/main/java/org/jboss/netty/example/discard/DiscardServerHandler.java
View File

@ -15,7 +15,6 @@
*/
package org.jboss.netty.example.discard;
import java.util.concurrent.atomic.AtomicLong;
import java.util.logging.Level;
import java.util.logging.Logger;
@ -40,10 +39,10 @@ public class DiscardServerHandler extends SimpleChannelUpstreamHandler {
private static final Logger logger = Logger.getLogger(
DiscardServerHandler.class.getName());
private final AtomicLong transferredBytes = new AtomicLong();
private long transferredBytes = 0;
public long getTransferredBytes() {
return transferredBytes.get();
return transferredBytes;
}
@Override
@ -59,7 +58,7 @@ public class DiscardServerHandler extends SimpleChannelUpstreamHandler {
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
// Discard received data silently by doing nothing.
transferredBytes.addAndGet(((ChannelBuffer) e.getMessage()).readableBytes());
transferredBytes += (((ChannelBuffer) e.getMessage()).readableBytes());
}
@Override