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

Reduce the cost of throwing a SeekAheadNoBackArrayException

Browse Source
This commit is contained in:
Trustin Lee 2012-05-30 17:37:12 -07:00
parent f799c9f215
commit d6cedb008b
1 changed files with 28 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
codec-http/src/main/java/io/netty/handler/codec/http/HttpPostBodyUtil.java
View File

@ -15,11 +15,11 @@
*/
package io.netty.handler.codec.http;
import java.nio.charset.Charset;
import io.netty.buffer.ChannelBuffer;
import io.netty.util.CharsetUtil;
import java.nio.charset.Charset;
/**
* Shared Static object between HttpMessageDecoder, HttpPostRequestDecoder and HttpPostRequestEncoder
*/
@ -118,13 +118,25 @@ final class HttpPostBodyUtil {
/**
* Exception when NO Backend Array is found
*/
*/
static class SeekAheadNoBackArrayException extends Exception {
static final SeekAheadNoBackArrayException INSTANCE = new SeekAheadNoBackArrayException();
private static final long serialVersionUID = -630418804938699495L;
private SeekAheadNoBackArrayException() {
// Hide
}
@Override
public Throwable fillInStackTrace() {
return this;
}
}
/**
* This class intends to decrease the CPU in seeking ahead some bytes in
* This class intends to decrease the CPU in seeking ahead some bytes in
* HttpPostRequestDecoder
*/
static class SeekAheadOptimize {
@ -144,30 +156,30 @@ final class HttpPostBodyUtil {
SeekAheadOptimize(ChannelBuffer buffer)
throws SeekAheadNoBackArrayException {
if (! buffer.hasArray()) {
throw new SeekAheadNoBackArrayException();
throw SeekAheadNoBackArrayException.INSTANCE;
}
this.buffer = buffer;
this.bytes = buffer.array();
this.pos = this.readerIndex = buffer.readerIndex();
this.limit = buffer.writerIndex();
bytes = buffer.array();
pos = readerIndex = buffer.readerIndex();
limit = buffer.writerIndex();
}
/**
*
*
* @param minus this value will be used as (currentPos - minus) to set
* the current readerIndex in the buffer.
* the current readerIndex in the buffer.
*/
void setReadPosition(int minus) {
pos -= minus;
readerIndex = pos;
buffer.readerIndex(readerIndex);
}
void clear() {
this.buffer = null;
this.bytes = null;
this.limit = 0;
this.pos = 0;
this.readerIndex = 0;
buffer = null;
bytes = null;
limit = 0;
pos = 0;
readerIndex = 0;
}
}