|
|
@ -526,8 +526,8 @@ process_queued_fetch_requests(libpq_source *src) |
|
|
|
} |
|
|
|
} |
|
|
|
else |
|
|
|
else |
|
|
|
{ |
|
|
|
{ |
|
|
|
pg_log_debug("received chunk for file \"%s\", offset " INT64_FORMAT ", size %d", |
|
|
|
pg_log_debug("received chunk for file \"%s\", offset %lld, size %d", |
|
|
|
filename, chunkoff, chunksize); |
|
|
|
filename, (long long int) chunkoff, chunksize); |
|
|
|
|
|
|
|
|
|
|
|
if (strcmp(filename, rq->path) != 0) |
|
|
|
if (strcmp(filename, rq->path) != 0) |
|
|
|
{ |
|
|
|
{ |
|
|
@ -535,8 +535,8 @@ process_queued_fetch_requests(libpq_source *src) |
|
|
|
filename, rq->path); |
|
|
|
filename, rq->path); |
|
|
|
} |
|
|
|
} |
|
|
|
if (chunkoff != rq->offset) |
|
|
|
if (chunkoff != rq->offset) |
|
|
|
pg_fatal("received data at offset " INT64_FORMAT " of file \"%s\", when requested for offset " INT64_FORMAT, |
|
|
|
pg_fatal("received data at offset %lld of file \"%s\", when requested for offset %lld", |
|
|
|
chunkoff, rq->path, (int64) rq->offset); |
|
|
|
(long long int) chunkoff, rq->path, (long long int) rq->offset); |
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* We should not receive more data than we requested, or |
|
|
|
* We should not receive more data than we requested, or |
|
|
|