Commit 915885cf authored by Shane Snyder's avatar Shane Snyder

make sure compression buffers are big enough

parent 410c684a
...@@ -48,9 +48,6 @@ ...@@ -48,9 +48,6 @@
/* default name record buf can store 2048 records of size 100 bytes */ /* default name record buf can store 2048 records of size 100 bytes */
#define DARSHAN_NAME_RECORD_BUF_SIZE (2048 * 100) #define DARSHAN_NAME_RECORD_BUF_SIZE (2048 * 100)
/* Default runtime compression buffer size */
#define DARSHAN_COMP_BUF_SIZE DARSHAN_MOD_MEM_MAX
/* structure to track registered modules */ /* structure to track registered modules */
struct darshan_core_module struct darshan_core_module
{ {
......
...@@ -405,7 +405,7 @@ void darshan_core_shutdown() ...@@ -405,7 +405,7 @@ void darshan_core_shutdown()
final_core->log_job_p->end_time = last_end_time; final_core->log_job_p->end_time = last_end_time;
} }
final_core->comp_buf = malloc(DARSHAN_COMP_BUF_SIZE); final_core->comp_buf = malloc(darshan_mod_mem_quota);
if(!(final_core->comp_buf)) if(!(final_core->comp_buf))
{ {
darshan_core_cleanup(final_core); darshan_core_cleanup(final_core);
...@@ -1558,7 +1558,7 @@ static int darshan_deflate_buffer(void **pointers, int *lengths, int count, ...@@ -1558,7 +1558,7 @@ static int darshan_deflate_buffer(void **pointers, int *lengths, int count,
} }
tmp_stream.next_out = (unsigned char *)comp_buf; tmp_stream.next_out = (unsigned char *)comp_buf;
tmp_stream.avail_out = DARSHAN_COMP_BUF_SIZE; tmp_stream.avail_out = darshan_mod_mem_quota;
/* loop over the input pointers */ /* loop over the input pointers */
for(i = 0; i < count; i++) for(i = 0; i < count; i++)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment