Changeset 74776 in vbox for trunk/src/VBox

Timestamp:

Oct 11, 2018 5:30:59 PM (6 years ago)

Author:

vboxsync

Message:

Main: Started implementing the IDataStream interface

Location:

trunk/src/VBox/Main

Files:

• Makefile.kmk (modified) (1 diff)
• include/DataStreamImpl.h (modified) (3 diffs)
• src-server/DataStreamImpl.cpp (added)

trunk/src/VBox/Main/Makefile.kmk

@@ -462 +462 @@
         src-server/ClientToken.cpp \
         src-server/CloudProviderManagerImpl.cpp \
+        src-server/DataStreamImpl.cpp \
         src-server/DHCPServerImpl.cpp \
         src-server/NetworkServiceRunner.cpp \

trunk/src/VBox/Main/include/DataStreamImpl.h

@@ -22 +22 @@
 #include "DataStreamWrap.h"
 
+#include <iprt/semaphore.h>
 
 class ATL_NO_VTABLE DataStream
@@ -41 +42 @@
     int i_write(const void *pvBuf, size_t cbWrite, size_t *pcbWritten);
 
+    /// Marks the end of the stream.
+    int i_close();
+
 private:
     // wrapped IDataStream attributes and methods
@@ -47 +51 @@
 
 private:
+    /** Maximum number of bytes the buffer can hold. */
+    unsigned long     m_aBufferSize;
+    /** The temporary buffer the conversion process writes into and the user reads from. */
     std::vector<BYTE> m_aBuffer;
+    /** Event semaphore for waiting until data is available. */
+    RTSEMEVENT        m_hSemEvtDataAvail;
+    /** Event semaphore for waiting until there is room in the buffer for writing. */
+    RTSEMEVENT        m_hSemEvtBufSpcAvail;
+    /** Flag whether the end of stream flag is set. */
+    bool              m_fEos;
 };