SequencerLite -> experimental::Sequencer

Signed-off-by: Denis Mindolin <[email protected]>

Author: demin80

quantum/quantum.h

@@ -80,8 +80,8 @@
 #include <quantum/util/quantum_sequence_key_statistics.h>
 #include <quantum/util/quantum_sequencer.h>
 #include <quantum/util/quantum_sequencer_configuration.h>
-#include <quantum/util/quantum_sequencer_lite.h>
-#include <quantum/util/quantum_sequencer_lite_configuration.h>
+#include <quantum/util/quantum_sequencer_experimental.h>
+#include <quantum/util/quantum_sequencer_configuration_experimental.h>
 #include <quantum/util/quantum_spinlock_util.h>
 #include <quantum/util/quantum_util.h>
 

…ntum_sequencer_configuration_base_impl.h …uencer_configuration_experimental_impl.hquantum/util/impl/quantum_sequencer_configuration_base_impl.h renamed to quantum/util/impl/quantum_sequencer_configuration_experimental_impl.h quantum/util/impl/quantum_sequencer_configuration_base_impl.h renamed to quantum/util/impl/quantum_sequencer_configuration_experimental_impl.h

@@ -21,73 +21,107 @@
 
 #include <quantum/util/quantum_sequence_key_statistics.h>
 #include <quantum/interface/quantum_icoro_context_base.h>
+#include <list>
+#include <vector>
+#include <atomic>
+#include <memory>
 
 namespace Bloomberg {
 namespace quantum {
+namespace experimental {
+
+inline const std::string&
+SequencerConfigurationSchemaProvider::getJsonSchema()
+{
+    static std::string schema = R"JSON(
+    {
+        "$schema" : "http://json-schema.org/draft-04/schema#",
+        "$id" : "bloomberg:sequencer.quantum.json",
+        "title": "Quantum sequencer settings",
+        "type": "object",
+        "properties": {
+            "bucketCount": {
+                "type": "number",
+                "default": 100
+            }
+        },
+        "additionalProperties": false,
+        "required": []
+    }
+    )JSON";
+    return schema;
+}
+
+inline const std::string&
+SequencerConfigurationSchemaProvider::getJsonSchemaUri()
+{
+    static std::string uri = "bloomberg:sequencer.quantum.json";
+    return uri;
+}
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::setBucketCount(size_t bucketCount)
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setBucketCount(size_t bucketCount)
 {
     _bucketCount = bucketCount;
     return *this;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
 size_t
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::getBucketCount() const
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getBucketCount() const
 {
     return _bucketCount;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::setHash(const Hash& hash)
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setHash(const Hash& hash)
 {
     _hash = hash;
     return *this;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
 const Hash&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::getHash() const
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getHash() const
 {
     return _hash;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::setKeyEqual(const KeyEqual& keyEqual)
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setKeyEqual(const KeyEqual& keyEqual)
 {
     _keyEqual = keyEqual;
     return *this;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
 const KeyEqual&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::getKeyEqual() const
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getKeyEqual() const
 {
     return _keyEqual;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::setAllocator(const Allocator& allocator)
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setAllocator(const Allocator& allocator)
 {
     _allocator = allocator;
     return *this;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
 const Allocator&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::getAllocator() const
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getAllocator() const
 {
     return _allocator;
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::setExceptionCallback(
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setExceptionCallback(
     const ExceptionCallback&
     exceptionCallback)
 
@@ -97,10 +131,10 @@ SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::setException
 }
 
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
-const typename SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::ExceptionCallback&
-SequencerConfigurationBase<SequenceKey, Hash, KeyEqual, Allocator>::getExceptionCallback() const
+const typename SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::ExceptionCallback&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getExceptionCallback() const
 {
     return _exceptionCallback;
 }
 
-}}
+}}}

quantum/util/impl/quantum_sequencer_configuration_impl.h

@@ -68,6 +68,84 @@ SequencerConfigurationSchemaProvider::getJsonSchemaUri()
     return uri;
 }
 
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setBucketCount(size_t bucketCount)
+{
+    _bucketCount = bucketCount;
+    return *this;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+size_t
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getBucketCount() const
+{
+    return _bucketCount;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setHash(const Hash& hash)
+{
+    _hash = hash;
+    return *this;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+const Hash&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getHash() const
+{
+    return _hash;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setKeyEqual(const KeyEqual& keyEqual)
+{
+    _keyEqual = keyEqual;
+    return *this;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+const KeyEqual&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getKeyEqual() const
+{
+    return _keyEqual;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setAllocator(const Allocator& allocator)
+{
+    _allocator = allocator;
+    return *this;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+const Allocator&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getAllocator() const
+{
+    return _allocator;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setExceptionCallback(
+    const ExceptionCallback&
+    exceptionCallback)
+
+{
+    _exceptionCallback = exceptionCallback;
+    return *this;
+}
+
+template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
+const typename SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::ExceptionCallback&
+SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::getExceptionCallback() const
+{
+    return _exceptionCallback;
+}
+
 template <class SequenceKey, class Hash, class KeyEqual, class Allocator>
 SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>&
 SequencerConfiguration<SequenceKey, Hash, KeyEqual, Allocator>::setControlQueueId(int controlQueueId)