@@ -22,7 +22,6 @@ class Session(object):
22
22
def __init__ (self , async_session ):
23
23
"""Wrap `async_session` on a synchronous msgpack-rpc interface."""
24
24
self ._async_session = async_session
25
- self ._greenlets = set ()
26
25
self ._request_cb = self ._notification_cb = None
27
26
self ._pending_messages = deque ()
28
27
self ._is_running = False
@@ -140,12 +139,10 @@ def handler():
140
139
args , format_exc ())
141
140
response .send (repr (err ), error = True )
142
141
debug ('greenlet %s is now dying...' , gr )
143
- self ._greenlets .remove (gr )
144
142
145
143
# Create a new greenlet to handle the request
146
144
gr = greenlet .greenlet (handler )
147
145
debug ('received rpc request, greenlet %s will handle it' , gr )
148
- self ._greenlets .add (gr )
149
146
gr .switch ()
150
147
151
148
def _on_notification (self , name , args ):
@@ -157,9 +154,7 @@ def handler():
157
154
warn ("error caught while processing notification '%s %s': %s" ,
158
155
name , args , format_exc ())
159
156
debug ('greenlet %s is now dying...' , gr )
160
- self ._greenlets .remove (gr )
161
157
162
158
gr = greenlet .greenlet (handler )
163
159
debug ('received rpc notification, greenlet %s will handle it' , gr )
164
- self ._greenlets .add (gr )
165
160
gr .switch ()
0 commit comments