michelp

test_basic_multipart (zmq.tests.test_multipart.TestMultipartGreen) ... ^CTraceback (most recent call last):
  File "/home/michel/dev/sb/bin/nosetests", line 9, in <module>
    load_entry_point('nose==1.1.2', 'console_scripts', 'nosetests')()
  File "/home/michel/dev/sb/local/lib/python2.7/site-packages/nose-1.1.2-py2.7.egg/nose/core.py", line 118, in __init__
    **extra_args)
  File "/usr/lib/python2.7/unittest/main.py", line 95, in __init__
    self.runTests()
  File "/home/michel/dev/sb/local/lib/python2.7/site-packages/nose-1.1.2-py2.7.egg/nose/core.py", line 197, in runTests
    result = self.testRunner.run(self.test)
  File "/home/michel/dev/sb/local/lib/python2.7/site-packages/nose-1.1.2-py2.7.egg/nose/core.py", line 61, in run

michelp

michel@ranger:/tmp/tmpPqghzRbuildout-libzmq/zeromq-3.2.0 $ make
Making all in src
make[1]: Entering directory `/tmp/tmpPqghzRbuildout-libzmq/zeromq-3.2.0/src'
make  all-am
make[2]: Entering directory `/tmp/tmpPqghzRbuildout-libzmq/zeromq-3.2.0/src'
make[2]: Nothing to be done for `all-am'.
make[2]: Leaving directory `/tmp/tmpPqghzRbuildout-libzmq/zeromq-3.2.0/src'
make[1]: Leaving directory `/tmp/tmpPqghzRbuildout-libzmq/zeromq-3.2.0/src'
Making all in doc
make[1]: Entering directory `/tmp/tmpPqghzRbuildout-libzmq/zeromq-3.2.0/doc'

michelp

                              tc@box:~$ ll /bin/*server                                                                                      
                              -rwxr-xr-x    1 root     root          9103 Jul  2 07:34 /bin/pubsub_server                                    
                              -rwxr-xr-x    1 root     root          9105 Jul  2 07:34 /bin/pushpull_server                                  
                              -rwxr-xr-x    1 root     root          8956 Jul  2 07:34 /bin/reqrep_server                                    
                              tc@box:~$ sudo /bin/pubsub_server                                                                              
                              sudo: unable to execute /bin/pubsub_server: No such file or directory                                          
                              tc@box:~$   

michelp

from gevent import Event
from itertools import ifilter
from operator import methodcaller

def eselect(events, timeout=None):
    waiter = Event()
    for e in events:
        e.rawlink(waiter.set)
    waiter.wait(timeout)
    return ifilter(methodcaller('is_set'), events)

michelp

Installed /home/michel/dev/bedrock                                                                                                           
Processing dependencies for bedrock==0.0.0                                                                                                   
Searching for pycassa==1.6.0                                                                                                                 
Reading http://pypi.python.org/simple/pycassa/                                                                                               
Reading http://github.com/pycassa/pycassa                                                                                                    
Best match: pycassa 1.6.0                                                                                                                    
Downloading http://pypi.python.org/packages/source/p/pycassa/pycassa-1.6.0.tar.gz#md5=d22b78175f9fb3ff05c5fe53a28df901                       
Processing pycassa-1.6.0.tar.g

michelp

michel@ubuntu:~/tmp/bar$ bin/easy_install pycassa==1.6.0
Searching for pycassa==1.6.0
Reading http://pypi.python.org/simple/pycassa/
Reading http://github.com/pycassa/pycassa
Best match: pycassa 1.6.0
Downloading http://pypi.python.org/packages/source/p/pycassa/pycassa-1.6.0.tar.gz#md5=d22b78175f9fb3ff05c5fe53a28df901
Processing pycassa-1.6.0.tar.gz
Running pycassa-1.6.0/setup.py -q bdist_egg --dist-dir /tmp/easy_install-66DMbZ/pycassa-1.6.0/egg-dist-tmp-g8XBWo
zip_safe flag not set; analyzing archive contents...
Adding pycassa 1.6.0 to easy-install.pth file

michelp

"""
Example for waking a poller in another thread by using a PUSH/PULL waker socket pair
"""
import threading
import time
import zmq

ctx = zmq.Context()

# setup the wake machinery

michelp

>>> try:
...  s = gevent.spawn(lambda: 1/0).join()
... except ZeroDivisionError:
...  print 'boop'
... 
Traceback (most recent call last):
  File "/home/michel/dev/sb/local/lib/python2.7/site-packages/gevent-0.13.7-py2.7-linux-i686.egg/gevent/greenlet.py", line 390, in run
    result = self._run(*self.args, **self.kwargs)
  File "<stdin>", line 2, in <lambda>
ZeroDivisionError: integer division or modulo by zero

michelp

    def _run(self):
        try:
            gevent.joinall([gevent.spawn(j) for j in 
                            (self._read_sub, self._read_router, self._send_pub)])
        finally:
            self.context.term()

michelp

        parser = App.build_option_parser(self, description, version)
        parser.add_argument(
            '-c', '--control',
            dest='control',
            default='ipc://control.sock',
            help='Endpoint for nrv control.',
            )
        return parser

    def prepare_to_run_command(self, cmd):