docs: answers to the woke police

docs/source/AdministratorGuide/Introduction/configurationbasics.rst

@@ -16,7 +16,7 @@ Normally, services are always exposed on the same port, which is defined in the
 
 As a general rule, services can be duplicated,
 meaning you can have the same service running on multiple hosts, thus reducing the load.
-There are only 2 cases of DIRAC services that have a "master/slave" concept, and these are the Configuration Service
+There are only 2 cases of DIRAC services that have a "controller/worker" concept, and these are the Configuration Service
 and the Accounting/DataStore service.
 The WorkloadManagement/Matcher service should also not be duplicated.
 

docs/source/AdministratorGuide/ServerInstallations/InstallingDiracServer.rst

@@ -443,7 +443,7 @@ operation is the registration of the new host in the already functional Configur
 
         #
         #   These options define the DIRAC components being installed on "this" DIRAC server.
-        #   The simplest option is to install a slave of the Configuration Server and a
+        #   The simplest option is to install a worker of the Configuration Server and a
         #   SystemAdministrator for remote management.
         #
         #  The following options defined components to be installed

docs/source/AdministratorGuide/ServerInstallations/scalingAndLimitations.rst

@@ -90,11 +90,11 @@ Services
 +--------------------+---------------------------------------------------------------------------------------------------+-------------+---------------------------------------------------------------------------+-----------+
 | **System**         | **Component**                                                                                     |**Duplicate**| **Remarque**                                                              | **HTTPs** +
 +--------------------+---------------------------------------------------------------------------------------------------+-------------+---------------------------------------------------------------------------+-----------+
-| Accounting         | :mod:`DataStore <DIRAC.AccountingSystem.Service.DataStoreHandler>`                                | PARTIAL     | One master and helpers (See :ref:`datastorehelpers`)                      |           +
+| Accounting         | :mod:`DataStore <DIRAC.AccountingSystem.Service.DataStoreHandler>`                                | PARTIAL     | One controller and helpers (See :ref:`datastorehelpers`)                      |           +
 +                    +---------------------------------------------------------------------------------------------------+-------------+---------------------------------------------------------------------------+-----------+
 |                    | :mod:`ReportGenerator <DIRAC.AccountingSystem.Service.ReportGeneratorHandler>`                    |             |                                                                           |           +
 +--------------------+---------------------------------------------------------------------------------------------------+-------------+---------------------------------------------------------------------------+-----------+
-| Configuration      | :mod:`Configuration <DIRAC.ConfigurationSystem.Service.ConfigurationHandler>`                     | PARTIAL     | One master (rw) and slaves (ro). It's advised to have several CS slaves   | YES       +
+| Configuration      | :mod:`Configuration <DIRAC.ConfigurationSystem.Service.ConfigurationHandler>`                     | PARTIAL     | One controller (rw) and workers (ro). Should have several CS workers      | YES       +
 +--------------------+---------------------------------------------------------------------------------------------------+-------------+---------------------------------------------------------------------------+-----------+
 | DataManagement     | :mod:`DataIntegrity <DIRAC.DataManagementSystem.Service.DataIntegrityHandler>`                    | YES         |                                                                           | YES       +
 +                    +---------------------------------------------------------------------------------------------------+-------------+---------------------------------------------------------------------------+-----------+

docs/source/AdministratorGuide/Systems/Configuration/index.rst

@@ -5,22 +5,22 @@ Configuration System
 ====================
 
 The configuration system serves the configuration to any other client (be it another server or a standard client).
-The infrastructure is master/slave based.
+The infrastructure is controller/worker based.
 
-******
-Master
-******
+**********
+Controller
+**********
 
-The master Server holds the central configuration in a local file. This file is then served to the clients, and synchronized with the slave servers.
+The controller Server holds the central configuration in a local file. This file is then served to the clients, and synchronized with the worker servers.
 
-the master server also regularly pings the slave servers to make sure they are still alive. If not, they are removed from the list of CS.
+the controller server also regularly pings the worker servers to make sure they are still alive. If not, they are removed from the list of CS.
 
-When changes are committed to the master, a backup of the existing configuration file is made in ``etc/csbackup``.
+When changes are committed to the controller, a backup of the existing configuration file is made in ``etc/csbackup``.
 
-******
-Slaves
-******
+*******
+Workers
+*******
 
-Slave server registers themselves to the master when starting.
+worker server registers themselves to the controller when starting.
 They synchronize their configuration on a regular bases (every 5 minutes by default).
-Note that the slave CS do not hold the configuration in a local file, but only in memory.
+Note that the worker CS do not hold the configuration in a local file, but only in memory.

docs/source/DeveloperGuide/Overview/index.rst

@@ -132,7 +132,7 @@ Configuration Service
 The Configuration Service is built in the DISET framework to provide static configuration parameters to
 all the distributed DIRAC components. This is the backbone of the whole system and necessitates excellent
 reliability. Therefore, it is organized as a single master service where all the parameter
-updates are done and multiple read-only slave services which are distributed geographically, on VO-boxes
+updates are done and multiple read-only worker services which are distributed geographically, on VO-boxes
 at Tier-1 LCG sites in the case of LHCb. All the servers are queried by clients in a load balancing way.
 This arrangement ensures configuration data consistency together with very good scalability properties.
 

docs/source/DeveloperGuide/Systems/RequestManagement/index.rst

@@ -201,7 +201,7 @@ The agent will try to execute request as a whole in one go.
    :alt: Treating of Request in the RequestExecutionAgent.
    :align: center
 
-The `RequestExecutingAgent` is using the `ProcessPool` utility to create slave workers (subprocesses running `RequestTask`)
+The `RequestExecutingAgent` is using the `ProcessPool` utility to create workers (subprocesses running `RequestTask`)
 designated to execute requests read from `ReqDB`. Each worker is processing request execution using following steps:
 
   * downloading and setting up request's owner proxy

src/DIRAC/AccountingSystem/Service/DataStoreHandler.py

@@ -1,6 +1,6 @@
 """ DataStore is the service for inserting accounting reports (rows) in the Accounting DB
 
-    This service CAN be duplicated iff the first is a "master" and all the others are slaves.
+    This service CAN be duplicated iff the first is a "controller" and all the others are workers.
     See the information about :ref:`datastorehelpers`.
 
 .. literalinclude:: ../ConfigTemplate.cfg
@@ -171,7 +171,7 @@ def export_compactDB(self):
         """
         Compact the db by grouping buckets
         """
-        # if we are running slaves (not only one service) we can redirect the request to the master
+        # if we are running workers (not only one service) we can redirect the request to the master
         # For more information please read the Administrative guide Accounting part!
         # ADVICE: If you want to trigger the bucketing, please make sure the bucketing is not running!!!!
         if self.runBucketing:

src/DIRAC/ConfigurationSystem/Agent/Bdii2CSAgent.py

@@ -103,7 +103,7 @@ def execute(self):
         if not result["OK"]:
             self.log.warn("Could not download a fresh copy of the CS data", result["Message"])
 
-        # Refresh the configuration from the master server
+        # Refresh the configuration from the controller server
         gConfig.forceRefresh(fromMaster=True)
 
         if self.processCEs:

src/DIRAC/ConfigurationSystem/Client/CSAPI.py

@@ -98,7 +98,7 @@ def initialize(self):
             return self.__initialized
         retVal = gConfig.getOption("/DIRAC/Configuration/MasterServer")
         if not retVal["OK"]:
-            self.__initialized = S_ERROR("Master server is not known. Is everything initialized?")
+            self.__initialized = S_ERROR("Controller server is not known. Is everything initialized?")
             return self.__initialized
         self.__rpcClient = ConfigurationClient(url=gConfig.getValue("/DIRAC/Configuration/MasterServer", ""))
         self.__csMod = Modificator(
@@ -925,7 +925,7 @@ def getCurrentCFG(self):
     def showDiff(self):
         """Just shows the differences accumulated within the Modificator object"""
         diffData = self.__csMod.showCurrentDiff()
-        gLogger.notice("Accumulated diff with master CS")
+        gLogger.notice("Accumulated diff with Controller CS")
         for line in diffData:
             if line[0] in ("+", "-"):
                 gLogger.notice(line)

src/DIRAC/ConfigurationSystem/Client/CSCLI.py

@@ -43,7 +43,7 @@ class CSCLI(CLI):
     def __init__(self):
         CLI.__init__(self)
         self.connected = False
-        self.masterURL = "unset"
+        self.controllerURL = "unset"
         self.writeEnabled = False
         self.modifiedData = False
         self.rpcClient = None
@@ -83,11 +83,11 @@ def _setConnected(self, connected, writeEnabled):
         self.writeEnabled = writeEnabled
         if connected:
             if writeEnabled:
-                self.prompt = f"({self.masterURL})-{colorize('Connected', 'green')}> "
+                self.prompt = f"({self.controllerURL})-{colorize('Connected', 'green')}> "
             else:
-                self.prompt = f"({self.masterURL})-{colorize('Connected (RO)', 'yellow')}> "
+                self.prompt = f"({self.controllerURL})-{colorize('Connected (RO)', 'yellow')}> "
         else:
-            self.prompt = f"({self.masterURL})-{colorize('Disconnected', 'red')}> "
+            self.prompt = f"({self.controllerURL})-{colorize('Disconnected', 'red')}> "
 
     def do_quit(self, dummy):
         """
@@ -104,7 +104,7 @@ def do_quit(self, dummy):
 
     def _setStatus(self, connected=True):
         if not connected:
-            self.masterURL = "unset"
+            self.controllerURL = "unset"
             self._setConnected(False, False)
         else:
             retVal = self.rpcClient.writeEnabled()
@@ -118,23 +118,23 @@ def _setStatus(self, connected=True):
                 self._setConnected(True, False)
 
     def _tryConnection(self):
-        print(f"Trying connection to {self.masterURL}")
+        print(f"Trying connection to {self.controllerURL}")
         try:
-            self.rpcClient = ConfigurationClient(url=self.masterURL)
+            self.rpcClient = ConfigurationClient(url=self.controllerURL)
             self._setStatus()
         except Exception as x:
-            gLogger.error("Couldn't connect to master CS server", f"{self.masterURL} ({str(x)})")
+            gLogger.error("Couldn't connect to controller CS server", f"{self.controllerURL} ({str(x)})")
             self._setStatus(False)
 
     def do_connect(self, args=""):
         """
-        Connects to configuration master server (in specified url if provided).
+        Connects to configuration controller server (in specified url if provided).
 
         Usage: connect <url>
         """
         if not args or not isinstance(args, str):
-            self.masterURL = gConfigurationData.getMasterServer()
-            if self.masterURL != "unknown" and self.masterURL:
+            self.controllerURL = gConfigurationData.getMasterServer()
+            if self.controllerURL != "unknown" and self.controllerURL:
                 self._tryConnection()
             else:
                 self._setStatus(False)
@@ -144,7 +144,7 @@ def do_connect(self, args=""):
                 print("Must specify witch url to connect")
                 self._setStatus(False)
             else:
-                self.masterURL = splitted[0].strip()
+                self.controllerURL = splitted[0].strip()
                 self._tryConnection()
 
     def do_sections(self, args):
@@ -247,7 +247,7 @@ def do_writeToServer(self, dummy):
             choice = input("Do you really want to send changes to server? yes/no [no]: ")
             choice = choice.lower()
             if choice in ("yes", "y"):
-                print(f"Uploading changes to {self.masterURL} (It may take some seconds)...")
+                print(f"Uploading changes to {self.controllerURL} (It may take some seconds)...")
                 response = self.modificator.commit()
                 if response["OK"]:
                     self.modifiedData = False

src/DIRAC/ConfigurationSystem/Client/ConfigurationClient.py

@@ -63,7 +63,7 @@ class ConfigurationClient(Client):
 
     def __init__(self, **kwargs):
         # By default we use Configuration/Server as url, client do the resolution
-        # In some case url has to be static (when a slave register to the master server for example)
+        # In some case url has to be static (when a worker register to the controller server for example)
         # It's why we can use 'url' as keyword arguments
         if "url" not in kwargs:
             kwargs["url"] = "Configuration/Server"

src/DIRAC/ConfigurationSystem/Service/TornadoConfigurationHandler.py

@@ -59,9 +59,9 @@ def export_getCompressedDataIfNewer(self, sClientVersion):
 
     def export_publishSlaveServer(self, sURL):
         """
-        Used by slave server to register as a slave server.
+        Used by worker server to register as a worker server.
 
-        :param sURL: The url of the slave server.
+        :param sURL: The url of the worker server.
         """
         self.ServiceInterface.publishSlaveServer(sURL)
         return S_OK()

src/DIRAC/ConfigurationSystem/private/Refresher.py

@@ -70,7 +70,7 @@ def autoRefreshAndPublish(self, sURL):
         """
         gLogger.debug("Setting configuration refresh as automatic")
         if not gConfigurationData.getAutoPublish():
-            gLogger.debug("Slave server won't auto publish itself")
+            gLogger.debug("Worker server won't auto publish itself")
         if not gConfigurationData.getName():
             import DIRAC
 

src/DIRAC/ConfigurationSystem/private/RefresherBase.py

@@ -1,13 +1,11 @@
 import time
-import random
-
 
 from DIRAC.ConfigurationSystem.Client.ConfigurationData import gConfigurationData
 from DIRAC.ConfigurationSystem.Client.PathFinder import getGatewayURLs
-from DIRAC.FrameworkSystem.Client.Logger import gLogger
 from DIRAC.Core.Utilities import List
 from DIRAC.Core.Utilities.EventDispatcher import gEventDispatcher
-from DIRAC.Core.Utilities.ReturnValues import S_OK, S_ERROR
+from DIRAC.Core.Utilities.ReturnValues import S_ERROR, S_OK
+from DIRAC.FrameworkSystem.Client.Logger import gLogger
 
 
 def _updateFromRemoteLocation(serviceClient):
@@ -90,29 +88,31 @@ def _refreshAndPublish(self):
         Refresh configuration and publish local updates
         """
         self._lastUpdateTime = time.time()
-        gLogger.info("Refreshing from master server")
-        sMasterServer = gConfigurationData.getMasterServer()
-        if sMasterServer:
+        gLogger.info("Refreshing from controller server")
+        sControllerServer = gConfigurationData.getMasterServer()
+        if sControllerServer:
             from DIRAC.ConfigurationSystem.Client.ConfigurationClient import ConfigurationClient
 
             oClient = ConfigurationClient(
-                url=sMasterServer,
+                url=sControllerServer,
                 timeout=self._timeout,
                 useCertificates=gConfigurationData.useServerCertificate(),
                 skipCACheck=gConfigurationData.skipCACheck(),
             )
             dRetVal = _updateFromRemoteLocation(oClient)
             if not dRetVal["OK"]:
-                gLogger.error("Can't update from master server", dRetVal["Message"])
+                gLogger.error("Can't update from controller server", dRetVal["Message"])
                 return False
             if gConfigurationData.getAutoPublish():
-                gLogger.info("Publishing to master server...")
+                gLogger.info("Publishing to controller server...")
                 dRetVal = oClient.publishSlaveServer(self._url)
                 if not dRetVal["OK"]:
-                    gLogger.error("Can't publish to master server", dRetVal["Message"])
+                    gLogger.error("Can't publish to controller server", dRetVal["Message"])
             return True
         else:
-            gLogger.warn("No master server is specified in the configuration, trying to get data from other slaves")
+            gLogger.warn(
+                "No controller server is specified in the configuration, trying to get data from other Workers"
+            )
             return self._refresh()["OK"]
 
     def _refresh(self, fromMaster=False):
@@ -127,9 +127,9 @@ def _refresh(self, fromMaster=False):
             initialServerList = gatewayList
             gLogger.debug("Using configuration gateway", str(initialServerList[0]))
         elif fromMaster:
-            masterServer = gConfigurationData.getMasterServer()
-            initialServerList = [masterServer]
-            gLogger.debug(f"Refreshing from master {masterServer}")
+            controllerServer = gConfigurationData.getMasterServer()
+            initialServerList = [controllerServer]
+            gLogger.debug(f"Refreshing from controller {controllerServer}")
         else:
             initialServerList = gConfigurationData.getServers()
             gLogger.debug(f"Refreshing from list {str(initialServerList)}")

src/DIRAC/ConfigurationSystem/private/ServiceInterface.py

@@ -11,44 +11,44 @@
 
 class ServiceInterface(ServiceInterfaceBase, threading.Thread):
     """
-    Service interface, manage Slave/Master server for CS
+    Service interface, manage Worker/Controller server for CS
     Thread components
     """
 
     def __init__(self, sURL):
         threading.Thread.__init__(self)
         ServiceInterfaceBase.__init__(self, sURL)
 
-    def _launchCheckSlaves(self):
+    def _launchCheckWorkers(self):
         """
-        Start loop which check if slaves are alive
+        Start loop which check if Workers are alive
         """
-        gLogger.info("Starting purge slaves thread")
+        gLogger.info("Starting purge Workers thread")
         self.daemon = True
         self.start()
 
     def run(self):
         while True:
             iWaitTime = gConfigurationData.getSlavesGraceTime()
             time.sleep(iWaitTime)
-            self._checkSlavesStatus()
+            self._checkWorkersStatus()
 
-    def _updateServiceConfiguration(self, urlSet, fromMaster=False):
+    def _updateServiceConfiguration(self, urlSet, fromController=False):
         """
-        Update configuration of a set of slave services in parallel
+        Update configuration of a set of Worker services in parallel
 
         :param set urlSet: a set of service URLs
-        :param fromMaster: flag to force updating from the master CS
+        :param fromController: flag to force updating from the master CS
         :return: Nothing
         """
         if not urlSet:
             return
         with ThreadPoolExecutor(max_workers=len(urlSet)) as executor:
-            futureUpdate = {executor.submit(self._forceServiceUpdate, url, fromMaster): url for url in urlSet}
+            futureUpdate = {executor.submit(self._forceServiceUpdate, url, fromController): url for url in urlSet}
             for future in as_completed(futureUpdate):
                 url = futureUpdate[future]
                 result = future.result()
                 if result["OK"]:
-                    gLogger.info("Successfully updated slave configuration", url)
+                    gLogger.info("Successfully updated Worker configuration", url)
                 else:
-                    gLogger.error("Failed to update slave configuration", url)
+                    gLogger.error("Failed to update Worker configuration", url)