(self, maxlen)
| 4424 | self.ws.send(data, websocket.ABNF.OPCODE_BINARY) |
| 4425 | |
| 4426 | def recv(self, maxlen): |
| 4427 | while len(self.recvbuf) < maxlen: |
| 4428 | self.recvbuf += self.ws.recv() |
| 4429 | |
| 4430 | ret = self.recvbuf[:maxlen] |
| 4431 | self.recvbuf = self.recvbuf[maxlen:] |
| 4432 | return ret |
| 4433 | |
| 4434 | # This might happen really early! |
| 4435 | l1.daemon.logsearch_start = 0 |