1 files changed, 83 insertions, 0 deletions
diff --git a/source/LCM/Buffers.h b/source/LCM/Buffers.h
new file mode 100644
index 0000000..2a2f213
--- /dev/null
+++ b/source/LCM/Buffers.h
@@ -0,0 +1,83 @@
+/*******************************************************************************
+ * Copyright (C) ST-Ericsson SA 2011
+ * License terms: 3-clause BSD license
+ ******************************************************************************/
+
+#ifndef _BUFFER_H_
+#define _BUFFER_H_
+
+#include "t_bulk_protocol.h"
+#include "MemMappedFile.h"
+#include "Queue.h"
+#include "Logger.h"
+#ifdef _WIN32
+#include "WinApiWrappers.h"
+#else
+#include "LinuxApiWrappers.h"
+#endif
+
+#include <string>
+#include <vector>
+
+struct TBulkVector {
+    uint8 *HeaderBuffer_p;
+    uint8 *Data_p;
+    uint64 Offset;
+    uint32 Length;
+    uint32 ChunkSize;
+
+    TBulkVector();
+    ~TBulkVector();
+};
+
+struct TBulkFile {
+    TBulkFile();
+    ~TBulkFile();
+
+    std::string strFileName;
+    std::vector<TBulkVector *> bulkVectors;
+    size_t refCount;
+    int iAllSessionsCompleted;
+    MemMappedFile *pMemMappedFile;
+
+    CCriticalSectionObject csBulkVectors;
+};
+
+class Buffers
+{
+public:
+    Buffers();
+    ~Buffers();
+
+    void SetLogger(Logger *logger) {
+        logger_ = logger;
+    }
+private:
+    //Member variables for Bulk Flash.
+    static std::vector<TBulkFile *> m_BulkFiles;
+    static CCriticalSectionObject csBulkFiles;
+    TBulkFile *m_BulkFile;
+public:
+    ErrorCode_e Init();
+    void *Allocate(int Size);
+    ErrorCode_e Release(void *Buffer_p, int Size);
+    uint32 Available(int BufferSize);
+    void Deinit();
+
+    //Functions for Bulk Flash
+    int AllocateBulkFile(std::string strFile);
+    uint64 GetBulkFileLength();
+
+    int AllocateBulkVector(TL_BulkVectorList_t *BulkVector_p, uint32 iChunkSize, uint64 lOffset, uint32 iLength);
+    void ReleaseBulkVector(TL_BulkVectorList_t *BulkVector_p);
+
+    void ReleaseBulkFile();
+    static void ReleaseAllBulkFiles();
+private:
+    uint32  buffersCount_;
+    Logger *logger_;
+    static const uint32 MAX_BUFFERS_COUNT;
+    void PrintF(const char *text, void *pVoid);
+};
+
+#endif // _BUFFER_H_