Show More
@@ -109,13 +109,11 b' class CommManager(LoggingConfigurable):' | |||||
109 | self.log.error("No such comm target registered: %s", target_name) |
|
109 | self.log.error("No such comm target registered: %s", target_name) | |
110 | comm.close() |
|
110 | comm.close() | |
111 | return |
|
111 | return | |
112 | self.register_comm(comm) |
|
|||
113 | try: |
|
112 | try: | |
114 | f(comm, msg) |
|
113 | f(comm, msg) | |
115 | except Exception: |
|
114 | except Exception: | |
116 | self.log.error("Exception opening comm with target: %s", target_name, exc_info=True) |
|
115 | self.log.error("Exception opening comm with target: %s", target_name, exc_info=True) | |
117 | comm.close() |
|
116 | comm.close() | |
118 | self.unregister_comm(comm) |
|
|||
119 |
|
117 | |||
120 | def comm_msg(self, stream, ident, msg): |
|
118 | def comm_msg(self, stream, ident, msg): | |
121 | """Handler for comm_msg messages""" |
|
119 | """Handler for comm_msg messages""" |
General Comments 0
You need to be logged in to leave comments.
Login now