Vahdat, 
We have already tested with the default value of the maximumPoolSize option, 
and we got the same problem. The version 2.10.2.

Flavio Magacho
Gerente de Desenvolvimento
Diretoria de Tecnologia da Informação
  M4U
+55 (21) 2546-4050 ▪ Ramal: 4082
+55 (21) 8889-1572
 Antes de imprimir, pense em sua responsabilidade e compromisso com o Meio 
Ambiente.
O conteúdo desta mensagem é confidencial e pode ser privilegiado. É vedada a 
sua cópia ou divulgação.
The contents of this message are confidential and may be privileged. Copying or 
disclosing is prohibited.


-----Original Message-----
From: Babak Vahdat [mailto:[email protected]] 
Sent: quarta-feira, 14 de agosto de 2013 06:08
To: [email protected]
Subject: Re: Load test on camel-netty

Hi

The maximumPoolSize option is *actually* the value for the corePoolSize of the 
ThreadPool being in charge, which is set to 100 in your case (the option naming 
seems a bit misleading to me). Can you try with smaller values for this option 
to see if you can still reproduce the problem.

Other than that depending on which Camel version you make use of the Netty 
OrderedThreadPoolExecutor is *not* in use, see
https://issues.apache.org/jira/browse/CAMEL-5689 which could cause 
OutOfMemoryError, search for OutOfMemoryError here:

http://netty.io/3.6/api/org/jboss/netty/handler/execution/ExecutionHandler.html

Babak


flavio.magacho wrote
> Hi,
> I'm expecting some problems while running a load test on camel-netty 
> component.
> 
> This is the route configuration:
> <route id="rtRead">
>                 
> <from
> uri="netty:tcp://pos-tcp-server.host:9000?decoder=#myDecoder&amp;encod
> er=#myEncoder&amp;sync=true&amp;reuseAddress=true&amp;synchronous=fals
> e&amp;workerCount=100&amp;maximumPoolSize=100”/>
>                 
> <log message="Lendo ${body}" />
>                 
> <to uri="ejb:local/GatewayBean?method=process" /> </route> After some 
> test cycles, we receive some exceptions like this:
> 2013-08-13 11:25:33,398 WARNING
> [org.jboss.netty.channel.DefaultChannelPipeline] [New I/O  worker #32] 
> An exception was thrown by a user handler while handling an exception 
> event
> ([id: 0x8c7d41bd, /10.10.0.28:53469 => /10.11.234.38:9000] EXCEPTION:
> java.lang.OutOfMemoryError: unable to create new native thread)
> java.lang.OutOfMemoryError: unable to create new native thread
>         at java.lang.Thread.start0(Native Method)
>         at java.lang.Thread.start(Thread.java:640)
>         at
> java.util.concurrent.ThreadPoolExecutor.addIfUnderCorePoolSize(ThreadPoolExecutor.java:703)
>         at
> java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:652)
>         at
> org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor.doUnorderedExecute(MemoryAwareThreadPoolExecutor.java:452)
>         at
> org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor$ChildExecutor.execute(OrderedMemoryAwareThreadPoolExecutor.java:292)
>         at
> org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor.doExecute(OrderedMemoryAwareThreadPoolExecutor.java:242)
>         at
> org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor.execute(MemoryAwareThreadPoolExecutor.java:437)
>         at
> org.jboss.netty.handler.execution.ExecutionHandler.handleUpstream(ExecutionHandler.java:172)
>         at
> org.jboss.netty.channel.Channels.fireExceptionCaught(Channels.java:533)
>         at org.jboss.netty.channel.Channels$7.run(Channels.java:507)
>         at
> org.jboss.netty.channel.socket.ChannelRunnableWrapper.run(ChannelRunnableWrapper.java:41)
>         at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.processEventQueue(AbstractNioWorker.java:453)
>         at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:330)
>         at
> org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>         at java.lang.Thread.run(Thread.java:662)
> 
> 
> It sounds strange, our test case has only 5 simultaneous opened 
> connections.
> For me we are heaving some leak of threads or we are having some 
> problems to close the SocketChannel correctly.
> 
> Thanks,
> Flavio Magacho
> Gerente de Desenvolvimento
> Diretoria de Tecnologia da Informação
> [cid:[email protected]]  M4U
> +55 (21) 2546-4050 ▪ Ramal: 4082
> +55 (21) 8889-1572
> þ Antes de imprimir, pense em sua responsabilidade e compromisso com o 
> Meio Ambiente.
> O conteúdo desta mensagem é confidencial e pode ser privilegiado. É 
> vedada a sua cópia ou divulgação.
> The contents of this message are confidential and may be privileged.
> Copying or disclosing is prohibited.





--
View this message in context: 
http://camel.465427.n5.nabble.com/Load-test-on-camel-netty-tp5737221p5737237.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to