synchronously and immediate shutdown

Adapter.cc

@@ -36,17 +36,25 @@ namespace pEp {
         notifyHandshake_t _notifyHandshake = nullptr;
         std::thread *_sync_thread = nullptr;
 
-        ::utility::locked_queue< SYNC_EVENT > q;
+        ::utility::locked_queue< SYNC_EVENT, ::free_Sync_event > q;
         std::mutex m;
 
         int _inject_sync_event(SYNC_EVENT ev, void *management)
         {
             try {
-                q.push_front(ev);
+                if (ev == nullptr)
+                    q.push_back(ev);
+                else
+                    q.push_front(ev);
             }
             catch (exception&) {
                 return 1;
             }
+            if (ev == nullptr) {
+                if (_sync_thread)
+                    _sync_thread->join();
+                q.clear();
+            }
             return 0;
         }
 
@@ -103,7 +111,6 @@ namespace pEp {
         {
             if (_sync_thread) {
                 _inject_sync_event(nullptr, nullptr);
-                _sync_thread->join();
                 delete _sync_thread;
                 _sync_thread = nullptr;
             }

Adapter.hxx

@@ -12,7 +12,7 @@ namespace pEp {
         extern notifyHandshake_t _notifyHandshake;
         extern std::thread *_sync_thread;
 
-        extern ::utility::locked_queue< SYNC_EVENT > q;
+        extern ::utility::locked_queue< SYNC_EVENT, ::free_Sync_event > q;
         extern std::mutex m;
 
         SYNC_EVENT _retrieve_next_sync_event(void *management, unsigned threshold);