coffee/cpp-ipc
1
0
Fork 0
mirror of https://github.com/mutouyun/cpp-ipc.git synced 2025-12-06 16:56:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

upd: optimize ut

Browse Source
This commit is contained in:
mutouyun 2023-04-16 20:45:05 +08:00
parent 4e05befbe9
commit 4e7688f109
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/concur/test_concur_concurrent.cpp
View File

@ -227,7 +227,7 @@ void test_broadcast(std::size_t np, std::size_t nc) {
std::uint64_t n; std::uint64_t n;
std::uint64_t i; std::uint64_t i;
}; };
concur::element<Data> circ[32] {}; concur::element<Data> circ[256] {};
PC pc; PC pc;
typename concur::traits<PC>::header hdr {imp::make_span(circ)}; typename concur::traits<PC>::header hdr {imp::make_span(circ)};
ASSERT_TRUE(hdr.valid()); ASSERT_TRUE(hdr.valid());
@ -251,7 +251,7 @@ void test_broadcast(std::size_t np, std::size_t nc) {
} }
std::this_thread::yield(); std::this_thread::yield();
if (k % (loop_size / 10) == 0) { if (k % (loop_size / 10) == 0) {
log.info("[", n, "] put count: ", i, ", retry: ", k, ", counters: ", counters[n]); log.info("[", n, "] put count: ", i, ", retry: ", k, ", counter: ", counters[n]);
std::this_thread::sleep_for(std::chrono::milliseconds(1)); std::this_thread::sleep_for(std::chrono::milliseconds(1));
} }
} }
@ -272,7 +272,7 @@ void test_broadcast(std::size_t np, std::size_t nc) {
std::this_thread::yield(); std::this_thread::yield();
} }
// The v.i variable always increases. // The v.i variable always increases.
if (last_i[(std::size_t)v.n] >= v.i) { if (last_i[(std::size_t)v.n] != (v.i - 1)) {
continue; continue;
} }
last_i[(std::size_t)v.n] = v.i; last_i[(std::size_t)v.n] = v.i;