|
Lines 204-209
def _response(self, msg, state):
|
Link Here
|
|---|
|
|---|
| 204 |
if not state.resend_queue: |
204 |
if not state.resend_queue: |
| 205 |
notifier.socket_add(state.socket, self._do_send, notifier.IO_WRITE) |
205 |
notifier.socket_add(state.socket, self._do_send, notifier.IO_WRITE) |
| 206 |
state.resend_queue.append((msg.id, data[ret:])) |
206 |
state.resend_queue.append((msg.id, data[ret:])) |
|
|
207 |
else: |
| 208 |
del state.requests[msg.id] |
| 207 |
except (SSL.WantReadError, SSL.WantWriteError, SSL.WantX509LookupError): |
209 |
except (SSL.WantReadError, SSL.WantWriteError, SSL.WantX509LookupError): |
| 208 |
CRYPT.info('UMCP: SSL error need to re-send chunk') |
210 |
CRYPT.info('UMCP: SSL error need to re-send chunk') |
| 209 |
notifier.socket_add(state.socket, self._do_send, notifier.IO_WRITE) |
211 |
notifier.socket_add(state.socket, self._do_send, notifier.IO_WRITE) |