请问该段代码,函数实现的功能是什么了?相互调用 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
一般代理都是这么实现的
|