forked from fabioz/PyDev.Debugger
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merged PR fabioz#156, updated it with fixes PR ipython/ipython#12804 …
…and PR ipython/ipython#12807
- Loading branch information
Showing
2 changed files
with
219 additions
and
26 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,209 @@ | ||
| """Inputhook for OS X | ||
| Calls NSApp / CoreFoundation APIs via ctypes. | ||
| """ | ||
|
|
||
| import os | ||
| from pydev_ipython.inputhook import stdin_ready | ||
| import time | ||
| from _pydev_imps._pydev_saved_modules import threading as _threading_ | ||
|
|
||
| # obj-c boilerplate from appnope, used under BSD 2-clause | ||
|
|
||
| import ctypes | ||
| import ctypes.util | ||
|
|
||
| objc = ctypes.cdll.LoadLibrary(ctypes.util.find_library('objc')) | ||
|
|
||
| void_p = ctypes.c_void_p | ||
|
|
||
| objc.objc_getClass.restype = void_p | ||
| objc.sel_registerName.restype = void_p | ||
| objc.objc_msgSend.restype = void_p | ||
| objc.objc_msgSend.argtypes = [void_p, void_p] | ||
|
|
||
| msg = objc.objc_msgSend | ||
|
|
||
| ccounter = True | ||
|
|
||
| def _utf8(s): | ||
| """ensure utf8 bytes""" | ||
| if not isinstance(s, bytes): | ||
| s = s.encode('utf8') | ||
| return s | ||
|
|
||
| def n(name): | ||
| """create a selector name (for ObjC methods)""" | ||
| return objc.sel_registerName(_utf8(name)) | ||
|
|
||
| def C(classname): | ||
| """get an ObjC Class by name""" | ||
| return objc.objc_getClass(_utf8(classname)) | ||
|
|
||
| # end obj-c boilerplate from appnope | ||
|
|
||
| # CoreFoundation C-API calls we will use: | ||
| CoreFoundation = ctypes.cdll.LoadLibrary(ctypes.util.find_library('CoreFoundation')) | ||
|
|
||
| CFFileDescriptorCreate = CoreFoundation.CFFileDescriptorCreate | ||
| CFFileDescriptorCreate.restype = void_p | ||
| CFFileDescriptorCreate.argtypes = [void_p, ctypes.c_int, ctypes.c_bool, void_p, void_p] | ||
|
|
||
| CFFileDescriptorGetNativeDescriptor = CoreFoundation.CFFileDescriptorGetNativeDescriptor | ||
| CFFileDescriptorGetNativeDescriptor.restype = ctypes.c_int | ||
| CFFileDescriptorGetNativeDescriptor.argtypes = [void_p] | ||
|
|
||
| CFFileDescriptorEnableCallBacks = CoreFoundation.CFFileDescriptorEnableCallBacks | ||
| CFFileDescriptorEnableCallBacks.restype = None | ||
| CFFileDescriptorEnableCallBacks.argtypes = [void_p, ctypes.c_ulong] | ||
|
|
||
| CFFileDescriptorCreateRunLoopSource = CoreFoundation.CFFileDescriptorCreateRunLoopSource | ||
| CFFileDescriptorCreateRunLoopSource.restype = void_p | ||
| CFFileDescriptorCreateRunLoopSource.argtypes = [void_p, void_p, void_p] | ||
|
|
||
| CFRunLoopGetCurrent = CoreFoundation.CFRunLoopGetCurrent | ||
| CFRunLoopGetCurrent.restype = void_p | ||
|
|
||
| CFRunLoopAddSource = CoreFoundation.CFRunLoopAddSource | ||
| CFRunLoopAddSource.restype = None | ||
| CFRunLoopAddSource.argtypes = [void_p, void_p, void_p] | ||
|
|
||
| CFRelease = CoreFoundation.CFRelease | ||
| CFRelease.restype = None | ||
| CFRelease.argtypes = [void_p] | ||
|
|
||
| CFFileDescriptorInvalidate = CoreFoundation.CFFileDescriptorInvalidate | ||
| CFFileDescriptorInvalidate.restype = None | ||
| CFFileDescriptorInvalidate.argtypes = [void_p] | ||
|
|
||
| # From CFFileDescriptor.h | ||
| kCFFileDescriptorReadCallBack = 1 | ||
| kCFRunLoopCommonModes = void_p.in_dll(CoreFoundation, 'kCFRunLoopCommonModes') | ||
|
|
||
|
|
||
| def _NSApp(): | ||
| """Return the global NSApplication instance (NSApp)""" | ||
| objc.objc_msgSend.argtypes = [void_p, void_p] | ||
| return msg(C('NSApplication'), n('sharedApplication')) | ||
|
|
||
|
|
||
| def _wake(NSApp): | ||
| """Wake the Application""" | ||
| objc.objc_msgSend.argtypes = [ | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| void_p, | ||
| ] | ||
| event = msg( | ||
| C("NSEvent"), | ||
| n( | ||
| "otherEventWithType:location:modifierFlags:" | ||
| "timestamp:windowNumber:context:subtype:data1:data2:" | ||
| ), | ||
| 15, # Type | ||
| 0, # location | ||
| 0, # flags | ||
| 0, # timestamp | ||
| 0, # window | ||
| None, # context | ||
| 0, # subtype | ||
| 0, # data1 | ||
| 0, # data2 | ||
| ) | ||
| objc.objc_msgSend.argtypes = [void_p, void_p, void_p, void_p] | ||
| msg(NSApp, n('postEvent:atStart:'), void_p(event), True) | ||
|
|
||
|
|
||
| _triggered = _threading_.Event() | ||
|
|
||
| def _input_callback(fdref, flags, info): | ||
| """Callback to fire when there's input to be read""" | ||
|
|
||
| _triggered.set() | ||
| CFFileDescriptorInvalidate(fdref) | ||
| CFRelease(fdref) | ||
| NSApp = _NSApp() | ||
| objc.objc_msgSend.argtypes = [void_p, void_p, void_p] | ||
| msg(NSApp, n('stop:'), NSApp) | ||
| _wake(NSApp) | ||
|
|
||
| _c_callback_func_type = ctypes.CFUNCTYPE(None, void_p, void_p, void_p) | ||
| _c_input_callback = _c_callback_func_type(_input_callback) | ||
|
|
||
| def _stop_on_read(fd): | ||
| """Register callback to stop eventloop when there's data on fd""" | ||
|
|
||
| _triggered.clear() | ||
| fdref = CFFileDescriptorCreate(None, fd, False, _c_input_callback, None) | ||
| CFFileDescriptorEnableCallBacks(fdref, kCFFileDescriptorReadCallBack) | ||
| source = CFFileDescriptorCreateRunLoopSource(None, fdref, 0) | ||
| loop = CFRunLoopGetCurrent() | ||
| CFRunLoopAddSource(loop, source, kCFRunLoopCommonModes) | ||
| CFRelease(source) | ||
|
|
||
|
|
||
| class Timer(_threading_.Thread): | ||
| def __init__(self, callback=None, interval=0.1): | ||
| super().__init__() | ||
| self.callback = callback | ||
| self.interval = interval | ||
| self._stopev = _threading_.Event() | ||
|
|
||
| def run(self, *args, **kwargs): | ||
| if callable(self.callback): | ||
| while not self._stopev.is_set(): | ||
| time.sleep(self.interval) | ||
| self.callback(self._stopev) | ||
|
|
||
|
|
||
| class FHSingleton(object): | ||
| """Implements a singleton resource manager for pipes. Avoids opening and | ||
| closing pipes during event loops. | ||
| """ | ||
| _instance = None | ||
| def __new__(cls): | ||
| if cls._instance is None: | ||
| cls._instance = super().__new__(cls) | ||
| cls.rh, cls.wh = os.pipe() | ||
| else: | ||
| # Clears the character written to trigger callback in the last | ||
| # loop. | ||
| os.read(cls.rh, 1) | ||
|
|
||
| return cls._instance | ||
|
|
||
|
|
||
| def inputhook_mac(): | ||
| fh = FHSingleton() | ||
|
|
||
| # stop_cb is used to cleanly terminate loop when last figure window is | ||
| # closed. | ||
| stop_cb = _threading_.Event() | ||
| def inputhook_cb(stop): | ||
| if stop_cb.is_set() or stdin_ready(): | ||
| os.write(fh.wh, b'x') | ||
| stop.set() | ||
|
|
||
|
|
||
| t = Timer(callback=inputhook_cb) | ||
| t.start() | ||
| NSApp = _NSApp() | ||
| objc.objc_msgSend.argtypes = [void_p, void_p] | ||
| _stop_on_read(fh.rh) | ||
| msg(NSApp, n('run')) | ||
| if not _triggered.is_set(): | ||
| # app closed without firing callback, | ||
| # probably due to last window being closed. | ||
| # Run the loop manually in this case, | ||
| # since there may be events still to process (#9734) | ||
| CoreFoundation.CFRunLoopRun() | ||
| stop_cb.set() | ||
| t.join() |