| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ |
| H A D | ResourceRetentionSet.java | 34 private final DeletionService delService; field in ResourceRetentionSet
37 ResourceRetentionSet(DeletionService delService, long targetSize) { in ResourceRetentionSet() argument
38 this(delService, targetSize, new LRUComparator()); in ResourceRetentionSet()
41 ResourceRetentionSet(DeletionService delService, long targetSize, in ResourceRetentionSet() argument
43 this(delService, targetSize, in ResourceRetentionSet()
47 ResourceRetentionSet(DeletionService delService, long targetSize, in ResourceRetentionSet() argument
50 this.delService = delService; in ResourceRetentionSet()
69 if (tracker.remove(resource, delService)) { in addResources()
|
| H A D | LocalResourcesTracker.java | 34 boolean remove(LocalizedResource req, DeletionService delService); in remove() argument
37 DeletionService delService); in getPathForLocalization() argument
|
| H A D | LocalResourcesTrackerImpl.java | 339 public boolean remove(LocalizedResource rem, DeletionService delService) { in remove() argument
355 delService.delete(getUser(), getPathToDelete(rsrc.getLocalPath())); in remove()
418 Path localDirPath, DeletionService delService) { in getPathForLocalization() argument
449 if (delService != null) { in getPathForLocalization()
450 delService.delete(getUser(), uniquePath); in getPathForLocalization()
|
| H A D | ResourceLocalizationService.java | 154 private final DeletionService delService; field in ResourceLocalizationService
183 ContainerExecutor exec, DeletionService delService, in ResourceLocalizationService() argument
189 this.delService = delService; in ResourceLocalizationService()
235 cleanUpLocalDirs(lfs, delService); in serviceInit()
322 tracker.remove(tracker.getLocalizedResource(req), delService); in recoverTrackerResources() local
473 new ResourceRetentionSet(delService, cacheTargetSize); in handleCacheCleanup()
539 delService.delete(userName, dir, new Path[] {}); in submitDirForDeletion()
803 delService); in addResource()
1090 dirPath, delService); in getPathForLocalization()
1151 delService.delete(context.getUser(), in run()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/ |
| H A D | DeletionService.java | 196 private final DeletionService delService; field in DeletionService.FileDeletionTask
202 private FileDeletionTask(DeletionService delService, String user, in FileDeletionTask() argument
204 this(INVALID_TASK_ID, delService, user, subDir, baseDirs); in FileDeletionTask()
207 private FileDeletionTask(int taskId, DeletionService delService, in FileDeletionTask() argument
210 this.delService = delService; in FileDeletionTask()
293 delService.exec.deleteAsUser(user, subDir, (Path[])null); in run()
295 delService.exec.deleteAsUser(user, subDir, in run()
351 delService.stateStore.removeDeletionTask(taskId); in fileDeletionTaskFinished()
366 successorTask.delService.scheduleFileDeletionTask(successorTask); in fileDeletionTaskFinished()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ |
| H A D | TestResourceLocalizationService.java | 204 delService.init(conf); in testLocalizationInit()
205 delService.start(); in testLocalizationInit()
248 delService.stop(); in testLocalizationInit()
262 delService.start(); in testDirectoryCleanupOnNewlyCreatedStateStore()
315 delService.stop(); in testDirectoryCleanupOnNewlyCreatedStateStore()
348 delService.start(); in testResourceRelease()
495 delService.stop(); in testResourceRelease()
748 delService.start(); in testLocalizerRunnerException()
804 delService.stop(); in testLocalizerRunnerException()
838 delService.start(); in testLocalizationHeartbeat()
[all …]
|
| H A D | TestResourceRetention.java | 42 DeletionService delService = mock(DeletionService.class); in testRsrcUnused() local
44 ResourceRetentionSet rss = new ResourceRetentionSet(delService, TARGET_MB); in testRsrcUnused()
|
| H A D | TestLocalResourcesTrackerImpl.java | 807 DeletionService delService = mock(DeletionService.class); in testGetPathForLocalization() local
821 delService); in testGetPathForLocalization()
823 verify(delService, times(1)).delete(eq(user), eq(conflictPath)); in testGetPathForLocalization()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/loghandler/ |
| H A D | TestNonAggregatingLogHandler.java | 239 DeletionService delService = new DeletionService(null); in testHandlingApplicationFinishedEvent() local
242 delService, in testHandlingApplicationFinishedEvent()
248 delService.init(conf); in testHandlingApplicationFinishedEvent()
249 delService.start(); in testHandlingApplicationFinishedEvent()
269 DeletionService delService, LocalDirsHandlerService dirsHandler) { in NonAggregatingLogHandlerWithMockExecutor() argument
270 this(dispatcher, delService, dirsHandler, new NMNullStateStoreService()); in NonAggregatingLogHandlerWithMockExecutor()
274 DeletionService delService, LocalDirsHandlerService dirsHandler, in NonAggregatingLogHandlerWithMockExecutor() argument
276 super(dispatcher, delService, dirsHandler, stateStore); in NonAggregatingLogHandlerWithMockExecutor()
511 static void testDeletionServiceCall(DeletionService delService, String user, in testDeletionServiceCall() argument
519 verify(delService).delete(eq(user), (Path) eq(null), in testDeletionServiceCall()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/loghandler/ |
| H A D | NonAggregatingLogHandler.java | 64 private final DeletionService delService; field in NonAggregatingLogHandler
73 DeletionService delService, LocalDirsHandlerService dirsHandler, in NonAggregatingLogHandler() argument
77 this.delService = delService; in NonAggregatingLogHandler()
245 NonAggregatingLogHandler.this.delService.delete(user, null, in run()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/ |
| H A D | TestNodeManagerReboot.java | 85 private DeletionService delService; field in TestNodeManagerReboot
198 verify(delService, times(1)).delete( in testClearLocalDirWhenNodeReboot()
202 verify(delService, times(1)).delete((String) isNull(), in testClearLocalDirWhenNodeReboot()
204 verify(delService, times(1)).scheduleFileDeletionTask( in testClearLocalDirWhenNodeReboot()
207 verify(delService, times(1)).scheduleFileDeletionTask( in testClearLocalDirWhenNodeReboot()
314 delService = spy(new DeletionService(exec)); in createDeletionService()
315 return delService; in createDeletionService()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/logaggregation/ |
| H A D | AppLogAggregatorImpl.java | 102 private final DeletionService delService; field in AppLogAggregatorImpl
136 this.delService = deletionService; in AppLogAggregatorImpl()
273 this.delService.delete(this.userUgi.getShortUserName(), null, in uploadLogsForContainers()
457 this.delService.delete(this.userUgi.getShortUserName(), null, in doAppLogAggregationPostCleanUp()
|
| /dports/net-mgmt/librenms/librenms-21.5.1/mibs/dasan/ |
| H A D | SLEV2-Security-MIB | 4671 delService(7)
4956 "delService"
|
| /dports/net-mgmt/observium/observium/mibs/dasan/ |
| H A D | SLEV2-Security-MIB | 4671 delService(7)
4956 "delService"
|