mirror of
https://github.com/ceph/ceph
synced 2024-12-29 06:52:35 +00:00
105 lines
2.5 KiB
Python
105 lines
2.5 KiB
Python
"""
|
|
Clock synchronizer
|
|
"""
|
|
import logging
|
|
import contextlib
|
|
|
|
from ..orchestra import run
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
@contextlib.contextmanager
|
|
def task(ctx, config):
|
|
"""
|
|
Sync or skew clock
|
|
|
|
This will initially sync the clocks. Eventually it should let us also
|
|
skew by some number of seconds.
|
|
|
|
example:
|
|
|
|
tasks:
|
|
- clock:
|
|
- ceph:
|
|
- interactive:
|
|
|
|
to sync.
|
|
|
|
:param ctx: Context
|
|
:param config: Configuration
|
|
"""
|
|
|
|
log.info('Syncing clocks and checking initial clock skew...')
|
|
for rem in ctx.cluster.remotes.iterkeys():
|
|
rem.run(
|
|
args=[
|
|
'sudo',
|
|
'service', 'ntp', 'stop',
|
|
run.Raw(';'),
|
|
'sudo',
|
|
'ntpdate',
|
|
# 'clock1.dreamhost.com',
|
|
# 'clock2.dreamhost.com',
|
|
# 'clock3.dreamhost.com',
|
|
# 'time.apple.com',
|
|
'0.debian.pool.ntp.org',
|
|
'1.debian.pool.ntp.org',
|
|
'2.debian.pool.ntp.org',
|
|
'3.debian.pool.ntp.org',
|
|
run.Raw(';'),
|
|
'sudo',
|
|
'service', 'ntp', 'start',
|
|
run.Raw(';'),
|
|
'PATH=/usr/bin:/usr/sbin',
|
|
'ntpdc', '-p',
|
|
],
|
|
logger=log.getChild(rem.name),
|
|
)
|
|
|
|
try:
|
|
yield
|
|
|
|
finally:
|
|
log.info('Checking final clock skew...')
|
|
for rem in ctx.cluster.remotes.iterkeys():
|
|
rem.run(
|
|
args=[
|
|
'PATH=/usr/bin:/usr/sbin',
|
|
'ntpdc', '-p',
|
|
],
|
|
logger=log.getChild(rem.name),
|
|
)
|
|
|
|
|
|
@contextlib.contextmanager
|
|
def check(ctx, config):
|
|
"""
|
|
Run ntpdc at the start and the end of the task.
|
|
|
|
:param ctx: Context
|
|
:param config: Configuration
|
|
"""
|
|
log.info('Checking initial clock skew...')
|
|
for rem in ctx.cluster.remotes.iterkeys():
|
|
rem.run(
|
|
args=[
|
|
'PATH=/usr/bin:/usr/sbin',
|
|
'ntpdc', '-p',
|
|
],
|
|
logger=log.getChild(rem.name),
|
|
)
|
|
|
|
try:
|
|
yield
|
|
|
|
finally:
|
|
log.info('Checking final clock skew...')
|
|
for rem in ctx.cluster.remotes.iterkeys():
|
|
rem.run(
|
|
args=[
|
|
'PATH=/usr/bin:/usr/sbin',
|
|
'ntpdc', '-p',
|
|
],
|
|
logger=log.getChild(rem.name),
|
|
)
|