diff options
author | Oleksandr Shulgin <oleksandr.shulgin@zalando.de> | 2015-10-14 18:39:20 +0200 |
---|---|---|
committer | Oleksandr Shulgin <oleksandr.shulgin@zalando.de> | 2015-10-14 18:39:20 +0200 |
commit | 28a1a00d1ce29a823a91417807b9d2b9cbf7b4dd (patch) | |
tree | c73c2844253c8a9ac120c601ea10f449fd309d56 /psycopg/pqpath.c | |
parent | e3097ec9562a09b66f3d73e5bf901c8295909f38 (diff) | |
download | psycopg2-28a1a00d1ce29a823a91417807b9d2b9cbf7b4dd.tar.gz |
Remove commented copy_both code in pqfetch.
Diffstat (limited to 'psycopg/pqpath.c')
-rw-r--r-- | psycopg/pqpath.c | 9 |
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; |