From 6bc60b02e382cb4a2a3d0a57266d7e3835afe747 Mon Sep 17 00:00:00 2001
From: gongshangguo <gongshangguo@admin.com>
Date: 星期三, 02 三月 2022 16:04:17 +0800
Subject: [PATCH] 业务端口类型
---
client/client.go | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/client/client.go b/client/client.go
index 1390cf4..c6b21ab 100644
--- a/client/client.go
+++ b/client/client.go
@@ -61,8 +61,6 @@
Writer *bufio.Writer
// 鍐欏叆閫氶亾
writeChan chan []byte
- // 閫�鍑洪�氶亾
- exitChan chan int8
// 杩炴帴鐘舵��
state State
// 鎶ユ枃澶�
@@ -110,7 +108,6 @@
c.readLock = new(sync.Mutex)
c.writeLock = new(sync.Mutex)
c.writeChan = make(chan []byte)
- c.exitChan = make(chan int8)
c.state = StateInit
c.tmpByte4Slice = make([]byte, 4)
c.waitGroup = &util.WaitGroupWrapper{}
@@ -438,6 +435,11 @@
return c.deviceId
}
+// 鑾峰彇杩炴帴鐘舵��
+func (c *Client) GetState() State {
+ return c.state
+}
+
// 鍒ゆ柇杩炴帴鏄惁鍏抽棴
func (c *Client) IsClosed() bool {
return c.state == StateDisconnected
@@ -464,6 +466,7 @@
if c.IsConnected() {
c.clientCallback.OnClose(c)
}
+ close(c.writeChan)
}
// 璁剧疆杩炴帴灞炴��
--
Gitblit v1.8.0