summaryrefslogtreecommitdiff
path: root/tests/poolTests.c
diff options
context:
space:
mode:
Diffstat (limited to 'tests/poolTests.c')
-rw-r--r--tests/poolTests.c19
1 files changed, 11 insertions, 8 deletions
diff --git a/tests/poolTests.c b/tests/poolTests.c
index 8b9a4700229d7..272e961d3800b 100644
--- a/tests/poolTests.c
+++ b/tests/poolTests.c
@@ -12,6 +12,7 @@
#include "pool.h"
#include "threading.h"
#include "util.h"
+#include "timefn.h"
#include <stddef.h>
#include <stdio.h>
@@ -25,25 +26,27 @@
#define ASSERT_EQ(lhs, rhs) ASSERT_TRUE((lhs) == (rhs))
struct data {
- pthread_mutex_t mutex;
+ ZSTD_pthread_mutex_t mutex;
unsigned data[16];
size_t i;
};
-static void fn(void *opaque) {
+static void fn(void *opaque)
+{
struct data *data = (struct data *)opaque;
ZSTD_pthread_mutex_lock(&data->mutex);
- data->data[data->i] = data->i;
+ data->data[data->i] = (unsigned)(data->i);
++data->i;
ZSTD_pthread_mutex_unlock(&data->mutex);
}
-static int testOrder(size_t numThreads, size_t queueSize) {
+static int testOrder(size_t numThreads, size_t queueSize)
+{
struct data data;
- POOL_ctx *ctx = POOL_create(numThreads, queueSize);
+ POOL_ctx* const ctx = POOL_create(numThreads, queueSize);
ASSERT_TRUE(ctx);
data.i = 0;
- ZSTD_pthread_mutex_init(&data.mutex, NULL);
+ (void)ZSTD_pthread_mutex_init(&data.mutex, NULL);
{ size_t i;
for (i = 0; i < 16; ++i) {
POOL_add(ctx, &fn, &data);
@@ -71,7 +74,7 @@ static void waitFn(void *opaque) {
/* Tests for deadlock */
static int testWait(size_t numThreads, size_t queueSize) {
struct data data;
- POOL_ctx *ctx = POOL_create(numThreads, queueSize);
+ POOL_ctx* const ctx = POOL_create(numThreads, queueSize);
ASSERT_TRUE(ctx);
{ size_t i;
for (i = 0; i < 16; ++i) {
@@ -93,7 +96,7 @@ typedef struct {
} poolTest_t;
static void waitLongFn(void *opaque) {
- poolTest_t* test = (poolTest_t*) opaque;
+ poolTest_t* const test = (poolTest_t*) opaque;
UTIL_sleepMilli(10);
ZSTD_pthread_mutex_lock(&test->mut);
test->val = test->val + 1;