diff options
| author | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2011-06-04 01:31:36 +0100 |
|---|---|---|
| committer | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2011-06-04 01:31:36 +0100 |
| commit | d9c0b8166f9ba17eacb09d5861409ab862447331 (patch) | |
| tree | c58184cefba8eac642c0c12d5d61562ccbeedcd4 /psycopg/connection_int.c | |
| parent | 3aad3d3143a8e5963b06b8905a040521d3c3bcaa (diff) | |
| download | psycopg2-d9c0b8166f9ba17eacb09d5861409ab862447331.tar.gz | |
Process notifies when data is received, not when the result is parsed
Notifies process access the connection, is not limited to the result, so
There is the possibility of loss of protocol sync in multithread programs.
Closes ticket #55.
Diffstat (limited to 'psycopg/connection_int.c')
| -rw-r--r-- | psycopg/connection_int.c | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/psycopg/connection_int.c b/psycopg/connection_int.c index 0544957..18a0a14 100644 --- a/psycopg/connection_int.c +++ b/psycopg/connection_int.c @@ -174,8 +174,6 @@ conn_notifies_process(connectionObject *self) PyObject *notify = NULL; PyObject *pid = NULL, *channel = NULL, *payload = NULL; - /* TODO: we are called without the lock! */ - while ((pgn = PQnotifies(self->pgconn)) != NULL) { Dprintf("conn_notifies_process: got NOTIFY from pid %d, msg = %s", |