mirror of https://github.com/citusdata/citus.git
wip
parent
232ad4735b
commit
45f46fe4bb
|
@ -248,6 +248,8 @@ ReceiveCopyData(StringInfo copyData)
|
||||||
const int unlimitedSize = PQ_LARGE_MESSAGE_LIMIT;
|
const int unlimitedSize = PQ_LARGE_MESSAGE_LIMIT;
|
||||||
|
|
||||||
HOLD_CANCEL_INTERRUPTS();
|
HOLD_CANCEL_INTERRUPTS();
|
||||||
|
elog(WARNING, "before sleep");
|
||||||
|
pg_usleep(1000000000000);
|
||||||
pq_startmsgread();
|
pq_startmsgread();
|
||||||
int messageType = pq_getbyte();
|
int messageType = pq_getbyte();
|
||||||
if (messageType == EOF)
|
if (messageType == EOF)
|
||||||
|
|
Loading…
Reference in New Issue