nik/FreedomBox
1
0
Fork 0
mirror of https://github.com/freedombox/FreedomBox.git synced 2026-09-19 04:59:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Inverted consuming dictionary.

Browse Source 
It now has the same structure as the hosting dictionary, making
generalized data processing *much* easier.  Inverting one was an
interesting experiment, but one that didn't pan out.
This commit is contained in:
Nick Daly 2012-05-29 18:27:34 -05:00
parent db2186f2ca
commit f5c38fdf8c
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
ugly_hacks/santiago/santiago.py
View File

@ -109,7 +109,7 @@ class Santiago(object):
hosting: { "someKey": { "someService": ( "http://a.list", hosting: { "someKey": { "someService": ( "http://a.list",
"http://of.locations" )}} "http://of.locations" )}}
consuming: { "someService": { "someKey": ( "http://a.list", consuming: { "someKey": { "someService": ( "http://a.list",
"http://of.locations" )}} "http://of.locations" )}}
Messages are delivered by defining both the source and destination Messages are delivered by defining both the source and destination
@ -200,6 +200,8 @@ class Santiago(object):
def __exit__(self, exc_type, exc_value, traceback): def __exit__(self, exc_type, exc_value, traceback):
"""Clean up and save all data to shut down the service.""" """Clean up and save all data to shut down the service."""
debug_log("Stopping Santiago.")
for connector in (list(self.listeners.itervalues()) + for connector in (list(self.listeners.itervalues()) +
list(self.senders.itervalues())): list(self.senders.itervalues())):
connector.stop() connector.stop()
@ -217,15 +219,14 @@ class Santiago(object):
def learn_service(self, host, service, locations): def learn_service(self, host, service, locations):
"""Learn a service somebody else hosts for me.""" """Learn a service somebody else hosts for me."""
if service not in self.consuming: if host not in self.consuming:
self.consuming[service] = dict() self.consuming[host] = dict()
if host not in self.consuming[service]: if service not in self.consuming[host]:
self.consuming[service][host] = set() self.consuming[host][service] = set()
if locations: if locations:
self.consuming[service][host] = ( self.consuming[host][service] |= locations
self.consuming[service][host] | locations)
def provide_service(self, client, service, locations): def provide_service(self, client, service, locations):
"""Start hosting a service for somebody else.""" """Start hosting a service for somebody else."""
@ -255,7 +256,7 @@ class Santiago(object):
"""Return where the host serves the service for me, the client.""" """Return where the host serves the service for me, the client."""
try: try:
return self.consuming[service][host] return self.consuming[host][service]
except KeyError as e: except KeyError as e:
logging.exception(e) logging.exception(e)
@ -692,7 +693,7 @@ if __name__ == "__main__":
senders = { "https": { "proxy_host": "localhost", senders = { "https": { "proxy_host": "localhost",
"proxy_port": 8118} } "proxy_port": 8118} }
hosting = { mykey: { "santiago": set( ["https://localhost:8080"] )}} hosting = { mykey: { "santiago": set( ["https://localhost:8080"] )}}
consuming = { "santiago": { mykey: set( ["https://localhost:8080"] )}} consuming = { mykey: { "santiago": set( ["https://localhost:8080"] )}}
santiago = Santiago(listeners, senders, santiago = Santiago(listeners, senders,
hosting, consuming, hosting, consuming,