Implementation of mechanisms for synchronisation of memory access at the knowledge level

.github/workflows/release.yml

@@ -71,7 +71,7 @@ jobs:
 
       - name: Install compilers (macOS)
         if: runner.os == 'macOS'
-        run: brew install cmake ninja ccache
+        run: brew install ninja ccache
 
       - name: Set Conan remote
         run: |

.gitignore

@@ -6,6 +6,7 @@ generated
 cmake-build-debug
 cmake-build-release
 cmake-build-debug-coverage
+cmake-build-*
 /CMakeUserPresets.json
 /ConanPresets.json
 
@@ -43,3 +44,14 @@ __pycache__
 *.log
 *.pdf
 *.run.xml
+
+CMakeCache.txt
+CMakeFiles/
+CPackConfig.cmake
+CPackSourceConfig.cmake
+CTestTestfile.cmake
+DartConfiguration.tcl
+Makefile
+cmake_install.cmake
+*.cmake
+*.tcl

sc-memory/sc-core/src/sc-store/sc-base/sc_thread.c

@@ -0,0 +1,35 @@
+/*
+ * This source file is part of an OSTIS project. For the latest info, see http://ostis.net
+ * Distributed under the MIT License
+ * (See accompanying file COPYING.MIT or copy at http://opensource.org/licenses/MIT)
+ */
+
+#include "sc_thread.h"
+
+#include "sc-core/sc_types.h"
+
+sc_thread * sc_thread_new(sc_thread_name * name, sc_thread_func func, sc_thread_data data)
+{
+  return g_thread_new(name, func, data);
+}
+
+void sc_thread_join(sc_thread * thread)
+{
+  if (thread != null_ptr)
+  {
+    g_thread_join(thread);
+  }
+}
+
+void sc_thread_unref(sc_thread * thread)
+{
+  if (thread != null_ptr)
+  {
+    g_thread_unref(thread);
+  }
+}
+
+void sc_thread_sleep(sc_uint32 milliseconds)
+{
+  g_usleep((gulong)milliseconds * 1000);
+}

sc-memory/sc-core/src/sc-store/sc-base/sc_thread.h

@@ -7,10 +7,20 @@
 #ifndef _sc_thread_h_
 #define _sc_thread_h_
 
+#include "sc-core/sc_types.h"
+
 #include <glib.h>
 
 typedef GThread sc_thread;
+typedef gpointer sc_thread_data;
+typedef gpointer (*sc_thread_func)(sc_thread_data);
+typedef gchar const sc_thread_name;
 
 #define sc_thread_self g_thread_self
 
+sc_thread * sc_thread_new(sc_thread_name * name, sc_thread_func func, sc_thread_data data);
+void sc_thread_join(sc_thread * thread);
+void sc_thread_unref(sc_thread * thread);
+void sc_thread_sleep(sc_uint32 milliseconds);
+
 #endif

sc-memory/sc-core/src/sc-store/sc-transaction/sc_element_version.c

@@ -0,0 +1,31 @@
+#include "sc_element_version.h"
+
+#include "sc-store/sc_version_segment.h"
+
+#include <sc-core/sc-base/sc_allocator.h>
+
+sc_element_data * sc_element_data_new()
+{
+  return sc_mem_new(sc_element_data, 1);
+}
+
+sc_element_version * sc_element_create_new_version(
+    sc_element const * element,
+    sc_element_data const * new_element_data,
+    sc_uint64 const transaction_id)
+{
+  if (new_element_data == null_ptr)
+    return null_ptr;
+
+  sc_element_version * new_version = sc_mem_new(sc_element_version, 1);
+  if (new_version == null_ptr)
+    return null_ptr;
+
+  new_version->data = new_element_data;
+  new_version->transaction_id = transaction_id;
+  new_version->version_id = sc_version_segment_get_next_version_id(element);
+  new_version->parent_version = element->version_history->current_version;
+  new_version->is_committed = SC_FALSE;
+
+  return new_version;
+}

sc-memory/sc-core/src/sc-store/sc-transaction/sc_element_version.h

@@ -0,0 +1,39 @@
+#ifndef SC_ELEMENT_VERSION_H
+#define SC_ELEMENT_VERSION_H
+
+#include "sc-core/sc_types.h"
+#include "sc-store/sc_element.h"
+
+typedef struct sc_element_data
+{
+  sc_element_flags flags;
+
+  sc_addr first_out_arc;
+  sc_addr first_in_arc;
+#ifdef SC_OPTIMIZE_SEARCHING_INCOMING_CONNECTORS_FROM_STRUCTURES
+  sc_addr first_in_arc_from_structure;
+#endif
+
+  sc_arc_info arc;
+
+  sc_uint32 incoming_arcs_count;
+  sc_uint32 outgoing_arcs_count;
+} sc_element_data;
+
+sc_element_data * sc_element_data_new();
+
+typedef struct sc_element_version
+{
+  sc_element_data const * data;
+  sc_uint64 version_id;
+  sc_uint64 transaction_id;
+  struct sc_element_version * parent_version;
+  sc_bool is_committed;  // redundant?
+} sc_element_version;
+
+sc_element_version * sc_element_create_new_version(
+    sc_element const * element,
+    sc_element_data const * new_element_data,
+    sc_uint64 transaction_id);
+
+#endif