mirror of
https://github.com/freedombox/FreedomBox.git
synced 2026-06-03 10:50:20 +00:00
cde0b47064
- Implemented `email_server ipc postconf_set_many_v1` - Implemented `lock.Mutex` (fcntl.lockf and threading.Lock based mutex) - FIXME: Lock file permissions - Implemented `postconf` (thread-safe postconf operations) - Started using service orientation
40 lines
1.1 KiB
Python
40 lines
1.1 KiB
Python
# SPDX-License-Identifier: AGPL-3.0-or-later
|
|
import contextlib
|
|
import fcntl
|
|
import os
|
|
import threading
|
|
|
|
|
|
class Mutex:
|
|
"""File and pthread lock based resource mutex"""
|
|
|
|
def __init__(self, lock_file):
|
|
self.thread_mutex = threading.Lock()
|
|
self.lock_path = '/var/lock/' + lock_file
|
|
|
|
@contextlib.contextmanager
|
|
def lock_threads_only(self):
|
|
"""Acquire the thread lock but not the file lock"""
|
|
self.thread_mutex.acquire(timeout=5)
|
|
try:
|
|
yield
|
|
finally:
|
|
self.thread_mutex.release()
|
|
|
|
@contextlib.contextmanager
|
|
def lock_all(self):
|
|
"""Acquire both the thread lock and the file lock"""
|
|
with self.lock_threads_only():
|
|
fd = open(self.lock_path, 'wb')
|
|
# FIXME: Who can lock?
|
|
try:
|
|
os.fchmod(fd.fileno(), 0o666) # rw-rw-rw-
|
|
except OSError:
|
|
pass
|
|
fcntl.lockf(fd, fcntl.LOCK_EX)
|
|
try:
|
|
yield
|
|
finally:
|
|
fcntl.lockf(fd, fcntl.LOCK_UN)
|
|
fd.close()
|