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

Free the GIL in blocking operations in V2 COPY FROM.

Browse Source
This commit is contained in:
Daniele Varrazzo 2010-04-07 23:52:53 +01:00
parent aeec583ff1
commit e8286084e9
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
psycopg/pqpath.c
View File

@ -1065,13 +1065,18 @@ _pq_copy_in(cursorObject *curs)
o = PyObject_CallFunction(func, NULL); o = PyObject_CallFunction(func, NULL);
if (o == NULL) goto clear; if (o == NULL) goto clear;
if (o == Py_None || PyString_GET_SIZE(o) == 0) break; if (o == Py_None || PyString_GET_SIZE(o) == 0) break;
Py_BEGIN_ALLOW_THREADS;
rv = PQputline(curs->conn->pgconn, PyString_AS_STRING(o)); rv = PQputline(curs->conn->pgconn, PyString_AS_STRING(o));
Py_END_ALLOW_THREADS;
Py_DECREF(o); Py_DECREF(o);
if (0 != rv) goto clear; if (0 != rv) goto clear;
} }
Py_XDECREF(o); Py_XDECREF(o);
Py_BEGIN_ALLOW_THREADS;
PQputline(curs->conn->pgconn, "\\.\n"); PQputline(curs->conn->pgconn, "\\.\n");
PQendcopy(curs->conn->pgconn); PQendcopy(curs->conn->pgconn);
Py_END_ALLOW_THREADS;
/* if for some reason we're using a protocol 3 libpq to connect to a /* if for some reason we're using a protocol 3 libpq to connect to a
protocol 2 backend we still need to cycle on the result set */ protocol 2 backend we still need to cycle on the result set */