// processServerProxy process down link traffic
processServerProxy process down link traffic
// processServerProxy process down link traffic
func (c *conntrack) processServerProxy() {
	buf := make([]byte, tcpBufSize)
	for {
		n, err := c.rconn.Read(buf)
		if n == 0 {
			c.rconn.Close()
			c.lconn.Close()
			break
		}
		if err != nil {
			c.rconn.Close()
			c.lconn.Close()
			break
		}
		_, rerr := c.lconn.Write(buf[:n])
		if rerr != nil {
			c.rconn.Close()
			c.lconn.Close()
			break
		}
	}
}
func ( c * conntrack ) processServerProxy ( ) { buf := make ( [ ] byte , tcpBufSize ) for { n , err := c . rconn . Read ( buf ) if n == 0 { c . rconn . Close ( ) c . lconn . Close ( ) break } if err != nil { c . rconn . Close ( ) c . lconn . Close ( ) break } _ , rerr := c . lconn . Write ( buf [ : n ] ) if rerr != nil { c . rconn . Close ( ) c . lconn . Close ( ) break } } }
processServerProxy process down link traffic
processServerProxy process down link traffic