Fix spill to file threshold check

Author: knizhnik

multimaster.c

@@ -504,6 +504,8 @@ MtmAdjustOldestXid(TransactionId xid)
         MtmTransState *ts, *prev = NULL;
         int i;
 
+		return  FirstNormalTransactionId;
+
 		MtmLock(LW_EXCLUSIVE);
         ts = (MtmTransState*)hash_search(MtmXid2State, &xid, HASH_FIND, NULL);
         if (ts != NULL && ts->status == TRANSACTION_STATUS_COMMITTED) { 

multimaster.h

@@ -47,6 +47,7 @@
 #define MULTIMASTER_ADMIN               "mtm_admin"
 
 #define USEC 1000000
+#define MB   (1024*1024)
 
 #define USEC_TO_MSEC(t) ((t)/1000)
 #define MSEC_TO_USEC(t) ((t)*1000)

pglogical_receiver.c

@@ -449,7 +449,7 @@ pglogical_receiver_main(Datum main_arg)
 			{
                 stmt = copybuf + hdr_len;
 
-				if (buf.used >= MtmTransSpillThreshold) { 
+				if (buf.used >= MtmTransSpillThreshold*MB) { 
 					if (spill_file < 0) {
 						int file_id;
 						spill_file = MtmCreateSpillFile(nodeId, &file_id);