mirror of
https://git.proxmox.com/git/libgit2
synced 2025-11-04 08:48:25 +00:00
45 lines
869 B
C
45 lines
869 B
C
#include "clar_libgit2.h"
|
|
#include "thread_helpers.h"
|
|
|
|
void run_in_parallel(
|
|
int repeats,
|
|
int threads,
|
|
void *(*func)(void *),
|
|
void (*before_test)(void),
|
|
void (*after_test)(void))
|
|
{
|
|
int r, t, *id = git__calloc(threads, sizeof(int));
|
|
#ifdef GIT_THREADS
|
|
git_thread *th = git__calloc(threads, sizeof(git_thread));
|
|
cl_assert(th != NULL);
|
|
#else
|
|
void *th = NULL;
|
|
#endif
|
|
|
|
cl_assert(id != NULL);
|
|
|
|
for (r = 0; r < repeats; ++r) {
|
|
if (before_test) before_test();
|
|
|
|
for (t = 0; t < threads; ++t) {
|
|
id[t] = t;
|
|
#ifdef GIT_THREADS
|
|
cl_git_pass(git_thread_create(&th[t], func, &id[t]));
|
|
#else
|
|
cl_assert(func(&id[t]) == &id[t]);
|
|
#endif
|
|
}
|
|
|
|
#ifdef GIT_THREADS
|
|
for (t = 0; t < threads; ++t)
|
|
cl_git_pass(git_thread_join(&th[t], NULL));
|
|
memset(th, 0, threads * sizeof(git_thread));
|
|
#endif
|
|
|
|
if (after_test) after_test();
|
|
}
|
|
|
|
git__free(id);
|
|
git__free(th);
|
|
}
|