请教一下该代码段的功能

[acpanda]

请问该段代码，函数实现的功能是什么了？相互调用 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
}

[Immortal]

这个你得结合 Con 结构体的 reader 和 writer 的实现一起看才能知道哦

[rrfeng]

函数实现的功能就是互相 copy

至于它能干什么你得问写这个函数的人了

[rrfeng]

看起来像代理程序转发链接数据的。

[acpanda]

@rrfeng 问题是，互相 copy 不会形成一个环吗？

[acpanda]

@Immortal 如果都是 net.Conn 的实现了？

[acpanda]

@rrfeng 都是实现了 net.Conn 的 reader 和 writer。我的疑惑是，两次调用交换了参数的位置，不会形成一个循环吗？

[rrfeng]

@acpanda 同一个对象的 reader 和 writer 对应的不一定是同一个 buffer，这么说就明白了吧

[sirgod]

tcp 连接是双工的，如果你在同一端先写再读，那么读出来的并不是刚才你写进去的，而是另一端的人写进去的

[JohnSmith]

一般代理都是这么实现的