User: bobclark
Date: 03/01/23 12:38:26

Modified
 /common/system/
  pq.cpp
 /common/system/pub/
  pq.h

Log
 better thread safety in queues

File Changes:

Directory: /common/system/
==========================

File [changed]: pq.cpp
Url: https://common.helixcommunity.org/source/browse/common/system/pq.cpp.diff?r1=1.1.1.1&r2=1.2
Delta lines:  +1 -0
-------------------
--- pq.cpp	18 Oct 2002 01:45:09 -0000	1.1.1.1
+++ pq.cpp	23 Jan 2003 20:38:26 -0000	1.2
@@ -149,6 +149,7 @@
 
     pCallback->AddRef();
     i->m_pCallback  = pCallback;
+    i->m_bRemoved = 0;
 
 #ifdef SMP_PQ_DEBUG
     if (pCallback < 0x8000)

Directory: /common/system/pub/
==============================

File [changed]: pq.h
Url: https://common.helixcommunity.org/source/browse/common/system/pub/pq.h.diff?r1=1.1.1.1&r2=1.2
Delta lines:  +3 -2
-------------------
--- pq.h	18 Oct 2002 01:45:09 -0000	1.1.1.1
+++ pq.h	23 Jan 2003 20:38:26 -0000	1.2
@@ -62,7 +62,7 @@
 {
 public:
     FAST_CACHE_MEM
-    PQElem() : m_pCallback(0), m_pNext(0), m_bDefunct(0), m_Id(0)
+    PQElem() : m_pCallback(0), m_pNext(0), m_bDefunct(0), m_Id(0), m_bRemoved(0)
     {
 	m_Time.tv_sec   = 0;
 	m_Time.tv_usec  = 0;
@@ -71,6 +71,7 @@
     PQElem*	    	m_pNext;
     Timeval	    	m_Time;
     BOOL	    	m_bDefunct;
+    BOOL	    	m_bRemoved;
     UINT32		m_Id;
 };
 
@@ -103,7 +104,7 @@
     virtual void	free_mem() { }
 
     virtual void	remove(UINT32 handle);
-    BOOL		removeifexists(UINT32 handle);
+    virtual BOOL	removeifexists(UINT32 handle);
 
     int		empty() { return m_lElementCount == 0; }
     int		immediate() { return (!empty()) && (m_HeadTime.tv_sec == 0 && m_HeadTime.tv_usec == 0); }




---------------------------------------------------------------------
To unsubscribe, e-mail: cvs-unsubscribe at common.helixcommunity.org
For additional commands, e-mail: cvs-help at common.helixcommunity.org