向远程主机写数据 :return:
(self, data)
| 339 | return self.__sock.fileno() |
| 340 | |
| 341 | def write(self, data): |
| 342 | """ |
| 343 | 向远程主机写数据 |
| 344 | :return: |
| 345 | """ |
| 346 | while 1: |
| 347 | try: |
| 348 | length = self.__sock.send(data) |
| 349 | if length == len(data): |
| 350 | break |
| 351 | else: |
| 352 | # 截取尚未写完的数据,接下来再次发送 |
| 353 | data = data[length:] |
| 354 | except socket.error as e: |
| 355 | if e.errno == 35: |
| 356 | time.sleep(.01) |
| 357 | else: |
| 358 | raise |
| 359 | |
| 360 | def read(self, callback): |
| 361 | """ |
no outgoing calls
no test coverage detected