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

Method addTask

fdbclient/DatabaseBackupAgent.actor.cpp:1372–1400  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 5

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

Tested by

no test coverage detected