Navigation Menu

Skip to content

Commit

Permalink
OSLO updates for stable
Browse files Browse the repository at this point in the history
Fixes bug 1172922
Fixes bug 1159889
Fixes bug 1158319

Change-Id: I6257b5636b7b98d26ee43cbbf6087d9279a5b97c
  • Loading branch information
Gary Kotton committed May 6, 2013
1 parent 0602bac commit 5a86b4e
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 10 deletions.
17 changes: 9 additions & 8 deletions quantum/openstack/common/rpc/impl_qpid.py
Expand Up @@ -40,8 +40,8 @@
cfg.StrOpt('qpid_hostname',
default='localhost',
help='Qpid broker hostname'),
cfg.StrOpt('qpid_port',
default='5672',
cfg.IntOpt('qpid_port',
default=5672,
help='Qpid broker port'),
cfg.ListOpt('qpid_hosts',
default=['$qpid_hostname:$qpid_port'],
Expand Down Expand Up @@ -331,15 +331,16 @@ def _lookup_consumer(self, receiver):

def reconnect(self):
"""Handles reconnecting and re-establishing sessions and queues"""
if self.connection.opened():
try:
self.connection.close()
except qpid_exceptions.ConnectionError:
pass

attempt = 0
delay = 1
while True:
# Close the session if necessary
if self.connection.opened():
try:
self.connection.close()
except qpid_exceptions.ConnectionError:
pass

broker = self.brokers[attempt % len(self.brokers)]
attempt += 1

Expand Down
4 changes: 2 additions & 2 deletions quantum/openstack/common/rpc/matchmaker.py
Expand Up @@ -35,10 +35,10 @@
default='/etc/nova/matchmaker_ring.json',
help='Matchmaker ring file (JSON)'),
cfg.IntOpt('matchmaker_heartbeat_freq',
default='300',
default=300,
help='Heartbeat frequency'),
cfg.IntOpt('matchmaker_heartbeat_ttl',
default='600',
default=600,
help='Heartbeat time-to-live.'),
]

Expand Down
8 changes: 8 additions & 0 deletions quantum/openstack/common/setup.py
Expand Up @@ -171,6 +171,14 @@ def generate_authors():
" log --format='%aN <%aE>' | sort -u | "
"egrep -v '" + jenkins_email + "'")
changelog = _run_shell_command(git_log_cmd)
signed_cmd = ("git log --git-dir=" + git_dir +
" | grep -i Co-authored-by: | sort -u")
signed_entries = _run_shell_command(signed_cmd)
if signed_entries:
new_entries = "\n".join(
[signed.split(":", 1)[1].strip()
for signed in signed_entries.split("\n") if signed])
changelog = "\n".join((changelog, new_entries))
mailmap = _parse_git_mailmap(git_dir)
with open(new_authors, 'w') as new_authors_fh:
new_authors_fh.write(canonicalize_emails(changelog, mailmap))
Expand Down

0 comments on commit 5a86b4e

Please sign in to comment.