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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
|
# This module was copied almost verbatim from Sketch. The only change is
# the base class of ConnectorError which was a Sketch specific exception
# class.
# Sketch - A Python-based interactive drawing program
# Copyright (C) 1997, 1998, 2000, 2001, 2003 by Bernhard Herzog
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Library General Public
# License as published by the Free Software Foundation; either
# version 2 of the License, or (at your option) any later version.
#
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# Library General Public License for more details.
#
# You should have received a copy of the GNU Library General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
__version__ = "$Revision: 1952 $"
#
# The Connector
#
import sys
from types import MethodType
from Thuban import _
class ConnectorError(Exception):
pass
class Connector:
def __init__(self):
self.connections = {}
def Connect(self, object, channel, function, args):
idx = id(object)
if self.connections.has_key(idx):
channels = self.connections[idx]
else:
channels = self.connections[idx] = {}
if channels.has_key(channel):
receivers = channels[channel]
else:
receivers = channels[channel] = []
info = (function, args)
try:
receivers.remove(info)
except ValueError:
pass
receivers.append(info)
def Disconnect(self, object, channel, function, args):
try:
receivers = self.connections[id(object)][channel]
except KeyError:
raise ConnectorError, \
_('no receivers for channel %s of %s') % (channel, object)
try:
receivers.remove((function, args))
except ValueError:
raise ConnectorError,\
_('receiver %s%s is not connected to channel %s of %s') \
% (function, args, channel, object)
if not receivers:
# the list of receivers is empty now, remove the channel
channels = self.connections[id(object)]
del channels[channel]
if not channels:
# the object has no more channels
del self.connections[id(object)]
def Issue(self, object, channel, *args):
#print object, channel, args
try:
receivers = self.connections[id(object)][channel]
except KeyError:
return
# Iterate over a copy of receivers because the receivers might
# unsubscribe themselves when receiving a message and Disconnect
# would modify receivers in place while we're iterating over it.
for func, fargs in receivers[:]:
try:
apply(func, args + fargs)
except:
sys.stderr.write(_("Warning: %s.%s: %s%s\n")
% (object, channel, func, fargs))
import traceback
traceback.print_exc()
def RemovePublisher(self, object):
i = id(object)
if self.connections.has_key(i):
del self.connections[i]
# don't use try: del ... ; except KeyError here. That would create a
# new reference of object in a traceback object and this method should
# be callable from a __del__ method (at least for versions prior
# Python 1.5)
def HasSubscribers(self, object):
return self.connections.has_key(id(object))
def print_connections(self):
# for debugging
for id, channels in self.connections.items():
for name, subscribers in channels.items():
print hex(id), name
for func, args in subscribers:
if type(func) == MethodType:
print _('\tmethod %s of %s') % (func.im_func.func_name,
func.im_self)
else:
print '\t', func
_the_connector = Connector()
Connect = _the_connector.Connect
Issue = _the_connector.Issue
RemovePublisher = _the_connector.RemovePublisher
Disconnect = _the_connector.Disconnect
def Subscribe(channel, function, *args):
return Connect(None, channel, function, args)
class Publisher:
# Flag indicating whether the publisher instance was destroyed.
_was_destroyed = False
def __del__(self):
# the new finalization code in 1.5.1 might bind RemovePublisher
# to None before all objects derived from Publisher are deleted...
if RemovePublisher is not None:
RemovePublisher(self)
def Subscribe(self, channel, func, *args):
Connect(self, channel, func, args)
def Unsubscribe(self, channel, func, *args):
"""Unsubscribe from the channel.
If the publisher's Destroy method has been called already, do
nothing, because the subscriptions will already have been
removed in Destroy and trying to disconnect it here will lead to
exceptions.
"""
if not self._was_destroyed:
Disconnect(self, channel, func, args)
def issue(self, channel, *args):
apply(Issue, (self, channel,) + args)
def Destroy(self):
"""Remove all subscriptions of messages sent by self."""
RemovePublisher(self)
self._was_destroyed = True
class Conduit(Publisher):
def _do_forward(self, *args, **kw):
self.issue(args[-1], *args[:-1], **kw)
def subscribe_forwarding(self, channel, obj):
if obj is not None:
obj.Subscribe(channel, self._do_forward, channel)
def unsubscribe_forwarding(self, channel, obj):
if obj is not None:
obj.Unsubscribe(channel, self._do_forward, channel)
|
