Merge pull request #4 from rockyzh/master

possible block of SetDeadline
wxiaoguang · Jun 4, 2017 · 6e2931b · 6e2931b
2 parents 07e202b + 80c9002
commit 6e2931b
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/go/kcp/kcpconn.go b/go/kcp/kcpconn.go
@@ -493,8 +493,8 @@ func (s *KCPConn) SetDeadline(t time.Time) error {
     s.deadlineRead = t
     s.deadlineWrite = t
 
-    s.chReadEvent <- struct{}{}
-    s.chWriteEvent <- struct{}{}
+    s.notifyReadEvent()
+    s.notifyWriteEvent()
 
     return nil
 }
@@ -505,7 +505,7 @@ func (s *KCPConn) SetReadDeadline(t time.Time) error {
     defer s.mu.Unlock()
     s.deadlineRead = t
 
-    s.chReadEvent <- struct{}{}
+    s.notifyReadEvent()
 
     return nil
 }
@@ -516,7 +516,7 @@ func (s *KCPConn) SetWriteDeadline(t time.Time) error {
     defer s.mu.Unlock()
     s.deadlineWrite = t
 
-    s.chWriteEvent <- struct{}{}
+    s.notifyWriteEvent()
 
     return nil
 }