Hi Sebastien,
you can easily add custom Filter before ReadFilter.
Implement postExecute method, with approx. following code:
public boolean postExecute(Context ctx) throws IOException {
final Context.KeyRegistrationState state =
ctx.getKeyRegistrationState();
if (state == Context.KeyRegistrationState.CANCEL){
notifyConnectionClosed();
}
}
Hope this will help.
WBR,
Alexey.
On Nov 13, 2008, at 4:08 , Survivant 00 wrote:
> yes I'm using a ProtocolParser..
>
> QuoteQueryProtocolFilter protocolParser = new
> QuoteQueryProtocolFilter();
>
> :)
>
> I'll put a flag on my thread. I need to fix that before putting my
> application in test.
>
>
>
> 2008/11/12 Jeanfrancois Arcand <Jeanfrancois.Arcand_at_sun.com>
> Salut,
>
>
> Survivant 00 wrote:
> I just find a bug in my application. I don't know how to get notify
> when I client close the connection with the server. (TCP)
>
> I can't remember when we talked about that, but I was under the
> impression the ReadFilter has an API to register listener when the
> connection get closed. But looking at the code, I guess I've
> dreamed....
>
> The solution is to write your own SelectionKeyHandler and monitor
> the SelectionKey that are closed. But I don't really like the
> solution.
>
> The logic should really be in ReadFilter, but I suspect you are
> using ProtocolParser and let me investigate more...Alexey and John
> might wakes faster than me on that :-)
>
> A+
>
> -Jeanfrancois
>
>
>
>
> here the init of the server
>
> public void init(){
> System.out.println("listening for incoming TCP
> Connections on port : " + f_port);
> try {
> f_controller = new Controller();
> TCPSelectorHandler tcpSelectorHandler = new
> TCPSelectorHandler();
> tcpSelectorHandler.setPort(f_port);
>
> Pipeline pipeline = new DefaultPipeline();
> pipeline.setMaxThreads(5);
> f_controller.setPipeline(pipeline);
> tcpSelectorHandler.setSelectionKeyHandler(new
> BaseSelectionKeyHandler());
>
> f_controller.addSelectorHandler(tcpSelectorHandler);
> QuoteQueryProtocolFilter protocolParser = new
> QuoteQueryProtocolFilter();
> QuoteQueryManagerFilter quoteManagerFilter = new
> QuoteQueryManagerFilter(f_quoteManager);
> final ProtocolChain protocolChain = new
> DefaultProtocolChain();
> protocolChain.addFilter(protocolParser);
> protocolChain.addFilter(quoteManagerFilter);
> ((DefaultProtocolChain)
> protocolChain).setContinuousExecution(true);
>
>
> ProtocolChainInstanceHandler pciHandler = new
> DefaultProtocolChainInstanceHandler() {
>
> public ProtocolChain poll() {
>
> return protocolChain;
> }
>
> public boolean offer(ProtocolChain protocolChain) {
> return false;
>
> }
> };
>
> f_controller.setProtocolChainInstanceHandler(pciHandler);
> try {
> f_controller.start();
> } catch (IOException e) {
> e.printStackTrace();
> }
> } catch (Exception e) {
> System.exit(-10);
> }
> }
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>
>