| 272 | } |
| 273 | |
| 274 | void MainWidget::commitValue(QList<CmdMsg> &cmd) { |
| 275 | if(cmd.size() <= 0) |
| 276 | return; |
| 277 | runWait(true); |
| 278 | _haveError = false; |
| 279 | _taskMsg = new TaskMsg(); |
| 280 | _taskMsg->_taskid = THREAD_COMMIT_VALUE_TASK; |
| 281 | _vTaskId.push_back(THREAD_COMMIT_VALUE_TASK); |
| 282 | _taskMsg->_host = _vMasterClients[cmd[0]._clientIndex]._host; |
| 283 | _taskMsg->_port = _vMasterClients[cmd[0]._clientIndex]._port; |
| 284 | _taskMsg->_passwd = _vMasterClients[cmd[0]._clientIndex]._passwd; |
| 285 | _taskMsg->_clientIndex = cmd[0]._clientIndex; |
| 286 | _taskMsg->_dbIndex = cmd[0]._dbIndex; |
| 287 | _workThread = new WorkThread(cmd,_taskMsg); |
| 288 | |
| 289 | connect(_workThread, &WorkThread::finishWork, this, &MainWidget::finishWork); |
| 290 | connect(_workThread, &WorkThread::runError, this, &MainWidget::runError); |
| 291 | |
| 292 | _threadPool->start(_workThread); |
| 293 | _taskMsg = nullptr; |
| 294 | _workThread = nullptr; |
| 295 | } |
| 296 | |
| 297 | void MainWidget::recvData(const TaskMsg taskMsg) { |
| 298 | if(taskMsg._taskid == THREAD_SCAN_KEY_TASK) { |
nothing calls this directly
no outgoing calls
no test coverage detected