bah

Signed-off-by: Olivier Wilkinson (reivilibre) <oliverw@matrix.org>

.github/workflows/tests.yml

@@ -499,7 +499,7 @@ jobs:
 
       - run: |
           set -o pipefail
-          POSTGRES=${{ (matrix.database == 'Postgres') && 1 || '' }} WORKERS=${{ (matrix.arrangement == 'workers') && 1 || '' }} COMPLEMENT_DIR=`pwd`/complement synapse/scripts-dev/complement.sh -json 2>&1 | synapse/.ci/scripts/gotestfmt
+          POSTGRES=${{ (matrix.database == 'Postgres') && 1 || '' }} WORKERS=${{ (matrix.arrangement == 'workers') && 1 || '' }} COMPLEMENT_DIR=`pwd`/complement COMPLEMENT_ALWAYS_PRINT_SERVER_LOGS=1 synapse/scripts-dev/complement.sh -json -run TestFed 2>&1 | synapse/.ci/scripts/gotestfmt
         shell: bash
         name: Run Complement Tests
 

changelog.d/14416.misc

@@ -0,0 +1 @@
+WIP CI Testing only.

docker/configure_workers_and_start.py

@@ -210,7 +210,7 @@ WORKERS_CONFIG: Dict[str, Dict[str, Any]] = {
     },
     "frontend_proxy": {
         "app": "synapse.app.generic_worker",
-        "listener_resources": ["client", "replication"],
+        "listener_resources": ["client"],
         "endpoint_patterns": ["^/_matrix/client/(api/v1|r0|v3|unstable)/keys/upload"],
         "shared_extra_conf": {},
         "worker_extra_conf": (

synapse/app/generic_worker.py

@@ -14,6 +14,7 @@
 # limitations under the License.
 import logging
 import sys
+import time
 from typing import Dict, List, Optional, Tuple
 
 from twisted.internet import address
@@ -393,6 +394,7 @@ class GenericWorkerServer(HomeServer):
         logger.info("Synapse worker now listening on port %d", port)
 
     def start_listening(self) -> None:
+        start = time.time()
         for listener in self.config.worker.worker_listeners:
             if listener.type == "http":
                 self._listen_http(listener)
@@ -418,6 +420,9 @@ class GenericWorkerServer(HomeServer):
             else:
                 logger.warning("Unsupported listener type: %s", listener.type)
 
+        end = time.time()
+        logger.error("TIMING start_listening %.6f", end - start)
+
         self.get_replication_command_handler().start_replication(self)