-
Notifications
You must be signed in to change notification settings - Fork 5.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[object store refactor 2/n] More refactor on PlasmaAllocator, and add unit tests #17313
Conversation
943f74a
to
900fde1
Compare
900fde1
to
3c845eb
Compare
3c845eb
to
5e62e41
Compare
5e62e41
to
73c6b97
Compare
73c6b97
to
5bca4bf
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM! Nit comments
return p.set_value(allocator_ ? allocator_->FallbackAllocated() : 0); | ||
}, | ||
"PlasmaStoreRunner.GetFallbackAllocatedMemory"); | ||
return p.get_future().get(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Isn't this blocking btw?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yup it is
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
an alternative is to make those counters std::atomic...
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This sounds like an better option to me! Hopefully we can remove these issues when solving the threading model problrm…
bool fallback_enabled) { | ||
dlmalloc_config.hugepages_enabled = hugepage_enabled; | ||
dlmalloc_config.directory = plasma_directory; | ||
dlmalloc_config.fallback_directory = fallback_directory; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Maybe we can add a check that this directory is not /dev/shm?
Btw, I am down to merge this once we solve the blocking FallbackAllocated call |
9885165
to
14fa38e
Compare
54bb716
to
28fe635
Compare
14fa38e
to
c8bdc41
Compare
RAY_LOG(ERROR) << "MapViewOfFile() failed. GetLastError() = " << GetLastError(); | ||
} | ||
if (!allocated_once) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
windows bug caught by unit test!
fix windows fix windows
fab8664
to
bc03a0d
Compare
This the 2nd PR that refactor PlasmaStore for modularization and testability. Previous PR: #17307 , Next PR: #17332
In this PR, we further refactor PlasmaAllocator for better testability. Specifically
Test Plan
-[x] existing tests
-[x] added unit tests