cadey
/
route
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

tun2: goroutine it up fam

This commit is contained in:
Cadey Ratio 2017-03-26 16:11:59 -07:00
parent 7cf2a9a616
commit d25fe6c7e7
1 changed files with 28 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
lib/tun2/server.go
View File

@ -159,40 +159,42 @@ func (s *Server) ListenAndServe() error {
s.connlock.Lock()
for _, c := range s.conns {
req, err := http.NewRequest("GET", "http://backend/health", nil)
if err != nil {
panic(err)
}
go func() {
req, err := http.NewRequest("GET", "http://backend/health", nil)
if err != nil {
panic(err)
}
ln.Log(c.F(), ln.F{
"action": "sending_ping",
})
ln.Log(c.F(), ln.F{
"action": "sending_ping",
})
stream, err := c.session.OpenStream()
if err != nil {
ln.Error(err)
stream, err := c.session.OpenStream()
if err != nil {
ln.Error(err)
c.cancel()
}
c.cancel()
}
err = req.Write(stream)
if err != nil {
ln.Error(err)
err = req.Write(stream)
if err != nil {
ln.Error(err)
c.cancel()
}
c.cancel()
}
_, err = ioutil.ReadAll(stream)
if err != nil {
ln.Error(err)
c.cancel()
}
_, err = ioutil.ReadAll(stream)
if err != nil {
ln.Error(err)
c.cancel()
}
stream.Close()
stream.Close()
ln.Log(ln.F{
"action": "ping_health_is_good",
}, c.F())
ln.Log(ln.F{
"action": "ping_health_is_good",
}, c.F())
}()
}
s.connlock.Unlock()