fixed #708

streamserver.go

@@ -84,6 +84,7 @@ func NewStreamServer(password []byte, client net.Conn, timeout int) (*StreamServ
 	if time.Now().Unix()-i > 60 {
 		x.BP12.Put(s.cn)
 		x.BP2048.Put(s.RB)
+		WaitReadErr(s.Client)
 		return nil, nil, errors.New("Expired request")
 	}
 	if i%2 == 0 {
@@ -213,6 +214,7 @@ func (s *StreamServer) Read() (int, error) {
 		return 0, err
 	}
 	if _, err := s.ca.Open(s.RB[:0], s.cn, s.RB[:2+16], nil); err != nil {
+		WaitReadErr(s.Client)
 		return 0, err
 	}
 	l := int(binary.BigEndian.Uint16(s.RB[:2]))

waitreaderr.go

@@ -0,0 +1,26 @@
+// Copyright (c) 2016-present Cloud <[email protected]>
+//
+// This program is free software; you can redistribute it and/or
+// modify it under the terms of version 3 of the GNU General Public
+// License as published by the Free Software Foundation.
+//
+// This program is distributed in the hope that it will be useful, but
+// WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+// General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see <https://www.gnu.org/licenses/>.
+
+package brook
+
+import "net"
+
+func WaitReadErr(conn net.Conn) {
+	var b [2048]byte
+	for {
+		if _, err := conn.Read(b[:]); err != nil {
+			return
+		}
+	}
+}