python – Twisted Conch – 流量控制

我有一个Twisted Conch SSH服务器,典型的情况是：

git通过OpenSSH客户端>> — WAN1 —>>扭曲的海螺svr>> — WAN2 – >> Git服务器

有一段时间,’git push’通过WAN1发送数据的速度比通过WAN2代理的速度快,所以我需要告诉客户端减速(在任何TCP数据包丢失导致调整TCP窗口大小之前)以避免在Twisted服务器上缓冲太多.读取RFC for SSH这是通过不通过adj窗口来确认的,这将导致git push阻塞syscall写入openssh支持的管道.

在方法def ssh_CHANNEL_DATA(self,packet)中查看conch / ssh / connection.py:L216：
我可以通过将localWindowSize设置为0来完成此操作,并且当230上的谓词仍应传递时,飞行数据仍将着陆(给出localWindowLeft).我想知道这是否是正确的方法,还是我错过了一些关于使用Twisted SSH Conch进行流量控制的盲目明显的东西？ *

注意：我承认在(通道)上有一些方法用于stopWriting和startWriting,我可以覆盖,所以我有钩子来控制传输’git pull’的另一面,但我对另一方感兴趣. IPush / IPull生产商似乎也不适用于这个级别,我不知道如何在没有屠宰海螺的情况下将这些更高的抽象结合起来？

解决方法

我没有使用Twisted,根本不知道Conch,但没有其他人回答,我会试一试.

作为一般原则,您可能希望在网络中间缓冲很少(如果有的话). (Jim Gettys关于“缓冲膨胀”的说明很有启发性.)所以很明显,你问的是一个明智的问题.

我假设当数据从客户端到达时,Conch会在代码中调用一个函数.在您将数据传递到后端服务器之前,只是不能从该调用返回就足够了吗？内核仍然会在入站和出站套接字中缓冲数据,因此不会立即向下游客户端发送条件,但我希望它能够稳定状态.

当然,作为替代方案,您可以在与SSH不同的层上穿过此路由器.如果您在较低层进行隧道连接,因此您有一个端到端TCP连接,那么TCP堆栈应该找出一个好的窗口大小.

如果您在更高层进行隧道传输,通过执行git push到中间服务器,然后使用post-receive挂钩在剩下的时间内推送对象,那么您将获得最大缓冲(它全部假脱机到磁盘)并且响应更快到客户端的时间,但总延迟时间更长.它具有实现起来更简单的独特优势.