equal
deleted
inserted
replaced
26 import Queue as _queue |
26 import Queue as _queue |
27 import SocketServer as socketserver |
27 import SocketServer as socketserver |
28 import xmlrpclib |
28 import xmlrpclib |
29 |
29 |
30 from .thirdparty.concurrent import futures |
30 from .thirdparty.concurrent import futures |
|
31 |
|
32 def future_set_exception_info(f, exc_info): |
|
33 f.set_exception_info(*exc_info) |
31 else: |
34 else: |
32 import concurrent.futures as futures |
35 import concurrent.futures as futures |
33 import http.cookiejar as cookielib |
36 import http.cookiejar as cookielib |
34 import http.client as httplib |
37 import http.client as httplib |
35 import pickle |
38 import pickle |
36 import queue as _queue |
39 import queue as _queue |
37 import socketserver |
40 import socketserver |
38 import xmlrpc.client as xmlrpclib |
41 import xmlrpc.client as xmlrpclib |
|
42 |
|
43 def future_set_exception_info(f, exc_info): |
|
44 f.set_exception(exc_info[0]) |
39 |
45 |
40 empty = _queue.Empty |
46 empty = _queue.Empty |
41 queue = _queue.Queue |
47 queue = _queue.Queue |
42 |
48 |
43 def identity(a): |
49 def identity(a): |