Refector CFS intialization

Author: knizhnik

src/backend/storage/file/cfs.c

@@ -389,23 +389,31 @@ void cfs_decrypt(const char* fname, void* block, uint32 offs, uint32 size)
  *	Section 3: Compression implementation.
  * ----------------------------------------------------------------
  */
-void cfs_initialize()
+int cfs_shmem_size()
 {
-	cfs_state = (CfsState*)ShmemAlloc(sizeof(CfsState));
-	memset(&cfs_state->gc_stat, 0, sizeof cfs_state->gc_stat);
-	pg_atomic_init_flag(&cfs_state->gc_started);
-	pg_atomic_init_u32(&cfs_state->n_active_gc, 0);
-	cfs_state->n_workers = 0;
-	cfs_state->gc_enabled = cfs_gc_enabled;
-	cfs_state->max_iterations = 0;
-	
-	if (cfs_encryption)
-		cfs_crypto_init();
-
-	elog(LOG, "Start CFS version %s compression algorithm %s encryption %s", 
-		 CFS_VERSION, cfs_algorithm(), cfs_encryption ? "enabled" : "disabled");
+	return sizeof(CfsState);
 }
 
+void cfs_initialize()
+{
+	bool found;
+	cfs_state = (CfsState*)ShmemInitStruct("CFS Control", sizeof(CfsState), &found);
+	if (!found)
+	{
+		memset(&cfs_state->gc_stat, 0, sizeof cfs_state->gc_stat);
+		pg_atomic_init_flag(&cfs_state->gc_started);
+		pg_atomic_init_u32(&cfs_state->n_active_gc, 0);
+		cfs_state->n_workers = 0;
+		cfs_state->gc_enabled = cfs_gc_enabled;
+		cfs_state->max_iterations = 0;
+		
+		if (cfs_encryption)
+			cfs_crypto_init();
+		
+		elog(LOG, "Start CFS version %s compression algorithm %s encryption %s GC %s", 
+			 CFS_VERSION, cfs_algorithm(), cfs_encryption ? "enabled" : "disabled", cfs_gc_enabled ? "enabled" : "disabled");
+	}
+}
 int cfs_msync(FileMap* map)
 {
 #ifdef WIN32
@@ -566,7 +574,7 @@ void cfs_lock_file(FileMap* map, char const* file_path)
 				char* map_bck_path = psprintf("%s.cfm.bck", file_path);
 				char* file_bck_path = psprintf("%s.bck", file_path);
 
-				elog(WARNING, "CFS indicates that GC of %s was interrupted: try to perform recovery", file_path);
+				elog(WARNING, "CFS indicates that GC of %s was interrupted: trying to perform recovery", file_path);
 
 				if (access(file_bck_path, R_OK) != 0)
 				{

src/backend/storage/ipc/ipci.c

@@ -44,6 +44,7 @@
 #include "storage/procsignal.h"
 #include "storage/sinvaladt.h"
 #include "storage/spin.h"
+#include "storage/cfs.h"
 #include "utils/snapmgr.h"
 
 
@@ -142,6 +143,7 @@ CreateSharedMemoryAndSemaphores(bool makePrivate, int port)
 		size = add_size(size, BTreeShmemSize());
 		size = add_size(size, SyncScanShmemSize());
 		size = add_size(size, AsyncShmemSize());
+		size = add_size(size, cfs_shmem_size());
 #ifdef EXEC_BACKEND
 		size = add_size(size, ShmemBackendArraySize());
 #endif
@@ -254,7 +256,8 @@ CreateSharedMemoryAndSemaphores(bool makePrivate, int port)
 	BTreeShmemInit();
 	SyncScanShmemInit();
 	AsyncShmemInit();
-
+	cfs_initialize();
+	
 	/*
 	 * Init array of Latches  in SHMEM for WAITLSN
 	 */

src/backend/storage/lmgr/lwlocknames.txt

@@ -47,3 +47,4 @@ CommitTsLock						39
 ReplicationOriginLock				40
 MultiXactTruncationLock				41
 OldSnapshotTimeMapLock				42
+CfsGcLock                           43

src/backend/utils/misc/guc.c

@@ -10859,12 +10859,14 @@ static void set_cfs_gc_enabled(bool newval, void* extra)
 {
 	cfs_gc_enabled = newval;
 	if (cfs_state && MyProcPid == PostmasterPid) 
-		cfs_control_gc(newval);
+	{
+		cfs_state->gc_enabled = newval;
+	}
 }
 
 static char const* show_cfs_gc_enabled(void)
 {
-	return cfs_gc_enabled ? "on" : "off";
+	return (cfs_state ? cfs_state->gc_enabled : cfs_gc_enabled) ? "on" : "off";
 }
 
 

src/include/storage/cfs.h

@@ -119,6 +119,7 @@ int      cfs_msync(FileMap* map);
 FileMap* cfs_mmap(int md);
 int      cfs_munmap(FileMap* map);
 void     cfs_initialize(void);
+int      cfs_shmem_size(void);
 
 void     cfs_encrypt(const char* fname, void* block, uint32 offs, uint32 size);
 void     cfs_decrypt(const char* fname, void* block, uint32 offs, uint32 size);