postgrespro
diff --git a/‎src/backend/commands/dbcommands.c
Lines changed: 3 additions & 3 deletions b/‎src/backend/commands/dbcommands.c
Lines changed: 3 additions & 3 deletions
diff --git a/‎src/backend/commands/tablespace.c
Lines changed: 11 additions & 6 deletions b/‎src/backend/commands/tablespace.c
Lines changed: 11 additions & 6 deletions
diff --git a/‎src/backend/storage/file/cfs.c
Lines changed: 1 addition & 0 deletions b/‎src/backend/storage/file/cfs.c
Lines changed: 1 addition & 0 deletions
@@ -1227,11 +1227,11 @@ movedb(const char *dbname, const char *tblspcname)
 		/*
 		 * Copy files from the old tablespace to the new one
 		 */
-		if (src_compressed ^ dst_compressed) { 
+		if (src_compressed ^ dst_compressed)
 			copyzipdir(src_dbpath, src_compressed, dst_dbpath, dst_compressed);
-		} else { 
+		else
 			copydir(src_dbpath, dst_dbpath, false);
-		}
+
 
 		/*
 		 * Record the filesystem change in XLOG
 
@@ -1062,21 +1062,26 @@ AlterTableSpaceOptions(AlterTableSpaceOptionsStmt *stmt)
 	/* If tablespace should be compressed */
 	compressed = getBoolOption(stmt->options, "compression", false);
 
-	if (compressed ^ is_tablespace_compressed(tablespaceoid)) {
+	if (compressed ^ is_tablespace_compressed(tablespaceoid))
+	{
 		char* tbsdir = psprintf("pg_tblspc/%u/%s", tablespaceoid, TABLESPACE_VERSION_DIRECTORY);
-		if (!directory_is_empty(tbsdir)) {
+
+		if (!directory_is_empty(tbsdir))
 			ereport(ERROR,
 					(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
 					 errmsg("It is not possible to toggle compression option for tablespace")));
-		} else { 
+		else
+		{
 			char* compressionFilePath = psprintf("%s/pg_compression", tbsdir);
-			if (compressed) { 
+
+			if (compressed)
+			{
 				FILE* comp = fopen(compressionFilePath, "w");
 				fputs(cfs_algorithm(), comp);
 				fclose(comp);
-			} else {
-				unlink(compressionFilePath);
 			}
+			else
+				unlink(compressionFilePath);
 		}
 	}
 
 
@@ -807,6 +807,7 @@ static bool cfs_gc_file(char* map_path)
 					Assert(rc);
 					cfs_decrypt(block, (off_t)i*BLCKSZ, size);
 					res = cfs_decompress(decomressedBlock, BLCKSZ, block, size);
+
 					if (res != BLCKSZ)
 					{
 						pg_atomic_fetch_sub_u32(&map->lock, CFS_GC_LOCK); /* release lock */
Original file line number	Diff line number	Diff line change
`@@ -807,6 +807,7 @@ static bool cfs_gc_file(char* map_path)`
`807`	`807`	`Assert(rc);`
`808`	`808`	`cfs_decrypt(block, (off_t)i*BLCKSZ, size);`
`809`	`809`	`res = cfs_decompress(decomressedBlock, BLCKSZ, block, size);`
	`810`	`+`
`810`	`811`	`if (res != BLCKSZ)`
`811`	`812`	`{`
`812`	`813`	`pg_atomic_fetch_sub_u32(&map->lock, CFS_GC_LOCK); /* release lock */`