Commit Graph

257 Commits

Author SHA1 Message Date
Trustin Lee
cee920f3b8 Workaround for the bogus FindBugs warning in ReplayingDecoderBuffer 2008-11-07 02:41:29 +00:00
Trustin Lee
f73de01a68 Doesn't need to reject ReplayingDecoderBuffer.equals() 2008-11-07 02:36:57 +00:00
Trustin Lee
34b9b00723 Fixed a potential concurrency issue in DefaultChannelFuture.notifyListeners(), as advised by FindBugs 2008-11-07 02:35:04 +00:00
Trustin Lee
81d29bafc2 Fixed warnings reported by FindBugs 2008-11-07 02:26:21 +00:00
Trustin Lee
9d35088801 & -> && 2008-11-07 02:10:44 +00:00
Trustin Lee
d8cd49c1b7 Fixed a warning reported by FindBugs in CompositeChannelBuffer 2008-11-07 02:08:36 +00:00
Trustin Lee
33187d0285 Fixed issue: NETTY-62 ChannelBuffers.EMPTY_BUFFER is not final 2008-11-07 02:05:09 +00:00
Trustin Lee
3a2a7a3a3c Made sure NioWorker.cleanUpWriteBuffer() is called even if the worker thread is not running. 2008-11-07 02:00:07 +00:00
Trustin Lee
ea1a68cb83 Made sure that NioWorker.wakenUp is set to true only when its selector is really waken up 2008-11-06 17:31:07 +00:00
Trustin Lee
22f33539c1 Fixed a problem where NPE is thrown when NioWorker.write() is called too early 2008-11-06 15:01:08 +00:00
Trustin Lee
85e63a2c98 Potential fix for NPE during SocketChannel.register(..) 2008-11-06 12:56:45 +00:00
Trustin Lee
59abaa1657 Tiny code cleanup 2008-11-06 11:41:01 +00:00
Trustin Lee
00ec5be6dd Fixed a bug where NioWorker.register() hangs up with high CPU consumption when it failed to open a selector. 2008-11-06 11:39:17 +00:00
Trustin Lee
7f1ff668f7 Fixed a bug where NioWorker.register() hangs up with high CPU consumption when it failed to open a selector. 2008-11-06 11:19:48 +00:00
Trustin Lee
486218ab28 Potential fix for NPE during SocketChannel.register(..) 2008-11-06 10:55:56 +00:00
Trustin Lee
b15fe51e95 RegisterTask should be a static class. 2008-11-06 08:49:00 +00:00
Trustin Lee
87b4f886a6 Code cleanup 2008-10-06 13:25:27 +00:00
Trustin Lee
dddf14f79a Fixed a bug: NETTY-56 (The ChannFuture returned by SslHandler.handshake() is not completed when the associated Channel is closed during handshake.) 2008-10-03 02:53:57 +00:00
Trustin Lee
8f9769f8e9 Removed unnecessary links 2008-10-02 05:02:46 +00:00
Trustin Lee
5120c1172c Simplfied the factorial example using the new SimpleChannelHandler 2008-10-02 04:44:06 +00:00
Trustin Lee
ca1f11ff67 Forgot to add the 'throws' clause 2008-10-02 04:43:02 +00:00
Trustin Lee
da04e2cae9 Fixed issue: NETTY-54 (Improve SimpleChannelHandler to implement ChannelDownstreamHandler)
Fixed issue: NETTY-55 (Channel.unbind() method is missing.)
2008-10-02 04:40:46 +00:00
Trustin Lee
6c2230aac2 Swallow AsynchronousCloseException 2008-10-01 13:14:28 +00:00
Trustin Lee
4376cd5a91 Fixed a bug: NETTY-53 (ClassNotFoundException when an ObjectDecoder with no ClassLoader specified tries to decode an object.)
* Explicitly acquired the current thread's context class loader if a user specified no or null class loader.
2008-10-01 11:06:18 +00:00
Trustin Lee
8d5d8fd172 Fixed another race condition which occurs when OP_WRITE and OP_READ flags are set/cleared at the same time 2008-10-01 08:42:26 +00:00
Trustin Lee
cfa6794292 Potential fix for NETTY-52 (IllegalArgumentException when trying to change the current interestOps) 2008-10-01 05:25:01 +00:00
Trustin Lee
dae3b05ebb Replaced FastQueue with LinkedTransferQueue 2008-10-01 04:49:10 +00:00
Trustin Lee
6d372c367b Added LinkedTransferQueue 2008-10-01 03:18:36 +00:00
Trustin Lee
2f4e20ce7a Made more generic 2008-09-30 14:23:38 +00:00
Trustin Lee
44c409ca24 More accurate default receive buffer size predictor implementation 2008-09-30 13:02:41 +00:00
Trustin Lee
0831b32090 Decreased the default maximum receive buffer size to 64KiB - it's enough for more cases. 2008-09-30 06:29:16 +00:00
Trustin Lee
950a386d3f Code cleanup 2008-09-30 01:53:24 +00:00
Trustin Lee
7de92967c2 Made MemoryAwareThreadPoolExecutor.shouldCount() extensible 2008-09-30 01:52:02 +00:00
Trustin Lee
85dc8f93f5 Fixed a bug where per-channel memory limitation didn't work correctly 2008-09-30 01:49:22 +00:00
Trustin Lee
8c15102bc3 Fixed issue NETTY-51 (MemoryAwareThreadPoolExecutor and its subtypes should use long instead of int to store the counters) 2008-09-30 00:42:04 +00:00
Trustin Lee
6f18c940dd Fixed issue NETTY-50 (Dead lock in MemoryAwareThreadPoolExecutor)
* Made sure that the max memory size properties become immutable
2008-09-30 00:31:32 +00:00
Trustin Lee
50f043fa3e Fixed issue NETTY-50 (Dead lock in MemoryAwareThreadPoolExecutor)
* Fixed incorrect release condition
2008-09-30 00:16:42 +00:00
Trustin Lee
d7c53437e9 Fixed errors in JavaDoc about OIO-based transport shutdown 2008-09-29 06:51:41 +00:00
Trustin Lee
8fb2f7c789 It's actually enough with a simple shutdown lock because we have only one acceptor thread. 2008-09-28 15:07:47 +00:00
Trustin Lee
dccc9f8665 * Improved the throughput of the server-side accept operation
* Added FastQueue.isEmpty()
2008-09-28 15:01:21 +00:00
Trustin Lee
4d17db6eb1 Using LinkedList seems to yield same or better performance 2008-09-28 14:21:38 +00:00
Trustin Lee
40b1f26c34 Made sure all segments are evaluated on poll for potentially better throughput (still proof-of-concept - getting better) 2008-09-28 14:12:28 +00:00
Trustin Lee
597cbd870c Isolated unchecked cast warning from FastQueue.poll() 2008-09-28 13:57:17 +00:00
Trustin Lee
6611563c8c Fixed a race condition in FastQueue 2008-09-28 13:52:49 +00:00
Trustin Lee
5170838e79 Added direct buffer support (disabled by default and can't be enabled without recompilation for now - should be fixed in 3.1.) 2008-09-28 12:51:50 +00:00
Trustin Lee
b64124efd6 * Renamed WriteMessageQueue to FastQueue, made it generic and optimized it
* Added ConcurrentFastQueue (proof of concept yet - slow)
2008-09-27 14:22:52 +00:00
Trustin Lee
a0d132a4d8 Moved WriteMessageQueue to the util package 2008-09-27 11:53:00 +00:00
Trustin Lee
f2c1734636 Reduced contention between I/O thread and writer 2008-09-26 12:28:09 +00:00
Trustin Lee
90ea9aa047 Formatting 2008-09-26 09:05:41 +00:00
Trustin Lee
362ecf640b Fixed a bug where DiscardClient didn't work since the last optimization 2008-09-26 09:04:02 +00:00