func forward(src net.Conn, network, address string, timeout time.Duration) {
defer src.Close()
dst, err := net.DialTimeout(network, address, timeout)
if err != nil {
log.Printf("dial err: %s", err)
return
}
defer dst.Close()
cpErr := make(chan error)
go cp(cpErr, src, dst)
go cp(cpErr, dst, src)
select {
case err = <-cpErr:
if err != nil {
log.Printf("copy err: %v", err)
}
}
log.Printf("disconnect: %s", src.RemoteAddr())
}
func cp(c chan error, w io.Writer, r io.Reader) {
_, err := io.Copy(w, r)
c <- err
fmt.Println("cp end")
}
Seems like it doesn't work, io.Copy() still block its goroutine
On Wednesday, 16 November 2016 18:09:40 UTC+3, Peter Waller wrote:
>
> If connTwo is closed, Read will return io.EOF, and io.Copy will return.
> (With no error, because copy runs until io.EOF is reached).
>
> If that's not happening for you, can you give an example to reproduce?
>
> On 16 November 2016 at 14:49, Alexander Menzhinsky <amenz...@gmail.com
> <javascript:>> wrote:
>
>> When implementing a proxy server I would like to stop reading from a
>> connection when another is closed. I use the io.Copy but basically it uses
>> the Read function.
>> go io.Copy(connOne, connTwo)
>>
>> Is it possible?
>>
>> --
>> You received this message because you are subscribed to the Google Groups
>> "golang-nuts" group.
>> To unsubscribe from this group and stop receiving emails from it, send an
>> email to golang-nuts...@googlegroups.com <javascript:>.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
--
You received this message because you are subscribed to the Google Groups
"golang-nuts" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to golang-nuts+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
