Revision 41f2249e
| b/README.develop | ||
|---|---|---|
| 188 | 188 |
|
| 189 | 189 |
DB_HANDLER_KEY = 'ganeti.%s.#' % BACKEND_PREFIX_ID.split('-')[0]
|
| 190 | 190 |
BINDINGS[0] = ("events-%s" % BACKEND_PREFIX_ID.split('-')[0], EXCHANGE_GANETI, DB_HANDLER_KEY, 'update_db')
|
| 191 |
QUEUES += ("events-%s" % BACKEND_PREFIX_ID.split('-')[0], )
|
|
| 191 | 192 |
|
| 192 | 193 |
9. Start the system |
| 193 | 194 |
$ ./bin/python logic/dispatcher.py # DB synch daemon |
| b/logic/dispatcher.py | ||
|---|---|---|
| 67 | 67 |
self.logger.info("Attempting to connect to %s",
|
| 68 | 68 |
settings.RABBIT_HOST) |
| 69 | 69 |
try: |
| 70 |
conn = amqp.Connection( host=settings.RABBIT_HOST,
|
|
| 71 |
userid=settings.RABBIT_USERNAME, |
|
| 72 |
password=settings.RABBIT_PASSWORD, |
|
| 73 |
virtual_host=settings.RABBIT_VHOST) |
|
| 70 |
conn = amqp.Connection(host=settings.RABBIT_HOST, |
|
| 71 |
userid=settings.RABBIT_USERNAME,
|
|
| 72 |
password=settings.RABBIT_PASSWORD,
|
|
| 73 |
virtual_host=settings.RABBIT_VHOST)
|
|
| 74 | 74 |
except socket.error: |
| 75 | 75 |
time.sleep(1) |
| 76 | 76 |
pass |
| ... | ... | |
| 219 | 219 |
signal(SIGINT, _exit_handler) |
| 220 | 220 |
signal(SIGTERM, _exit_handler) |
| 221 | 221 |
child(sys.argv[1:], logger) |
| 222 |
time.sleep(5) |
|
| 223 | 222 |
sys.exit(0) |
| 224 | 223 |
else: |
| 225 | 224 |
pids = (os.getpid(), newpid) |
| ... | ... | |
| 231 | 230 |
signal(SIGINT, _parent_handler) |
| 232 | 231 |
signal(SIGTERM, _parent_handler) |
| 233 | 232 |
|
| 234 |
# Wait for the last child process to exit |
|
| 235 |
try: |
|
| 236 |
os.wait() |
|
| 237 |
except Exception : |
|
| 238 |
pass |
|
| 233 |
# Wait for all children process to die, one by one |
|
| 234 |
for c in children: |
|
| 235 |
try: |
|
| 236 |
os.wait() |
|
| 237 |
except Exception: |
|
| 238 |
pass |
|
| 239 | 239 |
|
| 240 | 240 |
|
| 241 | 241 |
if __name__ == "__main__": |
Also available in: Unified diff