cy/goproxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Signed-off-by: arraykeys@gmail.com <arraykeys@gmail.com>

Browse Source
This commit is contained in:
arraykeys@gmail.com
2018-03-13 17:14:25 +08:00
parent f348298acd
commit f756d62b19
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
services/mux_server.go
View File

@ -266,14 +266,6 @@ func (s *MuxServer) GetConn(index string) (conn net.Conn, err error) {
} }
s.sessions.Set(index, session) s.sessions.Set(index, session)
log.Printf("session[%s] created", index) log.Printf("session[%s] created", index)
} else {
session = _session.(*smux.Session)
}
conn, err = session.OpenStream()
if err != nil {
session.Close()
s.sessions.Remove(index)
} else {
go func() { go func() {
for { for {
if session.IsClosed() { if session.IsClosed() {
@ -283,8 +275,14 @@ func (s *MuxServer) GetConn(index string) (conn net.Conn, err error) {
time.Sleep(time.Second * 5) time.Sleep(time.Second * 5)
} }
}() }()
} else {
session = _session.(*smux.Session)
}
conn, err = session.OpenStream()
if err != nil {
session.Close()
s.sessions.Remove(index)
} }
return return
} }
func (s *MuxServer) getParentConn() (conn net.Conn, err error) { func (s *MuxServer) getParentConn() (conn net.Conn, err error) {