Skip site navigation (1) Skip section navigation (2)

Re: implementing asynchronous notifications

From: Oliver Jowett <oliver(at)opencloud(dot)com>
To: Andras Kadinger <bandit(at)surfnonstop(dot)com>
Cc: pgsql-jdbc(at)postgresql(dot)org
Subject: Re: implementing asynchronous notifications
Date: 2005-04-11 04:22:29
Message-ID: (view raw, whole thread or download thread mbox)
Lists: pgsql-jdbc
Andras Kadinger wrote:
> On Mon, 11 Apr 2005, Andras Kadinger wrote:
>>I am unclear as to how to handle possible protocol errors (e.g. when what
>>we end up reading from the connection is not an 'A'sync Notify).  
>>Theoretically, in a working connection this should not happen though.
> Yes, it could: reading the PostgreSQL protocol documentation, it says
> "frontends should always be prepared to accept and display NoticeResponse
> messages, even when the connection is nominally idle".
> So I now added code to process Error 'N'otifications as well.

You also need to handle errors ('E'). Try shutting down a postmaster (-m
fast) while idle connections are around -- they'll get spontaneous FATAL

> +        try {
> +            executor.processNotifies();
> +        } catch (SQLException e) {};

Don't eat the exceptions, let them propagate.

(ugh, getNotifications() does not throw SQLException. We should probably
change that..)

> +            while (protoConnection.getTransactionState() == ProtocolConnection.TRANSACTION_IDLE && pgStream.getSocket().getInputStream().available()>0) {

Can you move that reference following into a method on PGStream?
(hasMessagePending() or something)

The test on transaction state is a bit misleading since the connection's
transaction state should never change inside the loop. Perhaps making
that a separate test would be clearer.

I'm not sure if available() is guaranteed to work on a socket stream
everywhere (it works fine here, though), but I suppose that at worst you
get the existing behaviour where you need to send a query.

Otherwise, seems fine!


In response to


pgsql-jdbc by date

Next:From: Kris JurkaDate: 2005-04-11 05:25:27
Subject: Re: Minor Feature Request
Previous:From: Andras KadingerDate: 2005-04-11 03:51:29
Subject: Re: implementing asynchronous notifications

Privacy Policy | About PostgreSQL
Copyright © 1996-2018 The PostgreSQL Global Development Group