|
|
@@ -66,11 +66,11 @@ const (
|
|
|
)
|
|
|
|
|
|
type clientExecutor struct {
|
|
|
- id string
|
|
|
- executor *shell.Executor
|
|
|
- mu sync.Mutex ///////////////////// 同ID串行执行
|
|
|
- lastPing time.Time ///////////////////// 用于超时回收
|
|
|
- state executorState ///////////////////// 执行器的状态
|
|
|
+ id string /////////////////// 客户端唯一ID
|
|
|
+ executor *shell.Executor /////////////////// 本地的执行器
|
|
|
+ mu sync.Mutex /////////////////// 同ID串行执行
|
|
|
+ lastPing time.Time /////////////////// 用于超时回收
|
|
|
+ state executorState /////////////////// 执行器的状态
|
|
|
}
|
|
|
|
|
|
func ModuleInit(mqttBroker, mqttUsername, mqttPassword string) bool {
|