Skip to content

Commit

Permalink
preflight script formatting changes
Browse files Browse the repository at this point in the history
  • Loading branch information
pcmoritz committed Aug 20, 2017
1 parent 22188a6 commit 5aa4b0d
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 8 deletions.
4 changes: 1 addition & 3 deletions cpp/src/plasma/malloc.cc
Original file line number Diff line number Diff line change
Expand Up @@ -195,6 +195,4 @@ void get_malloc_mapinfo(void* addr, int* fd, int64_t* map_size, ptrdiff_t* offse
*offset = 0;
}

void set_malloc_granularity(int value) {
change_mparam(M_GRANULARITY, value);
}
void set_malloc_granularity(int value) { change_mparam(M_GRANULARITY, value); }
2 changes: 1 addition & 1 deletion cpp/src/plasma/store.cc
Original file line number Diff line number Diff line change
Expand Up @@ -765,7 +765,7 @@ int main(int argc, char* argv[]) {
"pass an argument with the flag '--shm-size' to 'docker run'.";
}
} else {
set_malloc_granularity(1024 * 1024 * 1024); // 1 GB
set_malloc_granularity(1024 * 1024 * 1024); // 1 GB
}
#endif
// Make it so dlmalloc fails if we try to request more memory than is
Expand Down
2 changes: 1 addition & 1 deletion cpp/src/plasma/store.h
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@
#define PLASMA_STORE_H

#include <deque>
#include <vector>
#include <string>
#include <vector>

#include "plasma/common.h"
#include "plasma/events.h"
Expand Down
9 changes: 6 additions & 3 deletions python/pyarrow/io.pxi
Original file line number Diff line number Diff line change
Expand Up @@ -543,15 +543,18 @@ cdef class FixedSizeBufferOutputStream(NativeFile):
self.is_open = True

def set_memcopy_threads(self, int num_threads):
cdef CFixedSizeBufferWriter* writer = <CFixedSizeBufferWriter*> self.wr_file.get()
cdef CFixedSizeBufferWriter* writer = \
<CFixedSizeBufferWriter*> self.wr_file.get()
writer.set_memcopy_threads(num_threads)

def set_memcopy_blocksize(self, int64_t blocksize):
cdef CFixedSizeBufferWriter* writer = <CFixedSizeBufferWriter*> self.wr_file.get()
cdef CFixedSizeBufferWriter* writer = \
<CFixedSizeBufferWriter*> self.wr_file.get()
writer.set_memcopy_blocksize(blocksize)

def set_memcopy_threshold(self, int64_t threshold):
cdef CFixedSizeBufferWriter* writer = <CFixedSizeBufferWriter*> self.wr_file.get()
cdef CFixedSizeBufferWriter* writer = \
<CFixedSizeBufferWriter*> self.wr_file.get()
writer.set_memcopy_threshold(threshold)


Expand Down

0 comments on commit 5aa4b0d

Please sign in to comment.