mina-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Steven E. Harris" <...@panix.com>
Subject Re: Huge SessionBuffer event queue empties too slowly
Date Mon, 15 Jan 2007 16:48:49 GMT
Trustin Lee <trustin@gmail.com> writes:

> So incoming messageSent() events caused by session.write(new
> Quote()) are not being processed until messageReceived(IoSession,
> CmdReplicate) ends.  Writing from a separate thread is a good idea
> here, too.

This sounds related to my question from last week that has yet to
provoke any response:

  IoSession-level synchronization of ProtocolEncoder/ProtocolDecoder pair

Since writing that message, I've confirmed that all ByteBuffer write
requests to SocketSessionImpls (socket-based IoSessions) get pushed
into a queue, and are drawn out by a single worker thread to be
written to the actual socket.

Looking at ExecutorFilter.fireEvent(), if I'm not mistaken, no more
than one thread will ever service a given IoSession's event
queue. However, it's possible that one thread is writing outbound
messages (passing down through the filter chain) while
SocketIoProcessor's worker thread is reading and dispatching incoming
messages (passing up through the filter chain), possibly splitting off
to per-session worker threads via an ExecutorFilter.

If this description is accurate, can one then conclude that an
IoFilter's messageSent() and filterWrite() methods might be called
concurrently for a given IoSession?

Steven E. Harris

View raw message