Commit ec0aee82 authored by vipwzw's avatar vipwzw Committed by 33cn

fix test

parent 7d84bc46
...@@ -448,4 +448,7 @@ func (exec *Executor) procExecDelBlock(msg *queue.Message) { ...@@ -448,4 +448,7 @@ func (exec *Executor) procExecDelBlock(msg *queue.Message) {
// Close close executor // Close close executor
func (exec *Executor) Close() { func (exec *Executor) Close() {
elog.Info("exec module closed") elog.Info("exec module closed")
if exec.client != nil {
exec.client.Close()
}
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment