very simple non-working implementation of streambufs for hhvm

3 files changed, 163 insertions, 0 deletions

diff --git a/common/includes.h b/common/includes.h
new file mode 100644
index 0000000..db29f10
--- /dev/null
+++ b/common/includes.h
@@ -0,0 +1,23 @@
+/**
+ *  Includes.h
+ * 
+ *  All includes for compiling the common module files of PHP-CPP library
+ * 
+ *  @author Emiel Bruijntjes <emiel.bruijntjes@copernica.com>
+ *  @copyright 2014 Copernica BV
+ */
+
+/**
+ *  Standard C and C++ libraries
+ */
+#include <sstream>
+
+/**
+ *  Public include files
+ */
+#include "../include/modifiers.h"
+
+/**
+ *  Generic implementation header files
+ */
+#include "streambuf.h"
diff --git a/common/streambuf.cpp b/common/streambuf.cpp
new file mode 100644
index 0000000..2d87f9a
--- /dev/null
+++ b/common/streambuf.cpp
@@ -0,0 +1,60 @@
+/**
+ *  StreamBuf.cpp
+ *
+ *  Implementation file for the StreamBuf class
+ *
+ *  @see http://www.mr-edd.co.uk/blog/beginners_guide_streambuf
+ * 
+ *  @author Emiel Bruijntjes <emiel.bruijntjes@copernica.com>
+ *  @copyright 2014 Copernica BV
+ */
+#include "includes.h"
+
+/**
+ *  Set up namespace
+ */
+namespace Php {
+
+/**
+ *  Constructor
+ *  @param  error
+ */
+StreamBuf::StreamBuf(int error) : _error(error)
+{
+    // we reserve one byte, so that when overflow is called, we still have one
+    // byte extra in the buffer to put the overflowed byte int
+    setp(_buffer, _buffer+1024-1);
+}
+    
+
+/**
+ *  Method that is called when the internal buffer overflows
+ *  @param  c
+ *  @return int
+ */
+int StreamBuf::overflow(int c)
+{
+    // for error buffers, overflow is simply discarded
+    if (_error) return c;
+    
+    // end-of-file has not output, we call EOF directly, and by using the
+    // comma operator we ensure that EOF is returned
+    if (c == EOF) return sync(), EOF;
+    
+    // because we lied the underlying buffer about the size of the buffer
+    // by one byte, there is no real overflow, and we can still add the byte
+    // to the end of the buffer
+    *pptr() = c;
+    
+    // increment buffer size
+    pbump(1);
+    
+    // and now we're going to syn the buffer
+    return sync() == -1 ? EOF : c;
+}
+
+/**
+ *  End namespace
+ */
+}
+ 
\ No newline at end of file
diff --git a/common/streambuf.h b/common/streambuf.h
new file mode 100644
index 0000000..ed1506a
--- /dev/null
+++ b/common/streambuf.h
@@ -0,0 +1,80 @@
+/**
+ *  StreamBuf.h
+ *
+ *  PHP output stream buffer which is used by the Php::out object to
+ *  have an output stream just like the regular std::ostream buffers, 
+ *  but that sends all output to PHP output
+ *
+ *  @author Emiel Bruijntjes <emiel.bruijntjes@copernica.com>
+ *  @copyright 2014 Copernica BV
+ */
+
+/**
+ *  Set up namespace
+ */
+namespace Php {
+
+/**
+ *  Class definition
+ */
+class StreamBuf : public std::streambuf
+{
+public:
+    /**
+     *  Constructor
+     *  @param  error   the error type, or 0 for regular output
+     */
+    StreamBuf(int error);
+    
+    /**
+     *  No copying or moving
+     *  @param  that
+     */
+    StreamBuf(const StreamBuf &that) = delete;
+    StreamBuf(StreamBuf &&that) = delete;
+    
+    /**
+     *  Destructor
+     */
+    virtual ~StreamBuf() {}
+    
+    /**
+     *  No copying or moving
+     *  @param  that
+     */
+    StreamBuf &operator=(const StreamBuf &that) = delete;
+    StreamBuf &operator=(StreamBuf &&that) = delete;
+
+protected:
+    /**
+     *  Method that is called when the internal buffer overflows
+     *  @param  c
+     *  @return int
+     */
+    virtual int overflow(int c = EOF) override;
+    
+    /**
+     *  Called when the internal buffer should be synchronized
+     *  @return int
+     */
+    virtual int sync() override;
+
+private:
+    /**
+     *  The error type, or 0 for regular output
+     *  @var    int
+     */
+    int _error;
+
+    /**
+     *  The internal buffer
+     *  @var    char[]
+     */
+    char _buffer[1024];
+};
+
+/**
+ *  End namespace
+ */
+}
+