SynchronizationStatus.cs

using System;
using System.Collections.Generic;
 
namespace Waher.Networking.XMPP.NeuroLedger.Events
{
    public class SynchronizationStatus
    {
        private readonly List<KeyValuePair<string, string>> blockErrorsMessages = new List<KeyValuePair<string, string>>();
        private DateTime first = DateTime.MaxValue;
        private DateTime last = DateTime.MinValue;
        private uint nrBlocks = 0;
        private uint nrNew = 0;
        private uint nrUpdated = 0;
        private uint nrLoaded = 0;
        private uint nrDenied = 0;
        private uint blockErrors = 0;
        private uint objectErrors = 0;
        private ulong totalBytes = 0;
        private ulong loadedBytes = 0;
        private ulong events = 0;
        private ulong objectsAdded = 0;
        private ulong objectsDeleted = 0;
        private ulong objectsUpdated = 0;
        private bool done = false;
 
        public SynchronizationStatus()
        {
        }
 
        public DateTime First
        {
            get => this.first;
            internal set => this.first = value;
        }
 
        public DateTime Last
        {
            get => this.last;
            internal set => this.last = value;
        }
 
        public uint NrBlocks
        {
            get => this.nrBlocks;
            internal set => this.nrBlocks = value;
        }
 
        public uint NrNew
        {
            get => this.nrNew;
            internal set => this.nrNew = value;
        }
 
        public uint NrUpdated
        {
            get => this.nrUpdated;
            internal set => this.nrUpdated = value;
        }
 
        public uint NrLoaded
        {
            get => this.nrLoaded;
            internal set => this.nrLoaded = value;
        }
 
        public uint NrDenied
        {
            get => this.nrDenied;
            internal set => this.nrDenied = value;
        }
 
        public uint BlockErrors
        {
            get => this.blockErrors;
        }
 
        internal void IncBlockError(string Peer, string Message)
        {
            this.IncBlockError(Peer, Message, 1);
        }
 
        internal void IncBlockError(string Peer, string Message, uint NrBlocks)
        {
            lock (this.blockErrorsMessages)
            {
                this.blockErrors += NrBlocks;
                this.blockErrorsMessages.Add(new KeyValuePair<string, string>(Peer, Message));
            }
        }
 
        public KeyValuePair<string, string>[] PopBlockErrorMessages()
        {
            KeyValuePair<string, string>[] Result;
 
            lock (this.blockErrorsMessages)
            {
                if (this.blockErrorsMessages.Count == 0)
                    Result = null;
                else
                {
                    Result = this.blockErrorsMessages.ToArray();
                    this.blockErrorsMessages.Clear();
                }
            }
 
            return Result;
        }
 
        public uint ObjectErrors
        {
            get => this.objectErrors;
            internal set => this.objectErrors = value;
        }
 
        public ulong TotalBytes
        {
            get => this.totalBytes;
            internal set => this.totalBytes = value;
        }
 
        public ulong LoadedBytes
        {
            get => this.loadedBytes;
            internal set => this.loadedBytes = value;
        }
 
        public ulong Events
        {
            get => this.events;
            internal set => this.events = value;
        }
 
        public ulong ObjectsAdded
        {
            get => this.objectsAdded;
            internal set => this.objectsAdded = value;
        }
 
        public ulong ObjectsUpdated
        {
            get => this.objectsUpdated;
            internal set => this.objectsUpdated = value;
        }
 
        public ulong ObjectsDeleted
        {
            get => this.objectsDeleted;
            internal set => this.objectsDeleted = value;
        }
 
        public bool Done
        {
            get => this.done;
            internal set => this.done = value;
        }
    }
}