Added a new spin-wait method. Spins + yields for a system tick and then sleeps a tick.

[SVN r85505]

Author: igaztanaga

Jamfile.v2

@@ -2,4 +2,4 @@ import testing ;
 
 # Tests from Jamfiles in individual library test subdirectories
 build-project example ;   # test-suite interprocess_example
-build-project test ;      # test-suite interprocess_test
+build-project test ;      # test-suite interprocess_test

doc/interprocess.qbk

@@ -6716,7 +6716,8 @@ thank them:
 [section:release_notes_boost_1_55_00 Boost 1.55 Release]
 
 *  Fixed bugs [@https://svn.boost.org/trac/boost/ticket/7164 #7164],
-              [@https://svn.boost.org/trac/boost/ticket/8277 #8277].
+              [@https://svn.boost.org/trac/boost/ticket/8277 #8277],
+              [@https://svn.boost.org/trac/boost/ticket/8277 #9908].
 
 [endsect]
 

include/boost/interprocess/detail/intermodule_singleton_common.hpp

@@ -23,6 +23,7 @@
 #include <boost/interprocess/exceptions.hpp>
 #include <boost/type_traits/type_with_alignment.hpp>
 #include <boost/interprocess/detail/mpl.hpp>
+#include <boost/interprocess/sync/spin/wait.hpp>
 #include <boost/assert.hpp>
 #include <cstddef>
 #include <cstdio>
@@ -145,15 +146,15 @@ class intermodule_singleton_common
          //If previous state was initializing, this means that another winner thread is
          //trying to initialize the singleton. Just wait until completes its work.
          else if(previous_module_singleton_initialized == Initializing){
-            unsigned int k = 0;
+            spin_wait swait;
             while(1){
                previous_module_singleton_initialized = atomic_read32(&this_module_singleton_initialized);
                if(previous_module_singleton_initialized >= Initialized){
                   //Already initialized, or exception thrown by initializer thread
                   break;
                }
                else if(previous_module_singleton_initialized == Initializing){
-                  yield(k++);
+                  swait.yield();
                }
                else{
                   //This can't be happening!
@@ -207,7 +208,7 @@ class intermodule_singleton_common
    static void initialize_global_map_handle()
    {
       //Obtain unique map name and size
-      unsigned k = 0;
+      spin_wait swait;
       while(1){
          //Try to pass map state to initializing
          ::boost::uint32_t tmp = atomic_cas32(&this_module_map_initialized, Initializing, Uninitialized);
@@ -220,7 +221,7 @@ class intermodule_singleton_common
          }
          //If some other thread is doing the work wait
          else if(tmp == Initializing){
-            yield(k++);
+            swait.yield();
          }
          else{ //(tmp == Uninitialized)
             //If not initialized try it again?

include/boost/interprocess/detail/managed_open_or_create_impl.hpp

@@ -25,6 +25,7 @@
 #include <boost/interprocess/permissions.hpp>
 #include <boost/type_traits/alignment_of.hpp>
 #include <boost/type_traits/type_with_alignment.hpp>
+#include <boost/interprocess/sync/spin/wait.hpp>
 #include <boost/move/move.hpp>
 #include <boost/cstdint.hpp>
 
@@ -354,7 +355,7 @@ class managed_open_or_create_impl
          //file and know if we have really created it or just open it
          //drop me a e-mail!
          bool completed = false;
-         unsigned k = 0;
+         spin_wait swait;
          while(!completed){
             try{
                create_device<FileBased>(dev, id, size, perm, file_like_t());
@@ -385,7 +386,7 @@ class managed_open_or_create_impl
             catch(...){
                throw;
             }
-            yield(k++);
+            swait.yield();
          }
       }
 
@@ -432,12 +433,12 @@ class managed_open_or_create_impl
       else{
          if(FileBased){
             offset_t filesize = 0;
-            unsigned k = 0;
+            spin_wait swait;
             while(filesize == 0){
                if(!get_file_size(file_handle_from_mapping_handle(dev.get_mapping_handle()), filesize)){
                   throw interprocess_exception(error_info(system_error_code()));
                }
-               yield(k++);
+               swait.yield();
             }
             if(filesize == 1){
                throw interprocess_exception(error_info(corrupted_error));
@@ -449,9 +450,9 @@ class managed_open_or_create_impl
          boost::uint32_t *patomic_word = static_cast<boost::uint32_t*>(region.get_address());
          boost::uint32_t value = atomic_read32(patomic_word);
 
-         unsigned k = 0;
+         spin_wait swait;
          while(value == InitializingSegment || value == UninitializedSegment){
-            yield(k++);
+            swait.yield();
             value = atomic_read32(patomic_word);
          }