//******************************************************************************************************//  SubscriptionInfo.cs - Gbtc////  Copyright © 2010, Grid Protection Alliance.  All Rights Reserved.////  Licensed to the Grid Protection Alliance (GPA) under one or more contributor license agreements. See//  the NOTICE file distributed with this work for additional information regarding copyright ownership.//  The GPA licenses this file to you under the Eclipse Public License -v 1.0 (the "License"); you may//  not use this file except in compliance with the License. You may obtain a copy of the License at:////      http://www.opensource.org/licenses/eclipse-1.0.php////  Unless agreed to in writing, the subject software distributed under the License is distributed on an//  "AS-IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. Refer to the//  License for the specific language governing permissions and limitations.////  Code Modification History://  ----------------------------------------------------------------------------------------------------//  04/25/2012 - Stephen C. Wills//       Generated original version of source code.////****************************************************************************************************** using System; namespace GSF.TimeSeries.Transport{     /// <summary>    /// Configuration object for data subscriptions.    /// </summary>    public abstract class SubscriptionInfo    {        #region [ Members ]         // Fields        private string m_filterExpression;         private bool m_useCompactMeasurementFormat;        private bool m_useMillisecondResolution;         private bool m_udpDataChannel;        private int m_dataChannelLocalPort;         private double m_lagTime;        private double m_leadTime;        private bool m_useLocalClockAsRealTime;         private string m_startTime;        private string m_stopTime;        private string m_constraintParameters;        private int m_processingInterval;         private string m_waitHandleNames;        private int m_waitHandleTimeout;         private string m_extraConnectionStringParameters;         #endregion         #region [ Constructors ]         /// <summary>        /// Creates a new instance of the <see cref="SubscriptionInfo"/> class.        /// </summary>        public SubscriptionInfo()        {            m_useCompactMeasurementFormat = true;            m_dataChannelLocalPort = 9500;            m_lagTime = 10.0;            m_leadTime = 5.0;            m_processingInterval = -1;        }         #endregion         #region [ Properties ]         /// <summary>        /// Gets or sets the filter expression used to define which        /// measurements are being requested by the subscriber.        /// </summary>        public virtual string FilterExpression        {            get            {                return m_filterExpression;            }            set            {                m_filterExpression = value;            }        }         /// <summary>        /// Gets or sets the flag that determines whether to use the        /// compact measurement format or the full measurement format        /// for transmitting measurements to the subscriber.        /// </summary>        public virtual bool UseCompactMeasurementFormat        {            get            {                return m_useCompactMeasurementFormat;            }            set            {                m_useCompactMeasurementFormat = value;            }        }         /// <summary>        /// Gets or sets the flag that determines whether the subscriber        /// is requesting its data over a separate UDP data channel.        /// </summary>        public virtual bool UdpDataChannel        {            get            {                return m_udpDataChannel;            }            set            {                m_udpDataChannel = value;            }        }         /// <summary>        /// Gets or sets the port number that the UDP data channel binds to.        /// This value is only used when the subscriber requests a separate        /// UDP data channel.        /// </summary>        public virtual int DataChannelLocalPort        {            get            {                return m_dataChannelLocalPort;            }            set            {                m_dataChannelLocalPort = value;            }        }         /// <summary>        /// Gets or sets the allowed past time deviation        /// tolerance in seconds (can be subsecond).        /// </summary>        public virtual double LagTime        {            get            {                return m_lagTime;            }            set            {                m_lagTime = value;            }        }         /// <summary>        /// Gets or sets the allowed future time deviation        /// tolerance, in seconds (can be subsecond).        /// </summary>        public virtual double LeadTime        {            get            {                return m_leadTime;            }            set            {                m_leadTime = value;            }        }         /// <summary>        /// Gets or sets the flag that determines whether the server's        /// local clock is used as real-time. If false, the timestamps        /// of the measurements will be used as real-time.        /// </summary>        public virtual bool UseLocalClockAsRealTime        {            get            {                return m_useLocalClockAsRealTime;            }            set            {                m_useLocalClockAsRealTime = value;            }        }         /// <summary>        /// Gets or sets the flag that determines whether measurement timestamps use        /// millisecond resolution. If false, they will use <see cref="Ticks"/> resolution.        /// </summary>        /// <remarks>        /// This flag determines the size of the timestamps transmitted as part of        /// the compact measurement format when the server is using base time offsets.        /// </remarks>        public virtual bool UseMillisecondResolution        {            get            {                return m_useMillisecondResolution;            }            set            {                m_useMillisecondResolution = value;            }        }         /// <summary>        /// Gets or sets the start time of the requested        /// temporal session for streaming historic data.        /// </summary>        /// <remarks>        /// <para>        /// When the <see cref="StartTime"/> or <see cref="StopTime"/> temporal processing contraints are defined (i.e., not <c>null</c>), this        /// specifies the start and stop time over which the subscriber session will process data. Passing in <c>null</c> for the <see cref="StartTime"/>        /// and <see cref="StopTime"/> specifies the the subscriber session will process data in standard, i.e., real-time, operation.        /// </para>        ///         /// <para>        /// Both the <see cref="StartTime"/> and <see cref="StopTime"/> parameters can be specified in one of the        /// following formats:        /// <list type="table">        ///     <listheader>        ///         <term>Time Format</term>        ///         <description>Format Description</description>        ///     </listheader>        ///     <item>        ///         <term>12-30-2000 23:59:59.033</term>        ///         <description>Absolute date and time.</description>        ///     </item>        ///     <item>        ///         <term>*</term>        ///         <description>Evaluates to <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-20s</term>        ///         <description>Evaluates to 20 seconds before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-10m</term>        ///         <description>Evaluates to 10 minutes before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-1h</term>        ///         <description>Evaluates to 1 hour before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-1d</term>        ///         <description>Evaluates to 1 day before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        /// </list>        /// </para>        /// </remarks>        public virtual string StartTime        {            get            {                return m_startTime;            }            set            {                m_startTime = value;            }        }         /// <summary>        /// Gets or sets the stop time of the requested        /// temporal session for streaming historic data.        /// </summary>        /// <remarks>        /// <para>        /// When the <see cref="StartTime"/> or <see cref="StopTime"/> temporal processing contraints are defined (i.e., not <c>null</c>), this        /// specifies the start and stop time over which the subscriber session will process data. Passing in <c>null</c> for the <see cref="StartTime"/>        /// and <see cref="StopTime"/> specifies the the subscriber session will process data in standard, i.e., real-time, operation.        /// </para>        ///         /// <para>        /// Both the <see cref="StartTime"/> and <see cref="StopTime"/> parameters can be specified in one of the        /// following formats:        /// <list type="table">        ///     <listheader>        ///         <term>Time Format</term>        ///         <description>Format Description</description>        ///     </listheader>        ///     <item>        ///         <term>12-30-2000 23:59:59.033</term>        ///         <description>Absolute date and time.</description>        ///     </item>        ///     <item>        ///         <term>*</term>        ///         <description>Evaluates to <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-20s</term>        ///         <description>Evaluates to 20 seconds before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-10m</term>        ///         <description>Evaluates to 10 minutes before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-1h</term>        ///         <description>Evaluates to 1 hour before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        ///     <item>        ///         <term>*-1d</term>        ///         <description>Evaluates to 1 day before <see cref="DateTime.UtcNow"/>.</description>        ///     </item>        /// </list>        /// </para>        /// </remarks>        public virtual string StopTime        {            get            {                return m_stopTime;            }            set            {                m_stopTime = value;            }        }         /// <summary>        /// Gets or sets the aditional constraint parameters        /// supplied to temporal adapters in a temporal session.        /// </summary>        public virtual string ConstraintParameters        {            get            {                return m_constraintParameters;            }            set            {                m_constraintParameters = value;            }        }         /// <summary>        /// Gets or sets the processing interval requested by the subscriber.        /// A value of <c>-1</c> indicates the default processing interval.        /// A value of <c>0</c> indicates data will be processed as fast as        /// possible.        /// </summary>        /// <remarks>        /// With the exception of the values of -1 and 0, the <see cref="ProcessingInterval"/> value specifies the desired historical playback data        /// processing interval in milliseconds. This is basically a delay, or timer interval, overwhich to process data. Setting this value to -1 means        /// to use the default processing interval while setting the value to 0 means to process data as fast as possible.        /// </remarks>        public virtual int ProcessingInterval        {            get            {                return m_processingInterval;            }            set            {                m_processingInterval = value;            }        }         /// <summary>        /// Gets or sets the wait handle names used to deterministically        /// wait for data to become available on the server side.        /// </summary>        public virtual string WaitHandleNames        {            get            {                return m_waitHandleNames;            }            set            {                m_waitHandleNames = value;            }        }         /// <summary>        /// Gets or sets the amount of time to wait on the wait handles        /// identified by the <see cref="WaitHandleNames"/> before the        /// operation times out.        /// </summary>        public virtual int WaitHandleTimeout        {            get            {                return m_waitHandleTimeout;            }            set            {                m_waitHandleTimeout = value;            }        }         /// <summary>        /// Gets or sets the additional connection string parameters to        /// be applied to the connection string sent to the publisher        /// during subscription.        /// </summary>        public virtual string ExtraConnectionStringParameters        {            get            {                return m_extraConnectionStringParameters;            }            set            {                m_extraConnectionStringParameters = value;            }        }         #endregion         #region [ Methods ]         /// <summary>        /// Creates a shallow copy of this        /// <see cref="SubscriptionInfo"/> object.        /// </summary>        /// <returns>The copy of this object.</returns>        public virtual SubscriptionInfo Copy()        {            return (SubscriptionInfo)MemberwiseClone();        }         #endregion    }     /// <summary>    /// Configuration object for synchronized data subscriptions.    /// </summary>    public sealed class SynchronizedSubscriptionInfo : SubscriptionInfo    {        #region [ Members ]         // Fields        private bool m_remotelySynchronized;         private int m_framesPerSecond;        private DownsamplingMethod m_downsamplingMethod;        private bool m_allowPreemptivePublishing;         private bool m_allowSortsByArrival;        private bool m_ignoreBadTimestamps;        private long m_timeResolution;         #endregion         #region [ Constructors ]         /// <summary>        /// Creates a new instance of the <see cref="SynchronizedSubscriptionInfo"/> class.        /// </summary>        /// <param name="remotelySynchronized">Flag that determines whether the subscription defined by this object is remotely synchronized or locally synchronized.</param>        /// <param name="framesPerSecond">Frame rate of the subscription in frames per second.</param>        public SynchronizedSubscriptionInfo(bool remotelySynchronized, int framesPerSecond)        {            m_remotelySynchronized = remotelySynchronized;             m_framesPerSecond = framesPerSecond;            m_downsamplingMethod = DownsamplingMethod.LastReceived;            m_allowPreemptivePublishing = true;             m_allowSortsByArrival = true;            m_timeResolution = Ticks.PerMillisecond;        }         #endregion         #region [ Properties ]         /// <summary>        /// Gets or sets the flag that determines whether this subscription        /// is remotely synchronized or locally synchronized.        /// </summary>        public bool RemotelySynchronized        {            get            {                return m_remotelySynchronized;            }            set            {                m_remotelySynchronized = value;            }        }         /// <summary>        /// Gets or sets the frame rate of the subscription in frames per second.        /// </summary>        public int FramesPerSecond        {            get

Lines 1–500 of 704. Load more