Searched refs:resource_tracker (Results 1 – 12 of 12) sorted by relevance
163 resource_tracker = tracking.ResourceTracker()164 with tracking.resource_tracker_scope(resource_tracker):168 self.assertEqual(2, len(resource_tracker.resources))169 self.assertEqual("test1", resource_tracker.resources[0].resource_handle)170 self.assertEqual("test2", resource_tracker.resources[1].resource_handle)187 resource_tracker = tracking.ResourceTracker()188 with tracking.resource_tracker_scope(resource_tracker):201 self.assertEqual(2, len(resource_tracker.resources))202 self.assertEqual("test1", resource_tracker.resources[0].resource_handle)203 self.assertEqual("test2", resource_tracker.resources[1].resource_handle)
159 def resource_tracker_scope(resource_tracker): argument180 _RESOURCE_TRACKER_STACK.append(resource_tracker)303 for resource_tracker in _RESOURCE_TRACKER_STACK:304 resource_tracker.add_resource(self)
39 from . import resource_tracker40 tracker_fd = resource_tracker.getfd()
14 from . import resource_tracker92 resource_tracker.getfd()]113 resource_tracker.ensure_running()308 resource_tracker._resource_tracker._fd,
112 from . import resource_tracker113 resource_tracker._resource_tracker._fd = tracker_fd
481 from multiprocessing import resource_tracker482 resource_tracker._resource_tracker._stop()
79 from .resource_tracker import register86 from .resource_tracker import unregister
119 from .resource_tracker import register240 from .resource_tracker import unregister
1325 from . import resource_tracker1326 resource_tracker.ensure_running()
3550 resource_tracker = tracking.ResourceTracker()3551 with tracking.resource_tracker_scope(resource_tracker):3558 if resource_tracker.resources:3582 resource_tracker = tracking.ResourceTracker()3583 with tracking.resource_tracker_scope(resource_tracker):3589 if resource_tracker.resources:
968 two separate resource_tracker processes.1048 The multiprocessing.resource_tracker replaces the1050 resource_tracker also tracks shared_memory segments.
89 from multiprocessing import resource_tracker92 resource_tracker._CLEANUP_FUNCS[rtype](name)5116 for rtype in resource_tracker._CLEANUP_FUNCS:5159 from multiprocessing.resource_tracker import _resource_tracker5207 from multiprocessing.resource_tracker import _resource_tracker5216 from multiprocessing.resource_tracker import _resource_tracker