Lines 25-30
Link Here
|
25 |
import time |
24 |
import time |
26 |
import xmlrpclib |
25 |
import xmlrpclib |
|
|
26 |
# sets is deprecated as of python 2.6, but set is unavailable in 2.3 |
27 |
try: |
28 |
set |
29 |
except NameError: |
30 |
from sets import Set as set |
31 |
|
27 |
import XendDomain, XendDomainInfo, XendNode, XendDmesg |
32 |
import XendDomain, XendDomainInfo, XendNode, XendDmesg |
28 |
import XendLogging, XendTaskManager, XendAPIStore |
33 |
import XendLogging, XendTaskManager, XendAPIStore |
Lines 115-127
Link Here
|
115 |
def event_register(session, reg_classes): |
120 |
def event_register(session, reg_classes): |
116 |
if session not in event_registrations: |
121 |
if session not in event_registrations: |
117 |
event_registrations[session] = { |
122 |
event_registrations[session] = { |
118 |
'classes' : sets.Set(), |
123 |
'classes' : set(), |
119 |
'queue' : Queue.Queue(EVENT_QUEUE_LENGTH), |
124 |
'queue' : Queue.Queue(EVENT_QUEUE_LENGTH), |
120 |
'next-id' : 1 |
125 |
'next-id' : 1 |
121 |
} |
126 |
} |
122 |
if not reg_classes: |
127 |
if not reg_classes: |
123 |
reg_classes = classes |
128 |
reg_classes = classes |
124 |
event_registrations[session]['classes'].union_update(reg_classes) |
129 |
sessionclasses = event_registrations[session]['classes'] |
|
|
130 |
sessionclasses.union_update(reg_classes) |
125 |
def event_unregister(session, unreg_classes): |
131 |
def event_unregister(session, unreg_classes): |