tileradotorg/synapse
1
0
Fork 0
forked from MirrorHub/synapse
Code Pull requests Activity

Merge pull request #1124 from matrix-org/erikj/enable_state_caching_workers

Browse source 
Enable state caches on workers
This commit is contained in:
Erik Johnston 2016-09-15 15:01:47 +01:00 committed by GitHub
commit 241d7d2d62
6 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
synapse/app/appservice.py
View file

@ -187,6 +187,7 @@ def start(config_options):
def start(): def start():
ps.replicate() ps.replicate()
ps.get_datastore().start_profiling() ps.get_datastore().start_profiling()
ps.get_state_handler().start_caching()
reactor.callWhenRunning(start) reactor.callWhenRunning(start)

1
synapse/app/client_reader.py
View file

@ -191,6 +191,7 @@ def start(config_options):
reactor.run() reactor.run()
def start(): def start():
ss.get_state_handler().start_caching()
ss.get_datastore().start_profiling() ss.get_datastore().start_profiling()
ss.replicate() ss.replicate()

1
synapse/app/federation_reader.py
View file

@ -182,6 +182,7 @@ def start(config_options):
reactor.run() reactor.run()
def start(): def start():
ss.get_state_handler().start_caching()
ss.get_datastore().start_profiling() ss.get_datastore().start_profiling()
ss.replicate() ss.replicate()

1
synapse/app/media_repository.py
View file

@ -188,6 +188,7 @@ def start(config_options):
reactor.run() reactor.run()
def start(): def start():
ss.get_state_handler().start_caching()
ss.get_datastore().start_profiling() ss.get_datastore().start_profiling()
ss.replicate() ss.replicate()

1
synapse/app/pusher.py
View file

@ -276,6 +276,7 @@ def start(config_options):
ps.replicate() ps.replicate()
ps.get_pusherpool().start() ps.get_pusherpool().start()
ps.get_datastore().start_profiling() ps.get_datastore().start_profiling()
ps.get_state_handler().start_caching()
reactor.callWhenRunning(start) reactor.callWhenRunning(start)

1
synapse/app/synchrotron.py
View file

@ -465,6 +465,7 @@ def start(config_options):
def start(): def start():
ss.get_datastore().start_profiling() ss.get_datastore().start_profiling()
ss.replicate() ss.replicate()
ss.get_state_handler().start_caching()
reactor.callWhenRunning(start) reactor.callWhenRunning(start)