Blame tests/threads/thread_helpers.c
|
Packit Service |
20376f |
#include "clar_libgit2.h"
|
|
Packit Service |
20376f |
#include "thread_helpers.h"
|
|
Packit Service |
20376f |
|
|
Packit Service |
20376f |
void run_in_parallel(
|
|
Packit Service |
20376f |
int repeats,
|
|
Packit Service |
20376f |
int threads,
|
|
Packit Service |
20376f |
void *(*func)(void *),
|
|
Packit Service |
20376f |
void (*before_test)(void),
|
|
Packit Service |
20376f |
void (*after_test)(void))
|
|
Packit Service |
20376f |
{
|
|
Packit Service |
20376f |
int r, t, *id = git__calloc(threads, sizeof(int));
|
|
Packit Service |
20376f |
#ifdef GIT_THREADS
|
|
Packit Service |
20376f |
git_thread *th = git__calloc(threads, sizeof(git_thread));
|
|
Packit Service |
20376f |
cl_assert(th != NULL);
|
|
Packit Service |
20376f |
#else
|
|
Packit Service |
20376f |
void *th = NULL;
|
|
Packit Service |
20376f |
#endif
|
|
Packit Service |
20376f |
|
|
Packit Service |
20376f |
cl_assert(id != NULL);
|
|
Packit Service |
20376f |
|
|
Packit Service |
20376f |
for (r = 0; r < repeats; ++r) {
|
|
Packit Service |
20376f |
if (before_test) before_test();
|
|
Packit Service |
20376f |
|
|
Packit Service |
20376f |
for (t = 0; t < threads; ++t) {
|
|
Packit Service |
20376f |
id[t] = t;
|
|
Packit Service |
20376f |
#ifdef GIT_THREADS
|
|
Packit Service |
20376f |
cl_git_pass(git_thread_create(&th[t], func, &id[t]));
|
|
Packit Service |
20376f |
#else
|
|
Packit Service |
20376f |
cl_assert(func(&id[t]) == &id[t]);
|
|
Packit Service |
20376f |
#endif
|
|
Packit Service |
20376f |
}
|
|
Packit Service |
20376f |
|
|
Packit Service |
20376f |
#ifdef GIT_THREADS
|
|
Packit Service |
20376f |
for (t = 0; t < threads; ++t)
|
|
Packit Service |
20376f |
cl_git_pass(git_thread_join(&th[t], NULL));
|
|
Packit Service |
20376f |
memset(th, 0, threads * sizeof(git_thread));
|
|
Packit Service |
20376f |
#endif
|
|
Packit Service |
20376f |
|
|
Packit Service |
20376f |
if (after_test) after_test();
|
|
Packit Service |
20376f |
}
|
|
Packit Service |
20376f |
|
|
Packit Service |
20376f |
git__free(id);
|
|
Packit Service |
20376f |
git__free(th);
|
|
Packit Service |
20376f |
}
|