Fix compilation errors

This commit is contained in:
Markus Pilman 2022-10-05 07:47:20 -06:00
parent 23edfd0d59
commit 1f568fe9e9
2 changed files with 11 additions and 4 deletions

View File

@ -144,6 +144,14 @@ ACTOR static Future<Void> cheeseWaitActor() {
return Void();
}
size_t cheeseWaitActorSize() {
#ifndef OPEN_FOR_IDE
return sizeof(CheeseWaitActorActor);
#else
return 0ul;
#endif
}
ACTOR static void trivialVoidActor(int* result) {
*result = 1;
}
@ -1084,9 +1092,7 @@ TEST_CASE("#flow/flow/perf/actor patterns") {
ASSERT(out2[i].isReady());
}
printf("2xcheeseActor(chooseTwoActor(cheeseActor(fifo), never)): %0.2f M/sec\n", N / 1e6 / (timer() - start));
#ifndef OPEN_FOR_IDE
printf("sizeof(CheeseWaitActorActor) == %zu\n", sizeof(CheeseWaitActorActor));
#endif
printf("sizeof(CheeseWaitActorActor) == %zu\n", cheeseWaitActorSize());
}
{

View File

@ -542,7 +542,8 @@ ACTOR Future<Void> fetchCheckpointFile(Database cx,
wait(IAsyncFileSystem::filesystem()->deleteFile(localFile, true));
const int64_t flags = IAsyncFile::OPEN_ATOMIC_WRITE_AND_CREATE | IAsyncFile::OPEN_READWRITE |
IAsyncFile::OPEN_CREATE | IAsyncFile::OPEN_UNCACHED | IAsyncFile::OPEN_NO_AIO;
asyncFile = wait(IAsyncFileSystem::filesystem()->open(localFile, flags, 0666));
Reference<IAsyncFile> _asyncFile = wait(IAsyncFileSystem::filesystem()->open(localFile, flags, 0666));
asyncFile = std::move(_asyncFile);
state ReplyPromiseStream<FetchCheckpointReply> stream =
ssi.fetchCheckpoint.getReplyStream(FetchCheckpointRequest(metaData->checkpointID, remoteFile));