Ma/mscp
1
0
Fork 0
mirror of https://github.com/upa/mscp.git synced 2026-05-17 09:37:30 +08:00
Code Issues Packages Projects Releases 1 Wiki Activity

spawn monitor thread before copy threads

Browse Source
This commit is contained in:
Ryo Nakamura
2022-10-23 16:05:49 +09:00
parent 77e977ce8e
commit 03a20c77d8
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/main.c
View File

@@ -300,6 +300,14 @@ int main(int argc, char **argv)
goto out; goto out;
} }
/* spawn count thread */
ret = pthread_create(&mtid, NULL, sscp_monitor_thread, &sscp);
if (ret < 0) {
pr_err("pthread_create error: %d\n", ret);
stop_all(0);
goto join_out;
}
/* spawn threads */ /* spawn threads */
threads = calloc(nr_threads, sizeof(struct sscp_thread)); threads = calloc(nr_threads, sizeof(struct sscp_thread));
memset(threads, 0, nr_threads * sizeof(struct sscp_thread)); memset(threads, 0, nr_threads * sizeof(struct sscp_thread));
@@ -319,15 +327,6 @@ int main(int argc, char **argv)
} }
} }
/* spawn count thread */
ret = pthread_create(&mtid, NULL, sscp_monitor_thread, &sscp);
if (ret < 0) {
pr_err("pthread_create error: %d\n", ret);
stop_all(0);
goto join_out;
}
join_out: join_out:
/* waiting for threads join... */ /* waiting for threads join... */
for (n = 0; n < nr_threads; n++) for (n = 0; n < nr_threads; n++)