def __iq(self, t="get"):
iq = domish.Element((None, "iq"))
iq['from'] = self.id.full()
- iq['to'] = "pubsub.vplc27.inria.fr"
+ iq['to'] = "pubsub.%s" % self.id.host
iq['type'] = t
iq.addUniqueId()
return iq
for i in iq.query.elements():
node = i['node']
if node.startswith(resource_prefix):
- self.command_que.put(self.delete_node, node)
+ self.command_queue.put((self.delete_node, node))
self.add_result_hook("discover", delete_slice_resources)
self.discover()
t = task.LoopingCall(slicemgr.flush_commands)
t.start(5.0) # check every 5 seconds
+
+ reactor.callLater(1, slicemgr.create_node, "/OMF")
+ reactor.callLater(1, slicemgr.create_node, "/OMF/SYSTEM")
+
reactor.connectTCP(slicemgr.id.host, 5222, slicemgr.factory)
reactor.listenTCP(5053, server.Site(slicemgr), interface="localhost")
reactor.run(installSignalHandlers=True)