summaryrefslogtreecommitdiff
path: root/psycopg/pqpath.c
diff options
context:
space:
mode:
authorOleksandr Shulgin <oleksandr.shulgin@zalando.de>2015-10-14 18:39:20 +0200
committerOleksandr Shulgin <oleksandr.shulgin@zalando.de>2015-10-14 18:39:20 +0200
commit28a1a00d1ce29a823a91417807b9d2b9cbf7b4dd (patch)
treec73c2844253c8a9ac120c601ea10f449fd309d56 /psycopg/pqpath.c
parente3097ec9562a09b66f3d73e5bf901c8295909f38 (diff)
downloadpsycopg2-28a1a00d1ce29a823a91417807b9d2b9cbf7b4dd.tar.gz
Remove commented copy_both code in pqfetch.
Diffstat (limited to 'psycopg/pqpath.c')
-rw-r--r--psycopg/pqpath.c9
1 files changed, 2 insertions, 7 deletions
diff --git a/psycopg/pqpath.c b/psycopg/pqpath.c
index a42c9a1..111eb87 100644
--- a/psycopg/pqpath.c
+++ b/psycopg/pqpath.c
@@ -1760,6 +1760,7 @@ pq_copy_both(cursorObject *curs, PyObject *consume, int decode, double keepalive
FD_ZERO(&fds);
FD_SET(fd, &fds);
+ /* how long can we wait before we need to send a keepalive? */
gettimeofday(&curr_time, NULL);
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)");
curs->rowcount = -1;
ex = 0;
- /*if (curs->conn->async) {
- ex = 0;
- } else {
- ex = _pq_copy_both_v3(curs);
-
- if (PyErr_Occurred()) ex = -1;
- }*/
+ /* nothing to do here: _pq_copy_both_v3 will be called separately */
CLEARPGRES(curs->pgres);
break;