|
Lines 139-145
def _receive(self, socket):
|
Link Here
|
|---|
|
|---|
| 139 |
self._cleanup(socket) |
139 |
self._cleanup(socket) |
| 140 |
return False |
140 |
return False |
| 141 |
|
141 |
|
| 142 |
state = self.__states[socket] |
142 |
try: |
|
|
143 |
state = self.__states[socket] |
| 144 |
except KeyError: |
| 145 |
return False |
| 143 |
state.buffer += data |
146 |
state.buffer += data |
| 144 |
|
147 |
|
| 145 |
msg = None |
148 |
msg = None |
|
Lines 209-215
def _handle(self, state, msg):
|
Link Here
|
|---|
|
|---|
| 209 |
state.processor.request(msg) |
212 |
state.processor.request(msg) |
| 210 |
|
213 |
|
| 211 |
def _do_send(self, socket): |
214 |
def _do_send(self, socket): |
| 212 |
state = self.__states[socket] |
215 |
try: |
|
|
216 |
state = self.__states[socket] |
| 217 |
except KeyError: |
| 218 |
return False |
| 213 |
id, first = state.resend_queue.pop(0) |
219 |
id, first = state.resend_queue.pop(0) |
| 214 |
try: |
220 |
try: |
| 215 |
ret = socket.send(first) |
221 |
ret = socket.send(first) |