Show More
@@ -133,7 +133,12 b' class clienthandler(object):' | |||||
133 | response = self._responses[frame.requestid] |
|
133 | response = self._responses[frame.requestid] | |
134 |
|
134 | |||
135 | if action == 'responsedata': |
|
135 | if action == 'responsedata': | |
136 | self._processresponsedata(frame, meta, response) |
|
136 | # Any failures processing this frame should bubble up to the | |
|
137 | # future tracking the request. | |||
|
138 | try: | |||
|
139 | self._processresponsedata(frame, meta, response) | |||
|
140 | except BaseException as e: | |||
|
141 | self._futures[frame.requestid].set_exception(e) | |||
137 | else: |
|
142 | else: | |
138 | raise error.ProgrammingError( |
|
143 | raise error.ProgrammingError( | |
139 | 'unhandled action from clientreactor: %s' % action) |
|
144 | 'unhandled action from clientreactor: %s' % action) |
General Comments 0
You need to be logged in to leave comments.
Login now