Mailing-List: contact dev-help@directory.apache.org; run by ezmlm
Precedence: bulk
Reply-To: "Apache Directory Developers List" <dev@directory.apache.org>
Received-SPF: pass (asf.osuosl.org: domain of kumpera@gmail.com designates
 64.233.170.204 as permitted sender)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
        s=beta; d=gmail.com;
        h=received:message-id:date:from:to:subject:mime-version:content-type:content-transfer-encoding:content-disposition;
        b=tnhBX0qJMPIRfgGV4G125yIDPxRM+t8cKtitEEdDmc+/riPGdOwBwPwTlwsBYDQTOGssbmCRijbvdyKeGofmmbChCVQwQryor5psfh1WhYSo/GVVH00Vq174OJ0E3f/k5XrQ8p0ULGji+cJvW43OU1f4Oul3Ye191TbSHp0P9Io=
Message-ID: <8cca42d805081208507a108c66@mail.gmail.com>
Date: Fri, 12 Aug 2005 12:50:36 -0300
From: Rodrigo Kumpera <kumpera@gmail.com>
To: dev@directory.apache.org
Subject: [mina] Problems with SocketIoProcessor and IoThreadPoolFilter
Mime-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable
Content-Disposition: inline

Hi,

Great work with mina, it do makes writting nio servers easy. I=B4m
writing a filtering server and have the following scenario:

1-incoming connections, using ServiceRegistry with IoHandler.
2-filtering is done in a separate pool (using doug lea's
util.concurrent package)
3-fowarding the result to another server, using SocketIoProcessor and
IoThreadPoolFilter.

So fair I=B4ve been able to fine tune the thread pool used by the
ServiceRegistry (1).

My problem is with (2) and (3), I want to have a single thread pool to
be shared by the 3 stages of the server.
With the filtering stage I=B4m thinking about playing with=20
IoThreadPoolFilter implementation to use util.concurrent and expose
it's interface.
My problem when using a thread pool with the last stage, when
connecting to foreign hosts, is that it throws the following exception
under moderate load:

java.nio.channels.CancelledKeyException
        at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:55=
)
        at sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:59=
)
        at org.apache.mina.io.socket.SocketIoProcessor.flush(SocketIoProces=
sor.j
ava:511)
        at org.apache.mina.io.socket.SocketIoProcessor.flushSessions(Socket=
IoPro
cessor.java:422)
        at org.apache.mina.io.socket.SocketIoProcessor.access$300(SocketIoP=
roces
sor.java:41)
        at org.apache.mina.io.socket.SocketIoProcessor$Worker.run(SocketIoP=
roces
sor.java:546)

I tried to use the same IoThreadPoolFilter with an instance of
SocketIoProcessor and ServiceRegistry, but it doesn=B4t seen to work,
the server halts and don't make any progress.

Should I fill jira issues about these two problems?

Thank you very much,


Rodrigo Kumpera