MessageStatus.cs

using System;
using System.Collections.Generic;
using System.Net;
using Waher.Events;
 
namespace Waher.Networking.Cluster
{
    internal class MessageStatus
    {
        public Guid Id;
        public Dictionary<IPEndPoint, bool?> Acknowledged = new Dictionary<IPEndPoint, bool?>();
        public IClusterMessage Message;
        public IPEndPoint Destination;
        public byte[] MessageBinary;
        public DateTime Timeout;
        public DateTime TimeLimit;
        public EventHandlerAsync<ClusterMessageAckEventArgs> Callback;
        public object State;
 
        public bool IsComplete(EndpointStatus[] Statuses)
        {
            lock (this.Acknowledged)
            {
                foreach (EndpointStatus Status in Statuses)
                {
                    if (!this.Acknowledged.ContainsKey(Status.Endpoint))
                        return false;
                }
            }
 
            return true;
        }
 
        public EndpointAcknowledgement[] GetResponses(EndpointStatus[] Statuses)
        {
            EndpointAcknowledgement[] Result;
            int i, c;
 
            lock (this.Acknowledged)
            {
                foreach (EndpointStatus Status in Statuses)
                {
                    if (!this.Acknowledged.ContainsKey(Status.Endpoint))
                        this.Acknowledged[Status.Endpoint] = null;
                }
 
                Result = new EndpointAcknowledgement[c = this.Acknowledged.Count];
 
                i = 0;
                foreach (KeyValuePair<IPEndPoint, bool?> P in this.Acknowledged)
                    Result[i++] = new EndpointAcknowledgement(P.Key, P.Value);
            }
 
            return Result;
        }
    }
}