Merge pull request duboviy#2 from extended-debug/master

Merge pull requests (duboviy#1-#4) from remote extended-debug fork

Author: duboviy

get_os_info.py

@@ -0,0 +1,53 @@
+import os
+import time
+
+import psutil           # pip install psutil
+import humanfriendly    # pip install humanfriendly
+
+
+def get_os_info():
+    """ Get some OS info with psutils and humanfriendly. """
+    is_win = lambda: True if os.name == 'nt' else False
+    pid = os.getgid() if not is_win() else None
+    ppid = os.getppid()
+
+    now = time.time()
+
+    current_process = psutil.Process(pid=ppid)
+    process_uptime = current_process.create_time()
+    process_uptime_delta = now - process_uptime
+    process_uptime_human = humanfriendly.format_timespan(process_uptime_delta)
+
+    system_uptime = psutil.boot_time()
+    system_uptime_delta = now - system_uptime
+    system_uptime_human = humanfriendly.format_timespan(system_uptime_delta)
+
+    free_memory = psutil.disk_usage('/').free
+    total_memory = psutil.disk_usage('/').total
+    percent_used_memory = psutil.disk_usage('/').percent
+    used_memory = psutil.disk_usage('/').used
+    free_memory_human = humanfriendly.format_size(free_memory)
+
+    return vars()
+
+
+if __name__ == '__main__':
+    from pprint import pprint
+    pprint(get_os_info())
+    ### Output example:
+    # {'current_process': <psutil.Process(pid=10628, name='pycharm.exe') at 2074457600744>,
+    #  'free_memory': 28299886592,
+    #  'free_memory_human': '28.3 GB',
+    #  'is_win': <function get_os_info.<locals>.<lambda> at 0x000001E2FFDED158>,
+    #  'now': 1491982808.197413,
+    #  'percent_used_memory': 88.2,
+    #  'pid': 1001,
+    #  'ppid': 10628,
+    #  'process_uptime': 1491471889.0,
+    #  'process_uptime_delta': 510919.1974129677,
+    #  'process_uptime_human': '5 days, 21 hours and 55 minutes',
+    #  'system_uptime': 1490198873.0,
+    #  'system_uptime_delta': 1783935.1974129677,
+    #  'system_uptime_human': '2 weeks, 6 days and 15 hours',
+    #  'total_memory': 239530405888,
+    #  'used_memory': 211230519296}

module_functions_getter.py

@@ -0,0 +1,16 @@
+import operator
+import inspect
+
+
+def get_module_functions(module, function_prefix=''):
+    
+    def filter_function(inspected_function):
+        function_name, function = inspected_function
+        if (function_name.startswith(function_prefix) and
+            inspect.getmodule(function) == module):
+            return True
+
+    funcs = map(operator.itemgetter(1),
+                        filter(filter_function,
+                               inspect.getmembers(module, inspect.isfunction)))
+    return funcs

server.py

@@ -0,0 +1,42 @@
+import socket
+import sys
+
+HOST = ''  # interface
+PORT = 8888  # port
+
+s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+print('Socket created')
+
+# Bind socket to local host and port
+try:
+    s.bind((HOST, PORT))
+except socket.error as msg:
+    print('Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1])
+    sys.exit()
+
+print('Socket bind complete')
+
+# Start listening on socket
+s.listen(10)
+print('Socket now listening')
+
+# now keep talking with the client
+while 1:
+    conn, addr = s.accept()
+    print('Connected with ' + addr[0] + ':' + str(addr[1]))
+    conn.send(b'Welcome to the server. Type something and hit enter\n')
+    while True:
+        data = conn.recv(1024)
+        reply = 'Reply text\n'
+        if not data:
+            break
+
+        conn.sendall(bytes(reply, 'utf-8'))
+
+    conn.close()
+
+s.close()
+
+
+# To test just use:
+# >>> telnet localhost 8888

watcher.py

@@ -0,0 +1,41 @@
+import time
+from watchdog.observers import Observer
+from watchdog.events import PatternMatchingEventHandler
+
+
+class ScriptModifiedHandler(PatternMatchingEventHandler):
+    patterns = ['*.py']
+
+    def __init__(self):
+        super(ScriptModifiedHandler, self).__init__()
+	# you can add some init code here
+
+    def process(self, event):
+        print(event.src_path, event.event_type)
+
+    def on_modified(self, event):
+        self.process(event)
+		
+    def on_moved(self, event):
+	pass
+		
+    def on_deleted(self, event):
+	pass
+		
+    def on_created(self, event):
+	pass
+
+
+if __name__ == '__main__':
+    observer = Observer()
+    path = '.'
+    event_handler = ScriptModifiedHandler()
+    observer.schedule(event_handler, path, recursive=True)
+    observer.start()
+    try:
+        while True:
+            time.sleep(1)
+    except KeyboardInterrupt:
+        observer.stop()
+    observer.join()
+