| 1370 | } |
| 1371 | |
| 1372 | ACTOR static Future<Key> addTask(Reference<ReadYourWritesTransaction> tr, |
| 1373 | Reference<TaskBucket> taskBucket, |
| 1374 | Reference<Task> parentTask, |
| 1375 | Version prevBeginVersion, |
| 1376 | Version beginVersion, |
| 1377 | TaskCompletionKey completionKey, |
| 1378 | Reference<TaskFuture> waitFor = Reference<TaskFuture>()) { |
| 1379 | Key doneKey = wait(completionKey.get(tr, taskBucket)); |
| 1380 | auto task = makeReference<Task>(CopyDiffLogsTaskFunc::name, CopyDiffLogsTaskFunc::version, doneKey, 1); |
| 1381 | |
| 1382 | copyDefaultParameters(parentTask, task); |
| 1383 | |
| 1384 | task->params[DatabaseBackupAgent::keyBeginVersion] = BinaryWriter::toValue(beginVersion, Unversioned()); |
| 1385 | task->params[DatabaseBackupAgent::keyPrevBeginVersion] = BinaryWriter::toValue(prevBeginVersion, Unversioned()); |
| 1386 | |
| 1387 | if (!waitFor) { |
| 1388 | return taskBucket->addTask(tr, |
| 1389 | task, |
| 1390 | parentTask->params[Task::reservedTaskParamValidKey], |
| 1391 | task->params[BackupAgentBase::keyFolderId]); |
| 1392 | } |
| 1393 | |
| 1394 | wait(waitFor->onSetAddTask(tr, |
| 1395 | taskBucket, |
| 1396 | task, |
| 1397 | parentTask->params[Task::reservedTaskParamValidKey], |
| 1398 | task->params[BackupAgentBase::keyFolderId])); |
| 1399 | return LiteralStringRef("OnSetAddTask"); |
| 1400 | } |
| 1401 | |
| 1402 | StringRef getName() const override { return name; }; |
| 1403 |
nothing calls this directly
no test coverage detected