summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--lib/output/pq/pqConn.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/output/pq/pqConn.cpp b/lib/output/pq/pqConn.cpp
index 53fd3db..d35d011 100644
--- a/lib/output/pq/pqConn.cpp
+++ b/lib/output/pq/pqConn.cpp
@@ -70,17 +70,17 @@ namespace MyGrate::Output::Pq {
verify<PqErr>(PQresultStatus(res.get()) == PGRES_COPY_IN, "begin copy", res.get());
return fopencookie(this, "w",
{nullptr,
- [](void * cookie, const char * buf, size_t size) -> ssize_t {
+ [](void * cookie, const char * buf, size_t size) {
auto pq = static_cast<PqConn *>(cookie);
int rc;
- while (!(rc = PQputCopyData(pq->conn.get(), buf, size))) {
+ while (!(rc = PQputCopyData(pq->conn.get(), buf, (int)size))) {
sleep(1);
}
verify<PqErr>(rc == 1, "copy data", pq->conn.get());
- return size;
+ return (ssize_t)size;
},
nullptr,
- [](void * cookie) -> int {
+ [](void * cookie) {
static_cast<PqConn *>(cookie)->endBulkUpload(nullptr);
return 0;
}});