Ything-RepoMirrors/apple-foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2026-01-25 04:18:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Set noUnseed = true for ThreadReturnPromiseStream test

Browse Source
This commit is contained in:
Vishesh Yadav
2025-05-19 17:21:07 -07:00
parent ce9c8af259
commit 960b68062f
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fdbrpc/FlowTests.actor.cpp
View File

@@ -1619,6 +1619,7 @@ using namespace std::chrono_literals;
TEST_CASE("/flow/thread/ThreadReturnPromiseStream_Simple") {
state AsyncTaskExecutor exc(1);
noUnseed = true;
ThreadReturnPromiseStream<int> stream;
state ThreadFutureStream<int> f = stream.getFuture();
state Future<Void> t = exc.post([stream = std::move(stream)]() mutable {
@@ -1652,6 +1653,7 @@ TEST_CASE("/flow/thread/ThreadReturnPromiseStream_Simple") {
TEST_CASE("/flow/thread/ThreadReturnPromiseStream_Seq") {
state AsyncTaskExecutor exc(1);
noUnseed = true;
ThreadReturnPromiseStream<int> stream;
state ThreadFutureStream<int> f = stream.getFuture();
state Future<Void> t = exc.post([stream = std::move(stream)]() mutable {
@@ -1679,6 +1681,7 @@ TEST_CASE("/flow/thread/ThreadReturnPromiseStream_Seq") {
TEST_CASE("/flow/thread/ThreadReturnPromiseStream_Error") {
state AsyncTaskExecutor exc(1);
noUnseed = true;
{
ThreadReturnPromiseStream<int> s1;
@@ -1721,6 +1724,8 @@ TEST_CASE("/flow/thread/ThreadReturnPromiseStream_Error") {
}
TEST_CASE("/flow/IThreadPool/ThreadReturnPromiseStream_DestroyPromise") {
noUnseed = true;
{
std::cout << "ThreadReturnPromiseStream with future > 0, promise == 0, end_of_stream sent\n";
// After all references to PromiseStream are gone, FutureStream should still be able to get