Merge branch 'development' of https://github.com/siemens/embb into development

334832ca · Tobias Schuele · 4e6473e9 · cd283998 · 334832ca · 334832ca
Commit 334832ca authored Oct 07, 2014 by Tobias Schuele
20 changed files
--- a/CMakeCommon/CreateDoxygenDocumentationTarget.cmake
+++ b/CMakeCommon/CreateDoxygenDocumentationTarget.cmake
@@ -40,6 +40,11 @@ function (CreateDoxygenDocumentationTarget)
    if (TARGET doxygen)
      # Do nothing, since the repeated adding causes an error
    else()
+      set(DOXYGEN_TEMPLATE_FILES
+      "doc/reference/header.html")
+      file(COPY ${DOXYGEN_TEMPLATE_FILES} DESTINATION ${PROJECT_BINARY_DIR})
      add_custom_target (
        doxygen 
        #ALL

--- a/CMakeCommon/SetInstallPaths.cmake
+++ b/CMakeCommon/SetInstallPaths.cmake
@@ -33,7 +33,7 @@ function(SetInstallPaths)
    # Default install path is in build directory.
    if (DEFINED UNIX)
      set(CMAKE_INSTALL_PREFIX "/usr/local")
-      set(INSTALL_PREFIX_DOCS "/usr/local/share/doc/${CMAKE_PROJECT_NAME}-${EMBB_BASE_VERSION_MAJOR}.${EMBB_BASE_VERSION_MINOR}")
+      set(INSTALL_PREFIX_DOCS "/usr/local/share/doc/${CMAKE_PROJECT_NAME}-${EMBB_BASE_VERSION_MAJOR}.${EMBB_BASE_VERSION_MINOR}.${EMBB_BASE_VERSION_PATCH}")
    else()
      file(TO_CMAKE_PATH "$ENV{ProgramFiles}" _PROG_FILES) # 32-bit dir on win32, useless to us on win64
      file(TO_CMAKE_PATH "$ENV{ProgramFiles(x86)}" _PROG_FILES_X86) # 32-bit dir: only set on win64

--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -135,8 +135,11 @@ SetInstallPaths()
 ## DOXYGEN 
 #
-include(CMakeCommon/CreateDoxygenDocumentationTarget.cmake)
+if(EXISTS "${EMBB_SOURCE_DIR}/doc/reference/Doxyfile.in")
-CreateDoxygenDocumentationTarget()
+  include(CMakeCommon/CreateDoxygenDocumentationTarget.cmake)
+  CreateDoxygenDocumentationTarget()
+endif()
 if (INSTALL_DOCS STREQUAL ON)
  install(DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}/doc/

--- a/README.txt
+++ b/README.txt
--- a/base_c/src/core_set.c
+++ b/base_c/src/core_set.c
@@ -94,12 +94,22 @@ void embb_core_set_init(embb_core_set_t* core_set, int initializer) {
 #ifdef EMBB_HAS_HEADER_SYSINFO
 #include <sys/sysinfo.h>
 #endif
+#ifdef __FreeBSD__
+#include <sys/types.h>
+#include <sys/sysctl.h>
+#endif
 unsigned int embb_core_count_available() {
 #ifdef EMBB_HAS_HEADER_SYSINFO
  return get_nprocs();
+#elif defined __FreeBSD__
+  const size_t bs = sizeof(unsigned int);
+  char buf[bs];
+  size_t len = bs;
+  sysctlbyname("hw.ncpu", buf, &len, NULL, 0);
+  return *(unsigned int*)&buf;
 #else
-#error "No header sysinfo available!"
+#error "No implementation for embb_core_count_available()!"
 #endif
 }

--- a/base_c/src/memory_allocation.c
+++ b/base_c/src/memory_allocation.c
@@ -28,7 +28,7 @@
 #include <embb/base/c/internal/config.h>
 #include <embb/base/c/atomic.h>
 #include <embb/base/c/internal/unused.h>
-#include <malloc.h>
+#include <stdlib.h>
 #include <assert.h>
 #ifdef EMBB_DEBUG

--- a/containers_cpp/include/embb/containers/internal/hazard_pointer-inl.h
+++ b/containers_cpp/include/embb/containers/internal/hazard_pointer-inl.h
@@ -144,9 +144,18 @@ template< typename GuardType >
 HazardPointerThreadEntry<GuardType>::
 HazardPointerThreadEntry(GuardType undefined_guard, int guards_per_thread,
  size_t max_size_retired_list) :
+#ifdef EMBB_DEBUG
+  who_is_scanning(-1),
+#endif
  undefined_guard(undefined_guard),
  guards_per_thread(guards_per_thread),
  max_size_retired_list(max_size_retired_list),
+  // initially, each potential thread is active... if that is not the case
+  // another thread could call "HelpScan", and block this thread in making 
+  // progress.
+  // Still, threads can be leave the hazard pointer processing (deactivation),
+  // but this can only be done once, i.e., this is not revertable...
+  is_active(1),
  retired_list(max_size_retired_list),
  retired_list_temp(max_size_retired_list),
  hazard_pointer_list_temp(embb::base::Thread::GetThreadsMaxCount() *
@@ -231,16 +240,6 @@ HazardPointer< GuardType >::GetHazardPointerElementForCurrentThread() {
  // stop operating, and the others are responsible for his retired
  // list.
-  // int expected = false;
-  HazardPointerThreadEntry_t* current_thread_entry =
-    &hazard_pointer_thread_entry_array[GetCurrentThreadIndex()];
-  // If not active, activate it
-  if (!current_thread_entry->IsActive()) {
-    current_thread_entry->SetActive(true);
-    active_hazard_pointer++;
-  }
  return hazard_pointer_thread_entry_array[GetCurrentThreadIndex()];
 }
@@ -270,6 +269,16 @@ void HazardPointer< GuardType >::HelpScan() {
 template< typename GuardType >
 void HazardPointer< GuardType >::
 Scan(HazardPointerThreadEntry_t* currentHazardPointerEntry) {
+#ifdef EMBB_DEBUG
+  // scan should only be executed by one thread at a time, otherwise we have
+  // a bug... this assertions checks that
+  int expected = -1;
+  if (!currentHazardPointerEntry->GetScanningThread().CompareAndSwap(
+    expected, GetCurrentThreadIndex()))
+  {
+    assert(false);
+  }
+#endif
  // In this function, we compute the intersection between local retired
  // pointers and all hazard pointers. This intersection cannot be deleted and
  // forms the new local retired pointers list.
@@ -320,6 +329,10 @@ Scan(HazardPointerThreadEntry_t* currentHazardPointerEntry) {
  }
  currentHazardPointerEntry->SetRetired(
    currentHazardPointerEntry->GetRetiredTemp());
+#ifdef EMBB_DEBUG
+  currentHazardPointerEntry->GetScanningThread().Store(-1);
+#endif
 }
 template< typename GuardType >
@@ -335,7 +348,8 @@ HazardPointer< GuardType >::HazardPointer(
  GuardType undefined_guard, int guards_per_thread) :
  undefined_guard(undefined_guard),
  guards_per_thread(guards_per_thread),
-  active_hazard_pointer(0),
+  //initially, all potential hazard pointers are active...
+  active_hazard_pointer(embb::base::Thread::GetThreadsMaxCount()),
  free_guard_callback(free_guard_callback) {
  hazard_pointers = embb::base::Thread::GetThreadsMaxCount();
@@ -388,6 +402,7 @@ void HazardPointer< GuardType >::EnqueuePointerForDeletion(
  if (IsThresholdExceeded()) {
    HazardPointerThreadEntry_t* currentHazardPointerEntry =
      &GetHazardPointerElementForCurrentThread();
    Scan(currentHazardPointerEntry);
    // Help deactivated threads to clean their retired nodes.

--- a/containers_cpp/include/embb/containers/internal/hazard_pointer.h
+++ b/containers_cpp/include/embb/containers/internal/hazard_pointer.h
@@ -169,6 +169,16 @@ class FixedSizeList {
 */
 template< typename GuardType >
 class HazardPointerThreadEntry {
+#ifdef EMBB_DEBUG
+  public:
+    embb::base::Atomic<int>& GetScanningThread()
+    {
+      return who_is_scanning;
+    }
+  private:
+    embb::base::Atomic<int> who_is_scanning;
+#endif
  private:
   /**
    * Value of the undefined guard (means that no guard is set).

--- a/dataflow_cpp/include/embb/dataflow/internal/select.h
+++ b/dataflow_cpp/include/embb/dataflow/internal/select.h
@@ -27,6 +27,7 @@
 #ifndef EMBB_DATAFLOW_INTERNAL_SELECT_H_
 #define EMBB_DATAFLOW_INTERNAL_SELECT_H_
+#include <embb/dataflow/internal/action.h>
 #include <embb/dataflow/internal/signal.h>
 #include <embb/dataflow/internal/node.h>
 #include <embb/dataflow/internal/inputs.h>

--- a/dataflow_cpp/include/embb/dataflow/internal/switch.h
+++ b/dataflow_cpp/include/embb/dataflow/internal/switch.h
@@ -27,6 +27,7 @@
 #ifndef EMBB_DATAFLOW_INTERNAL_SWITCH_H_
 #define EMBB_DATAFLOW_INTERNAL_SWITCH_H_
+#include <embb/dataflow/internal/action.h>
 #include <embb/dataflow/internal/signal.h>
 #include <embb/dataflow/internal/node.h>
 #include <embb/dataflow/internal/inputs.h>

--- a/doc/reference/Doxyfile.in
+++ b/doc/reference/Doxyfile.in
@@ -205,7 +205,7 @@ IGNORE_PREFIX          = cm
 GENERATE_HTML          = YES
 HTML_OUTPUT            = html
 HTML_FILE_EXTENSION    = .html
-HTML_HEADER            = 
+HTML_HEADER            = header.html 
 HTML_FOOTER            = 
 HTML_STYLESHEET        = 
 HTML_EXTRA_STYLESHEET  = @CMAKE_SOURCE_DIR@/doc/reference/DoxygenHTMLStyle.css

--- a/doc/reference/header.html
+++ b/doc/reference/header.html
+<!-- HTML header for doxygen 1.8.6-->
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml">
+<head>
+<meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/>
+<meta http-equiv="X-UA-Compatible" content="IE=9"/>
+<meta name="generator" content="Doxygen $doxygenversion"/>
+<!--BEGIN PROJECT_NAME--><title>$projectname: $title</title><!--END PROJECT_NAME-->
+<!--BEGIN !PROJECT_NAME--><title>$title</title><!--END !PROJECT_NAME-->
+<link href="$relpath^tabs.css" rel="stylesheet" type="text/css"/>
+<script type="text/javascript" src="$relpath^jquery.js"></script>
+<script type="text/javascript" src="$relpath^dynsections.js"></script>
+<script type="text/javascript">
+var is_modules_page = location.pathname.match(".*modules.html");
+$(document).ready(function() { if (toggleLevel && is_modules_page) toggleLevel(2); });
+</script>
+$treeview
+$search
+$mathjax
+<link href="$relpath^$stylesheet" rel="stylesheet" type="text/css" />
+$extrastylesheet
+</head>
+<body>
+<div id="top"><!-- do not remove this div, it is closed by doxygen! -->
+<!--BEGIN TITLEAREA-->
+<div id="titlearea">
+<table cellspacing="0" cellpadding="0">
+ <tbody>
+ <tr style="height: 56px;">
+  <!--BEGIN PROJECT_LOGO-->
+  <td id="projectlogo"><img alt="Logo" src="$relpath^$projectlogo"/></td>
+  <!--END PROJECT_LOGO-->
+  <!--BEGIN PROJECT_NAME-->
+  <td style="padding-left: 0.5em;">
+   <div id="projectname">$projectname
+   <!--BEGIN PROJECT_NUMBER-->&#160;<span id="projectnumber">$projectnumber</span><!--END PROJECT_NUMBER-->
+   </div>
+   <!--BEGIN PROJECT_BRIEF--><div id="projectbrief">$projectbrief</div><!--END PROJECT_BRIEF-->
+  </td>
+  <!--END PROJECT_NAME-->
+  <!--BEGIN !PROJECT_NAME-->
+   <!--BEGIN PROJECT_BRIEF-->
+    <td style="padding-left: 0.5em;">
+    <div id="projectbrief">$projectbrief</div>
+    </td>
+   <!--END PROJECT_BRIEF-->
+  <!--END !PROJECT_NAME-->
+  <!--BEGIN DISABLE_INDEX-->
+   <!--BEGIN SEARCHENGINE-->
+   <td>$searchbox</td>
+   <!--END SEARCHENGINE-->
+  <!--END DISABLE_INDEX-->
+ </tr>
+ </tbody>
+</table>
+</div>
+<!--END TITLEAREA-->
+<!-- end header part -->
--- a/mtapi_c/src/embb_mtapi_id_pool_t.c
+++ b/mtapi_c/src/embb_mtapi_id_pool_t.c
@@ -42,7 +42,7 @@ void embb_mtapi_id_pool_initialize(
  for (ii = 1; ii < capacity; ii++) {
    that->id_buffer[ii] = ii;
  }
-  that->ids_availabe = capacity - 1;
+  that->ids_available = capacity - 1;
  that->put_id_position = 0;
  that->get_id_position = 1;
  embb_mtapi_spinlock_initialize(&that->lock);
@@ -50,7 +50,7 @@ void embb_mtapi_id_pool_initialize(
 void embb_mtapi_id_pool_finalize(embb_mtapi_id_pool_t * that) {
  that->capacity = 0;
-  that->ids_availabe = 0;
+  that->ids_available = 0;
  that->get_id_position = 0;
  that->put_id_position = 0;
  embb_mtapi_alloc_deallocate(that->id_buffer);
@@ -64,9 +64,9 @@ mtapi_uint_t embb_mtapi_id_pool_allocate(embb_mtapi_id_pool_t * that) {
  assert(MTAPI_NULL != that);
  if (embb_mtapi_spinlock_acquire(&that->lock)) {
-    if (0 < that->ids_availabe) {
+    if (0 < that->ids_available) {
      /* take away one id */
-      that->ids_availabe--;
+      that->ids_available--;
      /* acquire position to fetch id from */
      mtapi_uint_t id_position = that->get_id_position;
@@ -93,7 +93,7 @@ void embb_mtapi_id_pool_deallocate(
  assert(MTAPI_NULL != that);
  if (embb_mtapi_spinlock_acquire(&that->lock)) {
-    if (that->capacity > that->ids_availabe) {
+    if (that->capacity > that->ids_available) {
      /* acquire position to put id to */
      mtapi_uint_t id_position = that->put_id_position;
      that->put_id_position++;
@@ -105,7 +105,7 @@ void embb_mtapi_id_pool_deallocate(
      that->id_buffer[id_position] = id;
      /* make it available */
-      that->ids_availabe++;
+      that->ids_available++;
    }
    embb_mtapi_spinlock_release(&that->lock);
  } else {

--- a/mtapi_c/src/embb_mtapi_id_pool_t.h
+++ b/mtapi_c/src/embb_mtapi_id_pool_t.h
@@ -48,7 +48,7 @@ extern "C" {
 struct embb_mtapi_id_pool_struct {
  mtapi_uint_t capacity;
  mtapi_uint_t *id_buffer;
-  mtapi_uint_t ids_availabe;
+  mtapi_uint_t ids_available;
  mtapi_uint_t get_id_position;
  mtapi_uint_t put_id_position;
  embb_mtapi_spinlock_t lock;

--- a/scripts/create_tarball.sh
+++ b/scripts/create_tarball.sh
@@ -140,6 +140,11 @@ rsync \
 --exclude "doc/tutorial/content" \
 --exclude "doc/tutorial/*.tex" \
 --exclude "doc/tutorial/*.bib" \
+ --exclude "doc/reference/*.xml" \
+ --exclude "doc/reference/*.dox" \
+ --exclude "doc/reference/*.in" \
+ --exclude "doc/reference/header.html" \
+ --exclude "doc/reference/*.css" \
 --exclude "doc/examples/insert_snippets.py" \
 --archive --recursive ${d} $MYTMPDIR/${n}

--- a/scripts/insert_license.sh
+++ b/scripts/insert_license.sh
--- a/scripts/remove_license.sh
+++ b/scripts/remove_license.sh
--- a/scripts/run_cpplint.sh
+++ b/scripts/run_cpplint.sh
--- a/scripts/run_tests_cygwin.sh
+++ b/scripts/run_tests_cygwin.sh
--- a/scripts/run_tests_linux.sh
+++ b/scripts/run_tests_linux.sh