MCPcopy Create free account
hub / github.com/apple/foundationdb / addTask

Method addTask

fdbclient/DatabaseBackupAgent.actor.cpp:1102–1129  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers 5

addTaskMethod · 0.45
addTaskMethod · 0.45
addTaskFunction · 0.45
Future<Key> addTaskFunction · 0.45
addTaskMethod · 0.45

Calls 4

copyDefaultParametersFunction · 0.85
UnversionedFunction · 0.85
getMethod · 0.65
onSetAddTaskMethod · 0.45

Tested by

no test coverage detected