netInterfaceParallelLock.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2021 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/


#pragma once

#include "vrlinkNetworkInterface/vrlinkNetworkInterfaceDefines.h"
#include <tbb/spin_rw_mutex.h>
#include <string>

namespace makVrf
{
   class DT_DLL_vrlinkNetworkInterface DtNetInterfaceParallelLock
   {
   public:
      DtNetInterfaceParallelLock();

      DtNetInterfaceParallelLock& acquire(const std::string&, tbb::spin_rw_mutex&, bool write = true);

      DtNetInterfaceParallelLock& writeLockAcquire(const std::string&, tbb::spin_rw_mutex&);

      void upgrade_to_writer();
      void downgrade_to_reader();
      void release();

      static void SetUsingParallelPublishing(bool);
      static bool UsingParallelPublishing();

   protected:
      tbb::spin_rw_mutex::scoped_lock myLock;
      static bool theUsingParallelPublishing;
      std::string myArea;
      bool myForceWriteLocked;
   };

   class DT_DLL_vrlinkNetworkInterface DtScopedNetInterfaceParallelLock
   {
   public:
      DtScopedNetInterfaceParallelLock(DtNetInterfaceParallelLock& lock);
      virtual ~DtScopedNetInterfaceParallelLock();

      void acquire(tbb::spin_rw_mutex&, bool write = true);
      void upgrade_to_writer();
      void downgrade_to_reader();
      void release();

   protected:
      DtNetInterfaceParallelLock& myLock;
      bool myReleased;
   };
}

#include "vrlinkNetworkInterface/netInterfaceParallelLock.inl"