这是一个创建于 2561 天前的主题，其中的信息可能已经有所发展或是发生改变。
请问该段代码，函数实现的功能是什么了？相互调用 io.Copy 的意图是？
func Join(c Conn, c2 Conn) (int64, int64) {
var wait sync.WaitGroup
pipe := func(to Conn, from Conn, bytesCopied *int64) {
defer to.Close()
defer from.Close()
defer wait.Done()
var err error
*bytesCopied, err = io.Copy(to, from)
if err != nil {
from.Warn("Copied %d bytes to %s before failing with error %v", *bytesCopied, to.Id(), err)
} else {
from.Debug("Copied %d bytes to %s", *bytesCopied, to.Id())
}
}
wait.Add(2)
var fromBytes, toBytes int64
go pipe(c, c2, &fromBytes)
go pipe(c2, c, &toBytes)
c.Info("Joined with connection %s", c2.Id())
wait.Wait()
return fromBytes, toBytes
}
 |
1
Immortal 2017-12-17 16:34:20 +08:00
这个你得结合 Con 结构体的 reader 和 writer 的实现一起看才能知道哦
|
 |
2
rrfeng 2017-12-17 16:35:48 +08:00 via Android  1
函数实现的功能就是互相 copy
至于它能干什么你得问写这个函数的人了 |
|
3
rrfeng 2017-12-17 16:37:07 +08:00 via Android
看起来像代理程序转发链接数据的。
|
 |
6
acpanda OP @rrfeng 都是实现了 net.Conn 的 reader 和 writer。我的疑惑是，两次调用交换了参数的位置，不会形成一个循环吗？
|
|
7
rrfeng 2017-12-17 21:57:22 +08:00 via Android
@acpanda 同一个对象的 reader 和 writer 对应的不一定是同一个 buffer，这么说就明白了吧
|
 |
8
sirgod 2017-12-18 08:56:24 +08:00
tcp 连接是双工的，如果你在同一端先写再读，那么读出来的并不是刚才你写进去的，而是另一端的人写进去的
|
 |
9
JohnSmith 2017-12-18 10:33:12 +08:00
一般代理都是这么实现的
|
Select Language