FM / medusa

/usr/lib/python2.6/site-packages/supervisor/medusa/

/usr/lib/python2.6/site-packages/supervisor/medusa

Name	Size	Mode	Actions
auth_handler.py	4739	0644	edit dl rm
auth_handler.pyc	4513	0644	edit dl rm
auth_handler.pyo	4513	0644	edit dl rm
chat_server.py	4535	0644	edit dl rm
chat_server.pyc	6427	0644	edit dl rm
chat_server.pyo	6427	0644	edit dl rm
counter.py	1440	0644	edit dl rm
counter.pyc	2039	0644	edit dl rm
counter.pyo	2039	0644	edit dl rm
default_handler.py	6331	0644	edit dl rm
default_handler.pyc	5034	0644	edit dl rm
default_handler.pyo	5034	0644	edit dl rm
event_loop.py	2981	0644	edit dl rm
event_loop.pyc	3513	0644	edit dl rm
event_loop.pyo	3513	0644	edit dl rm
filesys.py	11206	0644	edit dl rm
filesys.pyc	13598	0644	edit dl rm
filesys.pyo	13598	0644	edit dl rm
ftp_server.py	40552	0644	edit dl rm
ftp_server.pyc	34727	0644	edit dl rm
ftp_server.pyo	34727	0644	edit dl rm
http_date.py	3415	0644	edit dl rm
http_date.pyc	3468	0644	edit dl rm
http_date.pyo	3468	0644	edit dl rm
http_server.py	25217	0644	edit dl rm
http_server.pyc	21468	0644	edit dl rm
http_server.pyo	21468	0644	edit dl rm
logger.py	8000	0644	edit dl rm
logger.pyc	10990	0644	edit dl rm
logger.pyo	10990	0644	edit dl rm
medusa_gif.py	2772	0644	edit dl rm
medusa_gif.pyc	1156	0644	edit dl rm
medusa_gif.pyo	1156	0644	edit dl rm
monitor.py	11054	0644	edit dl rm
monitor.pyc	12285	0644	edit dl rm
monitor.pyo	12285	0644	edit dl rm
monitor_client.py	3273	0644	edit dl rm
monitor_client.pyc	5390	0644	edit dl rm
monitor_client.pyo	5390	0644	edit dl rm
monitor_client_win32.py	1334	0644	edit dl rm
monitor_client_win32.pyc	2094	0644	edit dl rm
monitor_client_win32.pyo	2094	0644	edit dl rm
m_syslog.py	7351	0644	edit dl rm
m_syslog.pyc	4006	0644	edit dl rm
m_syslog.pyo	4006	0644	edit dl rm
producers.py	9439	0644	edit dl rm
producers.pyc	11634	0644	edit dl rm
producers.pyo	11634	0644	edit dl rm
put_handler.py	3324	0644	edit dl rm
put_handler.pyc	3511	0644	edit dl rm
put_handler.pyo	3511	0644	edit dl rm
redirecting_handler.py	1403	0644	edit dl rm
redirecting_handler.pyc	2159	0644	edit dl rm
redirecting_handler.pyo	2159	0644	edit dl rm
resolver.py	15559	0644	edit dl rm
resolver.pyc	12401	0644	edit dl rm
resolver.pyo	12401	0644	edit dl rm
rpc_client.py	9675	0644	edit dl rm
rpc_client.pyc	10346	0644	edit dl rm
rpc_client.pyo	10346	0644	edit dl rm
rpc_server.py	9953	0644	edit dl rm
rpc_server.pyc	9536	0644	edit dl rm
rpc_server.pyo	9536	0644	edit dl rm
script_handler.py	6554	0644	edit dl rm
script_handler.pyc	6651	0644	edit dl rm
script_handler.pyo	6651	0644	edit dl rm
setup.py	496	0644	edit dl rm
setup.pyc	729	0644	edit dl rm
setup.pyo	729	0644	edit dl rm
status_handler.py	9352	0644	edit dl rm
status_handler.pyc	9672	0644	edit dl rm
status_handler.pyo	9672	0644	edit dl rm
unix_user_handler.py	2312	0644	edit dl rm
unix_user_handler.pyc	2361	0644	edit dl rm
unix_user_handler.pyo	2361	0644	edit dl rm
virtual_handler.py	1724	0644	edit dl rm
virtual_handler.pyc	3164	0644	edit dl rm
virtual_handler.pyo	3164	0644	edit dl rm
xmlrpc_handler.py	2944	0644	edit dl rm
xmlrpc_handler.pyc	3784	0644	edit dl rm
xmlrpc_handler.pyo	3784	0644	edit dl rm
__init__.py	128	0644	edit dl rm
__init__.pyc	277	0644	edit dl rm
__init__.pyo	277	0644	edit dl rm

Edit: /usr/lib/python2.6/site-packages/supervisor/medusa/event_loop.py (2981B)

# -*- Mode: Python -*-

# This is an alternative event loop that supports 'schedulable events'.
# You can specify an event callback to take place after <n> seconds.

# Important usage note: The granularity of the time-check is limited
# by the <timeout> argument to 'go()'; if there is little or no
# activity and you specify a 30-second timeout interval, then the
# schedule of events may only be checked at those 30-second intervals.
# In other words, if you need 1-second resolution, you will have to
# poll at 1-second intervals.  This facility is more useful for longer
# timeouts ("if the channel doesn't close in 5 minutes, then forcibly
# close it" would be a typical usage).

import asyncore
import bisect
import time

socket_map = asyncore.socket_map

class event_loop:

def __init__ (self):
        self.events = []
        self.num_channels = 0
        self.max_channels = 0

def go (self, timeout=30.0, granularity=15):
        global socket_map
        last_event_check = 0
        while socket_map:
            now = int(time.time())
            if (now - last_event_check) >= granularity:
                last_event_check = now
                fired = []
                # yuck. i want my lisp.
                i = j = 0
                while i < len(self.events):
                    when, what = self.events[i]
                    if now >= when:
                        fired.append (what)
                        j = i + 1
                    else:
                        break
                    i = i + 1
                if fired:
                    self.events = self.events[j:]
                    for what in fired:
                        what (self, now)
            # sample the number of channels
            n = len(asyncore.socket_map)
            self.num_channels = n
            if n > self.max_channels:
                self.max_channels = n
            asyncore.poll (timeout)

def schedule (self, delta, callback):
        now = int (time.time())
        bisect.insort (self.events, (now + delta, callback))

def __len__ (self):
        return len(self.events)

class test (asyncore.dispatcher):

def __init__ (self):
        asyncore.dispatcher.__init__ (self)

def handle_connect (self):
        print 'Connected!'

def writable (self):
        return not self.connected

def connect_timeout_callback (self, event_loop, when):
        if not self.connected:
            print 'Timeout on connect'
            self.close()

def periodic_thing_callback (self, event_loop, when):
        print 'A Periodic Event has Occurred!'
        # re-schedule it.
        event_loop.schedule (self, 15, self.periodic_thing_callback)

if __name__ == '__main__':
    import socket
    el = event_loop()
    t = test ()
    t.create_socket (socket.AF_INET, socket.SOCK_STREAM)
    el.schedule (10, t.connect_timeout_callback)
    el.schedule (15, t.periodic_thing_callback)
    t.connect (('squirl', 80))
    el.go(1.0)

cmd: