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

Remove commented copy_both code in pqfetch.

Browse Source
This commit is contained in:
Oleksandr Shulgin 2015-10-14 18:39:20 +02:00
parent e3097ec956
commit 28a1a00d1c
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
psycopg/pqpath.c
View File

@ -1760,6 +1760,7 @@ pq_copy_both(cursorObject *curs, PyObject *consume, int decode, double keepalive
FD_ZERO(&fds); FD_ZERO(&fds);
FD_SET(fd, &fds); FD_SET(fd, &fds);
/* how long can we wait before we need to send a keepalive? */
gettimeofday(&curr_time, NULL); gettimeofday(&curr_time, NULL);
timeradd(&curs->repl_last_io, &keep_intr, &ping_time); timeradd(&curs->repl_last_io, &keep_intr, &ping_time);
@ -1880,13 +1881,7 @@ pq_fetch(cursorObject *curs, int no_result)
Dprintf("pq_fetch: data from a streaming replication slot (no tuples)"); Dprintf("pq_fetch: data from a streaming replication slot (no tuples)");
curs->rowcount = -1; curs->rowcount = -1;
ex = 0; ex = 0;
/*if (curs->conn->async) { /* nothing to do here: _pq_copy_both_v3 will be called separately */
ex = 0;
} else {
ex = _pq_copy_both_v3(curs);
if (PyErr_Occurred()) ex = -1;
}*/
CLEARPGRES(curs->pgres); CLEARPGRES(curs->pgres);
break; break;