Merge ~barryprice/charm-nrpe/+git/nrpe-charm:master into ~nrpe-charmers/charm-nrpe:master

Proposed by Barry Price
Status: Merged
Approved by: Junien F
Approved revision: da52077ebba6c2bba86a3f1310e66ad7f8fb8115
Merged at revision: 59f5025a825cd1c86ee9b9b71f1470a488820879
Proposed branch: ~barryprice/charm-nrpe/+git/nrpe-charm:master
Merge into: ~nrpe-charmers/charm-nrpe:master
Diff against target: 37 lines (+15/-6)
1 file modified
hooks/charmhelpers/core/services/base.py (+15/-6)
Reviewer Review Type Date Requested Status
Junien F Approve
Review via email: mp+337041@code.launchpad.net

Commit message

Restore our patch to charmhelpers

To post a comment you must log in.
Revision history for this message
🤖 Canonical IS Merge Bot (canonical-is-mergebot) wrote :

This merge proposal is being monitored by mergebot. Change the status to Approved to merge.

Revision history for this message
Junien F (axino) wrote :

+1

review: Approve
Revision history for this message
🤖 Canonical IS Merge Bot (canonical-is-mergebot) wrote :

Change successfully merged at revision 59f5025a825cd1c86ee9b9b71f1470a488820879

Preview Diff

[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
diff --git a/hooks/charmhelpers/core/services/base.py b/hooks/charmhelpers/core/services/base.py
index ca9dc99..345b60d 100644
--- a/hooks/charmhelpers/core/services/base.py
+++ b/hooks/charmhelpers/core/services/base.py
@@ -313,17 +313,26 @@ class PortManagerCallback(ManagerCallback):
313 with open(port_file) as fp:313 with open(port_file) as fp:
314 old_ports = fp.read().split(',')314 old_ports = fp.read().split(',')
315 for old_port in old_ports:315 for old_port in old_ports:
316 if bool(old_port):316 if bool(old_port) and not self.ports_contains(old_port, new_ports):
317 old_port = int(old_port)317 hookenv.close_port(old_port)
318 if old_port not in new_ports:
319 hookenv.close_port(old_port)
320 with open(port_file, 'w') as fp:318 with open(port_file, 'w') as fp:
321 fp.write(','.join(str(port) for port in new_ports))319 fp.write(','.join(str(port) for port in new_ports))
322 for port in new_ports:320 for port in new_ports:
321 # A port is either a number or 'ICMP'
322 protocol = 'TCP'
323 if str(port).upper() == 'ICMP':
324 protocol = 'ICMP'
323 if event_name == 'start':325 if event_name == 'start':
324 hookenv.open_port(port)326 hookenv.open_port(port, protocol)
325 elif event_name == 'stop':327 elif event_name == 'stop':
326 hookenv.close_port(port)328 hookenv.close_port(port, protocol)
329
330 def ports_contains(self, port, ports):
331 if not bool(port):
332 return False
333 if str(port).upper() != 'ICMP':
334 port = int(port)
335 return port in ports
327336
328337
329def service_stop(service_name):338def service_stop(service_name):

Subscribers

People subscribed via source and target branches