1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
from pydev_imports import SimpleXMLRPCServer
from pydev_ipython.inputhook import get_inputhook, set_return_control_callback
import select
import sys
select_fn = select.select
if sys.platform.startswith('java'):
select_fn = select.cpython_compatible_select
class InputHookedXMLRPCServer(SimpleXMLRPCServer):
''' An XML-RPC Server that can run hooks while polling for new requests.
This code was designed to work with IPython's inputhook methods and
to allow Debug framework to have a place to run commands during idle
too.
'''
def __init__(self, *args, **kwargs):
SimpleXMLRPCServer.__init__(self, *args, **kwargs)
# Tell the inputhook mechanisms when control should be returned
set_return_control_callback(self.return_control)
self.debug_hook = None
self.return_control_osc = False
def return_control(self):
''' A function that the inputhooks can call (via inputhook.stdin_ready()) to find
out if they should cede control and return '''
if self.debug_hook:
# Some of the input hooks check return control without doing
# a single operation, so we don't return True on every
# call when the debug hook is in place to allow the GUI to run
# XXX: Eventually the inputhook code will have diverged enough
# from the IPython source that it will be worthwhile rewriting
# it rather than pretending to maintain the old API
self.return_control_osc = not self.return_control_osc
if self.return_control_osc:
return True
r, unused_w, unused_e = select_fn([self], [], [], 0)
return bool(r)
def setDebugHook(self, debug_hook):
self.debug_hook = debug_hook
def serve_forever(self):
''' Serve forever, running defined hooks regularly and when idle.
Does not support shutdown '''
inputhook = get_inputhook()
while True:
# Block for default 1/2 second when no GUI is in progress
timeout = 0.5
if self.debug_hook:
self.debug_hook()
timeout = 0.1
if inputhook:
try:
inputhook()
# The GUI has given us an opportunity to try receiving, normally
# this happens because the input hook has already polled the
# server has knows something is waiting
timeout = 0.020
except:
inputhook = None
r, unused_w, unused_e = select_fn([self], [], [], timeout)
if self in r:
try:
self._handle_request_noblock()
except AttributeError:
# Older libraries do not support _handle_request_noblock, so fall
# back to the handle_request version
self.handle_request()
# Running the request may have changed the inputhook in use
inputhook = get_inputhook()
def shutdown(self):
raise NotImplementedError('InputHookedXMLRPCServer does not support shutdown')
|
