Skip to content
Snippets Groups Projects
Commit 152bb13b authored by Christopher J. Morrone's avatar Christopher J. Morrone
Browse files

Increase default stdio buffer sizes

parent 28643a47
No related branches found
No related tags found
No related merge requests found
......@@ -35,8 +35,8 @@
* The message cache uses up free message buffers, so STDIO_MAX_MSG_CACHE
* must be a number smaller than STDIO_MAX_FREE_BUF.
*/
#define STDIO_MAX_FREE_BUF 10
#define STDIO_MAX_MSG_CACHE 5
#define STDIO_MAX_FREE_BUF 1024
#define STDIO_MAX_MSG_CACHE 128
struct io_buf {
int ref_count;
......
......@@ -30,6 +30,8 @@
#include "src/common/io_hdr.h"
#include "src/srun/srun_job.h"
#define STDIO_MAX_FREE_BUF 1024
struct io_buf {
int ref_count;
uint32_t length;
......
......@@ -494,11 +494,11 @@ _job_create_internal(allocation_info_t *info)
/* "nhosts" number of IO protocol sockets */
job->ioserver = (eio_obj_t **)xmalloc(job->nhosts*sizeof(eio_obj_t *));
job->free_incoming = list_create(NULL); /* FIXME! Needs destructor */
for (i = 0; i < 10; i++) {
for (i = 0; i < STDIO_MAX_FREE_BUF; i++) {
list_enqueue(job->free_incoming, alloc_io_buf());
}
job->free_outgoing = list_create(NULL); /* FIXME! Needs destructor */
for (i = 0; i < 10; i++) {
for (i = 0; i < STDIO_MAX_FREE_BUF; i++) {
list_enqueue(job->free_outgoing, alloc_io_buf());
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment