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

Remove unused type

Browse Source
This commit is contained in:
Trustin Lee 2012-06-12 18:09:05 +09:00
parent fdb66b6294
commit dfce95dd5a
3 changed files with 0 additions and 181 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

89
handler/src/main/java/io/netty/handler/ssl/DefaultSslBufferPool.java
View File

@ -1,89 +0,0 @@
/*
* Copyright 2012 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.handler.ssl;
import java.nio.ByteBuffer;
public class DefaultSslBufferPool implements SslBufferPool {
private static final int DEFAULT_POOL_SIZE = MAX_PACKET_SIZE * 1024;
private final ByteBuffer[] pool;
private final int maxBufferCount;
private int index;
/**
* Creates a new buffer pool whose size is {@code 18113536}, which can
* hold {@code 1024} buffers.
*/
public DefaultSslBufferPool() {
this(DEFAULT_POOL_SIZE);
}
/**
* Creates a new buffer pool.
*
* @param maxPoolSize the maximum number of bytes that this pool can hold
*/
public DefaultSslBufferPool(int maxPoolSize) {
if (maxPoolSize <= 0) {
throw new IllegalArgumentException("maxPoolSize: " + maxPoolSize);
}
int maxBufferCount = maxPoolSize / MAX_PACKET_SIZE;
if (maxPoolSize % MAX_PACKET_SIZE != 0) {
maxBufferCount ++;
}
pool = new ByteBuffer[maxBufferCount];
this.maxBufferCount = maxBufferCount;
}
/**
* Returns the maximum size of this pool in byte unit. The returned value
* can be somewhat different from what was specified in the constructor.
*/
public int getMaxPoolSize() {
return maxBufferCount * MAX_PACKET_SIZE;
}
/**
* Returns the number of bytes which were allocated but have not been
* acquired yet. You can estimate how optimal the specified maximum pool
* size is from this value. If it keeps returning {@code 0}, it means the
* pool is getting exhausted. If it keeps returns a unnecessarily big
* value, it means the pool is wasting the heap space.
*/
public synchronized int getUnacquiredPoolSize() {
return index * MAX_PACKET_SIZE;
}
@Override
public synchronized ByteBuffer acquireBuffer() {
if (index == 0) {
return ByteBuffer.allocate(MAX_PACKET_SIZE);
} else {
return (ByteBuffer) pool[-- index].clear();
}
}
@Override
public synchronized void releaseBuffer(ByteBuffer buffer) {
if (index < maxBufferCount) {
pool[index ++] = buffer;
}
}
}

50
handler/src/main/java/io/netty/handler/ssl/SslBufferPool.java
View File

@ -1,50 +0,0 @@
/*
* Copyright 2012 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.handler.ssl;
import java.nio.ByteBuffer;
import javax.net.ssl.SSLEngine;
/**
* A {@link ByteBuffer} pool dedicated for {@link SslHandler} performance
* improvement.
*
* The reason why {@link SslHandler} requires a buffer pool is because the
* current {@link SSLEngine} implementation always requires a 17KiB buffer for
* every 'wrap' and 'unwrap' operation. In most cases, the actual size of the
* required buffer is much smaller than that, and therefore allocating a 17KiB
* buffer for every 'wrap' and 'unwrap' operation wastes a lot of memory
* bandwidth, resulting in the application performance degradation.
*/
public interface SslBufferPool {
// Returned buffers must be large enough to accomodate the maximum SSL record size.
// Header (5) + Data (2^14) + Compression (1024) + Encryption (1024) + MAC (20) + Padding (256)
int MAX_PACKET_SIZE = 18713;
/**
* Acquire a new {@link ByteBuffer} out of the {@link SslBufferPool}
*/
ByteBuffer acquireBuffer();
/**
* Release a previously acquired {@link ByteBuffer}
*
* @param buffer
*/
void releaseBuffer(ByteBuffer buffer);
}

42
transport/src/main/java/io/netty/channel/IllegalBufferAccessException.java
View File

@ -1,42 +0,0 @@
/*
* Copyright 2012 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.channel;
public class IllegalBufferAccessException extends ChannelPipelineException {
private static final long serialVersionUID = -1313647533364810258L;
private static final String DEFAULT_MESSAGE =
"The buffers that belong to a " + ChannelHandlerContext.class.getSimpleName() +
" must be accessed from the thread of the associated " +
EventExecutor.class.getSimpleName() + ".";
public IllegalBufferAccessException() {
this(DEFAULT_MESSAGE);
}
public IllegalBufferAccessException(String message, Throwable cause) {
super(message, cause);
}
public IllegalBufferAccessException(String message) {
super(message);
}
public IllegalBufferAccessException(Throwable cause) {
super(cause);
}
}