/usr/share/pyshared/ppworker.py is in python-pp 1.6.4-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 | # Parallel Python Software: http://www.parallelpython.com
# Copyright (c) 2005-2012, Vitalii Vanovschi
# All rights reserved.
# Redistribution and use in source and binary forms, with or without
# modification, are permitted provided that the following conditions are met:
# * Redistributions of source code must retain the above copyright notice,
# this list of conditions and the following disclaimer.
# * Redistributions in binary form must reproduce the above copyright
# notice, this list of conditions and the following disclaimer in the
# documentation and/or other materials provided with the distribution.
# * Neither the name of the author nor the names of its contributors
# may be used to endorse or promote products derived from this software
# without specific prior written permission.
#
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
# AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
# ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
# LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
# CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
# SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
# INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
# CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
# ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
# THE POSSIBILITY OF SUCH DAMAGE.
"""
Parallel Python Software, PP Worker
http://www.parallelpython.com - updates, documentation, examples and support
forums
"""
import sys
import os
import StringIO
import cPickle as pickle
import pptransport
copyright = "Copyright (c) 2005-2012 Vitalii Vanovschi. All rights reserved"
version = "1.6.4"
def preprocess(msg):
fname, fsources, imports = pickle.loads(msg)
fobjs = [compile(fsource, '<string>', 'exec') for fsource in fsources]
for module in imports:
try:
if not module.startswith("from ") and not module.startswith("import "):
module = "import " + module
exec module
globals().update(locals())
except:
print "An error has occured during the module import"
sys.excepthook(*sys.exc_info())
return fname, fobjs
class _WorkerProcess(object):
def __init__(self):
self.hashmap = {}
self.e = sys.__stderr__
self.sout = StringIO.StringIO()
# self.sout = open("/tmp/pp.debug","a+")
sys.stdout = self.sout
sys.stderr = self.sout
self.t = pptransport.CPipeTransport(sys.stdin, sys.__stdout__)
self.t.send(str(os.getpid()))
self.pickle_proto = int(self.t.receive())
def run(self):
try:
#execution cycle
while 1:
__fname, __fobjs = self.t.creceive(preprocess)
__sargs = self.t.receive()
for __fobj in __fobjs:
try:
exec __fobj
globals().update(locals())
except:
print "An error has occured during the " + \
"function import"
sys.excepthook(*sys.exc_info())
__args = pickle.loads(__sargs)
__f = locals()[__fname]
try:
__result = __f(*__args)
except:
print "An error has occured during the function execution"
sys.excepthook(*sys.exc_info())
__result = None
__sresult = pickle.dumps((__result, self.sout.getvalue()),
self.pickle_proto)
self.t.send(__sresult)
self.sout.truncate(0)
except:
print "A fatal error has occured during the function execution"
sys.excepthook(*sys.exc_info())
__result = None
__sresult = pickle.dumps((__result, self.sout.getvalue()),
self.pickle_proto)
self.t.send(__sresult)
if __name__ == "__main__":
# add the directory with ppworker.py to the path
sys.path.append(os.path.dirname(__file__))
wp = _WorkerProcess()
wp.run()
# Parallel Python Software: http://www.parallelpython.com
|