Welcome to mirror list, hosted at ThFree Co, Russian Federation.

git.blender.org/blender.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCampbell Barton <ideasman42@gmail.com>2019-04-17 07:17:24 +0300
committerCampbell Barton <ideasman42@gmail.com>2019-04-17 07:21:24 +0300
commite12c08e8d170b7ca40f204a5b0423c23a9fbc2c1 (patch)
tree8cf3453d12edb177a218ef8009357518ec6cab6a /tests/gtests/blenlib/BLI_linklist_lockfree_test.cc
parentb3dabc200a4b0399ec6b81f2ff2730d07b44fcaa (diff)
ClangFormat: apply to source, most of intern
Apply clang format as proposed in T53211. For details on usage and instructions for migrating branches without conflicts, see: https://wiki.blender.org/wiki/Tools/ClangFormat
Diffstat (limited to 'tests/gtests/blenlib/BLI_linklist_lockfree_test.cc')
-rw-r--r--tests/gtests/blenlib/BLI_linklist_lockfree_test.cc174
1 files changed, 80 insertions, 94 deletions
diff --git a/tests/gtests/blenlib/BLI_linklist_lockfree_test.cc b/tests/gtests/blenlib/BLI_linklist_lockfree_test.cc
index 309efaee00e..265637ef32c 100644
--- a/tests/gtests/blenlib/BLI_linklist_lockfree_test.cc
+++ b/tests/gtests/blenlib/BLI_linklist_lockfree_test.cc
@@ -9,122 +9,108 @@
#include "BLI_task.h"
#include "BLI_threads.h"
-
TEST(LockfreeLinkList, Init)
{
- LockfreeLinkList list;
- BLI_linklist_lockfree_init(&list);
- EXPECT_EQ(list.head, &list.dummy_node);
- EXPECT_EQ(list.tail, &list.dummy_node);
- BLI_linklist_lockfree_free(&list, NULL);
+ LockfreeLinkList list;
+ BLI_linklist_lockfree_init(&list);
+ EXPECT_EQ(list.head, &list.dummy_node);
+ EXPECT_EQ(list.tail, &list.dummy_node);
+ BLI_linklist_lockfree_free(&list, NULL);
}
TEST(LockfreeLinkList, InsertSingle)
{
- LockfreeLinkList list;
- LockfreeLinkNode node;
- BLI_linklist_lockfree_init(&list);
- BLI_linklist_lockfree_insert(&list, &node);
- EXPECT_EQ(list.head, &list.dummy_node);
- EXPECT_EQ(list.head->next, &node);
- EXPECT_EQ(list.tail, &node);
- BLI_linklist_lockfree_free(&list, NULL);
+ LockfreeLinkList list;
+ LockfreeLinkNode node;
+ BLI_linklist_lockfree_init(&list);
+ BLI_linklist_lockfree_insert(&list, &node);
+ EXPECT_EQ(list.head, &list.dummy_node);
+ EXPECT_EQ(list.head->next, &node);
+ EXPECT_EQ(list.tail, &node);
+ BLI_linklist_lockfree_free(&list, NULL);
}
TEST(LockfreeLinkList, InsertMultiple)
{
- static const int num_nodes = 128;
- LockfreeLinkList list;
- LockfreeLinkNode nodes[num_nodes];
- BLI_linklist_lockfree_init(&list);
- /* Insert all the nodes. */
- for (int i = 0; i < num_nodes; ++i) {
- BLI_linklist_lockfree_insert(&list, &nodes[i]);
- }
- /* Check head and tail. */
- EXPECT_EQ(list.head, &list.dummy_node);
- EXPECT_EQ(list.tail, &nodes[num_nodes - 1]);
- /* Check rest of the nodes. */
- int node_index = 0;
- for (LockfreeLinkNode *node = BLI_linklist_lockfree_begin(&list);
- node != NULL;
- node = node->next, ++node_index)
- {
- EXPECT_EQ(node, &nodes[node_index]);
- if (node_index != num_nodes - 1) {
- EXPECT_EQ(node->next, &nodes[node_index + 1]);
- }
- }
- /* Free list. */
- BLI_linklist_lockfree_free(&list, NULL);
+ static const int num_nodes = 128;
+ LockfreeLinkList list;
+ LockfreeLinkNode nodes[num_nodes];
+ BLI_linklist_lockfree_init(&list);
+ /* Insert all the nodes. */
+ for (int i = 0; i < num_nodes; ++i) {
+ BLI_linklist_lockfree_insert(&list, &nodes[i]);
+ }
+ /* Check head and tail. */
+ EXPECT_EQ(list.head, &list.dummy_node);
+ EXPECT_EQ(list.tail, &nodes[num_nodes - 1]);
+ /* Check rest of the nodes. */
+ int node_index = 0;
+ for (LockfreeLinkNode *node = BLI_linklist_lockfree_begin(&list); node != NULL;
+ node = node->next, ++node_index) {
+ EXPECT_EQ(node, &nodes[node_index]);
+ if (node_index != num_nodes - 1) {
+ EXPECT_EQ(node->next, &nodes[node_index + 1]);
+ }
+ }
+ /* Free list. */
+ BLI_linklist_lockfree_free(&list, NULL);
}
namespace {
struct IndexedNode {
- IndexedNode *next;
- int index;
+ IndexedNode *next;
+ int index;
};
-void concurrent_insert(TaskPool *__restrict pool,
- void *taskdata,
- int /*threadid*/)
+void concurrent_insert(TaskPool *__restrict pool, void *taskdata, int /*threadid*/)
{
- LockfreeLinkList *list = (LockfreeLinkList *)BLI_task_pool_userdata(pool);
- CHECK_NOTNULL(list);
- IndexedNode *node = (IndexedNode *)MEM_mallocN(sizeof(IndexedNode),
- "test node");
- node->index = POINTER_AS_INT(taskdata);
- BLI_linklist_lockfree_insert(list, (LockfreeLinkNode *)node);
+ LockfreeLinkList *list = (LockfreeLinkList *)BLI_task_pool_userdata(pool);
+ CHECK_NOTNULL(list);
+ IndexedNode *node = (IndexedNode *)MEM_mallocN(sizeof(IndexedNode), "test node");
+ node->index = POINTER_AS_INT(taskdata);
+ BLI_linklist_lockfree_insert(list, (LockfreeLinkNode *)node);
}
-
} // namespace
TEST(LockfreeLinkList, InsertMultipleConcurrent)
{
- static const int num_threads = 512;
- static const int num_nodes = 655360;
- /* Initialize list. */
- LockfreeLinkList list;
- BLI_linklist_lockfree_init(&list);
- /* Initialize task scheduler and pool. */
- TaskScheduler *scheduler = BLI_task_scheduler_create(num_threads);
- TaskPool *pool = BLI_task_pool_create_suspended(scheduler, &list);
- /* Push tasks to the pool. */
- for (int i = 0; i < num_nodes; ++i) {
- BLI_task_pool_push(pool,
- concurrent_insert,
- POINTER_FROM_INT(i),
- false,
- TASK_PRIORITY_HIGH);
- }
- /* Run all the tasks. */
- BLI_threaded_malloc_begin();
- BLI_task_pool_work_and_wait(pool);
- BLI_threaded_malloc_end();
- /* Verify we've got all the data properly inserted. */
- EXPECT_EQ(list.head, &list.dummy_node);
- bool *visited_nodes = (bool *)MEM_callocN(sizeof(bool) * num_nodes,
- "visited nodes");
- /* First, we make sure that none of the nodes are added twice. */
- for (LockfreeLinkNode *node_v = BLI_linklist_lockfree_begin(&list);
- node_v != NULL;
- node_v = node_v->next)
- {
- IndexedNode *node = (IndexedNode *)node_v;
- EXPECT_GE(node->index, 0);
- EXPECT_LT(node->index, num_nodes);
- EXPECT_FALSE(visited_nodes[node->index]);
- visited_nodes[node->index] = true;
- }
- /* Then we make sure node was added. */
- for (int node_index = 0; node_index < num_nodes; ++node_index) {
- EXPECT_TRUE(visited_nodes[node_index]);
- }
- MEM_freeN(visited_nodes);
- /* Cleanup data. */
- BLI_linklist_lockfree_free(&list, MEM_freeN);
- BLI_task_pool_free(pool);
- BLI_task_scheduler_free(scheduler);
+ static const int num_threads = 512;
+ static const int num_nodes = 655360;
+ /* Initialize list. */
+ LockfreeLinkList list;
+ BLI_linklist_lockfree_init(&list);
+ /* Initialize task scheduler and pool. */
+ TaskScheduler *scheduler = BLI_task_scheduler_create(num_threads);
+ TaskPool *pool = BLI_task_pool_create_suspended(scheduler, &list);
+ /* Push tasks to the pool. */
+ for (int i = 0; i < num_nodes; ++i) {
+ BLI_task_pool_push(pool, concurrent_insert, POINTER_FROM_INT(i), false, TASK_PRIORITY_HIGH);
+ }
+ /* Run all the tasks. */
+ BLI_threaded_malloc_begin();
+ BLI_task_pool_work_and_wait(pool);
+ BLI_threaded_malloc_end();
+ /* Verify we've got all the data properly inserted. */
+ EXPECT_EQ(list.head, &list.dummy_node);
+ bool *visited_nodes = (bool *)MEM_callocN(sizeof(bool) * num_nodes, "visited nodes");
+ /* First, we make sure that none of the nodes are added twice. */
+ for (LockfreeLinkNode *node_v = BLI_linklist_lockfree_begin(&list); node_v != NULL;
+ node_v = node_v->next) {
+ IndexedNode *node = (IndexedNode *)node_v;
+ EXPECT_GE(node->index, 0);
+ EXPECT_LT(node->index, num_nodes);
+ EXPECT_FALSE(visited_nodes[node->index]);
+ visited_nodes[node->index] = true;
+ }
+ /* Then we make sure node was added. */
+ for (int node_index = 0; node_index < num_nodes; ++node_index) {
+ EXPECT_TRUE(visited_nodes[node_index]);
+ }
+ MEM_freeN(visited_nodes);
+ /* Cleanup data. */
+ BLI_linklist_lockfree_free(&list, MEM_freeN);
+ BLI_task_pool_free(pool);
+ BLI_task_scheduler_free(scheduler);
}