Control Errors from several instances of a filesystemwatcher obj

See more:

C#

file-system

My problem initially was to ensure that an instance of filesystemwatcher could recover from lost of network in a remote directory monitoring, or if de directory its was monitoring were to deleted and created again.

After a while searching the web I came up with this:

class watcher
{

    static string _path;
    static string _mask;

    static FileSystemWatcher m_Watcher;

    public watcher(string path, string mask)
    {
        m_Watcher = new FileSystemWatcher();
        _path = path;
        _mask = mask;
    }

    public static void start()
    {
        m_Watcher.Filter = _mask;
        m_Watcher.Path = _path;


        m_Watcher.NotifyFilter = NotifyFilters.FileName;

        m_Watcher.IncludeSubdirectories = false;

        m_Watcher.Created += new FileSystemEventHandler(OnCreated);

        m_Watcher.Error += new ErrorEventHandler(OnError);

        m_Watcher.EnableRaisingEvents = true;


    }

    static void OnCreated(object sender, FileSystemEventArgs e)
    {
        Console.WriteLine("OnCreated " + e.FullPath);
    }

    static void OnError(object sender, ErrorEventArgs e)
    {

        if (e.GetException().GetType() == typeof(InternalBufferOverflowException))
        {
            Console.WriteLine("Error: File System Watcher internal buffer overflow at " + DateTime.Now);
        }
        else
        {
            Console.WriteLine("Error: Watched directory " + _path + " not accessible at " + DateTime.Now + Environment.NewLine + e.GetException().Message + Environment.NewLine);
            NotAccessibleError(m_Watcher);
        }

    }


    static void NotAccessibleError(FileSystemWatcher m_Watcher)
    {
        int iMaxAttempts = 120;
        int iTimeOut = 5000;
        int i = 0;

        while ((!Directory.Exists(m_Watcher.Path) || m_Watcher.EnableRaisingEvents == false) && i < iMaxAttempts)
        {
            i += 1;
            try
            {
                m_Watcher.EnableRaisingEvents = false;

                if (!Directory.Exists(m_Watcher.Path))
                {
                    Console.WriteLine("Directory Inaccesible " + m_Watcher.Path + " at " + DateTime.Now.ToString("HH:mm:ss"));
                    System.Threading.Thread.Sleep(iTimeOut);
                }
                if (Directory.Exists(m_Watcher.Path))
                {


                    m_Watcher.Dispose();
                    m_Watcher = null;

                    m_Watcher = new FileSystemWatcher();

                      m_Watcher.Filter = _mask;
                        m_Watcher.Path = _path;


                        m_Watcher.NotifyFilter = NotifyFilters.FileName;

                        m_Watcher.IncludeSubdirectories = false;

                        m_Watcher.Created += new FileSystemEventHandler(OnCreated);

                        m_Watcher.Error += new ErrorEventHandler(OnError);

                        m_Watcher.EnableRaisingEvents = true;

                    Console.WriteLine("Restart RaisingEvents Watcher for " + _path + " at " + DateTime.Now.ToString("HH:mm:ss"));
                }
            }
            catch (Exception error)
            {
                Console.WriteLine("Error trying Restart Service " + error.StackTrace + " at " + DateTime.Now.ToString("HH:mm:ss"));
                m_Watcher.EnableRaisingEvents = false;
                System.Threading.Thread.Sleep(iTimeOut);
            }
        }
    }

}

And the code that calls this, as example:

watcher watcher;

watcher = new watcher(@"C:\WORK\TESTING\01", "*.*");
watcher.start();
Console.WriteLine(@"starting Watcher for : C:\WORK\TESTING\01");

watcher = new watcher(@"C:\WORK\TESTING\02", "*.*");
watcher.start();
Console.WriteLine(@"starting Watcher for : C:\WORK\TESTING\02");

watcher = new watcher(@"T:\UTILS\TESTING\01", "*.*");
watcher.start();
Console.WriteLine(@"starting Watcher for : T:\UTILS\TESTING\01");

watcher = new watcher(@"T:\UTILS\TESTING\02", "*.*");
watcher.start();
Console.WriteLine(@"starting Watcher for : T:\UTILS\TESTING\02");

while (true)
{
    Thread.Sleep(5000);
}

If I only use one obj its works fine and recovers ok, but if I instance more than one obj of the class when he get an error it:

Assumes that there where 2 (for example) watcher that lost network but the information that I can see is only for the latest one that I have instanced.
So when the automatically recovers it creates 2 new watchers for the second directory.

It seems that the error is being thrown by the 2 obj’s but only the latest one is being stored and used by booth.

Any ideas for what I’m doing wrong?

Thanks in advance.