admin/mlib
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix data race.

Browse Source
This commit is contained in:
Patrick Pelissier committed 2017-12-25 01:20:58 +01:00
1 parent 602cc63c96
commit b4cf464e98
1 file changed
+2 -2
Download Patch File Download Diff File Expand all files Collapse all files
m-worker.h
+2 -2
View File
@@ -199,11 +199,11 @@ worker_init(worker_t g, unsigned int numWorker, unsigned int extraQueue, void (*
size_t numWorker_st = numWorker; size_t numWorker_st = numWorker;
g->worker = M_MEMORY_REALLOC(worker_thread_t, NULL, numWorker_st); g->worker = M_MEMORY_REALLOC(worker_thread_t, NULL, numWorker_st);
M_ASSERT_INIT (g->worker != NULL); M_ASSERT_INIT (g->worker != NULL);
g->numWorker_g = numWorker;
g->resetFunc_g = resetFunc;
for(size_t i = 0; i < numWorker; i++) { for(size_t i = 0; i < numWorker; i++) {
m_thread_create(g->worker[i].id, workeri_thread, M_ASSIGN_CAST(void*, g)); m_thread_create(g->worker[i].id, workeri_thread, M_ASSIGN_CAST(void*, g));
} }
g->numWorker_g = numWorker;
g->resetFunc_g = resetFunc;
} }
/* Clear of the worker module */ /* Clear of the worker module */