OPC сервер: описать интерфейс IConnectionPointContainer - C# - Ответ 2958506

#region **** _________________IConnectionPointContainer________________ ****
        public void EnumConnectionPoints( out IEnumConnectionPoints ppEnum )
        {
            throw new NotImplementedException();
        }
 
        public void FindConnectionPoint( ref Guid riid, out IConnectionPoint ppCP )
        {
            throw new NotImplementedException();
        }
        #endregion

/// <summary>
    /// Class used to identify a source of events of type SinkType.
    /// </summary>
    [ComVisible(false)]
    public interface IEventSource<SinkType>
        where SinkType : class
    {
        void OnSinkAdded(SinkType sink);
        void OnSinkRemoved(SinkType sink);
    }
 
    [ComVisible( true )]
    public class ConnectionPointContainer : IConnectionPointContainer
    {
        private Dictionary<Guid, IConnectionPoint> connectionPoints;
        public ConnectionPointContainer()
        {
            connectionPoints = new Dictionary<Guid, IConnectionPoint>();
        }
        public void AddEventSource<SinkType>( IEventSource<SinkType> source )
            where SinkType : class
        {
            if (null == source)
                throw new ArgumentNullException( "source" );
            if (connectionPoints.ContainsKey( typeof( SinkType ).GUID ))
                throw new ArgumentException( "EventSource guid already added to the list of connection points", "source" );
            connectionPoints.Add( typeof( SinkType ).GUID, new ConnectionPoint<SinkType>( this, source ) );
        }
 
        #region IConnectionPointContainer Members
        void IConnectionPointContainer.EnumConnectionPoints( out IEnumConnectionPoints ppEnum )
        {
            throw new NotImplementedException(); ;
        }
        void IConnectionPointContainer.FindConnectionPoint( ref Guid riid, out IConnectionPoint ppCP )
        {
            ppCP = connectionPoints[riid];
        }
        #endregion
    }
 
    public class ConnectionPoint<SinkType> : IConnectionPoint
        where SinkType : class
    {
        Dictionary<int, SinkType> sinks;
        private int nextCookie;
        private ConnectionPointContainer container;
        private IEventSource<SinkType> source;
        public ConnectionPoint(ConnectionPointContainer container, IEventSource<SinkType> source)
        {
            if(null == container)
                throw new ArgumentNullException("container");
            if(null == source)
                throw new ArgumentNullException("source");
            this.container = container;
            this.source = source;
            sinks = new Dictionary<int, SinkType>();
            nextCookie = 1;
        }
        #region IConnectionPoint Members
        public void Advise(object pUnkSink, out int pdwCookie)
        {
            SinkType sink = pUnkSink as SinkType;
            if(null == sink)
                Marshal.ThrowExceptionForHR(AM.Common.HRESULTS.E_NOINTERFACE);
            sinks.Add(nextCookie, sink);
            pdwCookie = nextCookie;
            source.OnSinkAdded(sink);
            nextCookie += 1;
        }
 
        public void EnumConnections(out IEnumConnections ppEnum)
        {
            throw new NotImplementedException(); ;
        }
 
        public void GetConnectionInterface(out Guid pIID)
        {
            pIID = typeof(SinkType).GUID;
        }
 
        public void GetConnectionPointContainer(out IConnectionPointContainer ppCPC)
        {
            ppCPC = this.container;
        }
 
        public void Unadvise(int dwCookie)
        {
            SinkType sink = sinks[dwCookie];
            sinks.Remove(dwCookie);
            source.OnSinkRemoved(sink);
        }
        #endregion
    }