2017-05-11 08:03:52 +08:00
|
|
|
//===- llvm/unittest/Support/ParallelTest.cpp -----------------------------===//
|
2013-04-13 02:40:39 +08:00
|
|
|
//
|
2019-01-19 16:50:56 +08:00
|
|
|
// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
|
|
|
|
// See https://llvm.org/LICENSE.txt for license information.
|
|
|
|
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
|
2013-04-13 02:40:39 +08:00
|
|
|
//
|
|
|
|
//===----------------------------------------------------------------------===//
|
|
|
|
///
|
|
|
|
/// \file
|
2018-05-01 23:54:18 +08:00
|
|
|
/// Parallel.h unit tests.
|
2013-04-13 02:40:39 +08:00
|
|
|
///
|
|
|
|
//===----------------------------------------------------------------------===//
|
|
|
|
|
2017-05-11 08:03:52 +08:00
|
|
|
#include "llvm/Support/Parallel.h"
|
2013-04-13 02:40:39 +08:00
|
|
|
#include "gtest/gtest.h"
|
|
|
|
#include <array>
|
|
|
|
#include <random>
|
|
|
|
|
|
|
|
uint32_t array[1024 * 1024];
|
|
|
|
|
2017-05-11 08:03:52 +08:00
|
|
|
using namespace llvm;
|
|
|
|
|
2017-05-11 14:35:51 +08:00
|
|
|
// Tests below are hanging up on mingw. Investigating.
|
|
|
|
#if !defined(__MINGW32__)
|
|
|
|
|
2013-04-13 02:40:39 +08:00
|
|
|
TEST(Parallel, sort) {
|
|
|
|
std::mt19937 randEngine;
|
|
|
|
std::uniform_int_distribution<uint32_t> dist;
|
|
|
|
|
|
|
|
for (auto &i : array)
|
|
|
|
i = dist(randEngine);
|
|
|
|
|
[Support] Move LLD's parallel algorithm wrappers to support
Essentially takes the lld/Common/Threads.h wrappers and moves them to
the llvm/Support/Paralle.h algorithm header.
The changes are:
- Remove policy parameter, since all clients use `par`.
- Rename the methods to `parallelSort` etc to match LLVM style, since
they are no longer C++17 pstl compatible.
- Move algorithms from llvm::parallel:: to llvm::, since they have
"parallel" in the name and are no longer overloads of the regular
algorithms.
- Add range overloads
- Use the sequential algorithm directly when 1 thread is requested
(skips task grouping)
- Fix the index type of parallelForEachN to size_t. Nobody in LLVM was
using any other parameter, and it made overload resolution hard for
for_each_n(par, 0, foo.size(), ...) because 0 is int, not size_t.
Remove Threads.h and update LLD for that.
This is a prerequisite for parallel public symbol processing in the PDB
library, which is in LLVM.
Reviewed By: MaskRay, aganea
Differential Revision: https://reviews.llvm.org/D79390
2020-05-05 11:03:19 +08:00
|
|
|
parallelSort(std::begin(array), std::end(array));
|
2020-04-13 19:46:41 +08:00
|
|
|
ASSERT_TRUE(llvm::is_sorted(array));
|
2013-04-13 02:40:39 +08:00
|
|
|
}
|
2017-04-07 16:11:28 +08:00
|
|
|
|
|
|
|
TEST(Parallel, parallel_for) {
|
|
|
|
// We need to test the case with a TaskSize > 1. We are white-box testing
|
|
|
|
// here. The TaskSize is calculated as (End - Begin) / 1024 at the time of
|
|
|
|
// writing.
|
|
|
|
uint32_t range[2050];
|
|
|
|
std::fill(range, range + 2050, 1);
|
[Support] Move LLD's parallel algorithm wrappers to support
Essentially takes the lld/Common/Threads.h wrappers and moves them to
the llvm/Support/Paralle.h algorithm header.
The changes are:
- Remove policy parameter, since all clients use `par`.
- Rename the methods to `parallelSort` etc to match LLVM style, since
they are no longer C++17 pstl compatible.
- Move algorithms from llvm::parallel:: to llvm::, since they have
"parallel" in the name and are no longer overloads of the regular
algorithms.
- Add range overloads
- Use the sequential algorithm directly when 1 thread is requested
(skips task grouping)
- Fix the index type of parallelForEachN to size_t. Nobody in LLVM was
using any other parameter, and it made overload resolution hard for
for_each_n(par, 0, foo.size(), ...) because 0 is int, not size_t.
Remove Threads.h and update LLD for that.
This is a prerequisite for parallel public symbol processing in the PDB
library, which is in LLVM.
Reviewed By: MaskRay, aganea
Differential Revision: https://reviews.llvm.org/D79390
2020-05-05 11:03:19 +08:00
|
|
|
parallelForEachN(0, 2049, [&range](size_t I) { ++range[I]; });
|
2017-04-07 16:11:28 +08:00
|
|
|
|
|
|
|
uint32_t expected[2049];
|
|
|
|
std::fill(expected, expected + 2049, 2);
|
|
|
|
ASSERT_TRUE(std::equal(range, range + 2049, expected));
|
|
|
|
// Check that we don't write past the end of the requested range.
|
2017-04-07 16:48:17 +08:00
|
|
|
ASSERT_EQ(range[2049], 1u);
|
2017-04-07 16:11:28 +08:00
|
|
|
}
|
2017-05-11 14:35:51 +08:00
|
|
|
|
|
|
|
#endif
|