|
|
@@ -100,14 +100,10 @@ func (c *ClientBind) receive(b []byte) (n int, ep conn.Endpoint, err error) {
|
|
|
}
|
|
|
|
|
|
func (c *ClientBind) Reset() {
|
|
|
- c.connAccess.Lock()
|
|
|
- defer c.connAccess.Unlock()
|
|
|
common.Close(common.PtrOrNil(c.conn))
|
|
|
}
|
|
|
|
|
|
func (c *ClientBind) Close() error {
|
|
|
- c.connAccess.Lock()
|
|
|
- defer c.connAccess.Unlock()
|
|
|
common.Close(common.PtrOrNil(c.conn))
|
|
|
if c.done == nil {
|
|
|
c.done = make(chan struct{})
|