summaryrefslogtreecommitdiff
path: root/lib/output/pq
diff options
context:
space:
mode:
Diffstat (limited to 'lib/output/pq')
-rw-r--r--lib/output/pq/pqConn.cpp6
1 files changed, 1 insertions, 5 deletions
diff --git a/lib/output/pq/pqConn.cpp b/lib/output/pq/pqConn.cpp
index f4e5226..983271e 100644
--- a/lib/output/pq/pqConn.cpp
+++ b/lib/output/pq/pqConn.cpp
@@ -85,11 +85,7 @@ namespace MyGrate::Output::Pq {
void
PqConn::endBulkUpload(const char * errormsg)
{
- int rc;
- while (!(rc = PQputCopyEnd(this->conn.get(), errormsg))) {
- sleep(1);
- }
- verify<PqErr>(rc == 1, "copy end rc", conn.get());
+ verify<PqErr>(PQputCopyEnd(this->conn.get(), errormsg) == 1, "copy end rc", conn.get());
ResPtr res {PQgetResult(conn.get()), &PQclear};
verify<PqErr>(PQresultStatus(res.get()) == PGRES_COMMAND_OK, "end copy", res.get());
}