external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix unlimited copy size variable's value

pull/5209/head
Sait Talha Nisanci 2021-08-18 17:02:15 +03:00
parent 29f5b99951
commit a1bfb4f31b
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/commands/transmit.c
View File

@ -245,7 +245,7 @@ static bool
ReceiveCopyData(StringInfo copyData) ReceiveCopyData(StringInfo copyData)
{ {
bool copyDone = true; bool copyDone = true;
const int unlimitedSize = 0; const int unlimitedSize = PQ_LARGE_MESSAGE_LIMIT;
HOLD_CANCEL_INTERRUPTS(); HOLD_CANCEL_INTERRUPTS();
pq_startmsgread(); pq_startmsgread();

1
src/include/distributed/version_compat.h
View File

@ -93,6 +93,7 @@
((&ProcGlobal->allPgXact[(pgproc)->pgprocno])->vacuumFlags) ((&ProcGlobal->allPgXact[(pgproc)->pgprocno])->vacuumFlags)
#define get_partition_parent_compat(a, b) get_partition_parent(a) #define get_partition_parent_compat(a, b) get_partition_parent(a)
#define RelationGetPartitionDesc_compat(a, b) RelationGetPartitionDesc(a) #define RelationGetPartitionDesc_compat(a, b) RelationGetPartitionDesc(a)
#define PQ_LARGE_MESSAGE_LIMIT 0
#endif #endif
#if PG_VERSION_NUM >= PG_VERSION_13 #if PG_VERSION_NUM >= PG_VERSION_13