Python socket.fileno方法代码示例

本文整理汇总了Python中socket.fileno方法的典型用法代码示例。如果您正苦于以下问题:Python socket.fileno方法的具体用法?Python socket.fileno怎么用?Python socket.fileno使用的例子?那么恭喜您, 这里精选的方法代码示例或许可以为您提供帮助。您也可以进一步了解该方法所在模块socket的用法示例。

在下文中一共展示了socket.fileno方法的16个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: poll

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def poll(self, timeout=100):
        if self.use_poll:
            ready = self.poller.poll(timeout)
        else:
            ready = []
            if len(self.targets) > 0:
                (rlist, wlist, xlist) = select.select(
                    self.targets.keys(), [], [], timeout
                )
                ready = [(x, None) for x in rlist]
        for one_ready in ready:
            target = self.targets.get(one_ready[0].fileno(), None)
            dbg("Targets %s" % str(self.targets.keys()))
            if target:
                # dbg("get socket with fileno: %s" % str(one_ready[0].fileno()) +  " len: %s" % len(one_ready) + " selected: %s " % str(target.fileno()) )
                # update time
                target.do_read(one_ready[0]) 
开发者ID:lemariva,项目名称:uPyEcho,代码行数:20,代码来源:main.py


示例2: do_read

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def do_read(self, socket):
        fileno = socket.fileno()
        dbg("Fileno %s" % fileno + " socket fileno %s" % self.socket.fileno())
        if fileno == self.socket.fileno():
            try:
                (client_socket, client_address) = self.socket.accept()
                self.poller.add(self, client_socket)
                self.client_sockets[client_socket.fileno()] = client_socket
            except Exception as e:
                dbg("################################## Socket busy! %s" % str(e))
        else:
            data, sender = self.client_sockets[fileno].recvfrom(4096)
            if not data:
                self.poller.remove(self, self.client_sockets[fileno])
                self.client_sockets[fileno].close()
            else:
                dbg("send response to socket!: %s" % str(fileno))
                self.handle_request(data, sender, self.client_sockets[fileno])
            gc.collect() 
开发者ID:lemariva,项目名称:uPyEcho,代码行数:23,代码来源:main.py


示例3: connect

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def connect(self, host, port):
        self.__state = CONNECTION_STATE.DISCONNECTED
        self.__fileno = None
        self.__socket = socket.socket(_getAddrType(host), socket.SOCK_STREAM)
        self.__socket.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, self.__sendBufferSize)
        self.__socket.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, self.__recvBufferSize)
        self.__socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
        self.__socket.setblocking(0)
        self.__readBuffer = bytes()
        self.__writeBuffer = bytes()
        self.__lastReadTime = monotonicTime()
        try:
            self.__socket.connect((host, port))
        except socket.error as e:
            if e.errno not in (socket.errno.EINPROGRESS, socket.errno.EWOULDBLOCK):
                return False
        self.__fileno = self.__socket.fileno()
        self.__state = CONNECTION_STATE.CONNECTING
        self.__poller.subscribe(self.__fileno,
                                 self.__processConnection,
                                 POLL_EVENT_TYPE.READ | POLL_EVENT_TYPE.WRITE | POLL_EVENT_TYPE.ERROR)
        return True 
开发者ID:bakwc,项目名称:PySyncObj,代码行数:25,代码来源:tcp_connection.py


示例4: testBadSelectableTypes

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def testBadSelectableTypes(self):
        class Nope: pass
        class Almost1:
            def fileno(self):
                return 'fileno'
        class Almost2:
            def fileno(self):
                return 'fileno'
        # Test some known error conditions
        for bad_selectable in [None, 1, object(), Nope(), Almost1(), Almost2()]:
            try:
                timeout = 0 # Can't wait forever
                rfd, wfd, xfd = select.select([bad_selectable], [], [], timeout)
            except (TypeError, select.error), x:
                pass
            else:
                self.fail("Selecting on '%s' should have raised TypeError or select.error" % str(bad_selectable)) 
开发者ID:ofermend,项目名称:medicare-demo,代码行数:22,代码来源:test_select.py


示例5: add

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def add(self, target, socket=None):
        if not socket:
            socket = target.sockets()
        if self.use_poll:
            self.poller.register(socket, select.POLLIN)
        # dbg("add device on fileno: %s" % socket.fileno() )
        self.targets[socket.fileno()] = target
        # dbg("size targets: %s" % len(self.targets)) 
开发者ID:lemariva,项目名称:uPyEcho,代码行数:10,代码来源:main.py


示例6: remove

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def remove(self, target, socket=None):
        if not socket:
            socket = target.sockets()
        if self.use_poll:
            self.poller.unregister(socket)
        # dbg("remove device on fileno: %s" % socket.fileno() )
        gc.collect() 
开发者ID:lemariva,项目名称:uPyEcho,代码行数:9,代码来源:main.py


示例7: fileno

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def fileno(self):
        return self.socket.fileno() 
开发者ID:lemariva,项目名称:uPyEcho,代码行数:4,代码来源:main.py


示例8: add

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def add(self, socket = None):
        if not socket:
            return
        self.poller.register(socket, select.POLLIN)
        self.targets[socket.fileno()] = socket 
开发者ID:lemariva,项目名称:uPyPortal,代码行数:7,代码来源:dns.py


示例9: remove

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def remove(self, socket = None):
        if not socket:
            return
        self.poller.unregister(socket)
        del(self.targets[socket.fileno()]) 
开发者ID:lemariva,项目名称:uPyPortal,代码行数:7,代码来源:dns.py


示例10: poll

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def poll(self, ip, timeout = 100):
        ready = self.poller.poll(timeout)
        for one_ready in ready:
            target = self.targets.get(one_ready[0].fileno(), None)
            if target:
                try:
                    data, sender = target.recvfrom(1024)
                    p = DNSQuery(data)
                    if any(word in p.domain for word in config.DNS_ANSWERS):
                        target.sendto(p.answer(ip), sender)
                        dbg('Replying: {:s} -> {:s}'.format(p.domain, ip))
                    #else:
                    #    dbg('Avoid responding: {:s} -> {:s}'.format(p.domain, ip))
                except Exception as e:
                    dbg('Exception occurs: ' + str(e)) 
开发者ID:lemariva,项目名称:uPyPortal,代码行数:17,代码来源:dns.py


示例11: __init__

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def __init__(self, poller, onMessageReceived = None, onConnected = None, onDisconnected = None,
                 socket=None, timeout=10.0, sendBufferSize = 2 ** 13, recvBufferSize = 2 ** 13):
        self.sendRandKey = None
        self.recvRandKey = None
        self.encryptor = None
        self.__socket = socket
        self.__readBuffer = bytes()
        self.__writeBuffer = bytes()
        self.__lastReadTime = monotonicTime()
        self.__timeout = timeout
        self.__poller = poller
        if socket is not None:
            self.__socket = socket
            self.__fileno = socket.fileno()
            self.__state = CONNECTION_STATE.CONNECTED
            self.__poller.subscribe(self.__fileno,
                                     self.__processConnection,
                                     POLL_EVENT_TYPE.READ | POLL_EVENT_TYPE.WRITE | POLL_EVENT_TYPE.ERROR)
        else:
            self.__state = CONNECTION_STATE.DISCONNECTED
            self.__fileno = None
            self.__socket = None
        self.__onMessageReceived = onMessageReceived
        self.__onConnected = onConnected
        self.__onDisconnected = onDisconnected
        self.__sendBufferSize = sendBufferSize
        self.__recvBufferSize = recvBufferSize 
开发者ID:bakwc,项目名称:PySyncObj,代码行数:32,代码来源:tcp_connection.py


示例12: fileno

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def fileno(self):
        return self.__fileno 
开发者ID:bakwc,项目名称:PySyncObj,代码行数:4,代码来源:tcp_connection.py


示例13: bind_and_listen_on_posix_socket

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def bind_and_listen_on_posix_socket(socket_name, accept_callback):
    """
    :param accept_callback: Called with `PosixSocketConnection` when a new
        connection is established.
    """
    assert socket_name is None or isinstance(socket_name, six.text_type)
    assert callable(accept_callback)
    # Py2 uses 0027 and Py3 uses 0o027, but both know
    # how to create the right value from the string '0027'.
    old_umask = os.umask(int('0027', 8))
    # Bind socket.
    socket_name, socket = _bind_posix_socket(socket_name)
    _ = os.umask(old_umask)
    # Listen on socket.
    socket.listen(0)
    def _accept_cb():
        connection, client_address = socket.accept()
        # Note: We don't have to put this socket in non blocking mode.
        #       This can cause crashes when sending big packets on OS X.
        posix_connection = PosixSocketConnection(connection)
        accept_callback(posix_connection)
    get_event_loop().add_reader(socket.fileno(), _accept_cb)
    logger.info('Listening on %r.' % socket_name)
    return socket_name 
开发者ID:prompt-toolkit,项目名称:pymux,代码行数:35,代码来源:posix.py


示例14: __init__

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def __init__(self, socket):
        self.socket = socket
        self._fd = socket.fileno()
        self._recv_buffer = b'' 
开发者ID:prompt-toolkit,项目名称:pymux,代码行数:6,代码来源:posix.py


示例15: _read_chunk_from_socket

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def _read_chunk_from_socket(socket):
    """
    (coroutine)
    Turn socket reading into coroutine.
    """
    fd = socket.fileno()
    f = Future()
    def read_callback():
        get_event_loop().remove_reader(fd)
        # Read next chunk.
        try:
            data = socket.recv(1024)
        except OSError as e:
            # On OSX, when we try to create a new window by typing "pymux
            # new-window" in a centain pane, very often we get the following
            # error: "OSError: [Errno 9] Bad file descriptor."
            # This doesn't seem very harmful, and we can just try again.
            logger.warning('Got OSError while reading data from client: %s. '
                           'Trying again.', e)
            f.set_result('')
            return
        if data:
            f.set_result(data)
        else:
            f.set_exception(BrokenPipeError)
    get_event_loop().add_reader(fd, read_callback)
    return f 
开发者ID:prompt-toolkit,项目名称:pymux,代码行数:34,代码来源:posix.py


示例16: _testSelectOnSocketFileno

# 需要导入模块: import socket [as 别名]
# 或者: from socket import fileno [as 别名]
def _testSelectOnSocketFileno(self):
        self.cli.setblocking(0)
        self.cli.connect( (self.HOST, self.PORT) )
        return
        try:
            rfd, wfd, xfd = select.select([self.cli.fileno()], [], [], 1)
        except Exception, x:
            self.fail("Selecting on socket.fileno() should not have raised exception: %s" % str(x)) 
开发者ID:ofermend,项目名称:medicare-demo,代码行数:10,代码来源:test_select.py



注:本文中的socket.fileno方法示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。