Integrate select-based listener (#48)
* add SelectListener * add SelectListener * test out select listener * fix tests * fix tests * fix tests * fix tests * fix tests * refactor * refactor * more secure registering in epoll listener * more secure registering in epoll listener, v1.1.1 * reduced timeout for select listener * refactor * refactor * refactor * got rid of monotonic dependency for Python 3.x * instantiate listener_class * daemonize the thread in constructor * daemonize the thread in constructor * refactor * refactor * refactor * refactor * more refactor * more refactor * more refactor * more refactor * don't overwrite client data * run these tests verbose * run these tests verbose * ImportError fix * fix tests for monotonic
Showing
- .travis.yml 5 additions, 3 deletions.travis.yml
- CHANGELOG.md 2 additions, 1 deletionCHANGELOG.md
- README.md 3 additions, 1 deletionREADME.md
- compile_definitions/xml_fields.py 1 addition, 1 deletioncompile_definitions/xml_fields.py
- coolamqp/__init__.py 1 addition, 1 deletioncoolamqp/__init__.py
- coolamqp/attaches/channeler.py 4 additions, 4 deletionscoolamqp/attaches/channeler.py
- coolamqp/attaches/publisher.py 2 additions, 2 deletionscoolamqp/attaches/publisher.py
- coolamqp/clustering/cluster.py 3 additions, 3 deletionscoolamqp/clustering/cluster.py
- coolamqp/clustering/single.py 6 additions, 1 deletioncoolamqp/clustering/single.py
- coolamqp/uplink/connection/connection.py 8 additions, 7 deletionscoolamqp/uplink/connection/connection.py
- coolamqp/uplink/handshake.py 5 additions, 6 deletionscoolamqp/uplink/handshake.py
- coolamqp/uplink/heartbeat.py 5 additions, 5 deletionscoolamqp/uplink/heartbeat.py
- coolamqp/uplink/listener/base_listener.py 100 additions, 0 deletionscoolamqp/uplink/listener/base_listener.py
- coolamqp/uplink/listener/epoll_listener.py 27 additions, 84 deletionscoolamqp/uplink/listener/epoll_listener.py
- coolamqp/uplink/listener/select_listener.py 75 additions, 0 deletionscoolamqp/uplink/listener/select_listener.py
- coolamqp/uplink/listener/socket.py 17 additions, 8 deletionscoolamqp/uplink/listener/socket.py
- coolamqp/uplink/listener/thread.py 42 additions, 13 deletionscoolamqp/uplink/listener/thread.py
- coolamqp/utils.py 19 additions, 0 deletionscoolamqp/utils.py
- setup.py 3 additions, 2 deletionssetup.py
- tests/test_clustering/test_a.py 3 additions, 3 deletionstests/test_clustering/test_a.py
Loading
Please register or sign in to comment