Mirrors/nekoray
1
0
Fork 0
mirror of https://github.com/MatsuriDayo/nekoray.git synced 2025-12-17 12:34:37 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

speedtest current selected

Browse Source
This commit is contained in:
arm64v8a
2023-01-29 15:11:52 +09:00
parent c59f6b9042
commit 686ebea22f
6 changed files with 117 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
ui/mainwindow_grpc.cpp
View File

@@ -41,8 +41,11 @@ void MainWindow::setup_grpc() {
inline bool speedtesting = false;
void MainWindow::speedtest_current_group(int mode) {
#ifndef NKR_NO_GRPC
if (speedtesting) return;
auto profiles = get_selected_or_group();
if (profiles.isEmpty()) return;
auto group = NekoRay::profileManager->CurrentGroup();
if (group->archive) return;
QStringList full_test_flags;
if (mode == libcore::FullTest) {
@@ -59,23 +62,13 @@ void MainWindow::speedtest_current_group(int mode) {
}
speedtesting = true;
runOnNewThread([=]() {
auto group = NekoRay::profileManager->CurrentGroup();
if (group->archive) return;
auto order = ui->proxyListTable->order; // copy
#ifndef NKR_NO_GRPC
runOnNewThread([this, profiles, mode, full_test_flags]() {
QMutex lock_write;
QMutex lock_return;
QList<QSharedPointer<NekoRay::ProxyEntity>> profiles;
int threadN = mode == libcore::FullTest ? 1 : NekoRay::dataStore->test_concurrent;
int threadN_finished = 0;
// 这个是按照显示的顺序
for (auto id: order) {
auto profile = NekoRay::profileManager->GetProfile(id);
if (profile != nullptr) profiles += profile;
}
auto profiles_test = profiles; // copy
// Threads
lock_return.lock();
@@ -84,13 +77,13 @@ void MainWindow::speedtest_current_group(int mode) {
forever {
//
lock_write.lock();
if (profiles.isEmpty()) {
if (profiles_test.isEmpty()) {
threadN_finished++;
if (threadN == threadN_finished) lock_return.unlock();
lock_write.unlock();
return;
}
auto profile = profiles.takeFirst();
auto profile = profiles_test.takeFirst();
lock_write.unlock();
//