summaryrefslogtreecommitdiff
path: root/src/common/binary-queue.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/common/binary-queue.h')
-rw-r--r--src/common/binary-queue.h96
1 files changed, 96 insertions, 0 deletions
diff --git a/src/common/binary-queue.h b/src/common/binary-queue.h
new file mode 100644
index 0000000..a70c9ec
--- /dev/null
+++ b/src/common/binary-queue.h
@@ -0,0 +1,96 @@
+/*
+ * Copyright (c) 2016 Samsung Electronics Co., Ltd All Rights Reserved
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/*
+ * @file binary-queue.h
+ * @author Przemyslaw Dobrowolski (p.dobrowolsk@samsung.com)
+ * Kyungwook Tak (k.tak@samsung.com)
+ * @version 1.0
+ * @brief This file is the header file of binary queue
+ */
+#pragma once
+
+#include <queue>
+#include <memory>
+#include <cstddef>
+
+#include "common/serialization.h"
+#include "common/types.h"
+
+using namespace CCHECKER::Common;
+
+namespace CCHECKER {
+
+class BinaryQueue : public IStream {
+public:
+ BinaryQueue();
+ virtual ~BinaryQueue();
+
+ BinaryQueue(BinaryQueue &&) = default;
+ BinaryQueue &operator=(BinaryQueue &&) = default;
+ BinaryQueue(const BinaryQueue &) = delete;
+ BinaryQueue &operator=(const BinaryQueue &) = delete;
+
+ RawBuffer pop(void);
+ void push(const RawBuffer &);
+
+ template <typename ...Args>
+ static BinaryQueue Serialize(const Args &...args);
+
+ template <typename ...Args>
+ void Deserialize(Args &...args);
+
+ virtual void read(size_t num, void *bytes) override;
+ virtual void write(size_t num, const void *bytes) override;
+
+private:
+ const static size_t MaxBucketSize = 1024; /* Bytes */
+
+ struct Bucket {
+ explicit Bucket(unsigned char *_data, size_t _size);
+ virtual ~Bucket();
+
+ /* extract ''size'' of bytes from bucket to dest and return updated dest */
+ void *extractTo(void *dest, size_t size);
+
+ Bucket(Bucket &&) = default;
+ Bucket &operator=(Bucket &&) = default;
+ Bucket(const Bucket &) = delete;
+ Bucket &operator=(const Bucket &) = delete;
+
+ unsigned char *data;
+ const unsigned char *cur; // current valid position of data
+ size_t left;
+ };
+
+ std::queue<std::unique_ptr<Bucket>> m_buckets;
+ size_t m_size;
+};
+
+template <typename ...Args>
+BinaryQueue BinaryQueue::Serialize(const Args &...args)
+{
+ BinaryQueue q;
+ Serializer<Args...>::Serialize(q, args...);
+ return q;
+}
+
+template <typename ...Args>
+void BinaryQueue::Deserialize(Args &...args)
+{
+ Deserializer<Args...>::Deserialize(*this, args...);
+}
+
+} // namespace CCHECKER