(self, fd, map=None)
| 926 | class file_dispatcher(dispatcher): |
| 927 | |
| 928 | def __init__(self, fd, map=None): |
| 929 | dispatcher.__init__(self, None, map) |
| 930 | self.connected = True |
| 931 | try: |
| 932 | fd = fd.fileno() |
| 933 | except AttributeError: |
| 934 | pass |
| 935 | self.set_file(fd) |
| 936 | # set it to non-blocking mode |
| 937 | flags = fcntl.fcntl(fd, fcntl.F_GETFL, 0) |
| 938 | flags = flags | os.O_NONBLOCK |
| 939 | fcntl.fcntl(fd, fcntl.F_SETFL, flags) |
| 940 | |
| 941 | def set_file(self, fd): |
| 942 | self.socket = file_wrapper(fd) |