prj/tech/libsrc/comtools/comconn.cpp

   1 ///////////////////////////////////////////////////////////////////////////////
   2 // $Source: x:/prj/tech/libsrc/comtools/RCS/comconn.cpp $
   3 // $Author: TOML $
   4 // $Date: 1996/10/10 14:31:26 $
   5 // $Revision: 1.2 $
   6 //
   7
   8 #include <lg.h>
   9 #include <comtools.h>
  10 #include <comconn.h>
  11
  12 ///////////////////////////////////////////////////////////////////////////////
  13
  14 int LGAPI GetCOMConnectionPriority(const void * p)
  15     {
  16     return ((sCOMConnection *)p)->priority;
  17     }
  18
  19 ///////////////////////////////////////////////////////////////////////////////
  20
  21 BOOL cCOMConnectionSetBase::Search(IUnknown * p)
  22     {
  23     // Because these lists never get very long, and because
  24     // insertion/removal is an uncommon event relative
  25     // to iteration, we simply use a linear search
  26     for (index_t i = 0; i < m_Connections.Size(); i++)
  27         {
  28         if (m_Connections[i].pSink == p)
  29             return TRUE;
  30         }
  31     return FALSE;
  32     }
  33
  34 ///////////////////////////////////////
  35
  36 BOOL cCOMConnectionSetBase::Insert(IUnknown * p, DWORD * pCookie)
  37     {
  38     if (Search(p))
  39         {
  40         CriticalMsg("Multiple connection point advises are not permitted");
  41         return FALSE;
  42         }
  43
  44     sCOMConnection connection;
  45     connection.pSink = p;
  46     connection.priority = 0;
  47     m_Connections.Append(connection);
  48
  49     p->AddRef();
  50     *pCookie = DWORD(p);
  51
  52     return TRUE;
  53     }
  54
  55 ///////////////////////////////////////
  56
  57 BOOL cCOMConnectionSetBase::Insert(IUnknown * p, int priority, DWORD * pCookie)
  58     {
  59     if (Search(p))
  60         {
  61         CriticalMsg("Multiple connection point advises are not permitted");
  62         return FALSE;
  63         }
  64
  65     m_fPrioritized = TRUE;
  66     m_fSorted = FALSE;
  67
  68     sCOMConnection connection;
  69     connection.pSink = p;
  70     connection.priority = priority;
  71     m_Connections.Append(connection);
  72
  73     p->AddRef();
  74     *pCookie = DWORD(p);
  75
  76     return TRUE;
  77     }
  78
  79 ///////////////////////////////////////
  80
  81 BOOL cCOMConnectionSetBase::Remove(DWORD cookie)
  82     {
  83     IUnknown * p = (IUnknown *) cookie;
  84     for (index_t i = 0; i < m_Connections.Size(); i++)
  85         {
  86         if (m_Connections[i].pSink == p)
  87             {
  88             m_Connections.DeleteItem(i);
  89             p->Release();
  90             return TRUE;
  91             }
  92         }
  93     CriticalMsg("Unknown notification sink");
  94     return FALSE;
  95     }
  96
  97 ///////////////////////////////////////
  98
  99 IUnknown * cCOMConnectionSetBase::GetFirst(tConnSetHandle & hIndex)
 100     {
 101     if (m_Connections.Size())
 102         {
 103         if (m_fPrioritized && !m_fSorted)
 104             {
 105             m_Connections.Sort();
 106             }
 107         hIndex = (tConnSetHandle)0;
 108         return m_Connections[(index_t)0].pSink;
 109         }
 110     return NULL;
 111     }
 112
 113 ///////////////////////////////////////
 114
 115 IUnknown * cCOMConnectionSetBase::GetNext(tConnSetHandle & hIndex)
 116     {
 117     const index_t index = (index_t)hIndex + 1;
 118     if (index < m_Connections.Size())
 119         {
 120         hIndex = (tConnSetHandle)index;
 121         return m_Connections[index].pSink;
 122         }
 123     return NULL;
 124     }
 125
 126 ///////////////////////////////////////