Commit 8725a8c6 authored by Olivier R-D's avatar Olivier R-D

fix possible race condition

parent e1305ae0
...@@ -159,17 +159,17 @@ class Subscription(object): ...@@ -159,17 +159,17 @@ class Subscription(object):
params.ItemsToCreate.append(mir) params.ItemsToCreate.append(mir)
params.TimestampsToReturn = ua.TimestampsToReturn.Neither params.TimestampsToReturn = ua.TimestampsToReturn.Neither
results = self.server.create_monitored_items(params)
result = results[0]
result.StatusCode.check()
data = SubscriptionItemData()
data.client_handle = mparams.ClientHandle
data.node = node
data.attribute = attr
data.server_handle = result.MonitoredItemId
data.mfilter = ua.downcast_extobject(result.FilterResult)
with self._lock: with self._lock:
results = self.server.create_monitored_items(params)
result = results[0]
result.StatusCode.check()
data = SubscriptionItemData()
data.client_handle = mparams.ClientHandle
data.node = node
data.attribute = attr
data.server_handle = result.MonitoredItemId
data.mfilter = ua.downcast_extobject(result.FilterResult)
self._monitoreditems_map[mparams.ClientHandle] = data self._monitoreditems_map[mparams.ClientHandle] = data
return result.MonitoredItemId return result.MonitoredItemId
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment