| 31 | '''Socket class supporting asynchronous operations.''' |
| 32 | |
| 33 | def __init__(self, asyncIOService, sock = None): |
| 34 | super(AsyncSocket, self).__init__() |
| 35 | self.__asyncIOService = asyncIOService |
| 36 | self.__acceptCallback = None |
| 37 | self.__connectCallback = None |
| 38 | self.__readCallback = None |
| 39 | self.__writeAllCallback = None |
| 40 | self.__writeBuffer = b'' |
| 41 | self.__maxReadBytes = 0 |
| 42 | self.__closed = False |
| 43 | if sock: |
| 44 | self.__socket = sock |
| 45 | else: |
| 46 | self.__socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
| 47 | self.__socket.setblocking(0) |
| 48 | asyncIOService.addAsyncSocket(self) |
| 49 | |
| 50 | def __str__(self): |
| 51 | return ('AsyncSocket [ fileno = %d ]' % self.fileno()) |