[Pymoul-svn] SF.net SVN: pymoul: [204] enumprocess/tags
Status: Alpha
Brought to you by:
tiran
From: <ti...@us...> - 2007-02-27 14:32:21
|
Revision: 204 http://pymoul.svn.sourceforge.net/pymoul/?rev=204&view=rev Author: tiran Date: 2007-02-27 06:32:21 -0800 (Tue, 27 Feb 2007) Log Message: ----------- Tagging 0.1 release Added Paths: ----------- enumprocess/tags/0.1/ enumprocess/tags/0.1/CHANGES.txt enumprocess/tags/0.1/INSTALL.txt enumprocess/tags/0.1/LICENSE.txt enumprocess/tags/0.1/README.txt enumprocess/tags/0.1/ez_setup.py enumprocess/tags/0.1/setup.py enumprocess/tags/0.1/src/enumprocess/__init__.py enumprocess/tags/0.1/src/enumprocess/processinfo.py enumprocess/tags/0.1/src/enumprocess.egg-info/SOURCES.txt enumprocess/tags/0.1/src/enumprocess.egg-info/dependency_links.txt enumprocess/tags/0.1/src/enumprocess.egg-info/top_level.txt enumprocess/tags/0.1/version.txt Removed Paths: ------------- enumprocess/tags/0.1/CHANGES.txt enumprocess/tags/0.1/INSTALL.txt enumprocess/tags/0.1/LICENSE.txt enumprocess/tags/0.1/README.txt enumprocess/tags/0.1/ez_setup.py enumprocess/tags/0.1/setup.py enumprocess/tags/0.1/src/enumprocess/__init__.py enumprocess/tags/0.1/src/enumprocess/processinfo.py enumprocess/tags/0.1/src/enumprocess.egg-info/SOURCES.txt enumprocess/tags/0.1/src/enumprocess.egg-info/dependency_links.txt enumprocess/tags/0.1/src/enumprocess.egg-info/top_level.txt enumprocess/tags/0.1/version.txt Copied: enumprocess/tags/0.1 (from rev 202, enumprocess/trunk) Deleted: enumprocess/tags/0.1/CHANGES.txt =================================================================== Copied: enumprocess/tags/0.1/CHANGES.txt (from rev 203, enumprocess/trunk/CHANGES.txt) =================================================================== Deleted: enumprocess/tags/0.1/INSTALL.txt =================================================================== --- enumprocess/trunk/INSTALL.txt 2007-02-27 14:29:15 UTC (rev 202) +++ enumprocess/tags/0.1/INSTALL.txt 2007-02-27 14:32:21 UTC (rev 204) @@ -1,13 +0,0 @@ -============ -Requirements -============ - - * Python 2.4+ http://www.python.org/ - * easy_install http://peak.telecommunity.com/DevCenter/EasyInstall - * setuptools (via easy install) - -============ -Installation -============ - - $ python setup.py install Copied: enumprocess/tags/0.1/INSTALL.txt (from rev 203, enumprocess/trunk/INSTALL.txt) =================================================================== --- enumprocess/tags/0.1/INSTALL.txt (rev 0) +++ enumprocess/tags/0.1/INSTALL.txt 2007-02-27 14:32:21 UTC (rev 204) @@ -0,0 +1,13 @@ +============ +Requirements +============ + + * Python 2.4+ http://www.python.org/ + * easy_install http://peak.telecommunity.com/DevCenter/EasyInstall + * setuptools (via easy install) + +============ +Installation +============ + + $ python setup.py install Deleted: enumprocess/tags/0.1/LICENSE.txt =================================================================== --- enumprocess/trunk/LICENSE.txt 2007-02-27 14:29:15 UTC (rev 202) +++ enumprocess/tags/0.1/LICENSE.txt 2007-02-27 14:32:21 UTC (rev 204) @@ -1,29 +0,0 @@ -Copyright (c) 2007 Christian Heimes. All rights reserved. - -Redistribution and use in source and binary forms, with or without -modification, are permitted provided that the following conditions are -met: - - 1. Redistributions of source code must retain the above copyright - notice, this list of conditions and the following disclaimer. - - 2. 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. - - 3. Neither the name of Infrae 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 INFRAE 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. Copied: enumprocess/tags/0.1/LICENSE.txt (from rev 203, enumprocess/trunk/LICENSE.txt) =================================================================== --- enumprocess/tags/0.1/LICENSE.txt (rev 0) +++ enumprocess/tags/0.1/LICENSE.txt 2007-02-27 14:32:21 UTC (rev 204) @@ -0,0 +1,29 @@ +Copyright (c) 2007 Christian Heimes. All rights reserved. + +Redistribution and use in source and binary forms, with or without +modification, are permitted provided that the following conditions are +met: + + 1. Redistributions of source code must retain the above copyright + notice, this list of conditions and the following disclaimer. + + 2. 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. + + 3. Neither the name of Infrae 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 INFRAE 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. Deleted: enumprocess/tags/0.1/README.txt =================================================================== --- enumprocess/trunk/README.txt 2007-02-27 14:29:15 UTC (rev 202) +++ enumprocess/tags/0.1/README.txt 2007-02-27 14:32:21 UTC (rev 204) @@ -1,17 +0,0 @@ -enumprocess -=========== - -The package contains for implementations: - - - an Unsupported implementation that raises UnsupportedError - - a Linux implementation that read the data from /proc - - a Unix/POSIX implementation that parses the output of ps - - a Windows implementation that uses ctypes to get the infos from psapi.dll - -API -=== - -getPids() - list of ints/longs -getPidNames() - mapping pid -> name -getPidDetails(pid) - detailed informations about a process -getPidDetails('self') - detailed informations about current process \ No newline at end of file Copied: enumprocess/tags/0.1/README.txt (from rev 203, enumprocess/trunk/README.txt) =================================================================== --- enumprocess/tags/0.1/README.txt (rev 0) +++ enumprocess/tags/0.1/README.txt 2007-02-27 14:32:21 UTC (rev 204) @@ -0,0 +1,17 @@ +enumprocess +=========== + +The package contains for implementations: + + - an Unsupported implementation that raises UnsupportedError + - a Linux implementation that read the data from /proc + - a Unix/POSIX implementation that parses the output of ps + - a Windows implementation that uses ctypes to get the infos from psapi.dll + +API +=== + +getPids() - list of ints/longs +getPidNames() - mapping pid -> name +getPidDetails(pid) - detailed informations about a process +getPidDetails('self') - detailed informations about current process \ No newline at end of file Deleted: enumprocess/tags/0.1/ez_setup.py =================================================================== --- enumprocess/trunk/ez_setup.py 2007-02-27 14:29:15 UTC (rev 202) +++ enumprocess/tags/0.1/ez_setup.py 2007-02-27 14:32:21 UTC (rev 204) @@ -1,228 +0,0 @@ -#!python -"""Bootstrap setuptools installation - -If you want to use setuptools in your package's setup.py, just include this -file in the same directory with it, and add this to the top of your setup.py:: - - from ez_setup import use_setuptools - use_setuptools() - -If you want to require a specific version of setuptools, set a download -mirror, or use an alternate download directory, you can do so by supplying -the appropriate options to ``use_setuptools()``. - -This file can also be run as a script to install or upgrade setuptools. -""" -import sys -DEFAULT_VERSION = "0.6c5" -DEFAULT_URL = "http://cheeseshop.python.org/packages/%s/s/setuptools/" % sys.version[:3] - -md5_data = { - 'setuptools-0.6b1-py2.3.egg': '8822caf901250d848b996b7f25c6e6ca', - 'setuptools-0.6b1-py2.4.egg': 'b79a8a403e4502fbb85ee3f1941735cb', - 'setuptools-0.6b2-py2.3.egg': '5657759d8a6d8fc44070a9d07272d99b', - 'setuptools-0.6b2-py2.4.egg': '4996a8d169d2be661fa32a6e52e4f82a', - 'setuptools-0.6b3-py2.3.egg': 'bb31c0fc7399a63579975cad9f5a0618', - 'setuptools-0.6b3-py2.4.egg': '38a8c6b3d6ecd22247f179f7da669fac', - 'setuptools-0.6b4-py2.3.egg': '62045a24ed4e1ebc77fe039aa4e6f7e5', - 'setuptools-0.6b4-py2.4.egg': '4cb2a185d228dacffb2d17f103b3b1c4', - 'setuptools-0.6c1-py2.3.egg': 'b3f2b5539d65cb7f74ad79127f1a908c', - 'setuptools-0.6c1-py2.4.egg': 'b45adeda0667d2d2ffe14009364f2a4b', - 'setuptools-0.6c2-py2.3.egg': 'f0064bf6aa2b7d0f3ba0b43f20817c27', - 'setuptools-0.6c2-py2.4.egg': '616192eec35f47e8ea16cd6a122b7277', - 'setuptools-0.6c3-py2.3.egg': 'f181fa125dfe85a259c9cd6f1d7b78fa', - 'setuptools-0.6c3-py2.4.egg': 'e0ed74682c998bfb73bf803a50e7b71e', - 'setuptools-0.6c3-py2.5.egg': 'abef16fdd61955514841c7c6bd98965e', - 'setuptools-0.6c4-py2.3.egg': 'b0b9131acab32022bfac7f44c5d7971f', - 'setuptools-0.6c4-py2.4.egg': '2a1f9656d4fbf3c97bf946c0a124e6e2', - 'setuptools-0.6c4-py2.5.egg': '8f5a052e32cdb9c72bcf4b5526f28afc', - 'setuptools-0.6c5-py2.3.egg': 'ee9fd80965da04f2f3e6b3576e9d8167', - 'setuptools-0.6c5-py2.4.egg': 'afe2adf1c01701ee841761f5bcd8aa64', - 'setuptools-0.6c5-py2.5.egg': 'a8d3f61494ccaa8714dfed37bccd3d5d', -} - -import sys, os - -def _validate_md5(egg_name, data): - if egg_name in md5_data: - from md5 import md5 - digest = md5(data).hexdigest() - if digest != md5_data[egg_name]: - print >>sys.stderr, ( - "md5 validation of %s failed! (Possible download problem?)" - % egg_name - ) - sys.exit(2) - return data - - -def use_setuptools( - version=DEFAULT_VERSION, download_base=DEFAULT_URL, to_dir=os.curdir, - download_delay=15 -): - """Automatically find/download setuptools and make it available on sys.path - - `version` should be a valid setuptools version number that is available - as an egg for download under the `download_base` URL (which should end with - a '/'). `to_dir` is the directory where setuptools will be downloaded, if - it is not already available. If `download_delay` is specified, it should - be the number of seconds that will be paused before initiating a download, - should one be required. If an older version of setuptools is installed, - this routine will print a message to ``sys.stderr`` and raise SystemExit in - an attempt to abort the calling script. - """ - try: - import setuptools - if setuptools.__version__ == '0.0.1': - print >>sys.stderr, ( - "You have an obsolete version of setuptools installed. Please\n" - "remove it from your system entirely before rerunning this script." - ) - sys.exit(2) - except ImportError: - egg = download_setuptools(version, download_base, to_dir, download_delay) - sys.path.insert(0, egg) - import setuptools; setuptools.bootstrap_install_from = egg - - import pkg_resources - try: - pkg_resources.require("setuptools>="+version) - - except pkg_resources.VersionConflict, e: - # XXX could we install in a subprocess here? - print >>sys.stderr, ( - "The required version of setuptools (>=%s) is not available, and\n" - "can't be installed while this script is running. Please install\n" - " a more recent version first.\n\n(Currently using %r)" - ) % (version, e.args[0]) - sys.exit(2) - -def download_setuptools( - version=DEFAULT_VERSION, download_base=DEFAULT_URL, to_dir=os.curdir, - delay = 15 -): - """Download setuptools from a specified location and return its filename - - `version` should be a valid setuptools version number that is available - as an egg for download under the `download_base` URL (which should end - with a '/'). `to_dir` is the directory where the egg will be downloaded. - `delay` is the number of seconds to pause before an actual download attempt. - """ - import urllib2, shutil - egg_name = "setuptools-%s-py%s.egg" % (version,sys.version[:3]) - url = download_base + egg_name - saveto = os.path.join(to_dir, egg_name) - src = dst = None - if not os.path.exists(saveto): # Avoid repeated downloads - try: - from distutils import log - if delay: - log.warn(""" ---------------------------------------------------------------------------- -This script requires setuptools version %s to run (even to display -help). I will attempt to download it for you (from -%s), but -you may need to enable firewall access for this script first. -I will start the download in %d seconds. - -(Note: if this machine does not have network access, please obtain the file - - %s - -and place it in this directory before rerunning this script.) ----------------------------------------------------------------------------""", - version, download_base, delay, url - ); from time import sleep; sleep(delay) - log.warn("Downloading %s", url) - src = urllib2.urlopen(url) - # Read/write all in one block, so we don't create a corrupt file - # if the download is interrupted. - data = _validate_md5(egg_name, src.read()) - dst = open(saveto,"wb"); dst.write(data) - finally: - if src: src.close() - if dst: dst.close() - return os.path.realpath(saveto) - -def main(argv, version=DEFAULT_VERSION): - """Install or upgrade setuptools and EasyInstall""" - - try: - import setuptools - except ImportError: - egg = None - try: - egg = download_setuptools(version, delay=0) - sys.path.insert(0,egg) - from setuptools.command.easy_install import main - return main(list(argv)+[egg]) # we're done here - finally: - if egg and os.path.exists(egg): - os.unlink(egg) - else: - if setuptools.__version__ == '0.0.1': - # tell the user to uninstall obsolete version - use_setuptools(version) - - req = "setuptools>="+version - import pkg_resources - try: - pkg_resources.require(req) - except pkg_resources.VersionConflict: - try: - from setuptools.command.easy_install import main - except ImportError: - from easy_install import main - main(list(argv)+[download_setuptools(delay=0)]) - sys.exit(0) # try to force an exit - else: - if argv: - from setuptools.command.easy_install import main - main(argv) - else: - print "Setuptools version",version,"or greater has been installed." - print '(Run "ez_setup.py -U setuptools" to reinstall or upgrade.)' - - - -def update_md5(filenames): - """Update our built-in md5 registry""" - - import re - from md5 import md5 - - for name in filenames: - base = os.path.basename(name) - f = open(name,'rb') - md5_data[base] = md5(f.read()).hexdigest() - f.close() - - data = [" %r: %r,\n" % it for it in md5_data.items()] - data.sort() - repl = "".join(data) - - import inspect - srcfile = inspect.getsourcefile(sys.modules[__name__]) - f = open(srcfile, 'rb'); src = f.read(); f.close() - - match = re.search("\nmd5_data = {\n([^}]+)}", src) - if not match: - print >>sys.stderr, "Internal error!" - sys.exit(2) - - src = src[:match.start(1)] + repl + src[match.end(1):] - f = open(srcfile,'w') - f.write(src) - f.close() - - -if __name__=='__main__': - if len(sys.argv)>2 and sys.argv[1]=='--md5update': - update_md5(sys.argv[2:]) - else: - main(sys.argv[1:]) - - - - - Copied: enumprocess/tags/0.1/ez_setup.py (from rev 203, enumprocess/trunk/ez_setup.py) =================================================================== --- enumprocess/tags/0.1/ez_setup.py (rev 0) +++ enumprocess/tags/0.1/ez_setup.py 2007-02-27 14:32:21 UTC (rev 204) @@ -0,0 +1,228 @@ +#!python +"""Bootstrap setuptools installation + +If you want to use setuptools in your package's setup.py, just include this +file in the same directory with it, and add this to the top of your setup.py:: + + from ez_setup import use_setuptools + use_setuptools() + +If you want to require a specific version of setuptools, set a download +mirror, or use an alternate download directory, you can do so by supplying +the appropriate options to ``use_setuptools()``. + +This file can also be run as a script to install or upgrade setuptools. +""" +import sys +DEFAULT_VERSION = "0.6c5" +DEFAULT_URL = "http://cheeseshop.python.org/packages/%s/s/setuptools/" % sys.version[:3] + +md5_data = { + 'setuptools-0.6b1-py2.3.egg': '8822caf901250d848b996b7f25c6e6ca', + 'setuptools-0.6b1-py2.4.egg': 'b79a8a403e4502fbb85ee3f1941735cb', + 'setuptools-0.6b2-py2.3.egg': '5657759d8a6d8fc44070a9d07272d99b', + 'setuptools-0.6b2-py2.4.egg': '4996a8d169d2be661fa32a6e52e4f82a', + 'setuptools-0.6b3-py2.3.egg': 'bb31c0fc7399a63579975cad9f5a0618', + 'setuptools-0.6b3-py2.4.egg': '38a8c6b3d6ecd22247f179f7da669fac', + 'setuptools-0.6b4-py2.3.egg': '62045a24ed4e1ebc77fe039aa4e6f7e5', + 'setuptools-0.6b4-py2.4.egg': '4cb2a185d228dacffb2d17f103b3b1c4', + 'setuptools-0.6c1-py2.3.egg': 'b3f2b5539d65cb7f74ad79127f1a908c', + 'setuptools-0.6c1-py2.4.egg': 'b45adeda0667d2d2ffe14009364f2a4b', + 'setuptools-0.6c2-py2.3.egg': 'f0064bf6aa2b7d0f3ba0b43f20817c27', + 'setuptools-0.6c2-py2.4.egg': '616192eec35f47e8ea16cd6a122b7277', + 'setuptools-0.6c3-py2.3.egg': 'f181fa125dfe85a259c9cd6f1d7b78fa', + 'setuptools-0.6c3-py2.4.egg': 'e0ed74682c998bfb73bf803a50e7b71e', + 'setuptools-0.6c3-py2.5.egg': 'abef16fdd61955514841c7c6bd98965e', + 'setuptools-0.6c4-py2.3.egg': 'b0b9131acab32022bfac7f44c5d7971f', + 'setuptools-0.6c4-py2.4.egg': '2a1f9656d4fbf3c97bf946c0a124e6e2', + 'setuptools-0.6c4-py2.5.egg': '8f5a052e32cdb9c72bcf4b5526f28afc', + 'setuptools-0.6c5-py2.3.egg': 'ee9fd80965da04f2f3e6b3576e9d8167', + 'setuptools-0.6c5-py2.4.egg': 'afe2adf1c01701ee841761f5bcd8aa64', + 'setuptools-0.6c5-py2.5.egg': 'a8d3f61494ccaa8714dfed37bccd3d5d', +} + +import sys, os + +def _validate_md5(egg_name, data): + if egg_name in md5_data: + from md5 import md5 + digest = md5(data).hexdigest() + if digest != md5_data[egg_name]: + print >>sys.stderr, ( + "md5 validation of %s failed! (Possible download problem?)" + % egg_name + ) + sys.exit(2) + return data + + +def use_setuptools( + version=DEFAULT_VERSION, download_base=DEFAULT_URL, to_dir=os.curdir, + download_delay=15 +): + """Automatically find/download setuptools and make it available on sys.path + + `version` should be a valid setuptools version number that is available + as an egg for download under the `download_base` URL (which should end with + a '/'). `to_dir` is the directory where setuptools will be downloaded, if + it is not already available. If `download_delay` is specified, it should + be the number of seconds that will be paused before initiating a download, + should one be required. If an older version of setuptools is installed, + this routine will print a message to ``sys.stderr`` and raise SystemExit in + an attempt to abort the calling script. + """ + try: + import setuptools + if setuptools.__version__ == '0.0.1': + print >>sys.stderr, ( + "You have an obsolete version of setuptools installed. Please\n" + "remove it from your system entirely before rerunning this script." + ) + sys.exit(2) + except ImportError: + egg = download_setuptools(version, download_base, to_dir, download_delay) + sys.path.insert(0, egg) + import setuptools; setuptools.bootstrap_install_from = egg + + import pkg_resources + try: + pkg_resources.require("setuptools>="+version) + + except pkg_resources.VersionConflict, e: + # XXX could we install in a subprocess here? + print >>sys.stderr, ( + "The required version of setuptools (>=%s) is not available, and\n" + "can't be installed while this script is running. Please install\n" + " a more recent version first.\n\n(Currently using %r)" + ) % (version, e.args[0]) + sys.exit(2) + +def download_setuptools( + version=DEFAULT_VERSION, download_base=DEFAULT_URL, to_dir=os.curdir, + delay = 15 +): + """Download setuptools from a specified location and return its filename + + `version` should be a valid setuptools version number that is available + as an egg for download under the `download_base` URL (which should end + with a '/'). `to_dir` is the directory where the egg will be downloaded. + `delay` is the number of seconds to pause before an actual download attempt. + """ + import urllib2, shutil + egg_name = "setuptools-%s-py%s.egg" % (version,sys.version[:3]) + url = download_base + egg_name + saveto = os.path.join(to_dir, egg_name) + src = dst = None + if not os.path.exists(saveto): # Avoid repeated downloads + try: + from distutils import log + if delay: + log.warn(""" +--------------------------------------------------------------------------- +This script requires setuptools version %s to run (even to display +help). I will attempt to download it for you (from +%s), but +you may need to enable firewall access for this script first. +I will start the download in %d seconds. + +(Note: if this machine does not have network access, please obtain the file + + %s + +and place it in this directory before rerunning this script.) +---------------------------------------------------------------------------""", + version, download_base, delay, url + ); from time import sleep; sleep(delay) + log.warn("Downloading %s", url) + src = urllib2.urlopen(url) + # Read/write all in one block, so we don't create a corrupt file + # if the download is interrupted. + data = _validate_md5(egg_name, src.read()) + dst = open(saveto,"wb"); dst.write(data) + finally: + if src: src.close() + if dst: dst.close() + return os.path.realpath(saveto) + +def main(argv, version=DEFAULT_VERSION): + """Install or upgrade setuptools and EasyInstall""" + + try: + import setuptools + except ImportError: + egg = None + try: + egg = download_setuptools(version, delay=0) + sys.path.insert(0,egg) + from setuptools.command.easy_install import main + return main(list(argv)+[egg]) # we're done here + finally: + if egg and os.path.exists(egg): + os.unlink(egg) + else: + if setuptools.__version__ == '0.0.1': + # tell the user to uninstall obsolete version + use_setuptools(version) + + req = "setuptools>="+version + import pkg_resources + try: + pkg_resources.require(req) + except pkg_resources.VersionConflict: + try: + from setuptools.command.easy_install import main + except ImportError: + from easy_install import main + main(list(argv)+[download_setuptools(delay=0)]) + sys.exit(0) # try to force an exit + else: + if argv: + from setuptools.command.easy_install import main + main(argv) + else: + print "Setuptools version",version,"or greater has been installed." + print '(Run "ez_setup.py -U setuptools" to reinstall or upgrade.)' + + + +def update_md5(filenames): + """Update our built-in md5 registry""" + + import re + from md5 import md5 + + for name in filenames: + base = os.path.basename(name) + f = open(name,'rb') + md5_data[base] = md5(f.read()).hexdigest() + f.close() + + data = [" %r: %r,\n" % it for it in md5_data.items()] + data.sort() + repl = "".join(data) + + import inspect + srcfile = inspect.getsourcefile(sys.modules[__name__]) + f = open(srcfile, 'rb'); src = f.read(); f.close() + + match = re.search("\nmd5_data = {\n([^}]+)}", src) + if not match: + print >>sys.stderr, "Internal error!" + sys.exit(2) + + src = src[:match.start(1)] + repl + src[match.end(1):] + f = open(srcfile,'w') + f.write(src) + f.close() + + +if __name__=='__main__': + if len(sys.argv)>2 and sys.argv[1]=='--md5update': + update_md5(sys.argv[2:]) + else: + main(sys.argv[1:]) + + + + + Deleted: enumprocess/tags/0.1/setup.py =================================================================== --- enumprocess/trunk/setup.py 2007-02-27 14:29:15 UTC (rev 202) +++ enumprocess/tags/0.1/setup.py 2007-02-27 14:32:21 UTC (rev 204) @@ -1,64 +0,0 @@ -#!/usr/bin/env python -"""enumprocess: list pids and processes - -TODO: long description -""" -__author__ = "Christian Heimes" -__version__ = "$Id$" -__revision__ = "$Revision$" - -import sys - -if sys.version_info < (2,4): - raise RuntimeError("Python 2.4+ required:\n%s" % sys.version) - -# boot strap easy setup -SETUPTOOLS_VERSION = "0.6c1" -from ez_setup import use_setuptools -use_setuptools(version=SETUPTOOLS_VERSION) - -# import the rest -from setuptools import setup -from setuptools import find_packages - -from distutils.core import setup - -VERSION = "0.1" - -me = "Christian Heimes" -email = "chr...@ch..." - -setup_infos = dict( - name = "enumprocess", - version = VERSION, - description = __doc__[:__doc__.find('\n')].strip(), - long_description = '\n'.join([line - for line in __doc__.split('\n')[1:]]), - author = "Christian Heimes", - author_email = "chr...@ch...", - maintainer = "Christian Heimes", - maintainer_email = "chr...@ch...", - url = "http://sourceforge.net/projects/pymoul/", - download_url= "http://cheeseshop.python.org/pypi/enumprocess", - license = "BSD License", - keywords = ["pid", "process", "enum", "proc", "ps", "psapi"], - platforms=['Independant'], - classifiers = ( - 'Development Status :: 4 - Beta', - 'Intended Audience :: Developers', - 'License :: OSI Approved :: BSD License', - 'Natural Language :: English', - 'Operating System :: Microsoft :: Windows', - 'Operating System :: POSIX', - 'Operating System :: POSIX :: Linux', - 'Programming Language :: Python', - 'Topic :: System', - 'Topic :: Software Development :: Libraries' - ), - setup_requires = ["setuptools>="+SETUPTOOLS_VERSION,], - packages = ['enumprocess'], - package_dir = {'' : 'src'}, - zip_safe = True, -) - -setup(**setup_infos) Copied: enumprocess/tags/0.1/setup.py (from rev 203, enumprocess/trunk/setup.py) =================================================================== --- enumprocess/tags/0.1/setup.py (rev 0) +++ enumprocess/tags/0.1/setup.py 2007-02-27 14:32:21 UTC (rev 204) @@ -0,0 +1,64 @@ +#!/usr/bin/env python +"""enumprocess: list pids and processes + +TODO: long description +""" +__author__ = "Christian Heimes" +__version__ = "$Id$" +__revision__ = "$Revision$" + +import sys + +if sys.version_info < (2,4): + raise RuntimeError("Python 2.4+ required:\n%s" % sys.version) + +# boot strap easy setup +SETUPTOOLS_VERSION = "0.6c1" +from ez_setup import use_setuptools +use_setuptools(version=SETUPTOOLS_VERSION) + +# import the rest +from setuptools import setup +from setuptools import find_packages + +from distutils.core import setup + +VERSION = "0.1" + +me = "Christian Heimes" +email = "chr...@ch..." + +setup_infos = dict( + name = "enumprocess", + version = VERSION, + description = __doc__[:__doc__.find('\n')].strip(), + long_description = '\n'.join([line + for line in __doc__.split('\n')[1:]]), + author = "Christian Heimes", + author_email = "chr...@ch...", + maintainer = "Christian Heimes", + maintainer_email = "chr...@ch...", + url = "http://sourceforge.net/projects/pymoul/", + download_url= "http://cheeseshop.python.org/pypi/enumprocess", + license = "BSD License", + keywords = ["pid", "process", "enum", "proc", "ps", "psapi"], + platforms=['Independant'], + classifiers = ( + 'Development Status :: 4 - Beta', + 'Intended Audience :: Developers', + 'License :: OSI Approved :: BSD License', + 'Natural Language :: English', + 'Operating System :: Microsoft :: Windows', + 'Operating System :: POSIX', + 'Operating System :: POSIX :: Linux', + 'Programming Language :: Python', + 'Topic :: System', + 'Topic :: Software Development :: Libraries' + ), + setup_requires = ["setuptools>="+SETUPTOOLS_VERSION,], + packages = ['enumprocess'], + package_dir = {'' : 'src'}, + zip_safe = True, +) + +setup(**setup_infos) Deleted: enumprocess/tags/0.1/src/enumprocess/__init__.py =================================================================== --- enumprocess/trunk/src/enumprocess/__init__.py 2007-02-27 14:29:15 UTC (rev 202) +++ enumprocess/tags/0.1/src/enumprocess/__init__.py 2007-02-27 14:32:21 UTC (rev 204) @@ -1,32 +0,0 @@ -# Copyright (c) 2007 Christian Heimes. All rights reserved. -# -# Redistribution and use in source and binary forms, with or without -# modification, are permitted provided that the following conditions are -# met: -# -# 1. Redistributions of source code must retain the above copyright -# notice, this list of conditions and the following disclaimer. -# -# 2. 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. -# -# 3. Neither the name of Infrae 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 INFRAE 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. -"""enum processes -""" -from processinfo import * Copied: enumprocess/tags/0.1/src/enumprocess/__init__.py (from rev 203, enumprocess/trunk/src/enumprocess/__init__.py) =================================================================== --- enumprocess/tags/0.1/src/enumprocess/__init__.py (rev 0) +++ enumprocess/tags/0.1/src/enumprocess/__init__.py 2007-02-27 14:32:21 UTC (rev 204) @@ -0,0 +1,32 @@ +# Copyright (c) 2007 Christian Heimes. All rights reserved. +# +# Redistribution and use in source and binary forms, with or without +# modification, are permitted provided that the following conditions are +# met: +# +# 1. Redistributions of source code must retain the above copyright +# notice, this list of conditions and the following disclaimer. +# +# 2. 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. +# +# 3. Neither the name of Infrae 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 INFRAE 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. +"""enum processes +""" +from processinfo import * Deleted: enumprocess/tags/0.1/src/enumprocess/processinfo.py =================================================================== --- enumprocess/trunk/src/enumprocess/processinfo.py 2007-02-27 14:29:15 UTC (rev 202) +++ enumprocess/tags/0.1/src/enumprocess/processinfo.py 2007-02-27 14:32:21 UTC (rev 204) @@ -1,477 +0,0 @@ -# Copyright (c) 2007 Christian Heimes. All rights reserved. -# -# Redistribution and use in source and binary forms, with or without -# modification, are permitted provided that the following conditions are -# met: -# -# 1. Redistributions of source code must retain the above copyright -# notice, this list of conditions and the following disclaimer. -# -# 2. 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. -# -# 3. Neither the name of Infrae 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 INFRAE 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. -"""Get process informations - -The module contains for implementations: - - - an Unsupported implementation that raises UnsupportedError - - a Linux implementation that read the data from /proc - - a Unix/POSIX implementation that parses the output of ps - - a Windows implementation that uses ctypes to get the infos from psapi.dll - -API -=== - getPids() - list of ints/longs - getPidNames() - mapping pid -> name - getPidDetails(pid) - detailed informations about a process - getPidDetails('self') - detailed informations about current process - ->>> cur = os.getpid() ->>> exe = sys.executable ->>> pids = getPids() ->>> pids > 1 -True ->>> isinstance(pids[0], (int, long)) -True ->>> cur in pids -True - ->>> mapping = getPidNames() ->>> cur in mapping -True ->>> mapping[cur].lower() in sys.executable -True - ->>> getPidDetails('self')['name'] == getPidDetails(cur)['name'] -True ->>> getPidDetails(cur)['name'] == mapping[cur] -True - ->>> for impl in (WinEnumProcesses(), LinuxProcReader(), PsParser()): -... if impl.supported(): -... isinstance(impl.getPids(), list) and None -... isinstance(impl.getPidNames(), dict) and None -""" -__author__ = "Christian Heimes" -__version__ = "$Id$" -__revision__ = "$Revision$" -__all__ = ['getPids', 'getPidNames', 'getPidDetails', 'supportedOS', - 'UnsupportedError'] - -import logging -import os -import os.path -import sys - - -LOG = logging.getLogger("processinfo") -NULL = "\x00" - -_plat = sys.platform.startswith -if _plat('win') or _plat('cygwin'): - from ctypes import windll, c_ulong, sizeof, c_buffer, byref - PSAPI = windll.psapi - KERNEL = windll.kernel32 - PROCESS_QUERY_INFORMATION = 0x0400 - PROCESS_VM_READ = 0x0010 - PROCESS_FLAGS = PROCESS_QUERY_INFORMATION | PROCESS_VM_READ -else: - from subprocess import Popen - from subprocess import PIPE - -class UnsupportedError(OSError): - """OS or command not supported error - """ - pass - -class Unsupported(object): - """Unsupported OS implementation - - Raises L{UnsupportedError} - """ - __slots__ = () - - @classmethod - def supported(cls): - """Supported flag property""" - return False - - @classmethod - def log(cls): - """Log information about the implementation""" - LOG.warning("Unsupported OS. Neither proc filesystem nor 'ps' works.") - - @classmethod - def getPids(cls): - """Get a list of pids - - @return: a list of pid numbers - @rtype: list(int) - """ - raise UnsupportedError - - @classmethod - def getPidNames(cls): - """Get a mapping of pid -> name - - @return: mapping of pid -> name - @rtype: dict(int:str) - """ - raise UnsupportedError - - @classmethod - def getPidDetails(pid): - """Get detailed informations about a process - - @param pid: pid number or 'self' - @type pid: int or basestring - @return: detailed information about a process - @rtype: dict(str:data) - """ - raise UnsupportedError - -class PsParser(object): - """Parse the output of the ps command - """ - __slots__ = () - - CMD = "ps -e --no-header --cols=1024" - PIDNAMES = "%s --format=pid,ucmd" % CMD - PIDS = "%s --format=pid" % CMD - - @classmethod - def supported(cls): - """Supported flag property""" - try: - cls._exec(cls.PIDS) - except Exception: # catch all! - return False - else: - return True - - @classmethod - def log(cls): - """Log information about the implementation""" - LOG.debug("Using the 'ps' command on POSIX os") - - @classmethod - def getPids(cls): - """Get a list of pids - """ - stdout = cls._exec(cls.PIDS) - if stdout is None: - return None - pids = [] - for line in stdout: - try: - pid = int(line.strip()) - except ValueError: - pass - else: - pids.append(pid) - return pids - - @classmethod - def getPidNames(cls): - """Get a list of pid -> name - """ - stdout = cls._exec(cls.PIDNAMES) - if stdout is None: - return None - mapping = {} - for line in stdout: - line = line.strip() - idx = line.find(' ') - pid, name = line[:idx], line[idx+1:] - try: - pid = int(pid) - except ValueError: - pass - else: - mapping[pid] = name - return mapping - - @classmethod - def getPidDetails(cls, pid): - """Get detailed informations about a process - - TODO - """ - if pid == 'self': - pid = os.getpid() - raise UnsupportedError("not implemented yet") - - @staticmethod - def _exec(cmd): - """Execute command cmd - - The method waits until the command has finished. It returns None of - something went wrong. - - @param cmd: Command to execute - @type cmd: str - @return: None or stdin as file like object - """ - try: - popen = Popen(cmd, shell=True, bufsize=-1, stdout=PIPE, - env = {'LC_ALL' : 'C'}) - rc = popen.wait() - except (OSError, ValueError): - LOG.exception("Failed to execute '%s'" % cmd) - return None - else: - if rc != 0: - LOG.error("'%s' returned with error code %i" % (cmd, rc)) - return None - else: - return popen.stdout - -class LinuxProcReader(object): - """Get process informations under Linux by reading /proc - - Tested under Linux, may work on other POSIX os with /proc, too. - """ - __slots__ = () - - PROC = "/proc" - - @classmethod - def supported(cls): - return os.path.isfile("%s/self/status" % cls.PROC) - - @classmethod - def log(cls): - """Log information about the implementation""" - LOG.debug("Using the proc filesystem on Linux") - - @classmethod - def getPids(cls): - """Get a list of pids - """ - pids = [] - for name in os.listdir(cls.PROC): - if os.path.isdir(cls.PROC + '/' + name): - try: - pids.append(int(name)) - except ValueError: - pass - return pids - - @classmethod - def getPidNames(cls): - """Get a list of pid -> name - """ - mapping = {} - for pid in cls.getPids(): - name = cls._readProcStatus(pid, searchkey='name') - if name is not None: - mapping[pid] = name - return mapping - - def getPidDetails(cls, pid): - """Get detailed informations about a process - """ - details = cls._readProcStatus(pid) - if details is None: - return None - details.update(cls._readProcOther(pid)) - details['cmdline'] = cls._readProcCmdline(pid) - return details - - @classmethod - def _readProcStatus(cls, pid, searchkey=None): - """Read and parse status informations for PID pid - - pid - pid as long or int or 'self' - - If searchkey is None the method returns a mapping of lower keys - to values (stripped). - If searchkey is given than the method immediatly returns the value - or returns None if they key can't be found. - """ - mapping = {} - status = '%s/%s/status' % (cls.PROC, pid) - try: - # read entiry file to avoid race conditions - lines = open(status, 'r').readlines() - except IOError: - LOG.exception("%s not found" % status) - return None - for line in lines: - try: - key, value = line.split(':\t') - except ValueError: - continue - key = key.lower() - value = value.strip() - #if value.endswith(' kB'): - # value = value[:-3] - if key == searchkey: - return value - mapping[key.lower()] = value - if searchkey is not None: - return None - return mapping - - @classmethod - def _readProcCmdline(cls, pid): - """Read cmdline informations for pid and returns a list similar to sys.argv - """ - try: - # read entiry file to avoid race conditions - data = open('%s/%s/cmdline' % (cls.PROC, pid), 'r').read() - except IOError: - return None - return data.split(NULL) - - @classmethod - def _readProcOther(cls, pid): - """Read other possible useful things - - cwd -> current work directory (may not exist) - exe -> path to executable (may not exist) - """ - return { - 'cwd' : os.path.realpath('%s/%s/cwd' % (cls.PROC, pid)), - 'exe' : os.path.realpath('%s/%s/exe' % (cls.PROC, pid)), - } - -class WinEnumProcesses(object): - """""Get process informations under Win32 with psapi.dll - - Based on enumprocesses from Eric Koome - http://aspn.activestate.com/ASPN/Cookbook/Python/Recipe/305279 - """ - __slots__ = () - - @classmethod - def supported(cls): - try: - cls.getPids() - except Exception: # catch all! - return False - else: - return True - - @classmethod - def log(cls): - """Log information about the implementation""" - LOG.debug("Using ctypes on Windows") - - @classmethod - def getPids(cls): - """Get a list of pids - """ - arr = c_ulong * 256 - lpidProcess = arr() - cb = sizeof(lpidProcess) - cbNeeded = c_ulong() - - # Call Enumprocesses to get hold of process id's - PSAPI.EnumProcesses(byref(lpidProcess), cb, byref(cbNeeded)) - nReturned = cbNeeded.value/sizeof(c_ulong()) # number of processes returned - return [pid for pid in lpidProcess][:nReturned] - - @classmethod - def getPidNames(cls): - """Get a list of pid -> name - """ - hModule = c_ulong() - count = c_ulong() - modname = c_buffer(51) - mapping = {} - for pid in cls.getPids(): - # Get handle to the process based on PID - hProcess = KERNEL.OpenProcess(PROCESS_FLAGS, False, pid) - if hProcess: - PSAPI.EnumProcessModules(hProcess, byref(hModule), - sizeof(hModule), byref(count)) - PSAPI.GetModuleBaseNameA(hProcess, hModule.value, modname, - sizeof(modname)) - try: - name = u"".join([c for c in modname if c != NULL]) - except UnicodeError, msg: - LOG.exception("Can't decode name of pid %s" % pid) - else: - mapping[pid] = name - modname[:] = sizeof(modname) * NULL - KERNEL.CloseHandle(hProcess) - - return mapping - - @classmethod - def getPidDetails(cls, pid): - """Get detailed informations about a process - """ - if pid == 'self': - pid = os.getpid() - - hModule = c_ulong() - count = c_ulong() - modname = c_buffer(51) - hProcess = KERNEL.OpenProcess(PROCESS_FLAGS, False, pid) - if not hProcess: - return None - - PSAPI.EnumProcessModules(hProcess, byref(hModule), - sizeof(hModule), byref(count)) - PSAPI.GetModuleBaseNameA(hProcess, hModule.value, modname, - sizeof(modname)) - try: - name = u"".join([c for c in modname if c != NULL]) - except UnicodeError, msg: - LOG.exception("Can't decode name of pid %s" % pid) - else: - name = None - - KERNEL.CloseHandle(hProcess) - return {'name' : name} - - -# Initialize global methods -_enumProcesses = None -for impl in (WinEnumProcesses(), LinuxProcReader(), PsParser()): - if impl.supported(): - impl.log() - _enumProcesses = impl - break - -if _enumProcesses is None: - LOG.error("System %s is not supported" % sys.platform) - _enumProcesses = Unsupported() - -getPids = _enumProcesses.getPids -getPidNames = _enumProcesses.getPidNames -getPidDetails = _enumProcesses.getPidDetails -supportedOS = _enumProcesses.supported() - -def test_suite(): - import unittest - from doctest import DocTestSuite - return unittest.TestSuite(( - DocTestSuite() - )) - -if __name__ == '__main__': - import unittest - logging.basicConfig() - unittest.main(defaultTest="test_suite") - print getPids() - print getPidNames() Copied: enumprocess/tags/0.1/src/enumprocess/processinfo.py (from rev 203, enumprocess/trunk/src/enumprocess/processinfo.py) =================================================================== --- enumprocess/tags/0.1/src/enumprocess/processinfo.py (rev 0) +++ enumprocess/tags/0.1/src/enumprocess/processinfo.py 2007-02-27 14:32:21 UTC (rev 204) @@ -0,0 +1,477 @@ +# Copyright (c) 2007 Christian Heimes. All rights reserved. +# +# Redistribution and use in source and binary forms, with or without +# modification, are permitted provided that the following conditions are +# met: +# +# 1. Redistributions of source code must retain the above copyright +# notice, this list of conditions and the following disclaimer. +# +# 2. 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. +# +# 3. Neither the name of Infrae 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 INFRAE 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. +"""Get process informations + +The module contains for implementations: + + - an Unsupported implementation that raises UnsupportedError + - a Linux implementation that read the data from /proc + - a Unix/POSIX implementation that parses the output of ps + - a Windows implementation that uses ctypes to get the infos from psapi.dll + +API +=== + getPids() - list of ints/longs + getPidNames() - mapping pid -> name + getPidDetails(pid) - detailed informations about a process + getPidDetails('self') - detailed informations about current process + +>>> cur = os.getpid() +>>> exe = sys.executable +>>> pids = getPids() +>>> pids > 1 +True +>>> isinstance(pids[0], (int, long)) +True +>>> cur in pids +True + +>>> mapping = getPidNames() +>>> cur in mapping +True +>>> mapping[cur].lower() in sys.executable +True + +>>> getPidDetails('self')['name'] == getPidDetails(cur)['name'] +True +>>> getPidDetails(cur)['name'] == mapping[cur] +True + +>>> for impl in (WinEnumProcesses(), LinuxProcReader(), PsParser()): +... if impl.supported(): +... isinstance(impl.getPids(), list) and None +... isinstance(impl.getPidNames(), dict) and None +""" +__author__ = "Christian Heimes" +__version__ = "$Id$" +__revision__ = "$Revision$" +__all__ = ['getPids', 'getPidNames', 'getPidDetails', 'supportedOS', + 'UnsupportedError'] + +import logging +import os +import os.path +import sys + + +LOG = logging.getLogger("processinfo") +NULL = "\x00" + +_plat = sys.platform.startswith +if _plat('win') or _plat('cygwin'): + from ctypes import windll, c_ulong, sizeof, c_buffer, byref + PSAPI = windll.psapi + KERNEL = windll.kernel32 + PROCESS_QUERY_INFORMATION = 0x0400 + PROCESS_VM_READ = 0x0010 + PROCESS_FLAGS = PROCESS_QUERY_INFORMATION | PROCESS_VM_READ +else: + from subprocess import Popen + from subprocess import PIPE + +class UnsupportedError(OSError): + """OS or command not supported error + """ + pass + +class Unsupported(object): + """Unsupported OS implementation + + Raises L{UnsupportedError} + """ + __slots__ = () + + @classmethod + def supported(cls): + """Supported flag property""" + return False + + @classmethod + def log(cls): + """Log information about the implementation""" + LOG.warning("Unsupported OS. Neither proc filesystem nor 'ps' works.") + + @classmethod + def getPids(cls): + """Get a list of pids + + @return: a list of pid numbers + @rtype: list(int) + """ + raise UnsupportedError + + @classmethod + def getPidNames(cls): + """Get a mapping of pid -> name + + @return: mapping of pid -> name + @rtype: dict(int:str) + """ + raise UnsupportedError + + @classmethod + def getPidDetails(pid): + """Get detailed informations about a process + + @param pid: pid number or 'self' + @type pid: int or basestring + @return: detailed information about a process + @rtype: dict(str:data) + """ + raise UnsupportedError + +class PsParser(object): + """Parse the output of the ps command + """ + __slots__ = () + + CMD = "ps -e --no-header --cols=1024" + PIDNAMES = "%s --format=pid,ucmd" % CMD + PIDS = "%s --format=pid" % CMD + + @classmethod + def supported(cls): + """Supported flag property""" + try: + cls._exec(cls.PIDS) + except Exception: # catch all! + return False + else: + return True + + @classmethod + def log(cls): + """Log information about the implementation""" + LOG.debug("Using the 'ps' command on POSIX os") + + @classmethod + def getPids(cls): + """Get a list of pids + """ + stdout = cls._exec(cls.PIDS) + if stdout is None: + return None + pids = [] + for line in stdout: + try: + pid = int(line.strip()) + except ValueError: + pass + else: + pids.append(pid) + return pids + + @classmethod + def getPidNames(cls): + """Get a list of pid -> name + """ + stdout = cls._exec(cls.PIDNAMES) + if stdout is None: + return None + mapping = {} + for line in stdout: + line = line.strip() + idx = line.find(' ') + pid, name = line[:idx], line[idx+1:] + try: + pid = int(pid) + except ValueError: + pass + else: + mapping[pid] = name + return mapping + + @classmethod + def getPidDetails(cls, pid): + """Get detailed informations about a process + + TODO + """ + if pid == 'self': + pid = os.getpid() + raise UnsupportedError("not implemented yet") + + @staticmethod + def _exec(cmd): + """Execute command cmd + + The method waits until the command has finished. It returns None of + something went wrong. + + @param cmd: Command to execute + @type cmd: str + @return: None or stdin as file like object + """ + try: + popen = Popen(cmd, shell=True, bufsize=-1, stdout=PIPE, + env = {'LC_ALL' : 'C'}) + rc = popen.wait() + except (OSError, ValueError): + LOG.exception("Failed to execute '%s'" % cmd) + return None + else: + if rc != 0: + LOG.error("'%s' returned with error code %i" % (cmd, rc)) + return None + else: + return popen.stdout + +class LinuxProcReader(object): + """Get process informations under Linux by reading /proc + + Tested under Linux, may work on other POSIX os with /proc, too. + """ + __slots__ = () + + PROC = "/proc" + + @classmethod + def supported(cls): + return os.path.isfile("%s/self/status" % cls.PROC) + + @classmethod + def log(cls): + """Log information about the implementation""" + LOG.debug("Using the proc filesystem on Linux") + + @classmethod + def getPids(cls): + """Get a list of pids + """ + pids = [] + for name in os.listdir(cls.PROC): + if os.path.isdir(cls.PROC + '/' + name): + try: + pids.append(int(name)) + except ValueError: + pass + return pids + + @classmethod + def getPidNames(cls): + """Get a list of pid -> name + """ + mapping = {} + for pid in cls.getPids(): + name = cls._readProcStatus(pid, searchkey='name') + if name is not None: + mapping[pid] = name + return mapping + + def getPidDetails(cls, pid): + """Get detailed informations about a process + """ + details = cls._readProcStatus(pid) + if details is None: + return None + details.update(cls._readProcOther(pid)) + details['cmdline'] = cls._readProcCmdline(pid) + return details + + @classmethod + def _readProcStatus(cls, pid, searchkey=None): + """Read and parse status informations for PID pid + + pid - pid as long or int or 'self' + + If searchkey is None the method returns a mapping of lower keys + to values (stripped). + If searchkey is given than the method immediatly returns the value + or returns None if they key can't be found. + """ + mapping = {} + status = '%s/%s/status' % (cls.PROC, pid) + try: + # read entiry file to avoid race conditions + lines = open(status, 'r').readlines() + except IOError: + LOG.exception("%s not found" % status) + return None + for line in lines: + try: + key, value = line.split(':\t') + except ValueError: + continue + key = key.lower() + value = value.strip() + #if value.endswith(' kB'): + # value = value[:-3] + if key == searchkey: + return value + mapping[key.lower()] = value + if searchkey is not None: + return None + return mapping + + @classmethod + def _readProcCmdline(cls, pid): + """Read cmdline informations for pid and returns a list similar to sys.argv + """ + try: + # read entiry file to avoid race conditions + data = open('%s/%s/cmdline' % (cls.PROC, pid), 'r').read() + except IOError: + return None + return data.split(NULL) + + @classmethod + def _readProcOther(cls, pid): + """Read other possible useful things + + cwd -> current work directory (may not exist) + exe -> path to executable (may not exist) + """ + return { + 'cwd' : os.path.realpath('%s/%s/cwd' % (cls.PROC, pid)), + 'exe' : os.path.realpath('%s/%s/exe' % (cls.PROC, pid)), + ... [truncated message content] |