Commit Graph

3071 Commits

Author SHA1 Message Date
Norman Maurer
b6abefb5b8 Add a replace(..) method to FrameDecoder and also to ReplayDecoder as it now extend FrameDecoder. This also fix #332 2012-05-19 17:08:45 +02:00
Frédéric Brégier
5e48c50589 Merge pull request #346 from fredericBregier/master
Proposal to fix 1rst issue presented in #345
2012-05-19 07:56:38 -07:00
Norman Maurer
3ca2a53e91 Add a replace(..) method to FrameDecoder and also to ReplayDecoder as it now extend FrameDecoder. This also fix #332 2012-05-19 16:35:22 +02:00
Frédéric Brégier
bc540d5ee1 Proposal for fix related to 1rst issue of #345
=> in configure (newcheckInterval/10)*10
(see http://www.javamex.com/tutorials/threads/sleep_issues.shtml)
2012-05-19 14:59:52 +03:00
Frédéric Brégier
2320a5919f Proposal for fix related to 1rst issue of #345
=> (getTimeToWait /10)*10
(see http://www.javamex.com/tutorials/threads/sleep_issues.shtml)
2012-05-19 14:54:59 +03:00
Norman Maurer
ed538209e5 Fix syntax. See #342 2012-05-19 13:19:24 +02:00
Norman Maurer
7691d79de6 Merge pull request #342 from jpinner/ssl_buffer_pool_interface
Make SslBufferPool an interface
2012-05-19 03:43:35 -07:00
Jeff Pinner
ddb7d75c96 Make SslBufferPool an interface 2012-05-18 13:49:01 -07:00
Norman Maurer
3d49975a3c Merge pull request #339 from fredericBregier/master
Fix compile errors which were introduced by #338
2012-05-18 12:41:57 -07:00
Frédéric Brégier
e54662f7d0 Same fix than other for correct import 2012-05-18 16:38:13 +03:00
Frédéric Brégier
a5fc2d82a5 Same fix than other for correct import 2012-05-18 16:37:46 +03:00
norman
bca791af4c Fix compile errors which were introduced by #338 2012-05-18 15:13:13 +02:00
Trustin Lee
e5da7b53dd Add UnsupportedMessageTypeException
- Replaced some IllegalArgumentExceptions with
  UnsupportedMessageTypeException
- MessageToMessage(Encoder|Decoder) should continue polling the
  inbound buffer if encode() or decode() returns null
  - aggregating codec can do that
2012-05-18 21:59:02 +09:00
Norman Maurer
ba8cfa5d33 Merge pull request #338 from fredericBregier/master
Improvement: Allow ObjectSizeEstimator in traffic shaping
2012-05-18 05:45:20 -07:00
Frédéric Brégier
1afb209010 import fix 2012-05-18 15:33:23 +03:00
Frédéric Brégier
9c2262716f Import fix 2012-05-18 15:32:59 +03:00
Frédéric Brégier
51debe1287 import fix 2012-05-18 15:32:36 +03:00
Frédéric Brégier
7d4a276ab0 Fix private class to static private class (dynamicity is not necessary there) 2012-05-18 15:26:21 +03:00
Frédéric Brégier
a1a60ec5b6 Add support for ObjectSizeEstimator 2012-05-18 15:23:11 +03:00
Frédéric Brégier
0996bac7ff Add support for ObjectSizeEstimator: in order to allow special optimization if possible from user code 2012-05-18 15:20:46 +03:00
Frédéric Brégier
923498de92 Add support for ObjectSizeEstimator 2012-05-18 15:17:02 +03:00
Trustin Lee
9d3eeb9719 Fix compilation errors 2012-05-18 17:50:38 +09:00
Trustin Lee
ddb839eaf9 Make ReplayingDecoder extend StreamToMessageDecoder 2012-05-18 17:38:44 +09:00
Trustin Lee
d4a26c3c52 Add StreamToMessageDecoder.replace() (#332) 2012-05-18 17:37:41 +09:00
Trustin Lee
ca12e41406 Fix a compiler warning 2012-05-18 16:58:40 +09:00
Trustin Lee
5c3b432f60 Fix test failures due to recent changes with codec exceptions 2012-05-18 15:45:12 +09:00
Trustin Lee
2802b231e5 Make all codecs throw a CodecException
- Added CodecException which is either EncoderException or
  DecoderException
- Made all decoder exceptions a subtype of DecoderException
- Replaced CodecEmbedderException with CodecException
- All abstract handlers wraps an exception with a CodecException
2012-05-18 15:42:36 +09:00
norman
88d60c15c7 Make all methods of SslBufferPool public so a subclass can be placed in another package. See #336 2012-05-18 08:12:42 +02:00
norman
d2ec45e573 Use the correct ChannelBufferFactory when creating new ChannelBuffers. See #335 2012-05-18 08:11:45 +02:00
norman
a99f258984 Make sure SslHandler also works if SslBufferPool use non heap ByteBuffers. See #329 2012-05-18 08:10:34 +02:00
Trustin Lee
251a18160c Move VoidEnum to util 2012-05-18 14:34:42 +09:00
Trustin Lee
dbd973d825 Introduce UniqueName, UniqueKey, and Signal
- UniqueKey removes the duplication between ChannelOption and
  AttributeKey
- UniqueName provides common name collision check for AttributeKey,
  ChannelOption, and Signal.
- Replaced ReplayError with Signal
2012-05-18 14:30:42 +09:00
Trustin Lee
5344dc242c Finish porting the codec package to the new API
- Removed deprecated classes
- Changed type parameter of StreamToMessageDecoder and
  MessageToMessageDecoder for more flexibility
- Made all tests in the codec package pass
2012-05-17 16:38:25 +09:00
Trustin Lee
1bf0dfe64a Retrofit ReplayingDecoder with the new API
- Moved up to 'codec' from 'codec.replay'
- Test passes with Redis client codec
2012-05-17 12:37:37 +09:00
Trustin Lee
2c99fda7b5 Remove unnecessary field 2012-05-16 23:07:19 +09:00
Trustin Lee
d3a3b329f3 Fix a compilation error 2012-05-16 23:05:58 +09:00
Trustin Lee
3669e31e14 Fix a compilation error in DefaultChannelPipeline 2012-05-16 23:03:11 +09:00
Trustin Lee
92a688e5b2 Retrofit the codec framework with the new API (in progress)
- Replaced FrameDecoder and OneToOne(Encoder|Decoder) with:
  - (Stream|Message)To(String|Message)(Encoder|Decoder)
- Moved the classes in 'codec.frame' up to 'codec'
- Fixed some bugs found while running unit tests
2012-05-16 23:02:06 +09:00
norman
ef384a7b21 Add JBoss Marshalling Encoder/Decoder. See #324 2012-05-16 13:00:49 +02:00
norman
52a7d28cb5 Make sure CompositeChanneBuffer does not throw a UnsupportedOperationException if discardReadBytes() discard the whole content of the buffer. See #325 2012-05-15 13:59:33 +02:00
Trustin Lee
894ececbb7 Convert DOS line ending to UNIX line ending 2012-05-15 17:14:02 +09:00
Trustin Lee
dd2e36e5d9 Remove unused or unmaintainable internal classes 2012-05-15 17:10:54 +09:00
Trustin Lee
957c04e597 Fix boundary check in DefaultChannelPipeline.addFirst(..)
- Thanks @normanmaurer
2012-05-15 14:49:23 +09:00
Trustin Lee
e16c835780 Simplify the echo client example 2012-05-15 14:16:27 +09:00
Trustin Lee
6eb540ca40 Add more convenient methods to ChannelPipeline
.. to simplify pipeline construction as shown in the echo example
2012-05-15 14:08:42 +09:00
Trustin Lee
d01d1d0843 Rename (Server)ChannelBuilder to (Server)ChannelBootstrap
- It does not build a new Channel but just helps bootstrapping it.
- Added shutdown() method for simpler deinitialization
- ServerChannelBootstrap has shorter method names for the parent channel
2012-05-15 13:45:25 +09:00
Trustin Lee
128851dd09 Bump up the backlog value 2012-05-15 13:18:46 +09:00
Trustin Lee
f00fadb9fd Simplify the construction of multi-threaded selector event loop
- Hide InternalLogger from users
2012-05-15 13:11:47 +09:00
Trustin Lee
311f17f6ef Replace Bootstrap with ChannelBuilder and ServerChannelBuilder
- Added ChannelInitializer which is supposed to be used with the
  builders
- Echo examples use ChannelBuilder and ServerChannelBuilder now
- Replace ChannelFuture.rethrowIfFailed() with sync*()
- Bug fixes
2012-05-14 23:57:23 +09:00
Trustin Lee
18d1861243 Remove duplicate groupId 2012-05-14 23:09:13 +09:00