Page MenuHomePhabricator
Differential D3634

[services] Backup - pull backup reactor - compaction - write response
ClosedPublic
Actions

Authored by • karol on Apr 6 2022, 7:39 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Mar 19, 8:31 AM
Unknown Object (File)
Sun, Mar 9, 6:22 PM
Unknown Object (File)
Sat, Mar 8, 3:32 PM
Unknown Object (File)
Sat, Mar 8, 3:32 PM
Unknown Object (File)
Sat, Mar 8, 3:32 PM
Unknown Object (File)
Sat, Mar 8, 3:30 PM
Unknown Object (File)
Mon, Mar 3, 12:52 PM
Unknown Object (File)
Thu, Feb 27, 6:01 AM
View All Files
Subscribers
• abosh
• adrian
ashoat
atul
• benschac
tomek

Details

Reviewers
tomek
• max
Commits
rCOMMbf058231b3df: [services] Backup - pull backup reactor - compaction - write response
Summary

Depends on D3637

The logic for writeResponse handling writing compaction chunks

Test Plan

The same as in D3535

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
services/
backup/
docker-server/
contents/
server/
src/
Reactors/
server/
23 lines

Diff 11108

View Options

services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h

Show First 20 Lines • Show All 69 Lines • ▼ Show 20 Lines switch (this->state) {
case State::DATA_CHUNKS: { case State::DATA_CHUNKS: {
// TODO initialize blob client reactor // TODO initialize blob client reactor
if (ServiceBlobClient::getInstance().putReactor == nullptr) { if (ServiceBlobClient::getInstance().putReactor == nullptr) {
throw std::runtime_error( throw std::runtime_error(
"blob client reactor has not been initialized"); "blob client reactor has not been initialized");
} }
ServiceBlobClient::getInstance().putReactor->scheduleSendingDataChunk( ServiceBlobClient::getInstance().putReactor->scheduleSendingDataChunk(
request.newcompactionchunk()); std::make_unique<std::string>(
std::move(*request.mutable_newcompactionchunk())));
return nullptr; return nullptr;
} }
} }
throw std::runtime_error("new backup - invalid state"); throw std::runtime_error("new backup - invalid state");
} }
void CreateNewBackupReactor::doneCallback() { void CreateNewBackupReactor::doneCallback() {
ServiceBlobClient::getInstance().putReactor->scheduleSendingDataChunk(""); ServiceBlobClient::getInstance().putReactor->scheduleSendingDataChunk(
std::make_unique<std::string>(""));
} }
} // namespace reactor } // namespace reactor
} // namespace network } // namespace network
} // namespace comm } // namespace comm