/usr/share/pyshared/kombu/utils/finalize.py is in python-kombu 1.4.3-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 | """
kombu.utils.finalize
====================
Execute cleanup handlers when objects go out of scope.
Taken from :class:`multiprocessing.util.Finalize`.
:copyright: (c) 2009 - 2011 by Ask Solem.
:license: BSD, see LICENSE for more details.
"""
import weakref
from itertools import count
class Finalize(object):
"""Object finalization using weakrefs."""
_count = count().next
_registry = {}
def __init__(self, obj, callback, args=(), kwargs=None,
exitpriority=None):
if obj is not None:
self._weakref = weakref.ref(obj, self)
else:
assert exitpriority is not None
self._callback = callback
self._args = args
self._kwargs = kwargs or {}
self._key = (exitpriority, self._count())
self._registry[self._key] = self
def __call__(self, wr=None):
"""Run the callback unless it has already been called or
cancelled."""
try:
self._registry.pop(self._key)
except KeyError:
pass
else:
try:
return self._callback(*self._args, **self._kwargs)
finally:
self._reset()
def _reset(self):
self._weakref = self._callback = self._args = \
self._kwargs = self._key = None
def cancel(self):
"""Cancel finalization of the object."""
try:
self._registry.pop(self._key)
except KeyError:
pass
else:
self._reset()
def still_active(self):
self._key in self._registry
def __repr__(self):
try:
obj = self._weakref()
except (AttributeError, TypeError):
return "<Finalize: (dead)>"
if obj is None:
return
x = '<Finalize object, callback=%s' % \
getattr(self._callback, '__name__', self._callback)
if self._args:
x += ', args=%r' % (self._args, )
if self._kwargs:
x += ', kwargs=%r' % (self._kwargs, )
if self._key[0] is not None:
x += ', exitprority=%r' % (self._key[0], )
return x + '>'
|