(self)
| 373 | self.bufstate = 1 |
| 374 | |
| 375 | def _stage1(self): |
| 376 | if self.bufstate == 1 and len(self.buff) >= self.bufneed: |
| 377 | packet = self.buff[:self.bufneed] |
| 378 | self.buff = self.buff[self.bufneed:] |
| 379 | self.bufneed = 4 |
| 380 | self.bufstate = 0 |
| 381 | return packet |
| 382 | |
| 383 | def pollmessage(self, wait): |
| 384 | packet = self.pollpacket(wait) |