| @@ 315-324 (lines=10) @@ | ||
| 312 | results = self.server.delete_monitored_items(params) |
|
| 313 | results[0].check() |
|
| 314 | with self._lock: |
|
| 315 | for k, v in self._monitoreditems_map.items(): |
|
| 316 | if v.server_handle == handle: |
|
| 317 | del(self._monitoreditems_map[k]) |
|
| 318 | return |
|
| 319 | ||
| 320 | def modify_monitored_item(self, handle, new_samp_time, new_queuesize=0, mod_filter_val=None): |
|
| 321 | """ |
|
| 322 | Modify a monitored item. |
|
| 323 | :param handle: Handle returned when originally subscribing |
|
| 324 | :param new_samp_time: New wanted sample time |
|
| 325 | :param new_queuesize: New wanted queuesize, default is 0 |
|
| 326 | :param mod_filter_val: New deadband filter value |
|
| 327 | :return: Return a Modify Monitored Item Result |
|
| @@ 111-117 (lines=7) @@ | ||
| 108 | ||
| 109 | def __init__(self): |
|
| 110 | super(CustomEvent, self).__init__(extended=True) |
|
| 111 | self.EventType = node.nodeid |
|
| 112 | curr_node = node |
|
| 113 | ||
| 114 | while curr_node.nodeid.Identifier != parent_identifier: |
|
| 115 | for prop in curr_node.get_properties(): |
|
| 116 | setattr(self, prop.get_browse_name().Name, prop.get_value()) |
|
| 117 | parents = curr_node.get_referenced_nodes(refs=ua.ObjectIds.HasSubtype, direction=ua.BrowseDirection.Inverse, includesubtypes=False) |
|
| 118 | if len(parents) != 1: # Something went wrong |
|
| 119 | return None |
|
| 120 | curr_node = parents[0] |
|