(self)
| 343 | return total |
| 344 | |
| 345 | def check_fullness(self): |
| 346 | if self.fullness > 32768: |
| 347 | if not self.too_full: |
| 348 | self.send(0, CMD_PING, 'rttest') |
| 349 | self.too_full = True |
| 350 | #ob = [] |
| 351 | #for b in self.outbuf: |
| 352 | # (s1,s2,c) = struct.unpack('!ccH', b[:4]) |
| 353 | # ob.append(c) |
| 354 | #log('outbuf: %d %r\n' % (self.amount_queued(), ob)) |
| 355 | |
| 356 | def send(self, channel, cmd, data): |
| 357 | data = str(data) |