psycopg/psycopg2
1
1
Fork 0
mirror of https://github.com/psycopg/psycopg2.git synced 2025-03-01 06:50:34 +03:00
Code Issues Packages Projects Releases Wiki Activity

Ref the async cursor before storing it in the connection

Browse Source
This commit is contained in:
Jan Urbański 2010-03-27 03:21:47 +01:00 committed by Federico Di Gregorio
parent eb646f71fa
commit 062a9602ae
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
psycopg/cursor_int.c
View File

@ -74,6 +74,7 @@ curs_get_last_result(cursorObject *self) {
IFCLEARPGRES(self->pgres); IFCLEARPGRES(self->pgres);
self->pgres = pgres; self->pgres = pgres;
} }
Py_XDECREF(self->conn->async_cursor);
self->conn->async_cursor = NULL; self->conn->async_cursor = NULL;
pthread_mutex_unlock(&(self->conn->lock)); pthread_mutex_unlock(&(self->conn->lock));
Py_END_ALLOW_THREADS; Py_END_ALLOW_THREADS;

2
psycopg/pqpath.c
View File

@ -299,6 +299,7 @@ pq_clear_async(connectionObject *conn)
Dprintf("pq_clear_async: clearing PGresult at %p", pgres); Dprintf("pq_clear_async: clearing PGresult at %p", pgres);
CLEARPGRES(pgres); CLEARPGRES(pgres);
} }
Py_XDECREF(conn->async_cursor);
conn->async_cursor = NULL; conn->async_cursor = NULL;
} }
@ -746,6 +747,7 @@ pq_execute(cursorObject *curs, const char *query, int async)
} }
else { else {
curs->conn->async_status = async_status; curs->conn->async_status = async_status;
Py_INCREF(curs);
curs->conn->async_cursor = (PyObject*)curs; curs->conn->async_cursor = (PyObject*)curs;
} }