From 4484dd954052a9b08188d0529d5cdc6d50977af6 Mon Sep 17 00:00:00 2001
From: Justin Ethier <justin.ethier@gmail.com>
Date: Wed, 29 Jul 2015 21:41:47 -0400
Subject: [PATCH] Added Cyc-flush-output-file

---
 include/cyclone/runtime.h |  2 ++
 runtime.c                 | 29 +++++++++++++++++++++++------
 2 files changed, 25 insertions(+), 6 deletions(-)

diff --git a/include/cyclone/runtime.h b/include/cyclone/runtime.h
index 9bece7b4..658e4221 100644
--- a/include/cyclone/runtime.h
+++ b/include/cyclone/runtime.h
@@ -148,6 +148,7 @@ port_type Cyc_io_open_output_file(object str);
 object Cyc_io_close_port(object port);
 object Cyc_io_close_input_port(object port);
 object Cyc_io_close_output_port(object port);
+object Cyc_io_flush_output_port(object port);
 object Cyc_io_delete_file(object filename);
 object Cyc_io_file_exists(object filename);
 object Cyc_io_read_char(object port);
@@ -357,6 +358,7 @@ extern const object primitive_open_91output_91file;
 extern const object primitive_close_91port;
 extern const object primitive_close_91input_91port;
 extern const object primitive_close_91output_91port;
+extern const object primitive_Cyc_91flush_91output_91port;
 extern const object primitive_file_91exists_127;
 extern const object primitive_delete_91file;
 extern const object primitive_read_91char;
diff --git a/runtime.c b/runtime.c
index dc447a6d..8669620b 100644
--- a/runtime.c
+++ b/runtime.c
@@ -1293,13 +1293,25 @@ object Cyc_io_close_output_port(object port) {
   return Cyc_io_close_port(port); }
 
 object Cyc_io_close_port(object port) {
-    Cyc_check_port(port);
-    {
-       FILE *stream = ((port_type *)port)->fp;
-       if (stream) fclose(stream);
-       ((port_type *)port)->fp = NULL;
+  Cyc_check_port(port);
+  {
+    FILE *stream = ((port_type *)port)->fp;
+    if (stream) fclose(stream);
+    ((port_type *)port)->fp = NULL;
+  }
+  return port;
+}
+
+object Cyc_io_flush_output_port(object port) {
+  Cyc_check_port(port);
+  {
+    FILE *stream = ((port_type *)port)->fp;
+    if (stream) { 
+      int rv = fflush(stream);
+      // TODO: handle error if non-zero value returned
     }
-    return port;
+  }
+  return port;
 }
 
 object Cyc_io_delete_file(object filename) {
@@ -1738,6 +1750,9 @@ void _close_91input_91port(object cont, object args) {
 void _close_91output_91port(object cont, object args) {  
     Cyc_check_num_args("close-output-port", 1, args);
     return_funcall1(cont, Cyc_io_close_output_port(car(args)));}
+void _Cyc_91flush_91output_91port(object cont, object args) {
+    Cyc_check_num_args("Cyc-flush-output-port", 1, args);
+    return_funcall1(cont, Cyc_io_flush_output_port(car(args)));}
 void _file_91exists_127(object cont, object args) {
     Cyc_check_num_args("file-exists?", 1, args);
     return_funcall1(cont, Cyc_io_file_exists(car(args)));}
@@ -2385,6 +2400,7 @@ static primitive_type open_91output_91file_primitive = {primitive_tag, "open-out
 static primitive_type close_91port_primitive = {primitive_tag, "close-port", &_close_91port};
 static primitive_type close_91input_91port_primitive = {primitive_tag, "close-input-port", &_close_91input_91port};
 static primitive_type close_91output_91port_primitive = {primitive_tag, "close-output-port", &_close_91output_91port};
+static primitive_type Cyc_91flush_91output_91port_primitive = {primitive_tag, "Cyc-flush-output-port", &_Cyc_91flush_91output_91port};
 static primitive_type file_91exists_127_primitive = {primitive_tag, "file-exists?", &_file_91exists_127};
 static primitive_type delete_91file_primitive = {primitive_tag, "delete-file", &_delete_91file};
 static primitive_type read_91char_primitive = {primitive_tag, "read-char", &_read_91char};
@@ -2499,6 +2515,7 @@ const object primitive_open_91output_91file = &open_91output_91file_primitive;
 const object primitive_close_91port = &close_91port_primitive;
 const object primitive_close_91input_91port = &close_91input_91port_primitive;
 const object primitive_close_91output_91port = &close_91output_91port_primitive;
+const object primitive_Cyc_91flush_91output_91port = &Cyc_91flush_91output_91port_primitive;
 const object primitive_file_91exists_127 = &file_91exists_127_primitive;
 const object primitive_delete_91file = &delete_91file_primitive;
 const object primitive_read_91char = &read_91char_primitive;