Emmanuel, thanks for the quick response. OrderedThreadPool didn't help.
The attached log might help you understand better what is happening - as said before every sent message has 2 parts, a header (~157 bytes) and a file (around 1-1.5 kb). Therefore I would expect the NIOProcessor to process first a small buffer (~157 bytes) and then a larger one (around 1-1.5 kb) repeatedly. As you can see in the log the Thread:NioProcessor-1 indeed processes 157 bytes long HeapBuffer (which is the header), and than 1451 long HeapBuffer (which is the file content). BUT after that, as you can see in line 22, the second call to FileWithHeaderWriteFilter sneaked in... Thanks, Guy -----Original Message----- From: Emmanuel Lécharny [mailto:[email protected]] Sent: Tuesday, September 14, 2010 1:15 PM To: [email protected] Subject: Re: Possible synchronization issue On 9/14/10 1:07 PM, Guy Itzhaki wrote: > No. > This is the filter I'm using: > new ExecutorFilter(Executors.newFixedThreadPool(2)) Try to use the OrderedThreadPool then. -- Regards, Cordialement, Emmanuel Lécharny www.iktek.com Click here to report this message as SPAM: http://vsp.ateranetworks.com/ReportSpam.php?sid=bac6f639c55903f79d352fe268f89f82_091d39d20cd5550151002e16cad2865b -- Powered by ATERA Networks --
