pypy / lib_pypy /

The branch 'stm-gc' does not exist.
import sys
import random

print >> sys.stderr, "warning: using lib_pypy/, the emulator"

_pending = {}

def set_num_threads(num):

def add(f, *args):
    r = random.random()
    assert r not in _pending    # very bad luck if it is
    _pending[r] = (f, args)

def add_epoll(ep, callback):
    for key, (f, args) in _pending.items():
        if getattr(f, '_reads_from_epoll_', None) is ep:
            raise ValueError("add_epoll(ep): ep is already registered")
    def poll_reader():
        # assume only one epoll is added.  If the _pending list is
        # now empty, wait.  If not, then just poll non-blockingly.
        if len(_pending) == 0:
            timeout = -1
            timeout = 0
        got = ep.poll(timeout=timeout)
        for fd, events in got:
            add(callback, fd, events)
    poll_reader._reads_from_epoll_ = ep

def remove_epoll(ep):
    for key, (f, args) in _pending.items():
        if getattr(f, '_reads_from_epoll_', None) is ep:
            del _pending[key]
        raise ValueError("remove_epoll(ep): ep is not registered")

def run():
    pending = _pending
        while pending:
            _, (f, args) = pending.popitem()
        pending.clear()   # this is the behavior we get with interp_transaction
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.