/dports/net/concourse-fly/concourse-6.7.1/atc/exec/ |
H A D | retry_step_test.go | 19 attempt1 *execfakes.FakeStep 32 attempt1 = new(execfakes.FakeStep) 40 step = Retry(attempt1, attempt2, attempt3) 66 attempt1.SucceededReturns(true) 89 attempt1.SucceededReturns(true) 101 attempt1.SucceededReturns(false) 137 attempt1.RunReturns(errors.New("nope")) 173 attempt1.RunReturns(errors.New("nope")) 253 attempt1.SucceededReturns(false) 292 attempt1.SucceededReturns(false) [all …]
|
/dports/misc/concourse/concourse-6.7.2/atc/exec/ |
H A D | retry_step_test.go | 19 attempt1 *execfakes.FakeStep 32 attempt1 = new(execfakes.FakeStep) 40 step = Retry(attempt1, attempt2, attempt3) 66 attempt1.SucceededReturns(true) 89 attempt1.SucceededReturns(true) 101 attempt1.SucceededReturns(false) 137 attempt1.RunReturns(errors.New("nope")) 173 attempt1.RunReturns(errors.New("nope")) 253 attempt1.SucceededReturns(false) 292 attempt1.SucceededReturns(false) [all …]
|
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/scheduler/ |
H A D | TaskSchedulerImplSuite.scala | 175 taskScheduler.submitTasks(attempt1) 179 taskScheduler.taskSetManagerForAttempt(attempt1.stageId, attempt1.stageAttemptId) 195 val attempt1 = FakeTask.createTaskSet(10) constant 198 taskScheduler.submitTasks(attempt1) 203 taskScheduler.taskSetManagerForAttempt(attempt1.stageId, attempt1.stageAttemptId) 230 taskScheduler.submitTasks(attempt1) 235 val mgr1 = taskScheduler.taskSetManagerForAttempt(attempt1.stageId, attempt1.stageAttemptId).get 266 val attempt1 = FakeTask.createTaskSet(1) constant 269 taskScheduler.submitTasks(attempt1) 431 taskScheduler.submitTasks(attempt1) [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/ |
H A D | TestApplicationMasterService.java | 83 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testRMIdentifierOnContainerAllocation() local 84 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testRMIdentifierOnContainerAllocation() 123 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testInvalidContainerReleaseRequest() local 179 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testProgressFilter() local 191 while(attempt1.getProgress()!=1){ in testProgressFilter() 198 while(attempt1.getProgress()!=0){ in testProgressFilter() 205 while(attempt1.getProgress()!=1){ in testProgressFilter() 212 while(attempt1.getProgress()!=0){ in testProgressFilter() 219 while(attempt1.getProgress()!=0.5){ in testProgressFilter() 226 while(attempt1.getProgress()!=0){ in testProgressFilter() [all …]
|
H A D | TestFifoScheduler.java | 121 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testAllocateContainerOnNodeWithoutOffSwitchSpecified() local 122 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testAllocateContainerOnNodeWithoutOffSwitchSpecified() 153 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in test() local 154 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in test() 216 while (attempt1.getJustFinishedContainers().size() < 1 in test() 222 Assert.assertEquals(1, attempt1.getJustFinishedContainers().size()); in test() 272 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testMinimumAllocation() local 273 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testMinimumAllocation() 539 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testResourceOverCommit() local 540 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testResourceOverCommit() [all …]
|
H A D | TestRMRestart.java | 216 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testRMRestart() local 365 attempt1 = loadedApp1.getCurrentAppAttempt(); in testRMRestart() 366 attemptId1 = attempt1.getAppAttemptId(); in testRMRestart() 398 am1 = rm2.sendAMLaunched(attempt1.getAppAttemptId()); in testRMRestart() 1221 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testAppAttemptTokensRestoredOnRMRestart() local 1234 attempt1.getClientTokenMasterKey().getEncoded(); in testAppAttemptTokensRestoredOnRMRestart() 1256 attempt1.getClientTokenMasterKey(), in testAppAttemptTokensRestoredOnRMRestart() 1749 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testQueueMetricsOnRMRestart() local 1794 attempt1 = loadedApp1.getCurrentAppAttempt(); in testQueueMetricsOnRMRestart() 1795 attemptId1 = attempt1.getAppAttemptId(); in testQueueMetricsOnRMRestart() [all …]
|
H A D | TestRM.java | 457 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testActivatingApplicationAfterAddingNM() local 458 ApplicationAttemptId attemptId1 = attempt1.getAppAttemptId(); in testActivatingApplicationAfterAddingNM()
|
/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/security/ |
H A D | TestNMTokenSecretManagerInNM.java | 50 final ApplicationAttemptId attempt1 = in testRecovery() local 64 getNMTokenId(secretMgr.createNMToken(attempt1, nodeId, "user1")); in testRecovery() 69 assertTrue(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery() 79 assertTrue(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery() 87 secretMgr.appFinished(attempt1.getApplicationId()); in testRecovery() 94 assertFalse(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery() 107 assertFalse(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery() 123 assertFalse(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/ |
H A D | TestAMRMRPCNodeUpdates.java | 134 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); 135 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); 144 allocate(attempt1.getAppAttemptId(), allocateRequest1); 154 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1); 162 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1); 175 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1); 206 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1);
|
H A D | TestAMRestart.java | 377 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testShouldNotCountFailureToMaxAttemptRetry() local 387 Assert.assertTrue(! attempt1.shouldCountTowardsMaxAttemptRetry()); in testShouldNotCountFailureToMaxAttemptRetry() 487 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testPreemptedAMRestartOnRMRestart() local 498 Assert.assertTrue(! attempt1.shouldCountTowardsMaxAttemptRetry()); in testPreemptedAMRestartOnRMRestart() 556 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testRMRestartOrFailoverNotCountedForAMFailures() local 557 Assert.assertTrue(((RMAppAttemptImpl) attempt1).mayBeLastAttempt()); in testRMRestartOrFailoverNotCountedForAMFailures() 569 status.setContainerId(attempt1.getMasterContainer().getId()); in testRMRestartOrFailoverNotCountedForAMFailures() 574 rm2.waitForState(attempt1.getAppAttemptId(), RMAppAttemptState.FAILED); in testRMRestartOrFailoverNotCountedForAMFailures()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/ |
H A D | TestTaskLogsTruncater.java | 388 TaskAttemptID attempt1 = new TaskAttemptID(baseTaskID, attemptsCount++); in testLogTruncationOnFinishingWithJVMReuse() local 389 Task task1 = new MapTask(null, attempt1, 0, new JobSplit.TaskSplitIndex(), in testLogTruncationOnFinishingWithJVMReuse() 393 writeRealChars(attempt1, attempt1, LogName.SYSLOG, 200, 'A'); in testLogTruncationOnFinishingWithJVMReuse() 395 File attemptDir = TaskLog.getAttemptDir(attempt1, false); in testLogTruncationOnFinishingWithJVMReuse() 403 writeRealChars(attempt1, attempt2, LogName.SYSLOG, 100, 'B'); in testLogTruncationOnFinishingWithJVMReuse() 409 writeRealChars(attempt1, attempt3, LogName.SYSLOG, 225, 'C'); in testLogTruncationOnFinishingWithJVMReuse() 417 File logFile = TaskLog.getTaskLogFile(attempt1, false, LogName.SYSLOG); in testLogTruncationOnFinishingWithJVMReuse() 420 assertEquals(150 + truncatedMsgSize, getAllLogsFileLengths(attempt1, false) in testLogTruncationOnFinishingWithJVMReuse() 429 attempt1, false); in testLogTruncationOnFinishingWithJVMReuse()
|
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/history/ |
H A D | ApplicationCacheSuite.scala | 391 val attempt1 = Some("01") constant 401 operations.putAppUI(appId, attempt1, true, t, t, t) 405 cache.get(id, attempt1) 420 val attempt1 = Some("01") constant 423 operations.putAppUI(appId, attempt1, true, 100, 110, 110) 437 cache.get(appId, attempt1)
|
H A D | FsHistoryProviderSuite.scala | 203 val attempt1 = newLogFile("app1", Some("attempt1"), inProgress = true) constant 204 writeFile(attempt1, true, None, 238 writeFile(attempt1, true, None,
|
/dports/textproc/jalingo/jalingo-0.6.0-src/src/ja/lingo/application/gui/main/describer/ |
H A D | DescriberGui.java | 234 …int attempt1 = forwardDirection ? editorPane.getSelectionEnd() : editorPane.getSelectionStart() - … in find() local 237 …int index = TextSearcher.indexOf( forwardDirection, article, searchText, attempt1, caseSensetive, … in find()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/x/t/ |
H A D | system_variable_enable_hello_notice.test | 25 newsession attempt1 -;
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/x/r/ |
H A D | system_variable_enable_hello_notice.result | 19 active session is now 'attempt1'
|
/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/recovery/ |
H A D | TestNMLeveldbStateStoreService.java | 727 ApplicationAttemptId attempt1 = ApplicationAttemptId.newInstance( in testNMTokenStorage() local 730 stateStore.storeNMTokenApplicationMasterKey(attempt1, attemptKey1); in testNMTokenStorage() 742 assertEquals(attemptKey1, loadedAppKeys.get(attempt1)); in testNMTokenStorage() 750 stateStore.removeNMTokenApplicationMasterKey(attempt1); in testNMTokenStorage() 763 assertNull(loadedAppKeys.get(attempt1)); in testNMTokenStorage()
|
/dports/www/moodle310/moodle/mod/h5pactivity/tests/local/ |
H A D | attempt_test.php | 218 $attempt1 = $this->generate_full_attempt($student, $cm); 232 attempt::delete_attempt($attempt1);
|
/dports/www/moodle311/moodle/mod/h5pactivity/tests/local/ |
H A D | attempt_test.php | 218 $attempt1 = $this->generate_full_attempt($student, $cm); 232 attempt::delete_attempt($attempt1);
|
/dports/www/moodle39/moodle/mod/h5pactivity/tests/local/ |
H A D | attempt_test.php | 218 $attempt1 = $this->generate_full_attempt($student, $cm); 232 attempt::delete_attempt($attempt1);
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/ |
H A D | TestAHSClient.java | 355 ApplicationAttemptReport attempt1 = in createAppReports() local 366 appAttempts.add(attempt1); in createAppReports()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/ |
H A D | TestFileOutputCommitter.java | 73 private static final String attempt1 = "attempt_200707121733_0001_m_000001_0"; field in TestFileOutputCommitter 74 private static final TaskAttemptID taskID1 = TaskAttemptID.forName(attempt1);
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
H A D | initial_syncer_test.cpp | 4037 BSONObj attempt1 = attempts["1"].Obj(); in TEST_F() local 4038 ASSERT_EQUALS(attempt1.nFields(), 3) << attempt1; in TEST_F() 4039 ASSERT_EQUALS(attempt1.getStringField("status"), std::string("OK")) << attempt1; in TEST_F() 4040 ASSERT_EQUALS(attempt1["durationMillis"].type(), NumberInt) << attempt1; in TEST_F() 4041 ASSERT_EQUALS(attempt1.getStringField("syncSource"), std::string("localhost:27017")) in TEST_F() 4042 << attempt1; in TEST_F()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ |
H A D | TestCapacityScheduler.java | 696 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testResourceOverCommit() local 697 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testResourceOverCommit() 751 while (attempt1.getJustFinishedContainers().size() < 1 in testResourceOverCommit() 757 Assert.assertEquals(1, attempt1.getJustFinishedContainers().size()); in testResourceOverCommit() 2077 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); 2078 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); 2097 attempt1.getAppAttemptId()); 2110 attempt1.getAppAttemptId());
|
H A D | TestContainerAllocation.java | 115 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testExcessReservationThanNodeManagerCapacity() local 116 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testExcessReservationThanNodeManagerCapacity()
|