mirrors/synapse
1
0
Fork 0
mirror of https://github.com/matrix-org/synapse.git synced 2025-10-31 08:11:24 +01:00
Code Issues Projects Releases Wiki Activity

Move makedirs to thread

Browse Source
This commit is contained in:
Erik Johnston 2017-10-13 10:25:01 +01:00
parent b60859d6cc
commit 64db043a71
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
synapse/rest/media/v1/media_repository.py
View File

@ -98,6 +98,7 @@ class MediaRepository(object):
@staticmethod @staticmethod
def _write_file_synchronously(source, fname, close_source=False): def _write_file_synchronously(source, fname, close_source=False):
MediaRepository._makedirs(fname)
source.seek(0) # Ensure we read from the start of the file source.seek(0) # Ensure we read from the start of the file
with open(fname, "wb") as f: with open(fname, "wb") as f:
shutil.copyfileobj(source, f) shutil.copyfileobj(source, f)
@ -120,7 +121,6 @@ class MediaRepository(object):
string: the file path written to in the primary media store string: the file path written to in the primary media store
""" """
fname = os.path.join(self.primary_base_path, path) fname = os.path.join(self.primary_base_path, path)
self._makedirs(fname)
# Write to the main repository # Write to the main repository
yield make_deferred_yieldable( yield make_deferred_yieldable(
@ -141,7 +141,6 @@ class MediaRepository(object):
""" """
if self.backup_base_path: if self.backup_base_path:
backup_fname = os.path.join(self.backup_base_path, path) backup_fname = os.path.join(self.backup_base_path, path)
self._makedirs(backup_fname)
# We can either wait for successful writing to the backup repository # We can either wait for successful writing to the backup repository
# or write in the background and immediately return # or write in the background and immediately return