From ed09391cfbbf1de9aff48a74dfe83a69170487a7 Mon Sep 17 00:00:00 2001
From: John Kerl <kerl.john.r@gmail.com>
Date: Fri, 30 Sep 2016 21:55:51 -0400
Subject: [PATCH] filter output-restriction iterate

---
 c/mapping/mlr_dsl_cst.c | 6 ++++++
 c/mapping/mlr_dsl_cst.h | 4 +++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/c/mapping/mlr_dsl_cst.c b/c/mapping/mlr_dsl_cst.c
index 1b856094b..84affcf50 100644
--- a/c/mapping/mlr_dsl_cst.c
+++ b/c/mapping/mlr_dsl_cst.c
@@ -290,6 +290,7 @@ static cst_statement_handler_t handle_print;
 	pcst->psubr_defsites    = lhmsv_alloc();
 	pcst->psubr_callsite_statements_to_resolve = sllv_alloc();
 	pcst->pfilter_evaluator = NULL; // xxx rm
+	pcst->flush_every_record = flush_every_record;
 
 	udf_defsite_state_t* pudf_defsite_state = NULL;
 	subr_defsite_t* psubr_defsite = NULL;
@@ -1580,6 +1581,7 @@ static mlr_dsl_cst_statement_t* alloc_tee(mlr_dsl_cst_t* pcst, mlr_dsl_ast_node_
 		pstatement->file_output_mode = file_output_mode_from_ast_node_type(poutput_node->type);
 		pstatement->pnode_handler = handle_tee_to_file;
 	}
+	pstatement->flush_every_record = pcst->flush_every_record;
 
 	return pstatement;
 }
@@ -1622,6 +1624,7 @@ static mlr_dsl_cst_statement_t* alloc_emitf(mlr_dsl_cst_t* pcst, mlr_dsl_ast_nod
 		pstatement->file_output_mode = file_output_mode_from_ast_node_type(poutput_node->type);
 		pstatement->pnode_handler = handle_emitf_to_file;
 	}
+	pstatement->flush_every_record = pcst->flush_every_record;
 
 	return pstatement;
 }
@@ -1720,6 +1723,7 @@ static mlr_dsl_cst_statement_t* alloc_emit(mlr_dsl_cst_t* pcst, mlr_dsl_ast_node
 		pstatement->file_output_mode = file_output_mode_from_ast_node_type(poutput_node->type);
 		pstatement->pnode_handler = output_all ? handle_emit_all_to_file : handle_emit_to_file;
 	}
+	pstatement->flush_every_record = pcst->flush_every_record;
 
 	return pstatement;
 }
@@ -1868,6 +1872,7 @@ static mlr_dsl_cst_statement_t* alloc_dump(mlr_dsl_cst_t* pcst, mlr_dsl_ast_node
 		pstatement->pmulti_out = multi_out_alloc();
 		pstatement->pnode_handler = handle_dump_to_file;
 	}
+	pstatement->flush_every_record = pcst->flush_every_record;
 
 	return pstatement;
 }
@@ -1899,6 +1904,7 @@ static mlr_dsl_cst_statement_t* alloc_print(mlr_dsl_cst_t* pcst, mlr_dsl_ast_nod
 		pstatement->file_output_mode = file_output_mode_from_ast_node_type(poutput_node->type);
 		pstatement->pmulti_out = multi_out_alloc();
 	}
+	pstatement->flush_every_record = pcst->flush_every_record;
 	pstatement->pnode_handler = handle_print;
 
 	return pstatement;
diff --git a/c/mapping/mlr_dsl_cst.h b/c/mapping/mlr_dsl_cst.h
index bad1e7fcf..90c4d01c0 100644
--- a/c/mapping/mlr_dsl_cst.h
+++ b/c/mapping/mlr_dsl_cst.h
@@ -60,7 +60,6 @@ typedef struct _cst_outputs_t {
 	int*    pshould_emit_rec;
 	sllv_t* poutrecs;
 	char*   oosvar_flatten_separator;
-	// xxx int     flush_every_record; // fflush on emit/tee/print/dump
 	cli_writer_opts_t* pwriter_opts;
 } cst_outputs_t;
 
@@ -215,6 +214,9 @@ typedef struct _mlr_dsl_cst_t {
 
 	// For mlr filter which takes restricted syntax
 	rval_evaluator_t* pfilter_evaluator;
+
+	// fflush on emit/tee/print/dump
+	int flush_every_record;
 } mlr_dsl_cst_t;
 
 // ----------------------------------------------------------------