hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 02:21:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #22 from amplab/fix

Browse source 
opening all memory segments now
This commit is contained in:
Robert Nishihara 2016-03-24 12:15:26 -07:00
commit 0a7e606279
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/ipc.cc
View file

@ -39,9 +39,12 @@ ObjHandle MemorySegmentPool::allocate(size_t size) {
// the process that will use the address
char* MemorySegmentPool::get_address(ObjHandle pointer) {
if (pointer.segmentid() >= segments_.size()) {
open_segment(pointer.segmentid());
for (int i = segments_.size(); i <= pointer.segmentid(); ++i) {
open_segment(i);
}
return static_cast<char*>(segments_[pointer.segmentid()]->get_address_from_handle(pointer.ipcpointer()));
}
managed_shared_memory* segment = segments_[pointer.segmentid()].get();
return static_cast<char*>(segment->get_address_from_handle(pointer.ipcpointer()));
}
MemorySegmentPool::~MemorySegmentPool() {