“轮询”指的是什么？这段代码到底在做什么？

Question

我目前正在构建一个python脚本，该脚本启用和禁用交换机上的某些端口，以查看交换机如何实现质量保证。我一直在使用一个名为paramiko的Python库，它实现了SSH来连接到我想要的任何设备，我指的是我的一个队友交付的遗留代码来编写更多的脚本。在一个遗留代码文件中，有一个名为_run_poll的函数，我不太清楚它到底在做什么

我已经尝试过研究“轮询”对SSH的意义，但我仍然不了解在运行“轮询”时会发生什么。它的定义似乎有点模糊。以下是函数：

def _run_poll(self, session, timeout, input_data):

    interval = 0.1
    maxseconds = timeout
    maxcount = maxseconds / interval


    i = 0
    timeout_flag = False
    self.info('polling (%d, %d)' % (maxseconds, maxcount))
    start = datetime.datetime.now()
    start_secs = time.mktime(start.timetuple())
    output = ''
    session.setblocking(0)
    while True:
        if session.recv_ready(): # returns true if data has been buffered
            data = session.recv(self.bufsize) # receive data from the channel
            output += data
            self.info('read %d bytes, total %d' % (len(data), len(output)))

            if session.send_ready(): 
                # We received a potential prompt.
                # In the future this could be made to work more like
                # pexpect with pattern matching.
                if i < len(input_data):
                    data = input_data[input_idx] + '\n'
                    i += 1
                    self.info('sending input data %d' % (len(data)))
                    session.send(data)

        self.info('session.exit_status_ready() = %s' % (str(session.exit_status_ready())))
        if session.exit_status_ready():
            break

        # Timeout check
        now = datetime.datetime.now()
        now_secs = time.mktime(now.timetuple())
        et_secs = now_secs - start_secs
        self.info('timeout check %d %d' % (et_secs, maxseconds))
        if et_secs > maxseconds:
            self.info('polling finished - timeout')
            timeout_flag = True
            break
        time.sleep(0.200)

    self.info('polling loop ended')
    if session.recv_ready():
        data = session.recv(self.bufsize)
        output += data
        self.info('read %d bytes, total %d' % (len(data), len(output)))

    self.info('polling finished - %d output bytes' % (len(output)))
    if timeout_flag:
        self.info('appending timeout message')
        output += '\nERROR: timeout after %d seconds\n' % (timeout)
        session.close()

    return output

我找不到太多的在线资源来描述这里发生了什么或关于“投票”的一般情况。有谁能帮我解释一下什么是“投票”以及这里发生了什么

Answer 1

维基百科关于Polling的文章将其定义为：

Actively sampling the status of an external device by a client program as a synchronous activity.

---

在您的代码中，这意味着它会定期（每200ms）检查SSH连接是否有任何传入数据和输出队列中的空闲容量