x/solar
Code Issues Proposed changes

Redis: fix tests

Browse Source
This commit is contained in:
Przemyslaw Kaminski 2015-06-09 09:40:50 +02:00
parent 9dce970909
commit 8dd75ed449
2 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
jenkins-config.yaml
View File

@ -1 +1,4 @@
clients-data-file: /tmp/connections.yaml clients-data-file: /tmp/connections.yaml
file-system-db:
storage-path: /tmp/storage

26
solar/solar/core/observer.py
View File

@ -17,18 +17,18 @@ class BaseObserver(object):
self.attached_to = attached_to self.attached_to = attached_to
self.name = name self.name = name
self.value = value self.value = value
#self.receivers = [] self.receivers = []
@property # @property
def receivers(self): # def receivers(self):
from solar.core import resource # from solar.core import resource
#
signals.CLIENTS = signals.Connections.read_clients() # signals.CLIENTS = signals.Connections.read_clients()
for receiver_name, receiver_input in signals.Connections.receivers( # for receiver_name, receiver_input in signals.Connections.receivers(
self.attached_to.name, # self.attached_to.name,
self.name # self.name
): # ):
yield resource.load(receiver_name).args[receiver_input] # yield resource.load(receiver_name).args[receiver_input]
def log(self, msg): def log(self, msg):
print '{} {}'.format(self, msg) print '{} {}'.format(self, msg)
@ -76,7 +76,7 @@ class BaseObserver(object):
if self.find_receiver(receiver): if self.find_receiver(receiver):
self.log('No multiple subscriptions from {}'.format(receiver)) self.log('No multiple subscriptions from {}'.format(receiver))
return return
#self.receivers.append(receiver) self.receivers.append(receiver)
receiver.subscribed(self) receiver.subscribed(self)
signals.Connections.add( signals.Connections.add(
@ -98,7 +98,7 @@ class BaseObserver(object):
""" """
self.log('Unsubscribe {}'.format(receiver)) self.log('Unsubscribe {}'.format(receiver))
if self.find_receiver(receiver): if self.find_receiver(receiver):
#self.receivers.remove(receiver) self.receivers.remove(receiver)
receiver.unsubscribed(self) receiver.unsubscribed(self)
signals.Connections.remove( signals.Connections.remove(