Add the node_heartbeat signal

This commit is contained in:
Roberto Rosario
2012-08-03 14:55:03 -04:00
parent 784aff8ded
commit ecd88553e4
3 changed files with 6 additions and 3 deletions

View File

@@ -5,6 +5,7 @@ import logging
from lock_manager.decorators import simple_locking
from .models import Node, ClusteringConfig
from .signals import node_heartbeat
LOCK_EXPIRE = 10
@@ -12,10 +13,11 @@ logger = logging.getLogger(__name__)
@simple_locking('node_heartbeat', 10)
def node_heartbeat():
def send_heartbeat():
logger.debug('starting')
node = Node.objects.myself()
node.send_heartbeat()
node_heartbeat.send(sender=node, node=node)
@simple_locking('house_keeping', 10)