here you go meftos

Author: Grant Bissett

README

@@ -0,0 +1 @@
+MAKE MONEY ONLINE IN YOU'RE 

monitor_file.rb

@@ -0,0 +1,43 @@
+#!/usr/bin/ruby -w
+require 'inotify'
+require 'socket'
+include Socket::Constants
+
+# Setup a server
+def setup_server(ip, port)
+  socket = Socket.new(AF_INET, SOCK_STREAM, 0)
+  sockaddr = Socket.pack_sockaddr_in(port, ip)
+  puts "Waiting for a connection on " + sockaddr.inspect
+  socket.bind(sockaddr)
+  socket.listen(5)
+  client, client_sockaddr = socket.accept
+
+  # Let's wait for someone to connect
+  read = ''
+  while data = client.recvfrom(1)
+    read += data.join
+    if read == 'START'
+      client.puts "ACK"
+
+      get_forked(client)
+      read = ''
+    end
+  end
+end
+
+def get_forked(client)
+  setup_listener(client)
+end
+
+def setup_listener(client)
+  file = ARGV.first
+
+  mon = Inotify.new
+  mon.add_watch(file, Inotify::MODIFY)
+  puts client.inspect
+  mon.each_event do |event|
+    client.puts "$$$"
+  end
+end
+
+setup_server('0.0.0.0', 1337)

prefork_monitor_file.rb

@@ -0,0 +1,84 @@
+#!/usr/bin/ruby
+require 'socket'
+require 'inotify'
+
+class Preforker 
+    attr_reader (:child_count)
+    
+    def initialize(prefork, max_clients_per_child, port, client_handler)
+        @prefork = prefork
+        @max_clients_per_child = max_clients_per_child
+        @port = port
+        @child_count = 0
+        
+        @reaper = proc {
+            trap('CHLD', @reaper)
+            pid = Process.wait
+            @child_count -= 1
+        }
+        
+        @huntsman = proc {
+            trap('CHLD', 'IGNORE')
+            trap('INT', 'IGNORE')
+            Process.kill('INT', 0)
+            exit
+        }
+        
+        @client_handler=client_handler
+    end
+    
+    def child_handler
+        trap('INT', 'EXIT')
+        @client_handler.setUp
+        # wish: sigprocmask UNblock SIGINT
+        @max_clients_per_child.times {
+            client = @server.accept or break
+            @client_handler.handle_request(client)
+            client.close
+        }
+        @client_handler.tearDown
+    end
+    
+    def make_new_child
+        # wish: sigprocmask block SIGINT
+        @child_count += 1
+        pid = fork do
+            child_handler
+        end
+        # wish: sigprocmask UNblock SIGINT
+    end
+    
+    def run
+        @server = TCPserver.open(@port)
+        trap('CHLD', @reaper)
+        trap('INT', @huntsman)
+        loop {
+            (@prefork - @child_count).times { |i|
+                make_new_child
+            }
+            sleep 0.1
+        }
+    end
+end
+
+class ClientHandler
+    @monitor
+    def setUp
+    	file = ARGV.first
+  		@monitor = Inotify.new
+  		@monitor.add_watch(file, Inotify::MODIFY)
+    end
+    
+    def tearDown
+   		@monitor.close 
+	end
+    
+    def handle_request(client)
+  		@monitor.each_event do |event|
+    		client.puts "$$$"
+  		end
+    end
+end
+
+server = Preforker.new(5, 100, 1337, ClientHandler.new)
+server.run