Commit 9c014706 authored by Jason Madden's avatar Jason Madden

More FFI fallout cleanup.

parent 17b074ff
...@@ -106,6 +106,10 @@ class AbstractWatcherType(type): ...@@ -106,6 +106,10 @@ class AbstractWatcherType(type):
def _fill_watcher(cls, name, bases, cls_dict): def _fill_watcher(cls, name, bases, cls_dict):
# TODO: refactor smaller # TODO: refactor smaller
# pylint:disable=too-many-locals # pylint:disable=too-many-locals
if name.endswith('_'):
# Strip trailing _ added to avoid keyword duplications
# e.g., async_
name = name[:-1]
def _mro_get(attr, bases, error=True): def _mro_get(attr, bases, error=True):
for b in bases: for b in bases:
try: try:
......
...@@ -444,7 +444,7 @@ class _SimulatedWithAsyncMixin(object): ...@@ -444,7 +444,7 @@ class _SimulatedWithAsyncMixin(object):
_watcher_skip_ffi = True _watcher_skip_ffi = True
def __init__(self, loop, *args, **kwargs): def __init__(self, loop, *args, **kwargs):
self._async = loop.async() self._async = loop.async_()
super(_SimulatedWithAsyncMixin, self).__init__(loop, *args, **kwargs) super(_SimulatedWithAsyncMixin, self).__init__(loop, *args, **kwargs)
def _watcher_create(self, _args): def _watcher_create(self, _args):
...@@ -538,8 +538,6 @@ class child(_SimulatedWithAsyncMixin, ...@@ -538,8 +538,6 @@ class child(_SimulatedWithAsyncMixin,
class async_(_base.AsyncMixin, watcher): class async_(_base.AsyncMixin, watcher):
_watcher_struct_name = 'uv_async_t'
def _watcher_ffi_init(self, args): def _watcher_ffi_init(self, args):
# It's dangerous to have a raw, non-initted struct # It's dangerous to have a raw, non-initted struct
# around; it will crash in uv_close() when we get GC'd, # around; it will crash in uv_close() when we get GC'd,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment