github
/
nps
mirror of https://github.com/ehang-io/nps
1
0
Fork 0
Code Issues Releases Wiki Activity

Clear bug

pull/59/head
刘河 2019-03-02 20:12:58 +08:00
parent 5fc51f40a7
commit cbc3bd2afe
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bridge/bridge.go
View File

@ -321,7 +321,7 @@ func (s *Bridge) ping() {
s.clientLock.Lock() s.clientLock.Lock()
arr := make([]int, 0) arr := make([]int, 0)
for k, v := range s.Client { for k, v := range s.Client {
if v.tunnel == nil { if v.tunnel == nil || v.signal == nil {
v.retryTime += 1 v.retryTime += 1
if v.retryTime >= 3 { if v.retryTime >= 3 {
arr = append(arr, k) arr = append(arr, k)
@ -387,6 +387,9 @@ func (s *Bridge) getConfig(c *conn.Conn, isPub bool, client *file.Client) {
} }
c.WriteAddOk() c.WriteAddOk()
c.Write([]byte(client.VerifyKey)) c.Write([]byte(client.VerifyKey))
s.clientLock.Lock()
s.Client[client.Id] = NewClient(nil, nil, nil)
s.clientLock.Unlock()
} }
case common.NEW_HOST: case common.NEW_HOST:
h, err := c.GetHostInfo() h, err := c.GetHostInfo()