Implement feature #7682 : Firebird 5 - use ParallelWorkers setting fr…

…om firebird.conf as default for all parallelised operations
FirebirdSQL · Jul 27, 2023 · 9ca1372 · 9ca1372
1 parent 7b130a4
commit 9ca1372
Show file tree

Hide file tree

Showing 8 changed files with 12 additions and 4 deletions.
diff --git a/src/alice/alice.cpp b/src/alice/alice.cpp
@@ -146,6 +146,7 @@ int alice(Firebird::UtilSvc* uSvc)
 #ifdef TRUSTED_AUTH
 	tdgbl->ALICE_data.ua_trusted = false;
 #endif
+	tdgbl->ALICE_data.ua_parallel_workers = uSvc->getParallelWorkers();
 
 	//  Start by parsing switches
 

diff --git a/src/alice/exe.cpp b/src/alice/exe.cpp
@@ -325,7 +325,7 @@ static void buildDpb(Firebird::ClumpletWriter& dpb, const SINT64 switches)
 		dpb.insertByte(isc_dpb_set_db_replica, tdgbl->ALICE_data.ua_replica_mode);
 	}
 
-	if (switches & sw_parallel_workers) {
+	if (tdgbl->ALICE_data.ua_parallel_workers > 0) {
 		dpb.insertInt(isc_dpb_parallel_workers, tdgbl->ALICE_data.ua_parallel_workers);
 	}
 

diff --git a/src/burp/burp.cpp b/src/burp/burp.cpp
@@ -597,7 +597,7 @@ int gbak(Firebird::UtilSvc* uSvc)
 	tdgbl->gbl_sw_old_descriptions = false;
 	tdgbl->gbl_sw_mode = false;
 	tdgbl->gbl_sw_skip_count = 0;
-	tdgbl->gbl_sw_par_workers = 1;
+	tdgbl->gbl_sw_par_workers = uSvc->getParallelWorkers();
 	tdgbl->action = NULL;
 
 	burp_fil* file = NULL;

diff --git a/src/burp/restore.epp b/src/burp/restore.epp
@@ -1019,7 +1019,8 @@ void create_database(BurpGlobals* tdgbl, Firebird::IProvider* provider, const TE
 	}
 	else
 	{
-		dpb.insertInt(isc_dpb_parallel_workers, tdgbl->gbl_sw_par_workers);
+		if (tdgbl->gbl_sw_par_workers > 0)
+			dpb.insertInt(isc_dpb_parallel_workers, tdgbl->gbl_sw_par_workers);
 		dpb.insertByte(isc_dpb_shutdown, isc_dpb_shut_multi);
 	}
 	dpb.insertInt(isc_dpb_shutdown_delay, 0);

diff --git a/src/common/UtilSvc.cpp b/src/common/UtilSvc.cpp
@@ -147,6 +147,7 @@ class StandaloneUtilityInterface : public UtilSvc
 	virtual void initStatus() { }
 	virtual bool utf8FileNames() { return false; }
 	virtual Firebird::ICryptKeyCallback* getCryptCallback() { return NULL; }
+	virtual int getParallelWorkers() { return 0; };
 };
 
 

diff --git a/src/common/UtilSvc.h b/src/common/UtilSvc.h
@@ -77,6 +77,7 @@ class UtilSvc : public Firebird::GlobalStorage
 	virtual unsigned int getAuthBlock(const unsigned char** bytes) = 0;
 	virtual bool utf8FileNames() = 0;
 	virtual Firebird::ICryptKeyCallback* getCryptCallback() = 0;
+	virtual int getParallelWorkers() = 0;
 
 	void setDataMode(bool value)
 	{

diff --git a/src/jrd/svc.cpp b/src/jrd/svc.cpp
@@ -701,7 +701,7 @@ Service::Service(const TEXT* service_name, USHORT spb_length, const UCHAR* spb_d
 	svc_username(getPool()), svc_sql_role(getPool()), svc_auth_block(getPool()),
 	svc_expected_db(getPool()), svc_trusted_role(false), svc_utf8(false),
 	svc_switches(getPool()), svc_perm_sw(getPool()), svc_address_path(getPool()),
-	svc_command_line(getPool()),
+	svc_command_line(getPool()), svc_parallel_workers(0),
 	svc_network_protocol(getPool()), svc_remote_address(getPool()), svc_remote_process(getPool()),
 	svc_remote_pid(0), svc_trace_manager(NULL), svc_crypt_callback(crypt_callback),
 	svc_existence(FB_NEW_POOL(*getDefaultMemoryPool()) SvcMutex(this)),
@@ -731,6 +731,8 @@ Service::Service(const TEXT* service_name, USHORT spb_length, const UCHAR* spb_d
 		if (svcname == "@@@")
 			svc_debug = true;
 #endif
+		// Could be overrided in SPB
+		svc_parallel_workers = Config::getParallelWorkers();
 
 		// Process the service parameter block.
 		ClumpletReader spb(ClumpletReader::spbList, spb_data, spb_length, spbVersionError);

diff --git a/src/jrd/svc.h b/src/jrd/svc.h
@@ -146,6 +146,7 @@ class Service : public Firebird::UtilSvc, public TypedHandle<type_svc>
 	virtual bool utf8FileNames();
 	// get database encryption key transfer callback routine
 	virtual Firebird::ICryptKeyCallback* getCryptCallback();
+	virtual int getParallelWorkers() { return svc_parallel_workers; }
 
 	virtual TraceManager* getTraceManager()
 	{
@@ -324,6 +325,7 @@ class Service : public Firebird::UtilSvc, public TypedHandle<type_svc>
 	Firebird::string	svc_perm_sw;	// Switches, taken from services table and/or passed using spb_command_line
 	Firebird::UCharBuffer	svc_address_path;
 	Firebird::string	svc_command_line;
+	int					svc_parallel_workers;
 
 	Firebird::string	svc_network_protocol;
 	Firebird::string	svc_remote_address;