| 1100 | } |
| 1101 | |
| 1102 | ACTOR static Future<Key> addTask(Reference<ReadYourWritesTransaction> tr, |
| 1103 | Reference<TaskBucket> taskBucket, |
| 1104 | Reference<Task> parentTask, |
| 1105 | Version prevBeginVersion, |
| 1106 | Version beginVersion, |
| 1107 | TaskCompletionKey completionKey, |
| 1108 | Reference<TaskFuture> waitFor = Reference<TaskFuture>()) { |
| 1109 | Key doneKey = wait(completionKey.get(tr, taskBucket)); |
| 1110 | auto task = makeReference<Task>(CopyLogsTaskFunc::name, CopyLogsTaskFunc::version, doneKey, 1); |
| 1111 | |
| 1112 | copyDefaultParameters(parentTask, task); |
| 1113 | task->params[BackupAgentBase::keyBeginVersion] = BinaryWriter::toValue(beginVersion, Unversioned()); |
| 1114 | task->params[DatabaseBackupAgent::keyPrevBeginVersion] = BinaryWriter::toValue(prevBeginVersion, Unversioned()); |
| 1115 | |
| 1116 | if (!waitFor) { |
| 1117 | return taskBucket->addTask(tr, |
| 1118 | task, |
| 1119 | parentTask->params[Task::reservedTaskParamValidKey], |
| 1120 | task->params[BackupAgentBase::keyFolderId]); |
| 1121 | } |
| 1122 | |
| 1123 | wait(waitFor->onSetAddTask(tr, |
| 1124 | taskBucket, |
| 1125 | task, |
| 1126 | parentTask->params[Task::reservedTaskParamValidKey], |
| 1127 | task->params[BackupAgentBase::keyFolderId])); |
| 1128 | return LiteralStringRef("OnSetAddTask"); |
| 1129 | } |
| 1130 | |
| 1131 | StringRef getName() const override { return name; }; |
| 1132 |
no test coverage detected