Ntp.Common.Process.Cluster Class Reference

Inheritance diagram for Ntp.Common.Process.Cluster:

Collaboration diagram for Ntp.Common.Process.Cluster:

Public Member Functions
	Cluster (Scheduler scheduler, IApplicationController controller, IEnumerable< IRequest > peers, LogBase log)
void	Activate ()
void	Dispose ()

Private Member Functions
	~Cluster ()
void	Dispose (bool disposing)

Private Attributes
bool	disposedValue
readonly LogBase	log
readonly IEnumerable< IRequest >	peers
bool	run
readonly Scheduler	scheduler
readonly EventWaitHandle	waitHandle

Detailed Description

Definition at line 31 of file Cluster.cs.

Constructor & Destructor Documentation

Ntp.Common.Process.Cluster.Cluster ( Scheduler  scheduler, IApplicationController  controller, IEnumerable< IRequest >  peers, LogBase  log  )

inline

Definition at line 33 of file Cluster.cs.

References e, Ntp.Common.App.IApplicationController.ExitApplication, and Ntp.Common.Process.Scheduler.WaitHandle.

        {
            this.scheduler = scheduler;
            this.peers = peers;
            this.log = log;

            waitHandle = new EventWaitHandle(false, EventResetMode.AutoReset);
            controller.ExitApplication += (sender, e) =>
            {
                run = false;
                waitHandle.Set();
                scheduler.WaitHandle.Set();
            };
        }

Ntp.Common.Process.Cluster.~Cluster ( )

inlineprivate

Definition at line 141 of file Cluster.cs.

        {
            Dispose(false);
        }

Member Function Documentation

void Ntp.Common.Process.Cluster.Activate ( )

inline

Definition at line 58 of file Cluster.cs.

References e.

        {
            bool activated = true;
            if (peers.Count() != 0)
            {
                log.ClusterStart();
            }

            run = true;
            while (run)
            {
                bool otherActive = false;
                foreach (var request in peers)
                {
                    try
                    {
                        string answer = request.Send("ping");

                        if (answer != null && answer == "*" && activated)
                        {
                            log.ClusterNodeAlive(request);
                        }
                        else if (answer != null && answer == "active" && activated)
                        {
                            log.ClusterNodeActive(request);
                        }
                        else if (activated)
                        {
                            log.ClusterNodeDead(request);
                        }

                        if (answer != null && answer == "active")
                        {
                            otherActive = true;
                        }
                    }
                    catch (Exception e)
                    {
                        log.ClusterNodeError(request, e);
                    }
                }

                if (!otherActive)
                {
                    try
                    {
                        scheduler.RunOneCycle();
                    }
                    catch (Exception e)
                    {
                        log.ClusterError(e);
                        return;
                    }
                }
                else
                {
                    waitHandle.WaitOne(10000);
                }

                // This node is now active and no longer "activated"
                activated = false;
            }

            scheduler.Stop();
        }

void Ntp.Common.Process.Cluster.Dispose ( bool  disposing )

inlineprivate

Definition at line 128 of file Cluster.cs.

        {
            if (disposedValue)
                return;

            if (disposing)
            {
                waitHandle.Dispose();
            }

            disposedValue = true;
        }

void Ntp.Common.Process.Cluster.Dispose ( )

inline

Definition at line 146 of file Cluster.cs.

        {
            Dispose(true);
            GC.SuppressFinalize(this);
        }

Member Data Documentation

bool Ntp.Common.Process.Cluster.disposedValue

private

Definition at line 126 of file Cluster.cs.

readonly LogBase Ntp.Common.Process.Cluster.log

private

Definition at line 52 of file Cluster.cs.

readonly IEnumerable<IRequest> Ntp.Common.Process.Cluster.peers

private

Definition at line 53 of file Cluster.cs.

bool Ntp.Common.Process.Cluster.run

private

Definition at line 56 of file Cluster.cs.

readonly Scheduler Ntp.Common.Process.Cluster.scheduler

private

Definition at line 54 of file Cluster.cs.

readonly EventWaitHandle Ntp.Common.Process.Cluster.waitHandle

private

Definition at line 55 of file Cluster.cs.

---

The documentation for this class was generated from the following file:

• Ntp.Common/Process/Cluster.cs