| 231 | } |
| 232 | |
| 233 | void MainWidget::initValueListData(const InitValueMsg &initValueMsg) { |
| 234 | |
| 235 | if(_vTaskId.indexOf(THREAD_DEL_KEY_TASK) != -1) { |
| 236 | QMessageBox::critical(this, tr("提示"), tr("后台删键任务未结束,请稍后进行键刷新操作!")); |
| 237 | return; |
| 238 | } |
| 239 | |
| 240 | if(_vTaskId.indexOf(THREAD_SCAN_KEY_TASK) != -1) { |
| 241 | QMessageBox::critical(this, tr("提示"), tr("后台扫描键任务未结束,请稍后进行键刷新操作!")); |
| 242 | return; |
| 243 | } |
| 244 | |
| 245 | _SCAN_VALUE_LOCK.lockForWrite(); |
| 246 | |
| 247 | ++_iScanValueSeq; |
| 248 | runWait(true); |
| 249 | _taskMsg = new TaskMsg(); |
| 250 | _taskMsg->_taskid = THREAD_SCAN_VALUE_TASK; |
| 251 | _vTaskId.push_back(THREAD_SCAN_VALUE_TASK); |
| 252 | _taskMsg->_sequence = _iScanValueSeq; |
| 253 | _taskMsg->_host = _vMasterClients[initValueMsg._clientIndex]._host; |
| 254 | _taskMsg->_port = _vMasterClients[initValueMsg._clientIndex]._port; |
| 255 | _taskMsg->_passwd = _vMasterClients[initValueMsg._clientIndex]._passwd; |
| 256 | _taskMsg->_clientIndex = initValueMsg._clientIndex; |
| 257 | _taskMsg->_dbIndex = initValueMsg._dbindex; |
| 258 | _taskMsg->_key = initValueMsg._key; |
| 259 | _taskMsg->_type = initValueMsg._type; |
| 260 | _taskMsg->_keyPattern = initValueMsg._valuePattern; |
| 261 | _workThread = new WorkThread(_taskMsg); |
| 262 | |
| 263 | connect(_workThread, &WorkThread::sendData, this, &MainWidget::recvData); |
| 264 | connect(_workThread, &WorkThread::finishWork, this, &MainWidget::finishWork); |
| 265 | connect(_workThread, &WorkThread::runError, this, &MainWidget::runError); |
| 266 | |
| 267 | _threadPool->start(_workThread); |
| 268 | _taskMsg = nullptr; |
| 269 | _workThread = nullptr; |
| 270 | |
| 271 | _SCAN_VALUE_LOCK.unlock(); |
| 272 | } |
| 273 | |
| 274 | void MainWidget::commitValue(QList<CmdMsg> &cmd) { |
| 275 | if(cmd.size() <= 0) |
no outgoing calls
no test coverage detected