Compare commits
138 Commits
5c0cc1edf5
...
interleave
Author | SHA1 | Date | |
---|---|---|---|
d6269c5b7c | |||
faacdff2d9 | |||
821179b8de | |||
681a961289 | |||
c73a3da14c | |||
5153d25cce | |||
d2ec4e7fae | |||
c7e2358746 | |||
ec1c1cf43f | |||
eaad0c69a7 | |||
309e6ab816 | |||
12b82c1be5 | |||
0cce9df8a8 | |||
0df09743da | |||
c4b0aa1085 | |||
051bfb05fe | |||
7e1bcbf9be | |||
4e685bbc3b | |||
b6bfc6f48d | |||
3b858551f3 | |||
2c1c26bc88 | |||
958ee15cfc | |||
9015b555de | |||
7aac73ee80 | |||
c06afeb81e | |||
b015711b7c | |||
f27ca6d6af | |||
c0bb175b7e | |||
6a6fe5738a | |||
dc16eccf06 | |||
3f15db7e82 | |||
e8a8b5aef1 | |||
b8fefff3ba | |||
2706b2f65e | |||
f1292efe41 | |||
a2d3d269ec | |||
8ff7a112b7 | |||
cf25b8626c | |||
e025f934d8 | |||
e5452c0f7d | |||
66fc526a55 | |||
21f08b9f88 | |||
10c2f06199 | |||
5cf04e9718 | |||
707b220fbc | |||
fd39065498 | |||
b963d481c9 | |||
e7ed47e288 | |||
04f138109b | |||
a0d07dd40c | |||
7fb408b466 | |||
6d265acfc7 | |||
67a61513b8 | |||
583f2e7612 | |||
66e5b033c0 | |||
1d705cd4b7 | |||
769cf8de9a | |||
84942a5bf8 | |||
7ad6872ee8 | |||
9db5eb960d | |||
5df25a138a | |||
381fbce0c0 | |||
87aeb349a3 | |||
28fb0d7faa | |||
5013c689a0 | |||
316bbf679f | |||
58aabe83f5 | |||
0c8a051913 | |||
11e8717da8 | |||
824037bf32 | |||
bbe964110e | |||
100449c76c | |||
51b5f638a4 | |||
767dacc742 | |||
978a7585b6 | |||
71b3c7fb7f | |||
420f50c40f | |||
69a131df38 | |||
8a4032e850 | |||
9c365435ea | |||
8eb5e76336 | |||
e8982074f2 | |||
f60833a57f | |||
47fd811efc | |||
73f93edf49 | |||
8bac1f66fc | |||
352c07cbc9 | |||
2e7e357355 | |||
147f5af16b | |||
323b239411 | |||
54c7ccb96b | |||
6a12210866 | |||
416504158e | |||
b0bc68a14e | |||
0de85ecda0 | |||
44afb8be00 | |||
ecdbaaf2c1 | |||
2c253c29b5 | |||
fe9678787d | |||
0ac259c782 | |||
8b1a0afc58 | |||
2018fa277c | |||
1faeb220d5 | |||
0dc657bfeb | |||
b51ef97c71 | |||
31ad3e8e1c | |||
e213237698 | |||
a1c61962a1 | |||
a28283748c | |||
cafa540fc8 | |||
b9c642d81d | |||
7abb129f03 | |||
3739ccaaf2 | |||
c3190c11ac | |||
52b4bf5a0e | |||
5516477956 | |||
f639db18a5 | |||
f8a1643714 | |||
a0a961ae58 | |||
f41a62471b | |||
d8f85dedc4 | |||
656939560b | |||
5580f9b71d | |||
628d16b7e6 | |||
d9e4a7d1b6 | |||
52201fa4c7 | |||
0814822d82 | |||
41df2398e8 | |||
84c4d0fcba | |||
6241533dfb | |||
0abf6a1ecf | |||
867136ff1b | |||
4b8f7320d3 | |||
6628092384 | |||
a0a4f1afea | |||
ca479c03ce | |||
0a2e133ab9 | |||
b0b31419b0 |
59
Bench.cpp
59
Bench.cpp
@@ -7,7 +7,6 @@
|
|||||||
void showMemory(const ConflictSet &cs);
|
void showMemory(const ConflictSet &cs);
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#define ANKERL_NANOBENCH_IMPLEMENT
|
|
||||||
#include "third_party/nanobench.h"
|
#include "third_party/nanobench.h"
|
||||||
|
|
||||||
constexpr int kNumKeys = 1000000;
|
constexpr int kNumKeys = 1000000;
|
||||||
@@ -18,26 +17,26 @@ constexpr int kPrefixLen = 0;
|
|||||||
|
|
||||||
constexpr int kMvccWindow = 100000;
|
constexpr int kMvccWindow = 100000;
|
||||||
|
|
||||||
std::span<const uint8_t> makeKey(Arena &arena, int index) {
|
TrivialSpan makeKey(Arena &arena, int index) {
|
||||||
|
|
||||||
auto result =
|
uint8_t *buf = new (arena) uint8_t[4 + kPrefixLen];
|
||||||
std::span<uint8_t>{new (arena) uint8_t[4 + kPrefixLen], 4 + kPrefixLen};
|
auto result = TrivialSpan{buf, 4 + kPrefixLen};
|
||||||
index = __builtin_bswap32(index);
|
index = __builtin_bswap32(index);
|
||||||
memset(result.data(), 0, kPrefixLen);
|
memset(buf, 0, kPrefixLen);
|
||||||
memcpy(result.data() + kPrefixLen, &index, 4);
|
memcpy(buf, &index, 4);
|
||||||
|
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
ConflictSet::ReadRange singleton(Arena &arena, std::span<const uint8_t> key) {
|
ConflictSet::ReadRange singleton(Arena &arena, TrivialSpan key) {
|
||||||
auto r =
|
uint8_t *buf = new (arena) uint8_t[key.size() + 1];
|
||||||
std::span<uint8_t>(new (arena) uint8_t[key.size() + 1], key.size() + 1);
|
auto r = TrivialSpan(buf, key.size() + 1);
|
||||||
memcpy(r.data(), key.data(), key.size());
|
memcpy(buf, key.data(), key.size());
|
||||||
r[key.size()] = 0;
|
buf[key.size()] = 0;
|
||||||
return {{key.data(), int(key.size())}, {r.data(), int(r.size())}, 0};
|
return {{key.data(), int(key.size())}, {r.data(), int(r.size())}, 0};
|
||||||
}
|
}
|
||||||
|
|
||||||
ConflictSet::ReadRange prefixRange(Arena &arena, std::span<const uint8_t> key) {
|
ConflictSet::ReadRange prefixRange(Arena &arena, TrivialSpan key) {
|
||||||
int index;
|
int index;
|
||||||
for (index = key.size() - 1; index >= 0; index--)
|
for (index = key.size() - 1; index >= 0; index--)
|
||||||
if ((key[index]) != 255)
|
if ((key[index]) != 255)
|
||||||
@@ -49,9 +48,10 @@ ConflictSet::ReadRange prefixRange(Arena &arena, std::span<const uint8_t> key) {
|
|||||||
assert(false);
|
assert(false);
|
||||||
}
|
}
|
||||||
|
|
||||||
auto r = std::span<uint8_t>(new (arena) uint8_t[index + 1], index + 1);
|
uint8_t *buf = new (arena) uint8_t[index + 1];
|
||||||
memcpy(r.data(), key.data(), index + 1);
|
auto r = TrivialSpan(buf, index + 1);
|
||||||
r[r.size() - 1]++;
|
memcpy(buf, key.data(), index + 1);
|
||||||
|
buf[r.size() - 1]++;
|
||||||
return {{key.data(), int(key.size())}, {r.data(), int(r.size())}, 0};
|
return {{key.data(), int(key.size())}, {r.data(), int(r.size())}, 0};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -82,14 +82,7 @@ void benchConflictSet() {
|
|||||||
++version;
|
++version;
|
||||||
}
|
}
|
||||||
|
|
||||||
// I don't know why std::less didn't work /shrug
|
auto points = set<TrivialSpan, std::less<>>(arena);
|
||||||
struct Less {
|
|
||||||
bool operator()(const std::span<const uint8_t> &lhs,
|
|
||||||
const std::span<const uint8_t> &rhs) const {
|
|
||||||
return lhs < rhs;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
auto points = set<std::span<const uint8_t>, Less>(arena);
|
|
||||||
|
|
||||||
while (points.size() < kOpsPerTx * 2 + 1) {
|
while (points.size() < kOpsPerTx * 2 + 1) {
|
||||||
// TODO don't use rand?
|
// TODO don't use rand?
|
||||||
@@ -333,16 +326,22 @@ void benchWorstCaseForRadixRangeRead() {
|
|||||||
auto end = std::vector<uint8_t>(kKeyLenForWorstCase - 1, 255);
|
auto end = std::vector<uint8_t>(kKeyLenForWorstCase - 1, 255);
|
||||||
end.push_back(254);
|
end.push_back(254);
|
||||||
|
|
||||||
weaselab::ConflictSet::Result result;
|
weaselab::ConflictSet::ReadRange r[] = {
|
||||||
weaselab::ConflictSet::ReadRange r{
|
{{begin.data(), int(begin.size())}, {end.data(), int(end.size())}, 0},
|
||||||
{begin.data(), int(begin.size())}, {end.data(), int(end.size())}, 0};
|
};
|
||||||
|
weaselab::ConflictSet::Result results[sizeof(r) / sizeof(r[0])];
|
||||||
|
for (auto &result : results) {
|
||||||
|
result = weaselab::ConflictSet::TooOld;
|
||||||
|
}
|
||||||
|
bench.batch(sizeof(r) / sizeof(r[0]));
|
||||||
|
|
||||||
bench.run("worst case for radix tree", [&]() {
|
bench.run("worst case for radix tree", [&]() {
|
||||||
for (int i = 0; i < 256; ++i) {
|
for (int i = 0; i < 256; ++i) {
|
||||||
result = weaselab::ConflictSet::TooOld;
|
cs[i]->check(r, results, sizeof(r) / sizeof(r[0]));
|
||||||
cs[i]->check(&r, &result, 1);
|
for (auto result : results) {
|
||||||
if (result != weaselab::ConflictSet::Commit) {
|
if (result != weaselab::ConflictSet::Commit) {
|
||||||
abort();
|
abort();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
104
CMakeLists.txt
104
CMakeLists.txt
@@ -33,6 +33,15 @@ endif()
|
|||||||
|
|
||||||
add_compile_options(-fdata-sections -ffunction-sections -Wswitch-enum
|
add_compile_options(-fdata-sections -ffunction-sections -Wswitch-enum
|
||||||
-Werror=switch-enum -fPIC)
|
-Werror=switch-enum -fPIC)
|
||||||
|
|
||||||
|
if(CMAKE_CXX_COMPILER_ID STREQUAL "Clang")
|
||||||
|
add_link_options("-Wno-unused-command-line-argument")
|
||||||
|
endif()
|
||||||
|
|
||||||
|
if(CMAKE_CXX_COMPILER_ID STREQUAL "GNU")
|
||||||
|
add_compile_options("-Wno-maybe-uninitialized")
|
||||||
|
endif()
|
||||||
|
|
||||||
if(NOT APPLE)
|
if(NOT APPLE)
|
||||||
# This causes some versions of clang to crash on macos
|
# This causes some versions of clang to crash on macos
|
||||||
add_compile_options(-g -fno-omit-frame-pointer)
|
add_compile_options(-g -fno-omit-frame-pointer)
|
||||||
@@ -72,12 +81,6 @@ else()
|
|||||||
add_link_options(-Wl,--gc-sections)
|
add_link_options(-Wl,--gc-sections)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
if(EMSCRIPTEN)
|
|
||||||
# https://github.com/emscripten-core/emscripten/issues/15377#issuecomment-1285167486
|
|
||||||
add_link_options(-lnodefs.js -lnoderawfs.js)
|
|
||||||
add_link_options(-s ALLOW_MEMORY_GROWTH)
|
|
||||||
endif()
|
|
||||||
|
|
||||||
if(NOT USE_SIMD_FALLBACK)
|
if(NOT USE_SIMD_FALLBACK)
|
||||||
cmake_push_check_state()
|
cmake_push_check_state()
|
||||||
list(APPEND CMAKE_REQUIRED_FLAGS -mavx)
|
list(APPEND CMAKE_REQUIRED_FLAGS -mavx)
|
||||||
@@ -101,12 +104,23 @@ target_compile_options(${PROJECT_NAME}-object PRIVATE -fno-exceptions
|
|||||||
-fvisibility=hidden)
|
-fvisibility=hidden)
|
||||||
target_include_directories(${PROJECT_NAME}-object
|
target_include_directories(${PROJECT_NAME}-object
|
||||||
PRIVATE ${CMAKE_CURRENT_SOURCE_DIR}/include)
|
PRIVATE ${CMAKE_CURRENT_SOURCE_DIR}/include)
|
||||||
|
if(NOT LD_EXE)
|
||||||
|
set(LD_EXE ld)
|
||||||
|
endif()
|
||||||
|
add_custom_command(
|
||||||
|
OUTPUT ${CMAKE_BINARY_DIR}/${PROJECT_NAME}.o
|
||||||
|
COMMAND ${LD_EXE} -r $<TARGET_OBJECTS:${PROJECT_NAME}-object> -o
|
||||||
|
${CMAKE_BINARY_DIR}/${PROJECT_NAME}.o
|
||||||
|
DEPENDS $<TARGET_OBJECTS:${PROJECT_NAME}-object>
|
||||||
|
COMMAND_EXPAND_LISTS)
|
||||||
|
|
||||||
add_library(${PROJECT_NAME} SHARED $<TARGET_OBJECTS:${PROJECT_NAME}-object>)
|
add_library(${PROJECT_NAME} SHARED ${CMAKE_BINARY_DIR}/${PROJECT_NAME}.o)
|
||||||
set_target_properties(
|
set_target_properties(
|
||||||
${PROJECT_NAME} PROPERTIES LIBRARY_OUTPUT_DIRECTORY
|
${PROJECT_NAME} PROPERTIES LIBRARY_OUTPUT_DIRECTORY
|
||||||
"${CMAKE_CURRENT_BINARY_DIR}/radix_tree")
|
"${CMAKE_CURRENT_BINARY_DIR}/radix_tree")
|
||||||
if(NOT CMAKE_BUILD_TYPE STREQUAL Debug)
|
if(CMAKE_BUILD_TYPE STREQUAL Debug)
|
||||||
|
set_target_properties(${PROJECT_NAME} PROPERTIES LINKER_LANGUAGE CXX)
|
||||||
|
else()
|
||||||
set_target_properties(${PROJECT_NAME} PROPERTIES LINKER_LANGUAGE C)
|
set_target_properties(${PROJECT_NAME} PROPERTIES LINKER_LANGUAGE C)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
@@ -116,19 +130,13 @@ if(HAS_VERSION_SCRIPT)
|
|||||||
LINKER:--version-script=${CMAKE_CURRENT_SOURCE_DIR}/linker.map)
|
LINKER:--version-script=${CMAKE_CURRENT_SOURCE_DIR}/linker.map)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
add_library(${PROJECT_NAME}-static STATIC
|
add_library(${PROJECT_NAME}-static STATIC ${CMAKE_BINARY_DIR}/${PROJECT_NAME}.o)
|
||||||
$<TARGET_OBJECTS:${PROJECT_NAME}-object>)
|
if(CMAKE_BUILD_TYPE STREQUAL Debug)
|
||||||
if(NOT CMAKE_BUILD_TYPE STREQUAL Debug)
|
set_target_properties(${PROJECT_NAME}-static PROPERTIES LINKER_LANGUAGE CXX)
|
||||||
|
else()
|
||||||
set_target_properties(${PROJECT_NAME}-static PROPERTIES LINKER_LANGUAGE C)
|
set_target_properties(${PROJECT_NAME}-static PROPERTIES LINKER_LANGUAGE C)
|
||||||
endif()
|
endif()
|
||||||
|
if(NOT APPLE)
|
||||||
if(APPLE)
|
|
||||||
add_custom_command(
|
|
||||||
TARGET ${PROJECT_NAME}-static
|
|
||||||
PRE_LINK
|
|
||||||
COMMAND ${CMAKE_CURRENT_SOURCE_DIR}/privatize_symbols_macos.sh
|
|
||||||
$<TARGET_OBJECTS:${PROJECT_NAME}-object>)
|
|
||||||
else()
|
|
||||||
add_custom_command(
|
add_custom_command(
|
||||||
TARGET ${PROJECT_NAME}-static
|
TARGET ${PROJECT_NAME}-static
|
||||||
POST_BUILD
|
POST_BUILD
|
||||||
@@ -144,6 +152,8 @@ include(CTest)
|
|||||||
# disable tests if this is being used through e.g. FetchContent
|
# disable tests if this is being used through e.g. FetchContent
|
||||||
if(CMAKE_SOURCE_DIR STREQUAL CMAKE_CURRENT_SOURCE_DIR AND BUILD_TESTING)
|
if(CMAKE_SOURCE_DIR STREQUAL CMAKE_CURRENT_SOURCE_DIR AND BUILD_TESTING)
|
||||||
|
|
||||||
|
add_library(nanobench ${CMAKE_CURRENT_SOURCE_DIR}/nanobench.cpp)
|
||||||
|
|
||||||
set(TEST_FLAGS -Wall -Wextra -Wunreachable-code -Wpedantic -UNDEBUG)
|
set(TEST_FLAGS -Wall -Wextra -Wunreachable-code -Wpedantic -UNDEBUG)
|
||||||
|
|
||||||
# corpus tests, which are tests curated by libfuzzer. The goal is to get broad
|
# corpus tests, which are tests curated by libfuzzer. The goal is to get broad
|
||||||
@@ -181,16 +191,20 @@ if(CMAKE_SOURCE_DIR STREQUAL CMAKE_CURRENT_SOURCE_DIR AND BUILD_TESTING)
|
|||||||
target_compile_options(driver_skip_list PRIVATE ${TEST_FLAGS})
|
target_compile_options(driver_skip_list PRIVATE ${TEST_FLAGS})
|
||||||
target_link_libraries(driver_skip_list PRIVATE skip_list)
|
target_link_libraries(driver_skip_list PRIVATE skip_list)
|
||||||
|
|
||||||
foreach(TEST ${CORPUS_TESTS})
|
# enable to test skip list
|
||||||
get_filename_component(hash ${TEST} NAME)
|
if(0)
|
||||||
add_test(NAME skip_list_${hash} COMMAND driver_skip_list ${TEST})
|
foreach(TEST ${CORPUS_TESTS})
|
||||||
endforeach()
|
get_filename_component(hash ${TEST} NAME)
|
||||||
|
add_test(NAME skip_list_${hash} COMMAND driver_skip_list ${TEST})
|
||||||
|
endforeach()
|
||||||
|
endif()
|
||||||
|
|
||||||
# ad hoc testing
|
# ad hoc testing
|
||||||
add_executable(conflict_set_main ConflictSet.cpp)
|
add_executable(conflict_set_main ConflictSet.cpp)
|
||||||
target_include_directories(conflict_set_main
|
target_include_directories(conflict_set_main
|
||||||
PRIVATE ${CMAKE_CURRENT_SOURCE_DIR}/include)
|
PRIVATE ${CMAKE_CURRENT_SOURCE_DIR}/include)
|
||||||
target_compile_definitions(conflict_set_main PRIVATE ENABLE_MAIN)
|
target_compile_definitions(conflict_set_main PRIVATE ENABLE_MAIN)
|
||||||
|
target_link_libraries(conflict_set_main PRIVATE nanobench)
|
||||||
|
|
||||||
if(NOT APPLE)
|
if(NOT APPLE)
|
||||||
# libfuzzer target, to generate/manage corpus
|
# libfuzzer target, to generate/manage corpus
|
||||||
@@ -251,6 +265,19 @@ if(CMAKE_SOURCE_DIR STREQUAL CMAKE_CURRENT_SOURCE_DIR AND BUILD_TESTING)
|
|||||||
add_test(NAME conflict_set_blackbox_${hash} COMMAND driver ${TEST})
|
add_test(NAME conflict_set_blackbox_${hash} COMMAND driver ${TEST})
|
||||||
endforeach()
|
endforeach()
|
||||||
|
|
||||||
|
find_program(VALGRIND_EXE valgrind)
|
||||||
|
if(VALGRIND_EXE AND NOT CMAKE_CROSSCOMPILING)
|
||||||
|
list(LENGTH CORPUS_TESTS len)
|
||||||
|
math(EXPR last "${len} - 1")
|
||||||
|
set(partition_size 100)
|
||||||
|
foreach(i RANGE 0 ${last} ${partition_size})
|
||||||
|
list(SUBLIST CORPUS_TESTS ${i} ${partition_size} partition)
|
||||||
|
add_test(NAME conflict_set_blackbox_valgrind_${i}
|
||||||
|
COMMAND ${VALGRIND_EXE} --error-exitcode=99 --
|
||||||
|
$<TARGET_FILE:driver> ${partition})
|
||||||
|
endforeach()
|
||||||
|
endif()
|
||||||
|
|
||||||
# scripted tests. Written manually to fill in anything libfuzzer couldn't
|
# scripted tests. Written manually to fill in anything libfuzzer couldn't
|
||||||
# find.
|
# find.
|
||||||
if(NOT CMAKE_CROSSCOMPILING)
|
if(NOT CMAKE_CROSSCOMPILING)
|
||||||
@@ -271,19 +298,14 @@ if(CMAKE_SOURCE_DIR STREQUAL CMAKE_CURRENT_SOURCE_DIR AND BUILD_TESTING)
|
|||||||
${Python3_EXECUTABLE}
|
${Python3_EXECUTABLE}
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/test_conflict_set.py test ${TEST}
|
${CMAKE_CURRENT_SOURCE_DIR}/test_conflict_set.py test ${TEST}
|
||||||
--build-dir ${CMAKE_CURRENT_BINARY_DIR})
|
--build-dir ${CMAKE_CURRENT_BINARY_DIR})
|
||||||
endforeach()
|
if(VALGRIND_EXE AND NOT CMAKE_CROSSCOMPILING)
|
||||||
endif()
|
add_test(
|
||||||
|
NAME script_test_${TEST}_valgrind
|
||||||
find_program(VALGRIND_EXE valgrind)
|
COMMAND
|
||||||
if(VALGRIND_EXE AND NOT CMAKE_CROSSCOMPILING)
|
${VALGRIND_EXE} ${Python3_EXECUTABLE}
|
||||||
list(LENGTH CORPUS_TESTS len)
|
${CMAKE_CURRENT_SOURCE_DIR}/test_conflict_set.py test ${TEST}
|
||||||
math(EXPR last "${len} - 1")
|
--build-dir ${CMAKE_CURRENT_BINARY_DIR})
|
||||||
set(partition_size 100)
|
endif()
|
||||||
foreach(i RANGE 0 ${last} ${partition_size})
|
|
||||||
list(SUBLIST CORPUS_TESTS ${i} ${partition_size} partition)
|
|
||||||
add_test(NAME conflict_set_blackbox_valgrind_${i}
|
|
||||||
COMMAND ${VALGRIND_EXE} --error-exitcode=99 --
|
|
||||||
$<TARGET_FILE:driver> ${partition})
|
|
||||||
endforeach()
|
endforeach()
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
@@ -336,7 +358,7 @@ if(CMAKE_SOURCE_DIR STREQUAL CMAKE_CURRENT_SOURCE_DIR AND BUILD_TESTING)
|
|||||||
|
|
||||||
# bench
|
# bench
|
||||||
add_executable(conflict_set_bench Bench.cpp)
|
add_executable(conflict_set_bench Bench.cpp)
|
||||||
target_link_libraries(conflict_set_bench PRIVATE ${PROJECT_NAME})
|
target_link_libraries(conflict_set_bench PRIVATE ${PROJECT_NAME} nanobench)
|
||||||
set_target_properties(conflict_set_bench PROPERTIES SKIP_BUILD_RPATH ON)
|
set_target_properties(conflict_set_bench PROPERTIES SKIP_BUILD_RPATH ON)
|
||||||
add_executable(real_data_bench RealDataBench.cpp)
|
add_executable(real_data_bench RealDataBench.cpp)
|
||||||
target_link_libraries(real_data_bench PRIVATE ${PROJECT_NAME})
|
target_link_libraries(real_data_bench PRIVATE ${PROJECT_NAME})
|
||||||
@@ -351,6 +373,14 @@ if(CMAKE_SOURCE_DIR STREQUAL CMAKE_CURRENT_SOURCE_DIR AND BUILD_TESTING)
|
|||||||
add_executable(server_bench ServerBench.cpp)
|
add_executable(server_bench ServerBench.cpp)
|
||||||
target_link_libraries(server_bench PRIVATE ${PROJECT_NAME})
|
target_link_libraries(server_bench PRIVATE ${PROJECT_NAME})
|
||||||
set_target_properties(server_bench PROPERTIES SKIP_BUILD_RPATH ON)
|
set_target_properties(server_bench PROPERTIES SKIP_BUILD_RPATH ON)
|
||||||
|
|
||||||
|
add_executable(interleaving_test InterleavingTest.cpp)
|
||||||
|
# work around lack of musttail for gcc
|
||||||
|
if(CMAKE_CXX_COMPILER_ID STREQUAL "GNU" AND CMAKE_BUILD_TYPE STREQUAL "Debug")
|
||||||
|
target_compile_options(interleaving_test PRIVATE -Og
|
||||||
|
-foptimize-sibling-calls)
|
||||||
|
endif()
|
||||||
|
target_link_libraries(interleaving_test PRIVATE nanobench)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
# packaging
|
# packaging
|
||||||
|
3898
ConflictSet.cpp
3898
ConflictSet.cpp
File diff suppressed because it is too large
Load Diff
15
Dockerfile
15
Dockerfile
@@ -8,25 +8,25 @@ RUN chmod -R 777 /tmp
|
|||||||
RUN apt-get update
|
RUN apt-get update
|
||||||
RUN apt-get upgrade -y
|
RUN apt-get upgrade -y
|
||||||
RUN TZ=America/Los_Angeles DEBIAN_FRONTEND=noninteractive apt-get install -y \
|
RUN TZ=America/Los_Angeles DEBIAN_FRONTEND=noninteractive apt-get install -y \
|
||||||
|
binutils-aarch64-linux-gnu \
|
||||||
build-essential \
|
build-essential \
|
||||||
ccache \
|
ccache \
|
||||||
clang \
|
|
||||||
cmake \
|
cmake \
|
||||||
curl \
|
curl \
|
||||||
doxygen \
|
|
||||||
file \
|
|
||||||
g++-aarch64-linux-gnu \
|
g++-aarch64-linux-gnu \
|
||||||
gcovr \
|
gcovr \
|
||||||
git \
|
git \
|
||||||
gperf \
|
gnupg \
|
||||||
graphviz \
|
|
||||||
libc6-dbg \
|
libc6-dbg \
|
||||||
|
lsb-release \
|
||||||
ninja-build \
|
ninja-build \
|
||||||
pre-commit \
|
pre-commit \
|
||||||
python3-requests \
|
python3-requests \
|
||||||
qemu-user \
|
qemu-user \
|
||||||
rpm \
|
rpm \
|
||||||
|
software-properties-common \
|
||||||
texlive-full \
|
texlive-full \
|
||||||
|
wget \
|
||||||
zstd
|
zstd
|
||||||
|
|
||||||
# Install recent valgrind from source
|
# Install recent valgrind from source
|
||||||
@@ -42,6 +42,11 @@ RUN curl -Ls https://sourceware.org/pub/valgrind/valgrind-3.22.0.tar.bz2 -o valg
|
|||||||
cd .. && \
|
cd .. && \
|
||||||
rm -rf /tmp/*
|
rm -rf /tmp/*
|
||||||
|
|
||||||
|
# Recent clang
|
||||||
|
RUN wget https://apt.llvm.org/llvm.sh && chmod +x ./llvm.sh && ./llvm.sh 20
|
||||||
|
|
||||||
|
RUN apt-get -y install clang llvm
|
||||||
|
|
||||||
# Set after building valgrind, which doesn't build with clang for some reason
|
# Set after building valgrind, which doesn't build with clang for some reason
|
||||||
ENV CC=clang
|
ENV CC=clang
|
||||||
ENV CXX=clang++
|
ENV CXX=clang++
|
||||||
|
256
InterleavingTest.cpp
Normal file
256
InterleavingTest.cpp
Normal file
@@ -0,0 +1,256 @@
|
|||||||
|
#include <alloca.h>
|
||||||
|
#include <cassert>
|
||||||
|
#ifdef __x86_64__
|
||||||
|
#include <immintrin.h>
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#include "third_party/nanobench.h"
|
||||||
|
|
||||||
|
struct Job {
|
||||||
|
int *input;
|
||||||
|
// Returned void* is a function pointer to the next continuation. We have to
|
||||||
|
// use void* because otherwise the type would be recursive.
|
||||||
|
typedef void *(*continuation)(Job *);
|
||||||
|
continuation next;
|
||||||
|
};
|
||||||
|
|
||||||
|
void *stepJob(Job *j) {
|
||||||
|
auto done = --(*j->input) == 0;
|
||||||
|
#ifdef __x86_64__
|
||||||
|
_mm_clflush(j->input);
|
||||||
|
#endif
|
||||||
|
return done ? nullptr : (void *)stepJob;
|
||||||
|
}
|
||||||
|
|
||||||
|
void sequential(Job **jobs, int count) {
|
||||||
|
for (int i = 0; i < count; ++i) {
|
||||||
|
do {
|
||||||
|
jobs[i]->next = (Job::continuation)jobs[i]->next(jobs[i]);
|
||||||
|
} while (jobs[i]->next);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void sequentialNoFuncPtr(Job **jobs, int count) {
|
||||||
|
for (int i = 0; i < count; ++i) {
|
||||||
|
while (stepJob(jobs[i]))
|
||||||
|
;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void interleaveSwapping(Job **jobs, int remaining) {
|
||||||
|
int current = 0;
|
||||||
|
while (remaining > 0) {
|
||||||
|
auto next = (Job::continuation)jobs[current]->next(jobs[current]);
|
||||||
|
jobs[current]->next = next;
|
||||||
|
if (next == nullptr) {
|
||||||
|
jobs[current] = jobs[remaining - 1];
|
||||||
|
--remaining;
|
||||||
|
} else {
|
||||||
|
++current;
|
||||||
|
}
|
||||||
|
if (current == remaining) {
|
||||||
|
current = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void interleaveBoundedCyclicList(Job **jobs, int count) {
|
||||||
|
if (count == 0) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
constexpr int kConcurrent = 32;
|
||||||
|
Job *inProgress[kConcurrent];
|
||||||
|
int nextJob[kConcurrent];
|
||||||
|
|
||||||
|
int started = std::min(kConcurrent, count);
|
||||||
|
for (int i = 0; i < started; i++) {
|
||||||
|
inProgress[i] = jobs[i];
|
||||||
|
nextJob[i] = i + 1;
|
||||||
|
}
|
||||||
|
nextJob[started - 1] = 0;
|
||||||
|
|
||||||
|
int prevJob = started - 1;
|
||||||
|
int job = 0;
|
||||||
|
for (;;) {
|
||||||
|
auto next = (Job::continuation)inProgress[job]->next(inProgress[job]);
|
||||||
|
inProgress[job]->next = next;
|
||||||
|
if (next == nullptr) {
|
||||||
|
if (started == count) {
|
||||||
|
if (prevJob == job)
|
||||||
|
break;
|
||||||
|
nextJob[prevJob] = nextJob[job];
|
||||||
|
job = prevJob;
|
||||||
|
} else {
|
||||||
|
int temp = started++;
|
||||||
|
inProgress[job] = jobs[temp];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
prevJob = job;
|
||||||
|
job = nextJob[job];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#ifndef __has_attribute
|
||||||
|
#define __has_attribute(x) 0
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#if __has_attribute(musttail)
|
||||||
|
#define MUSTTAIL __attribute__((musttail))
|
||||||
|
#else
|
||||||
|
#define MUSTTAIL
|
||||||
|
#endif
|
||||||
|
|
||||||
|
struct Context {
|
||||||
|
constexpr static int kConcurrent = 32;
|
||||||
|
Job **jobs;
|
||||||
|
Job *inProgress[kConcurrent];
|
||||||
|
void (*continuation[kConcurrent])(Context *, int64_t prevJob, int64_t job,
|
||||||
|
int64_t started, int64_t count);
|
||||||
|
int nextJob[kConcurrent];
|
||||||
|
};
|
||||||
|
|
||||||
|
void keepGoing(Context *context, int64_t prevJob, int64_t job, int64_t started,
|
||||||
|
int64_t count) {
|
||||||
|
prevJob = job;
|
||||||
|
job = context->nextJob[job];
|
||||||
|
MUSTTAIL return context->continuation[job](context, prevJob, job, started,
|
||||||
|
count);
|
||||||
|
}
|
||||||
|
|
||||||
|
void stepJobTailCall(Context *context, int64_t prevJob, int64_t job,
|
||||||
|
int64_t started, int64_t count);
|
||||||
|
|
||||||
|
void complete(Context *context, int64_t prevJob, int64_t job, int64_t started,
|
||||||
|
int64_t count) {
|
||||||
|
if (started == count) {
|
||||||
|
if (prevJob == job) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
context->nextJob[prevJob] = context->nextJob[job];
|
||||||
|
job = prevJob;
|
||||||
|
} else {
|
||||||
|
context->inProgress[job] = context->jobs[started++];
|
||||||
|
context->continuation[job] = stepJobTailCall;
|
||||||
|
}
|
||||||
|
prevJob = job;
|
||||||
|
job = context->nextJob[job];
|
||||||
|
MUSTTAIL return context->continuation[job](context, prevJob, job, started,
|
||||||
|
count);
|
||||||
|
}
|
||||||
|
|
||||||
|
void stepJobTailCall(Context *context, int64_t prevJob, int64_t job,
|
||||||
|
int64_t started, int64_t count) {
|
||||||
|
auto *j = context->inProgress[job];
|
||||||
|
auto done = --(*j->input) == 0;
|
||||||
|
#ifdef __x86_64__
|
||||||
|
_mm_clflush(j->input);
|
||||||
|
#endif
|
||||||
|
if (done) {
|
||||||
|
MUSTTAIL return complete(context, prevJob, job, started, count);
|
||||||
|
} else {
|
||||||
|
context->continuation[job] = stepJobTailCall;
|
||||||
|
MUSTTAIL return keepGoing(context, prevJob, job, started, count);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void useTailCalls(Job **jobs, int count) {
|
||||||
|
if (count == 0) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
Context context;
|
||||||
|
context.jobs = jobs;
|
||||||
|
int64_t started = std::min(Context::kConcurrent, count);
|
||||||
|
for (int i = 0; i < started; i++) {
|
||||||
|
context.inProgress[i] = jobs[i];
|
||||||
|
context.nextJob[i] = i + 1;
|
||||||
|
context.continuation[i] = stepJobTailCall;
|
||||||
|
}
|
||||||
|
context.nextJob[started - 1] = 0;
|
||||||
|
int prevJob = started - 1;
|
||||||
|
int job = 0;
|
||||||
|
return context.continuation[job](&context, prevJob, job, started, count);
|
||||||
|
}
|
||||||
|
|
||||||
|
void interleaveCyclicList(Job **jobs, int count) {
|
||||||
|
auto *nextJob = (int *)alloca(sizeof(int) * count);
|
||||||
|
|
||||||
|
for (int i = 0; i < count - 1; ++i) {
|
||||||
|
nextJob[i] = i + 1;
|
||||||
|
}
|
||||||
|
nextJob[count - 1] = 0;
|
||||||
|
|
||||||
|
int prevJob = count - 1;
|
||||||
|
int job = 0;
|
||||||
|
for (;;) {
|
||||||
|
auto next = (Job::continuation)jobs[job]->next(jobs[job]);
|
||||||
|
jobs[job]->next = next;
|
||||||
|
if (next == nullptr) {
|
||||||
|
if (prevJob == job)
|
||||||
|
break;
|
||||||
|
nextJob[prevJob] = nextJob[job];
|
||||||
|
job = prevJob;
|
||||||
|
}
|
||||||
|
prevJob = job;
|
||||||
|
job = nextJob[job];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
int main() {
|
||||||
|
ankerl::nanobench::Bench bench;
|
||||||
|
|
||||||
|
constexpr int kNumJobs = 10000;
|
||||||
|
bench.relative(true);
|
||||||
|
|
||||||
|
Job jobs[kNumJobs];
|
||||||
|
Job jobsCopy[kNumJobs];
|
||||||
|
int iters = 0;
|
||||||
|
int originalInput[kNumJobs];
|
||||||
|
for (int i = 0; i < kNumJobs; ++i) {
|
||||||
|
originalInput[i] = rand() % 5 + 3;
|
||||||
|
jobs[i].input = new int{originalInput[i]};
|
||||||
|
jobs[i].next = stepJob;
|
||||||
|
iters += *jobs[i].input;
|
||||||
|
}
|
||||||
|
bench.batch(iters);
|
||||||
|
|
||||||
|
for (auto [scheduler, name] :
|
||||||
|
{std::make_pair(sequentialNoFuncPtr, "sequentialNoFuncPtr"),
|
||||||
|
std::make_pair(sequential, "sequential"),
|
||||||
|
std::make_pair(useTailCalls, "useTailCalls"),
|
||||||
|
std::make_pair(interleaveSwapping, "interleavingSwapping"),
|
||||||
|
std::make_pair(interleaveBoundedCyclicList,
|
||||||
|
"interleaveBoundedCyclicList"),
|
||||||
|
std::make_pair(interleaveCyclicList, "interleaveCyclicList")}) {
|
||||||
|
for (int i = 0; i < kNumJobs; ++i) {
|
||||||
|
*jobs[i].input = originalInput[i];
|
||||||
|
}
|
||||||
|
memcpy(jobsCopy, jobs, sizeof(jobs));
|
||||||
|
Job *ps[kNumJobs];
|
||||||
|
for (int i = 0; i < kNumJobs; ++i) {
|
||||||
|
ps[i] = jobsCopy + i;
|
||||||
|
}
|
||||||
|
scheduler(ps, kNumJobs);
|
||||||
|
for (int i = 0; i < kNumJobs; ++i) {
|
||||||
|
if (*jobsCopy[i].input != 0) {
|
||||||
|
fprintf(stderr, "%s failed\n", name);
|
||||||
|
abort();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
bench.run(name, [&]() {
|
||||||
|
for (int i = 0; i < kNumJobs; ++i) {
|
||||||
|
*jobs[i].input = originalInput[i];
|
||||||
|
}
|
||||||
|
memcpy(jobsCopy, jobs, sizeof(jobs));
|
||||||
|
Job *ps[kNumJobs];
|
||||||
|
for (int i = 0; i < kNumJobs; ++i) {
|
||||||
|
ps[i] = jobsCopy + i;
|
||||||
|
}
|
||||||
|
scheduler(ps, kNumJobs);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
for (int i = 0; i < kNumJobs; ++i) {
|
||||||
|
delete jobs[i].input;
|
||||||
|
}
|
||||||
|
}
|
60
Internal.h
60
Internal.h
@@ -26,9 +26,38 @@ using namespace weaselab;
|
|||||||
#define DEBUG_VERBOSE 0
|
#define DEBUG_VERBOSE 0
|
||||||
#define SHOW_MEMORY 0
|
#define SHOW_MEMORY 0
|
||||||
|
|
||||||
[[nodiscard]] inline auto
|
// std::span is not trivially constructible. We want a span that leaves its
|
||||||
operator<=>(const std::span<const uint8_t> &lhs,
|
// members uninitialized for performance reasons.
|
||||||
const std::span<const uint8_t> &rhs) noexcept {
|
struct TrivialSpan {
|
||||||
|
TrivialSpan() = default;
|
||||||
|
TrivialSpan(const uint8_t *begin, int len) : begin(begin), len(len) {}
|
||||||
|
|
||||||
|
uint8_t back() const {
|
||||||
|
assert(len > 0);
|
||||||
|
return begin[len - 1];
|
||||||
|
}
|
||||||
|
uint8_t front() const {
|
||||||
|
assert(len > 0);
|
||||||
|
return begin[0];
|
||||||
|
}
|
||||||
|
uint8_t operator[](int i) const {
|
||||||
|
assert(0 <= i);
|
||||||
|
assert(i < len);
|
||||||
|
return begin[i];
|
||||||
|
}
|
||||||
|
int size() const { return len; }
|
||||||
|
TrivialSpan subspan(int offset, int len) { return {begin + offset, len}; }
|
||||||
|
const uint8_t *data() const { return begin; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
const uint8_t *begin;
|
||||||
|
int len;
|
||||||
|
};
|
||||||
|
|
||||||
|
static_assert(std::is_trivial_v<TrivialSpan>);
|
||||||
|
|
||||||
|
[[nodiscard]] inline auto operator<=>(const TrivialSpan &lhs,
|
||||||
|
const TrivialSpan &rhs) noexcept {
|
||||||
int cl = std::min<int>(lhs.size(), rhs.size());
|
int cl = std::min<int>(lhs.size(), rhs.size());
|
||||||
if (cl > 0) {
|
if (cl > 0) {
|
||||||
if (auto c = memcmp(lhs.data(), rhs.data(), cl) <=> 0; c != 0) {
|
if (auto c = memcmp(lhs.data(), rhs.data(), cl) <=> 0; c != 0) {
|
||||||
@@ -38,7 +67,7 @@ operator<=>(const std::span<const uint8_t> &lhs,
|
|||||||
return lhs.size() <=> rhs.size();
|
return lhs.size() <=> rhs.size();
|
||||||
}
|
}
|
||||||
|
|
||||||
[[nodiscard]] inline auto operator<=>(const std::span<const uint8_t> &lhs,
|
[[nodiscard]] inline auto operator<=>(const TrivialSpan &lhs,
|
||||||
const ConflictSet::Key &rhs) noexcept {
|
const ConflictSet::Key &rhs) noexcept {
|
||||||
int cl = std::min<int>(lhs.size(), rhs.len);
|
int cl = std::min<int>(lhs.size(), rhs.len);
|
||||||
if (cl > 0) {
|
if (cl > 0) {
|
||||||
@@ -46,7 +75,18 @@ operator<=>(const std::span<const uint8_t> &lhs,
|
|||||||
return c;
|
return c;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return lhs.size() <=> size_t(rhs.len);
|
return lhs.size() <=> rhs.len;
|
||||||
|
}
|
||||||
|
|
||||||
|
[[nodiscard]] inline auto operator<=>(const ConflictSet::Key &lhs,
|
||||||
|
const ConflictSet::Key &rhs) noexcept {
|
||||||
|
int cl = std::min<int>(lhs.len, rhs.len);
|
||||||
|
if (cl > 0) {
|
||||||
|
if (auto c = memcmp(lhs.p, rhs.p, cl) <=> 0; c != 0) {
|
||||||
|
return c;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return lhs.len <=> rhs.len;
|
||||||
}
|
}
|
||||||
|
|
||||||
// This header contains code that we want to reuse outside of ConflictSet.cpp or
|
// This header contains code that we want to reuse outside of ConflictSet.cpp or
|
||||||
@@ -538,7 +578,7 @@ struct ReferenceImpl {
|
|||||||
|
|
||||||
using Key = ConflictSet::Key;
|
using Key = ConflictSet::Key;
|
||||||
|
|
||||||
inline Key operator"" _s(const char *str, size_t size) {
|
inline Key operator""_s(const char *str, size_t size) {
|
||||||
return {reinterpret_cast<const uint8_t *>(str), int(size)};
|
return {reinterpret_cast<const uint8_t *>(str), int(size)};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -569,7 +609,7 @@ inline std::string printable(const Key &key) {
|
|||||||
return printable(std::string_view((const char *)key.p, key.len));
|
return printable(std::string_view((const char *)key.p, key.len));
|
||||||
}
|
}
|
||||||
|
|
||||||
inline std::string printable(std::span<const uint8_t> key) {
|
inline std::string printable(TrivialSpan key) {
|
||||||
return printable(std::string_view((const char *)key.data(), key.size()));
|
return printable(std::string_view((const char *)key.data(), key.size()));
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -677,10 +717,8 @@ struct TestDriver {
|
|||||||
arbitrary->randomBytes(begin + prefixLen, keyLen - prefixLen);
|
arbitrary->randomBytes(begin + prefixLen, keyLen - prefixLen);
|
||||||
writes[i].end.len = keyLen;
|
writes[i].end.len = keyLen;
|
||||||
writes[i].end.p = begin;
|
writes[i].end.p = begin;
|
||||||
auto c =
|
auto c = TrivialSpan(writes[i].begin.p, writes[i].begin.len) <=>
|
||||||
std::span<const uint8_t>(writes[i].begin.p,
|
TrivialSpan(writes[i].end.p, writes[i].end.len);
|
||||||
writes[i].begin.len) <=>
|
|
||||||
std::span<const uint8_t>(writes[i].end.p, writes[i].end.len);
|
|
||||||
if (c > 0) {
|
if (c > 0) {
|
||||||
using std::swap;
|
using std::swap;
|
||||||
swap(writes[i].begin, writes[i].end);
|
swap(writes[i].begin, writes[i].end);
|
||||||
|
42
Jenkinsfile
vendored
42
Jenkinsfile
vendored
@@ -36,18 +36,6 @@ pipeline {
|
|||||||
sh 'pre-commit run --all-files --show-diff-on-failure'
|
sh 'pre-commit run --all-files --show-diff-on-failure'
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
stage('Clang') {
|
|
||||||
agent {
|
|
||||||
dockerfile {
|
|
||||||
args '-v /home/jenkins/ccache:/ccache'
|
|
||||||
reuseNode true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
steps {
|
|
||||||
CleanBuildAndTest("")
|
|
||||||
recordIssues(tools: [clang()])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
stage('64 bit versions') {
|
stage('64 bit versions') {
|
||||||
agent {
|
agent {
|
||||||
dockerfile {
|
dockerfile {
|
||||||
@@ -81,7 +69,7 @@ pipeline {
|
|||||||
CleanBuildAndTest("-DUSE_SIMD_FALLBACK=ON")
|
CleanBuildAndTest("-DUSE_SIMD_FALLBACK=ON")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
stage('Release [gcc]') {
|
stage('Release [clang]') {
|
||||||
agent {
|
agent {
|
||||||
dockerfile {
|
dockerfile {
|
||||||
args '-v /home/jenkins/ccache:/ccache'
|
args '-v /home/jenkins/ccache:/ccache'
|
||||||
@@ -89,8 +77,8 @@ pipeline {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
steps {
|
steps {
|
||||||
CleanBuildAndTest("-DCMAKE_C_COMPILER=gcc -DCMAKE_CXX_COMPILER=g++ -DCMAKE_CXX_FLAGS=-DNVALGRIND")
|
CleanBuildAndTest("-DCMAKE_CXX_FLAGS=-DNVALGRIND")
|
||||||
recordIssues(tools: [gcc()])
|
recordIssues(tools: [clang()])
|
||||||
sh '''
|
sh '''
|
||||||
cd build
|
cd build
|
||||||
cpack -G DEB
|
cpack -G DEB
|
||||||
@@ -103,7 +91,19 @@ pipeline {
|
|||||||
minio bucket: 'jenkins', credentialsId: 'jenkins-minio', excludes: '', host: 'minio.weaselab.dev', includes: 'build/*.deb,build/*.rpm,paper/*.pdf', targetFolder: '${JOB_NAME}/${BUILD_NUMBER}/${STAGE_NAME}/'
|
minio bucket: 'jenkins', credentialsId: 'jenkins-minio', excludes: '', host: 'minio.weaselab.dev', includes: 'build/*.deb,build/*.rpm,paper/*.pdf', targetFolder: '${JOB_NAME}/${BUILD_NUMBER}/${STAGE_NAME}/'
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
stage('Release [gcc,aarch64]') {
|
stage('Release [gcc]') {
|
||||||
|
agent {
|
||||||
|
dockerfile {
|
||||||
|
args '-v /home/jenkins/ccache:/ccache'
|
||||||
|
reuseNode true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
steps {
|
||||||
|
CleanBuildAndTest("-DCMAKE_C_COMPILER=gcc -DCMAKE_CXX_COMPILER=g++ -DCMAKE_CXX_FLAGS=-DNVALGRIND")
|
||||||
|
recordIssues(tools: [gcc()])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
stage('Release [clang,aarch64]') {
|
||||||
agent {
|
agent {
|
||||||
dockerfile {
|
dockerfile {
|
||||||
args '-v /home/jenkins/ccache:/ccache'
|
args '-v /home/jenkins/ccache:/ccache'
|
||||||
@@ -129,16 +129,16 @@ pipeline {
|
|||||||
}
|
}
|
||||||
steps {
|
steps {
|
||||||
script {
|
script {
|
||||||
filter_args = "-f ConflictSet.cpp -f LongestCommonPrefix.h -f Metrics.h"
|
gcov_args = "-f ConflictSet.cpp -f LongestCommonPrefix.h -f Metrics.h --gcov-executable 'llvm-cov gcov' --exclude-noncode-lines"
|
||||||
}
|
}
|
||||||
CleanBuildAndTest("-DCMAKE_C_COMPILER=gcc -DCMAKE_CXX_COMPILER=g++ -DCMAKE_C_FLAGS=--coverage -DCMAKE_CXX_FLAGS=--coverage -DCMAKE_BUILD_TYPE=Debug -DDISABLE_TSAN=ON")
|
CleanBuildAndTest("-DCMAKE_C_FLAGS=--coverage -DCMAKE_CXX_FLAGS=--coverage -DCMAKE_BUILD_TYPE=Debug -DDISABLE_TSAN=ON")
|
||||||
sh """
|
sh """
|
||||||
gcovr ${filter_args} --cobertura > build/coverage.xml
|
gcovr ${gcov_args} --cobertura > build/coverage.xml
|
||||||
"""
|
"""
|
||||||
recordCoverage qualityGates: [[criticality: 'NOTE', metric: 'MODULE']], tools: [[parser: 'COBERTURA', pattern: 'build/coverage.xml']]
|
recordCoverage qualityGates: [[criticality: 'NOTE', metric: 'MODULE']], tools: [[parser: 'COBERTURA', pattern: 'build/coverage.xml']]
|
||||||
sh """
|
sh """
|
||||||
gcovr ${filter_args}
|
gcovr ${gcov_args}
|
||||||
gcovr ${filter_args} --fail-under-line 100 > /dev/null
|
gcovr ${gcov_args} --fail-under-line 100 > /dev/null
|
||||||
"""
|
"""
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -129,7 +129,7 @@ longestCommonPrefix(const uint8_t *ap, const uint8_t *bp, int cl) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
int i = 0;
|
int i = 0;
|
||||||
int end;
|
int end; // GCOVR_EXCL_LINE
|
||||||
|
|
||||||
// kStride * kUnrollCount at a time
|
// kStride * kUnrollCount at a time
|
||||||
end = cl & ~(kStride * kUnrollFactor - 1);
|
end = cl & ~(kStride * kUnrollFactor - 1);
|
||||||
|
@@ -1,4 +1,6 @@
|
|||||||
#include <atomic>
|
#include <atomic>
|
||||||
|
#include <cstdint>
|
||||||
|
#include <cstdlib>
|
||||||
#include <errno.h>
|
#include <errno.h>
|
||||||
#include <netdb.h>
|
#include <netdb.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
@@ -21,76 +23,33 @@
|
|||||||
|
|
||||||
std::atomic<int64_t> transactions;
|
std::atomic<int64_t> transactions;
|
||||||
|
|
||||||
constexpr int kBaseSearchDepth = 115;
|
|
||||||
constexpr int kWindowSize = 10000000;
|
constexpr int kWindowSize = 10000000;
|
||||||
|
|
||||||
std::string numToKey(int64_t num) {
|
constexpr int kNumPrefixes = 250000;
|
||||||
|
|
||||||
|
std::string makeKey(int64_t num, int suffixLen) {
|
||||||
std::string result;
|
std::string result;
|
||||||
result.resize(kBaseSearchDepth + sizeof(int64_t));
|
result.resize(sizeof(int64_t) + suffixLen);
|
||||||
memset(result.data(), 0, kBaseSearchDepth);
|
|
||||||
int64_t be = __builtin_bswap64(num);
|
int64_t be = __builtin_bswap64(num);
|
||||||
memcpy(result.data() + kBaseSearchDepth, &be, sizeof(int64_t));
|
memcpy(result.data(), &be, sizeof(int64_t));
|
||||||
|
memset(result.data() + sizeof(int64_t), 0, suffixLen);
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
void workload(weaselab::ConflictSet *cs) {
|
void workload(weaselab::ConflictSet *cs) {
|
||||||
int64_t version = kWindowSize;
|
int64_t version = kWindowSize;
|
||||||
cs->addWrites(nullptr, 0, version);
|
constexpr int kNumWrites = 16;
|
||||||
for (;; transactions.fetch_add(1, std::memory_order_relaxed)) {
|
for (;; transactions.fetch_add(1, std::memory_order_relaxed)) {
|
||||||
// Reads
|
std::vector<std::string> keys;
|
||||||
{
|
std::vector<weaselab::ConflictSet::WriteRange> writes;
|
||||||
auto beginK = numToKey(version - kWindowSize);
|
for (int i = 0; i < kNumWrites; ++i) {
|
||||||
auto endK = numToKey(version - 1);
|
keys.push_back(makeKey(rand() % kNumPrefixes, rand() % 50));
|
||||||
auto pointRv = version - kWindowSize + rand() % kWindowSize + 1;
|
|
||||||
auto pointK = numToKey(pointRv);
|
|
||||||
weaselab::ConflictSet::ReadRange reads[] = {
|
|
||||||
{
|
|
||||||
{(const uint8_t *)pointK.data(), int(pointK.size())},
|
|
||||||
{nullptr, 0},
|
|
||||||
pointRv,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
{(const uint8_t *)beginK.data(), int(beginK.size())},
|
|
||||||
{(const uint8_t *)endK.data(), int(endK.size())},
|
|
||||||
version - 2,
|
|
||||||
},
|
|
||||||
};
|
|
||||||
weaselab::ConflictSet::Result result[sizeof(reads) / sizeof(reads[0])];
|
|
||||||
cs->check(reads, result, sizeof(reads) / sizeof(reads[0]));
|
|
||||||
// for (int i = 0; i < sizeof(reads) / sizeof(reads[0]); ++i) {
|
|
||||||
// if (result[i] != weaselab::ConflictSet::Commit) {
|
|
||||||
// fprintf(stderr, "Unexpected conflict: [%s, %s) @ %" PRId64 "\n",
|
|
||||||
// printable(reads[i].begin).c_str(),
|
|
||||||
// printable(reads[i].end).c_str(), reads[i].readVersion);
|
|
||||||
// abort();
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
}
|
}
|
||||||
// Writes
|
for (int i = 0; i < kNumWrites; ++i) {
|
||||||
{
|
writes.push_back({{(const uint8_t *)keys[i].data(), int(keys[i].size())},
|
||||||
weaselab::ConflictSet::WriteRange w;
|
{nullptr, 0}});
|
||||||
auto k = numToKey(version);
|
|
||||||
w.begin.p = (const uint8_t *)k.data();
|
|
||||||
w.end.len = 0;
|
|
||||||
if (version % (kWindowSize / 2) == 0) {
|
|
||||||
for (int l = 0; l <= k.size(); ++l) {
|
|
||||||
w.begin.len = l;
|
|
||||||
cs->addWrites(&w, 1, version);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
w.begin.len = k.size();
|
|
||||||
cs->addWrites(&w, 1, version);
|
|
||||||
int64_t beginN = version - kWindowSize + rand() % kWindowSize;
|
|
||||||
auto b = numToKey(beginN);
|
|
||||||
auto e = numToKey(beginN + 1000);
|
|
||||||
w.begin.p = (const uint8_t *)b.data();
|
|
||||||
w.begin.len = b.size();
|
|
||||||
w.end.p = (const uint8_t *)e.data();
|
|
||||||
w.end.len = e.size();
|
|
||||||
cs->addWrites(&w, 1, version);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
// GC
|
cs->addWrites(writes.data(), writes.size(), version);
|
||||||
cs->setOldestVersion(version - kWindowSize);
|
cs->setOldestVersion(version - kWindowSize);
|
||||||
++version;
|
++version;
|
||||||
}
|
}
|
||||||
|
@@ -5,6 +5,7 @@ __stack_chk_guard@GLIBC_2.17
|
|||||||
abort@GLIBC_2.17
|
abort@GLIBC_2.17
|
||||||
free@GLIBC_2.17
|
free@GLIBC_2.17
|
||||||
malloc@GLIBC_2.17
|
malloc@GLIBC_2.17
|
||||||
|
memcmp@GLIBC_2.17
|
||||||
memcpy@GLIBC_2.17
|
memcpy@GLIBC_2.17
|
||||||
memmove@GLIBC_2.17
|
memmove@GLIBC_2.17
|
||||||
memset@GLIBC_2.17
|
memset@GLIBC_2.17
|
@@ -1,7 +1,8 @@
|
|||||||
set(CMAKE_SYSTEM_NAME Linux)
|
set(CMAKE_SYSTEM_NAME Linux)
|
||||||
set(CMAKE_SYSTEM_PROCESSOR aarch64)
|
set(CMAKE_SYSTEM_PROCESSOR aarch64)
|
||||||
set(CMAKE_C_COMPILER "/usr/bin/aarch64-linux-gnu-gcc")
|
set(CMAKE_C_COMPILER "clang;--target=aarch64-linux-gnu")
|
||||||
set(CMAKE_CXX_COMPILER "/usr/bin/aarch64-linux-gnu-g++")
|
set(CMAKE_CXX_COMPILER "clang++;--target=aarch64-linux-gnu")
|
||||||
set(CMAKE_FIND_ROOT_PATH /usr/aarch64-linux-gnu)
|
set(CMAKE_FIND_ROOT_PATH /usr/aarch64-linux-gnu)
|
||||||
set(CMAKE_CROSSCOMPILING_EMULATOR "qemu-aarch64;-L;/usr/aarch64-linux-gnu/")
|
set(CMAKE_CROSSCOMPILING_EMULATOR "qemu-aarch64;-L;/usr/aarch64-linux-gnu/")
|
||||||
set(CPACK_DEBIAN_PACKAGE_ARCHITECTURE arm64)
|
set(CPACK_DEBIAN_PACKAGE_ARCHITECTURE arm64)
|
||||||
|
set(LD_EXE "/usr/bin/aarch64-linux-gnu-ld")
|
||||||
|
BIN
corpus/003fdafe6e5f359e1043927b266e6ed6193562bc
Normal file
BIN
corpus/003fdafe6e5f359e1043927b266e6ed6193562bc
Normal file
Binary file not shown.
BIN
corpus/00533f61fd89afb9deb3dc978b368a3b3abf3992
Normal file
BIN
corpus/00533f61fd89afb9deb3dc978b368a3b3abf3992
Normal file
Binary file not shown.
BIN
corpus/00850bfa9ce0f9e64b8688db48dc6562be637d97
Normal file
BIN
corpus/00850bfa9ce0f9e64b8688db48dc6562be637d97
Normal file
Binary file not shown.
BIN
corpus/00c2f9be831326008b88fa8daa1f6a2ba54ff0ab
Normal file
BIN
corpus/00c2f9be831326008b88fa8daa1f6a2ba54ff0ab
Normal file
Binary file not shown.
BIN
corpus/00df1fd720151ee1fb20574f080e75190d715723
Normal file
BIN
corpus/00df1fd720151ee1fb20574f080e75190d715723
Normal file
Binary file not shown.
BIN
corpus/01466ed53837dddee4968104f692156ec738a946
Normal file
BIN
corpus/01466ed53837dddee4968104f692156ec738a946
Normal file
Binary file not shown.
BIN
corpus/0155e58949c6b4380c2dba35c72183c883ee12c8
Normal file
BIN
corpus/0155e58949c6b4380c2dba35c72183c883ee12c8
Normal file
Binary file not shown.
BIN
corpus/015d4b680de41003e894d6fd8b1216b4b5765b3b
Normal file
BIN
corpus/015d4b680de41003e894d6fd8b1216b4b5765b3b
Normal file
Binary file not shown.
BIN
corpus/01700660cf8938f7861559ae8f5fc00a55532679
Normal file
BIN
corpus/01700660cf8938f7861559ae8f5fc00a55532679
Normal file
Binary file not shown.
BIN
corpus/01e5c2c85ebe3fd89e03cc04d4a185e8aa5d3a8a
Normal file
BIN
corpus/01e5c2c85ebe3fd89e03cc04d4a185e8aa5d3a8a
Normal file
Binary file not shown.
BIN
corpus/026c293f183c14c6f173718d432b73f41e19cba8
Normal file
BIN
corpus/026c293f183c14c6f173718d432b73f41e19cba8
Normal file
Binary file not shown.
BIN
corpus/02781af3a149db8ecf015171b93eed4de428c8ce
Normal file
BIN
corpus/02781af3a149db8ecf015171b93eed4de428c8ce
Normal file
Binary file not shown.
BIN
corpus/027a04de710ae4e8998cabe76b61ed427c7748e9
Normal file
BIN
corpus/027a04de710ae4e8998cabe76b61ed427c7748e9
Normal file
Binary file not shown.
BIN
corpus/02b4c0e1317cc3d71ca9d05d3d855c9d0fbed0ed
Normal file
BIN
corpus/02b4c0e1317cc3d71ca9d05d3d855c9d0fbed0ed
Normal file
Binary file not shown.
BIN
corpus/02df8cae475c41d1bbaefe0fc7e23fd35a9a23c8
Normal file
BIN
corpus/02df8cae475c41d1bbaefe0fc7e23fd35a9a23c8
Normal file
Binary file not shown.
BIN
corpus/03119dd29f68a6a8ff8f67a653e7f4ba01c6847a
Normal file
BIN
corpus/03119dd29f68a6a8ff8f67a653e7f4ba01c6847a
Normal file
Binary file not shown.
BIN
corpus/033c4c71cb5ca5a3a933b9001be1d4246784fefb
Normal file
BIN
corpus/033c4c71cb5ca5a3a933b9001be1d4246784fefb
Normal file
Binary file not shown.
BIN
corpus/035247cc26d90aee0b4f9560833e5a495d890159
Normal file
BIN
corpus/035247cc26d90aee0b4f9560833e5a495d890159
Normal file
Binary file not shown.
BIN
corpus/03680111265d5f0b8816feb73069cf1f6538d4dd
Normal file
BIN
corpus/03680111265d5f0b8816feb73069cf1f6538d4dd
Normal file
Binary file not shown.
BIN
corpus/0370da7797ee28434459cf21350d311df2aed581
Normal file
BIN
corpus/0370da7797ee28434459cf21350d311df2aed581
Normal file
Binary file not shown.
BIN
corpus/037f4bcc441003fb4cc2cbfd4d986c201035a744
Normal file
BIN
corpus/037f4bcc441003fb4cc2cbfd4d986c201035a744
Normal file
Binary file not shown.
BIN
corpus/0381a9a3c6ea140cdd7ec8cf73eb2c56e01f8d54
Normal file
BIN
corpus/0381a9a3c6ea140cdd7ec8cf73eb2c56e01f8d54
Normal file
Binary file not shown.
BIN
corpus/038d82d16c1b0e6f6f59db9c26d4cd82973fe380
Normal file
BIN
corpus/038d82d16c1b0e6f6f59db9c26d4cd82973fe380
Normal file
Binary file not shown.
BIN
corpus/03c5f3b6189b03df9f473ad64e717ab2310e8a02
Normal file
BIN
corpus/03c5f3b6189b03df9f473ad64e717ab2310e8a02
Normal file
Binary file not shown.
BIN
corpus/040b817f7a2fde4d7bec916534e003b3a8036239
Normal file
BIN
corpus/040b817f7a2fde4d7bec916534e003b3a8036239
Normal file
Binary file not shown.
BIN
corpus/04338408516abc9c563802aadc522db002e0a5d0
Normal file
BIN
corpus/04338408516abc9c563802aadc522db002e0a5d0
Normal file
Binary file not shown.
BIN
corpus/0480d4ba79c290ac8ecfb000bc62f204326a6e2d
Normal file
BIN
corpus/0480d4ba79c290ac8ecfb000bc62f204326a6e2d
Normal file
Binary file not shown.
BIN
corpus/051590b47c5269306a3a8894eb3d72d86c4a6e71
Normal file
BIN
corpus/051590b47c5269306a3a8894eb3d72d86c4a6e71
Normal file
Binary file not shown.
BIN
corpus/05184b61aacd101ea39bc6f3b9985fec132b8125
Normal file
BIN
corpus/05184b61aacd101ea39bc6f3b9985fec132b8125
Normal file
Binary file not shown.
BIN
corpus/053c56641f68bea3be49d74416d62ca583d6492e
Normal file
BIN
corpus/053c56641f68bea3be49d74416d62ca583d6492e
Normal file
Binary file not shown.
BIN
corpus/056fee409c5511f6a7456cd4791d9385f6d5ebbe
Normal file
BIN
corpus/056fee409c5511f6a7456cd4791d9385f6d5ebbe
Normal file
Binary file not shown.
BIN
corpus/05a237bf01382822789d33bda1b24298e13bb031
Normal file
BIN
corpus/05a237bf01382822789d33bda1b24298e13bb031
Normal file
Binary file not shown.
BIN
corpus/05e78ae4ba5007b2ad39b69b19604f8cb90650bd
Normal file
BIN
corpus/05e78ae4ba5007b2ad39b69b19604f8cb90650bd
Normal file
Binary file not shown.
BIN
corpus/061a5fd2f5e90098ec417feda11d43b7ff3ecb79
Normal file
BIN
corpus/061a5fd2f5e90098ec417feda11d43b7ff3ecb79
Normal file
Binary file not shown.
BIN
corpus/065ec99952bffeb53f340d8cee645654f5b1e891
Normal file
BIN
corpus/065ec99952bffeb53f340d8cee645654f5b1e891
Normal file
Binary file not shown.
BIN
corpus/069fd605e510b2218cf1b10ec79ae00763aeb195
Normal file
BIN
corpus/069fd605e510b2218cf1b10ec79ae00763aeb195
Normal file
Binary file not shown.
BIN
corpus/06ceaf9ecc159477b48e4633d19c883e9f57dc52
Normal file
BIN
corpus/06ceaf9ecc159477b48e4633d19c883e9f57dc52
Normal file
Binary file not shown.
BIN
corpus/0707680f7d9ce11dd30c6536f05848d598fb27d4
Normal file
BIN
corpus/0707680f7d9ce11dd30c6536f05848d598fb27d4
Normal file
Binary file not shown.
BIN
corpus/0707d9709690c9700f27fd73d97c0325fa81c162
Normal file
BIN
corpus/0707d9709690c9700f27fd73d97c0325fa81c162
Normal file
Binary file not shown.
BIN
corpus/076a28139f92f4925500f0b41b21aeddc2a29ae9
Normal file
BIN
corpus/076a28139f92f4925500f0b41b21aeddc2a29ae9
Normal file
Binary file not shown.
BIN
corpus/0771614f4aee61a932eb4f6cec1f736fce997a1e
Normal file
BIN
corpus/0771614f4aee61a932eb4f6cec1f736fce997a1e
Normal file
Binary file not shown.
BIN
corpus/07854cf6f54c192387047cfc49a65e4b1bdca4a1
Normal file
BIN
corpus/07854cf6f54c192387047cfc49a65e4b1bdca4a1
Normal file
Binary file not shown.
BIN
corpus/078875343814fb2f6f7be30e0fd58a139d977f19
Normal file
BIN
corpus/078875343814fb2f6f7be30e0fd58a139d977f19
Normal file
Binary file not shown.
BIN
corpus/07c638816ecc7071961866ba3ed0aa1168f7e998
Normal file
BIN
corpus/07c638816ecc7071961866ba3ed0aa1168f7e998
Normal file
Binary file not shown.
BIN
corpus/07dd1f8dd4c6a46e82e6b5e738556e03bc909241
Normal file
BIN
corpus/07dd1f8dd4c6a46e82e6b5e738556e03bc909241
Normal file
Binary file not shown.
BIN
corpus/07df755fad1030e7d400b41c2e4b22ef1e72e026
Normal file
BIN
corpus/07df755fad1030e7d400b41c2e4b22ef1e72e026
Normal file
Binary file not shown.
BIN
corpus/086ae03d7492047d12383776a7a2dd10acb6a030
Normal file
BIN
corpus/086ae03d7492047d12383776a7a2dd10acb6a030
Normal file
Binary file not shown.
BIN
corpus/08b60f4f4dccb8b4b992b9a41dffd1cabb18da5c
Normal file
BIN
corpus/08b60f4f4dccb8b4b992b9a41dffd1cabb18da5c
Normal file
Binary file not shown.
BIN
corpus/08bd213542d71b1e07b7cafeba9816e2990278b6
Normal file
BIN
corpus/08bd213542d71b1e07b7cafeba9816e2990278b6
Normal file
Binary file not shown.
BIN
corpus/08f6fcd47ba57d41f5cae4a040e8318fc2f653da
Normal file
BIN
corpus/08f6fcd47ba57d41f5cae4a040e8318fc2f653da
Normal file
Binary file not shown.
BIN
corpus/08fb0c9ae5f25f3040bb0a1489ff0dc0b537ebfa
Normal file
BIN
corpus/08fb0c9ae5f25f3040bb0a1489ff0dc0b537ebfa
Normal file
Binary file not shown.
BIN
corpus/090ffb7c1949db26391498d8c7dc3b8f772b90ce
Normal file
BIN
corpus/090ffb7c1949db26391498d8c7dc3b8f772b90ce
Normal file
Binary file not shown.
BIN
corpus/09b0a61939d3133f61a4b0aaee5149503e3019a1
Normal file
BIN
corpus/09b0a61939d3133f61a4b0aaee5149503e3019a1
Normal file
Binary file not shown.
BIN
corpus/09c0b1f06a1e9bfdfb8842ec414f97ade10cddf4
Normal file
BIN
corpus/09c0b1f06a1e9bfdfb8842ec414f97ade10cddf4
Normal file
Binary file not shown.
BIN
corpus/0a0da5b17a24b0282501d2f380dc52aefd4d9b9f
Normal file
BIN
corpus/0a0da5b17a24b0282501d2f380dc52aefd4d9b9f
Normal file
Binary file not shown.
BIN
corpus/0a0f988838f8343c67b6aa6663fa999b1846d220
Normal file
BIN
corpus/0a0f988838f8343c67b6aa6663fa999b1846d220
Normal file
Binary file not shown.
BIN
corpus/0a3c2c7e2909abe5c5c33d77ac94848d16bff662
Normal file
BIN
corpus/0a3c2c7e2909abe5c5c33d77ac94848d16bff662
Normal file
Binary file not shown.
BIN
corpus/0a62d3271dacf28268503f4fead7f54ca479d33c
Normal file
BIN
corpus/0a62d3271dacf28268503f4fead7f54ca479d33c
Normal file
Binary file not shown.
BIN
corpus/0aa35cd848f2d94178b87dcf68272c8a3f96c42b
Normal file
BIN
corpus/0aa35cd848f2d94178b87dcf68272c8a3f96c42b
Normal file
Binary file not shown.
BIN
corpus/0ad70cc2a529b6d840f769816d3f7e2ab8acc68c
Normal file
BIN
corpus/0ad70cc2a529b6d840f769816d3f7e2ab8acc68c
Normal file
Binary file not shown.
BIN
corpus/0b323a04077fd639c7e0a51a750eb1259bb6a4b0
Normal file
BIN
corpus/0b323a04077fd639c7e0a51a750eb1259bb6a4b0
Normal file
Binary file not shown.
BIN
corpus/0b445ea9b2e9cd62d4bd681ab94324aea7fe6b98
Normal file
BIN
corpus/0b445ea9b2e9cd62d4bd681ab94324aea7fe6b98
Normal file
Binary file not shown.
BIN
corpus/0b5969da792544a3fd9bb8f9c7fd0a53ad17b938
Normal file
BIN
corpus/0b5969da792544a3fd9bb8f9c7fd0a53ad17b938
Normal file
Binary file not shown.
BIN
corpus/0b8cdd849f754ceb9950905ea35ad04f6593b6ae
Normal file
BIN
corpus/0b8cdd849f754ceb9950905ea35ad04f6593b6ae
Normal file
Binary file not shown.
BIN
corpus/0ba096610c940d2c622c714000c4ac5db73e999c
Normal file
BIN
corpus/0ba096610c940d2c622c714000c4ac5db73e999c
Normal file
Binary file not shown.
BIN
corpus/0baea27108df93d537bcc0de459495d5f17382a0
Normal file
BIN
corpus/0baea27108df93d537bcc0de459495d5f17382a0
Normal file
Binary file not shown.
BIN
corpus/0bc248eeac5de2872085e704d89ca0f24ddefa96
Normal file
BIN
corpus/0bc248eeac5de2872085e704d89ca0f24ddefa96
Normal file
Binary file not shown.
BIN
corpus/0bee3319fe0f3462a7f0cb7c8eeb616d4660add7
Normal file
BIN
corpus/0bee3319fe0f3462a7f0cb7c8eeb616d4660add7
Normal file
Binary file not shown.
BIN
corpus/0c03df024913af7478e1a72d96553e8c03aa5533
Normal file
BIN
corpus/0c03df024913af7478e1a72d96553e8c03aa5533
Normal file
Binary file not shown.
BIN
corpus/0c682ddd5107057be93216752a72bfad6d41d816
Normal file
BIN
corpus/0c682ddd5107057be93216752a72bfad6d41d816
Normal file
Binary file not shown.
BIN
corpus/0c6f460d9012fc295ac4ae3c23d9c9904ae9f496
Normal file
BIN
corpus/0c6f460d9012fc295ac4ae3c23d9c9904ae9f496
Normal file
Binary file not shown.
BIN
corpus/0c71425d945565f739bdf33d02d9a2f80fe81c29
Normal file
BIN
corpus/0c71425d945565f739bdf33d02d9a2f80fe81c29
Normal file
Binary file not shown.
BIN
corpus/0c757a21c9d2629c51923f943dc2c79c4bcbca4a
Normal file
BIN
corpus/0c757a21c9d2629c51923f943dc2c79c4bcbca4a
Normal file
Binary file not shown.
BIN
corpus/0c83b55eddb372f37fd479b982a26f7d76a9ee74
Normal file
BIN
corpus/0c83b55eddb372f37fd479b982a26f7d76a9ee74
Normal file
Binary file not shown.
BIN
corpus/0c8985cda07d3e60e5c2da19c00c0bf3aa9a2b31
Normal file
BIN
corpus/0c8985cda07d3e60e5c2da19c00c0bf3aa9a2b31
Normal file
Binary file not shown.
BIN
corpus/0cbb486e842f843588f084c6480e42e2cfef60b2
Normal file
BIN
corpus/0cbb486e842f843588f084c6480e42e2cfef60b2
Normal file
Binary file not shown.
BIN
corpus/0cfc86eecaf16f682bcce978ce41d35a016a0a7f
Normal file
BIN
corpus/0cfc86eecaf16f682bcce978ce41d35a016a0a7f
Normal file
Binary file not shown.
BIN
corpus/0d19837d6411c43e7e7c3f8ae592719fd1e556e2
Normal file
BIN
corpus/0d19837d6411c43e7e7c3f8ae592719fd1e556e2
Normal file
Binary file not shown.
BIN
corpus/0d28b7cc8c4d9359f045df42f88dd30ee52b8477
Normal file
BIN
corpus/0d28b7cc8c4d9359f045df42f88dd30ee52b8477
Normal file
Binary file not shown.
BIN
corpus/0dea4eac572bd1210f5cf582c4dc049696bfd3a3
Normal file
BIN
corpus/0dea4eac572bd1210f5cf582c4dc049696bfd3a3
Normal file
Binary file not shown.
BIN
corpus/0df8f73f7238fb993fc6c77b03dfbe0d88a668cf
Normal file
BIN
corpus/0df8f73f7238fb993fc6c77b03dfbe0d88a668cf
Normal file
Binary file not shown.
BIN
corpus/0e2c82cd38130dc94263a67b46afbf89407eee2a
Normal file
BIN
corpus/0e2c82cd38130dc94263a67b46afbf89407eee2a
Normal file
Binary file not shown.
BIN
corpus/0e3aaaf8e085bdf5f4419b176cea97d4bfcb62bf
Normal file
BIN
corpus/0e3aaaf8e085bdf5f4419b176cea97d4bfcb62bf
Normal file
Binary file not shown.
BIN
corpus/0ebb66b9b7a11c4858236dc5852386dedae328c0
Normal file
BIN
corpus/0ebb66b9b7a11c4858236dc5852386dedae328c0
Normal file
Binary file not shown.
BIN
corpus/0ed2d396bc5bd9b396942e6ec5569f46bef2476e
Normal file
BIN
corpus/0ed2d396bc5bd9b396942e6ec5569f46bef2476e
Normal file
Binary file not shown.
BIN
corpus/0eea457d59d763abe2b35aa044d839613f0c1eff
Normal file
BIN
corpus/0eea457d59d763abe2b35aa044d839613f0c1eff
Normal file
Binary file not shown.
BIN
corpus/0f5da08bcc16bd128afa52a03db7a726bc9e8f87
Normal file
BIN
corpus/0f5da08bcc16bd128afa52a03db7a726bc9e8f87
Normal file
Binary file not shown.
BIN
corpus/0f8959089fadd2c5542cc9148d86176e800d92d3
Normal file
BIN
corpus/0f8959089fadd2c5542cc9148d86176e800d92d3
Normal file
Binary file not shown.
BIN
corpus/0fbd6aa91e6a6c89f575d339b9f103a057b80ba6
Normal file
BIN
corpus/0fbd6aa91e6a6c89f575d339b9f103a057b80ba6
Normal file
Binary file not shown.
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user