[PBCKP-278] CFS is supported only by EE12+

Author: Daniel Shelepanov

engine.c

@@ -109,7 +109,7 @@ is_cfm_file_path(const char *filepath) {
 	return strlen(filepath) >= 5 && strcmp(&filepath[len-4], ".cfm") == 0;
 }
 
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 /*
  * Determines the relation file size specified by fullpath as if it
  * was not compressed.
@@ -540,7 +540,7 @@ assign_ptrack_map_size(int newval, void *extra)
  * For use in functions that copy directories bypassing buffer manager.
  */
 static void
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 ptrack_mark_file(Oid dbOid, Oid tablespaceOid,
 				 const char *filepath, const char *filename, bool is_cfs)
 #else
@@ -555,7 +555,7 @@ ptrack_mark_file(Oid dbOid, Oid tablespaceOid,
 	struct stat stat_buf;
 	int			oidchars;
 	char		oidbuf[OIDCHARS + 1];
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 	off_t       rel_size;
 #endif
 
@@ -576,7 +576,7 @@ ptrack_mark_file(Oid dbOid, Oid tablespaceOid,
 	oidbuf[oidchars] = '\0';
 	nodeRel(nodeOf(rnode)) = atooid(oidbuf);
 
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 	// if current tablespace is cfs-compressed and md_get_compressor_internal
 	// returns the type of the compressing algorithm for filepath, then it
 	// needs to be de-compressed to obtain its size
@@ -611,7 +611,7 @@ ptrack_walkdir(const char *path, Oid tablespaceOid, Oid dbOid)
 {
 	DIR		   *dir;
 	struct dirent *de;
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 	bool        is_cfs;
 #endif
 
@@ -622,7 +622,7 @@ ptrack_walkdir(const char *path, Oid tablespaceOid, Oid dbOid)
 		|| InitializingParallelWorker)
 		return;
 
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 	is_cfs = file_is_in_cfs_tablespace(path);
 #endif
 
@@ -653,7 +653,7 @@ ptrack_walkdir(const char *path, Oid tablespaceOid, Oid dbOid)
 		}
 
 		if (S_ISREG(fst.st_mode))
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 			ptrack_mark_file(dbOid, tablespaceOid, subpath, de->d_name, is_cfs);
 #else
 			ptrack_mark_file(dbOid, tablespaceOid, subpath, de->d_name);

engine.h

@@ -44,6 +44,9 @@
 #define PTRACK_MAGIC "ptk"
 #define PTRACK_MAGIC_SIZE 4
 
+/* CFS support macro */
+#define CFS_SUPPORT (defined(PGPRO_EE) && PG_VERSION_NUM >= 120000)
+
 /*
  * Header of ptrack map.
  */

ptrack.c

@@ -294,7 +294,7 @@ ptrack_gather_filelist(List **filelist, char *path, Oid spcOid, Oid dbOid)
 {
 	DIR		   *dir;
 	struct dirent *de;
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 	bool is_cfs;
 
 	is_cfs = file_is_in_cfs_tablespace(path);
@@ -360,7 +360,7 @@ ptrack_gather_filelist(List **filelist, char *path, Oid spcOid, Oid dbOid)
 				nodeSpc(pfl->relnode) = spcOid == InvalidOid ? DEFAULTTABLESPACE_OID : spcOid;
 				pfl->path = GetRelationPath(dbOid, nodeSpc(pfl->relnode),
 											nodeRel(pfl->relnode), InvalidBackendId, pfl->forknum);
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 				pfl->is_cfs_compressed = is_cfs
 					&& md_get_compressor_internal(pfl->relnode, InvalidBackendId, pfl->forknum) != 0;
 #endif
@@ -406,7 +406,7 @@ ptrack_filelist_getnext(PtScanCtx * ctx)
 	char	   *fullpath;
 	struct stat fst;
 	off_t       rel_st_size = 0;
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 	RelFileNodeBackend rnodebackend;
 #endif
 
@@ -455,7 +455,7 @@ ptrack_filelist_getnext(PtScanCtx * ctx)
 		return ptrack_filelist_getnext(ctx);
 	}
 
-#ifdef PGPRO_EE
+#if CFS_SUPPORT
 	rnodebackend.node = ctx->bid.relnode;
 	rnodebackend.backend = InvalidBackendId;