MCPcopy Create free account
hub / github.com/cc20110101/RedisView / initValueListData

Method initValueListData

src/RedisView/AppView/MainWidget.cpp:233–272  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

231}
232
233void 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
274void MainWidget::commitValue(QList<CmdMsg> &cmd) {
275 if(cmd.size() <= 0)

Callers 2

finishWorkMethod · 0.45
treeClickedMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected