Skip to content
Snippets Groups Projects
Commit d8e7cdd0 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

v1.2.10

parent b03b22d0
No related branches found
Tags v1.2.10
No related merge requests found
...@@ -4,3 +4,4 @@ have been made so far, between releases. ...@@ -4,3 +4,4 @@ have been made so far, between releases.
# v1.2.10 # v1.2.10
* made CoolAMQP importable on Windows
__version__ = '1.2.10_a2' __version__ = '1.2.10'
...@@ -14,8 +14,13 @@ from coolamqp.uplink.listener.base_listener import BaseListener ...@@ -14,8 +14,13 @@ from coolamqp.uplink.listener.base_listener import BaseListener
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
RO = select.EPOLLIN | select.EPOLLHUP | select.EPOLLERR try:
RW = RO | select.EPOLLOUT RO = select.EPOLLIN | select.EPOLLHUP | select.EPOLLERR
RW = RO | select.EPOLLOUT
except AttributeError:
# epoll listener will be unusable anyway
RO = 0
RW = 1
class EpollSocket(BaseSocket): class EpollSocket(BaseSocket):
......
...@@ -20,6 +20,7 @@ def get_listener_class(): # type: () -> tp.Type[BaseListener] ...@@ -20,6 +20,7 @@ def get_listener_class(): # type: () -> tp.Type[BaseListener]
try: try:
import select import select
select.EPOLLIN
select.epoll select.epoll
except AttributeError: except AttributeError:
return SelectListener # we're running on a platform that doesn't support epoll return SelectListener # we're running on a platform that doesn't support epoll
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment