33 lines
1.1 KiB
Python
33 lines
1.1 KiB
Python
import time
|
|
import threading
|
|
import Pyro4
|
|
import logging as log
|
|
|
|
DEFAULT_REFRESH_INTERVAL=(5 * 60)
|
|
PYRO4_URI="PYRO:058b7dde9ec53de9235cfc57a07ce17a9eabfce3@./u:/run/zfssmd.sock"
|
|
|
|
class ZFSSMDaemonRefresh(object):
|
|
"""
|
|
Spawns as thread to the daemon. Requests snapshot list refresh on interval.
|
|
"""
|
|
def __init__(self, interval=DEFAULT_REFRESH_INTERVAL, uri=PYRO4_URI):
|
|
"""
|
|
starts the thread
|
|
:param interval: interval to perform a request to daemon
|
|
:param uri: uri returned by Pyro4 daemon on launch
|
|
"""
|
|
self.interval = interval
|
|
self.uri = uri
|
|
|
|
thread = threading.Thread(target=self.run, args=())
|
|
thread.daemon = True
|
|
thread.start()
|
|
|
|
def run(self):
|
|
while True:
|
|
## FIXME Rework it as root process cursor if it's even possible to avoid RPC. For now it's not bad.
|
|
_uri = self.uri
|
|
zfssmd_connection = Pyro4.Proxy(_uri)
|
|
last_ref = zfssmd_connection.call_zfs_list_snapshots()
|
|
log.debug("Refreshed list " + str(last_ref))
|
|
time.sleep(self.interval) |