Monitoring a Folder for New Files

One aspect of intrusion detection is to monitor critical folders for new files. I have found that it can be done through the following C# code.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50

class WatchCurrentFolder { static FileSystemWatcher watcher = new FileSystemWatcher(); static void Main(string[] args) { watch(); } static void watch() { //watch current directory watcher.Path = Directory.GetCurrentDirectory(); //watch all types of files watcher.Filter = "*.*"; //watch for all types of activity watcher.NotifyFilter = NotifyFilters.Attributes | NotifyFilters.CreationTime | NotifyFilters.FileName | NotifyFilters.LastAccess | NotifyFilters.LastWrite | NotifyFilters.Size | NotifyFilters.Security; //subscribe to the Created event watcher.Created += new FileSystemEventHandler(OnChanged); //start watching watcher.EnableRaisingEvents = true; // Wait for the user to quit the program. Console.WriteLine("Press \'q\' to quit"); while (Console.Read() != 'q') ; } private static void OnChanged(object sender, FileSystemEventArgs e) { try { //this is important: because OS operations take sometime //wait for OS operations to complete, else IOException System.Threading.Thread.Sleep(1000); //how to handle the event: e.g. read contents of affected file string contents = File.ReadAllText(e.FullPath); } catch (IOException ie) { Console.WriteLine("\t{0}", ie); } } }

Design for High Availability

High availability (HA) systems often rely on HA hardware such as cluster computers. When a running computer encounters a hardware fault, another  computer-on-standby will be activated to take over. The HA system seems easy in concept, but in practice, it is not so. The main difficulty is not the HA hardware, but rather it is the HA software that you have to write (if you cannot buy the software off-the-shelf).

Over many years of designing software, I have found that high availability (HA) software are among the hardest types of software to design. High availability means the software has to run 24/7 continuously for a long period of time. This is difficult to achieve, because partly, we were taught in schools to write programs that did some tasks and then exit upon error or completion. This learned mindset becomes an unfortunate obstacle because HA programs must not exit or hang or crash. And partly because HA programs are often facing the Internet, they have to be resilient against Denial-of-Service (DoS) attacks. In addition, HA hardware often impose extra requirements on the software, such as disaster recovery.

Here I have listed down several guidelines that I have gathered while designing HA software.

1. Do not use multi-threading.

Reason: In multi-threading application, if 1 thread hangs, it is hard to debug.

Solution: Use multiple processes instead. Then if a process hangs, you can attach a debugger to it and then choose Debug->“Break all” (in Visual Studio) to find out where does it hang. This also has the advantage of lowering the coupling in the software. This means that the other processes can continue running, without being greatly affected.

2. Do not use blocking calls.

E.g. Sending socket messages would block forever if there was some problems with the network (no fault of the sender).

Solution: use non-blocking send() or set timeout in socket flags.

3. Do not use messaging mechanisms that require tight coupling between senders and receiver.

E.g. Sending messages to a ZMQ push-pull socket would block forever if the recipient hangs (no fault of the sender).

Solution: Decouple sender-receivers using ZMQ publisher-subscriber sockets/pattern

4. Do not forget to catch exceptions.

E.g. Sending messages to a UDP socket could fail if the queue is full or whatever other reasons (no fault of the sender). If you do not catch SocketException, your application is going to crash

Solution: Catch SocketException so that the application will continue running.  You have a couple of options: either ignore the failure or wait a while to re-send (hoping that the queue will eventually clear by itself). The first option could be viable in the case of UDP since the protocol is known for lost packets.

5. Log sufficient information in the exceptions.

E.g If you only catch the generic Exception, but not SocketException, you would lose the WinSock error code.

Solution: Catch the SocketException in order to log the error code. Also catch ZmqException. You can also wrap the SocketException inside another Exception (as an InnerException) if you want to log more information than is available from the SocketException.

6. Use a reliable logging framework, e.g. Log4Net.
   
   
7. Trace statements.

Add trace statements (e.g. log.Debug) into the forever loop to find out where is the program stuck.