action taken upon link being closed by peer
(self)
| 468 | continue |
| 469 | |
| 470 | def handle_EOF(self): |
| 471 | "action taken upon link being closed by peer" |
| 472 | self.EOFhook() |
| 473 | self.debug("handle_EOF") |
| 474 | for key in self.cvars: |
| 475 | cv = self.cvars[key] |
| 476 | cv.acquire() |
| 477 | self.responses[key] = ('EOF', None) |
| 478 | cv.notify() |
| 479 | cv.release() |
| 480 | # call our (possibly overridden) exit function |
| 481 | self.exithook() |
| 482 | |
| 483 | def EOFhook(self): |
| 484 | "Classes using rpc client/server can override to augment EOF action" |