← Back to branch summary

~ubuntu-branches/debian/jessie/subdownloader/jessie

« back to all changes in this revision

Viewing changes to modules/mmpython/synchronizedobject.py

  • Committer: Package Import Robot
  • Author(s): Emilien Klein, Jakub Wilk, Emilien Klein
  • Date: 2014-10-22 00:09:01 UTC
  • mfrom: (1.2.2)
  • Revision ID: package-import@ubuntu.com-20141022000901-968rxi9a15icm032
Tags: 2.0.18-1
http://bugs.debian.org/687126
http://bugs.debian.org/751920
* New upstream release (Closes: #687126, #751920).

[ Jakub Wilk ]
* Use canonical URIs for Vcs-* fields.
* Fix watch file.

[ Emilien Klein ]
* Transition from python_support to dh_python2. Affects files:
  - d/control
  - d/rules
  - d/subdownloader.install
  - d/subdownloader.links
* d/control:
  - Bump Standards-Version from 3.9.1 to 3.9.6 (one change performed to
    d/rules recommended target)
  - Replace Marco Rodrigues by myself in Uploaders
* d/rules: Fix debian-rules-missing-recommended-target Lintian warning
* d/patches/fix-non-ascii-download-path.patch: deleted as applied upstream
* d/patches/desktop-file-remove-path.patch: make the desktop file usable
* d/patches/no-mime-type-in-desktop-file.patch: Mime Type is unused, as
    the .desktop file doesn't provide an Exec code.
* d/patches/resize-icon.patch: Resize icon from 64x64 to 32x32

Show diffs side-by-side

added added

removed removed

Lines of Context:
modules/mmpython/synchronizedobject.py
 
1
# -*- coding: iso-8859-1 -*-
 
2
 
 
3
 
 
4
#
 
5
# synchronized objects and methods.
 
6
# By Andr� Bj�rby
 
7
# From http://aspn.activestate.com/ASPN/Cookbook/Python/Recipe/65202
 
8
# 
 
9
 
 
10
from types import *
 
11
 
 
12
def _get_method_names (obj):
 
13
    if type(obj) == InstanceType:
 
14
        return _get_method_names(obj.__class__)
 
15
    
 
16
    elif type(obj) == ClassType:
 
17
        result = []
 
18
        for name, func in obj.__dict__.items():
 
19
            if type(func) == FunctionType:
 
20
                result.append((name, func))
 
21
 
 
22
        for base in obj.__bases__:
 
23
            result.extend(_get_method_names(base))
 
24
 
 
25
        return result
 
26
 
 
27
 
 
28
class _SynchronizedMethod:
 
29
 
 
30
    def __init__ (self, method, obj, lock):
 
31
        self.__method = method
 
32
        self.__obj = obj
 
33
        self.__lock = lock
 
34
 
 
35
    def __call__ (self, *args, **kwargs):
 
36
        self.__lock.acquire()
 
37
        try:
 
38
            #print 'Calling method %s from obj %s' % (self.__method, self.__obj)
 
39
            return self.__method(self.__obj, *args, **kwargs)
 
40
        finally:
 
41
            self.__lock.release()
 
42
 
 
43
class SynchronizedObject:    
 
44
    def __init__ (self, obj, ignore=[], lock=None):
 
45
        import threading
 
46
 
 
47
        self.__methods = {}
 
48
        self.__obj = obj
 
49
        lock = lock and lock or threading.RLock()
 
50
        for name, method in _get_method_names(obj):
 
51
            if not name in ignore:
 
52
                self.__methods[name] = _SynchronizedMethod(method, obj, lock)
 
53
 
 
54
    def __getattr__ (self, name):
 
55
        try:
 
56
            return self.__methods[name]
 
57
        except KeyError:
 
58
            return getattr(self.__obj, name)
 
59