search

wsky / top-link

embedded duplex multi-channel endpoint and connection management for c#/java/...
6 stars 1 forks source link

resovle ChannelSender.send() OOM probelm #87

Closed wsky closed 10 years ago

wsky commented 10 years ago

https://github.com/wsky/top-link/compare/5acb8f1e9b...660e42b666

netty channel.write() was async and pending frame to send queue

simply add buffer count limit, or mem size limit is more useful

wsky commented 10 years ago

remove sendSync(), channelSender.send() not full async always, if reach max pendingCount, change to sendSync