summaryrefslogtreecommitdiff
path: root/src/common/binary-queue.h
diff options
context:
space:
mode:
authorsangwan.kwon <sangwan.kwon@samsung.com>2016-04-04 13:24:17 +0900
committersangwan.kwon <sangwan.kwon@samsung.com>2016-05-11 10:46:37 +0900
commit0e0c941196c0dc23eee6247a5182f6851e45ff48 (patch)
tree26b1c19e09d8b3f3239ac94bfdcacd7f8f49405e /src/common/binary-queue.h
parente05626bc306e8cf9d57604fd1e8b9d540b68e6cd (diff)
downloadcert-checker-ref/for/tizen.tar.gz
cert-checker-ref/for/tizen.tar.bz2
cert-checker-ref/for/tizen.zip
Implement on-demand style about server-sideref/for/tizen
[AS-IS] * cert-checker was daemon. [TO-BE] * Change to on-demand style. * cert-svc call cert-checker. * Add common library. Change-Id: Idab160e6103cf62299b97a5485a767de9831d614 Signed-off-by: sangwan.kwon <sangwan.kwon@samsung.com>
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