Page MenuHomePhabricator
Files F3365803

D5018.id16355.diff
No OneTemporary
Actions

D5018.id16355.diff
View Options

diff --git a/services/backup/src/Reactors/server/AddAttachmentsUtility.cpp b/services/backup/src/Reactors/server/AddAttachmentsUtility.cpp
--- a/services/backup/src/Reactors/server/AddAttachmentsUtility.cpp
+++ b/services/backup/src/Reactors/server/AddAttachmentsUtility.cpp
@@ -1,5 +1,7 @@
#include "AddAttachmentsUtility.h"
+#include "blob_client/src/lib.rs.h"
+
#include <glog/logging.h>
#include "BackupItem.h"
@@ -49,7 +51,7 @@
}
database::DatabaseManager::getInstance().putLogItem(*logItem);
}
- } catch (std::runtime_error &e) {
+ } catch (std::exception &e) {
LOG(ERROR) << e.what();
status = grpc::Status(grpc::StatusCode::INTERNAL, e.what());
}
@@ -72,10 +74,36 @@
// put into S3
std::condition_variable blobPutDoneCV;
std::mutex blobPutDoneCVMutex;
- // todo:blob perform put
- // todo:blob perform put:add chunk (std::move(data))
- // todo:blob perform put:add chunk ("")
- // todo:blob perform put:wait for completion
+ put_client_initialize_cxx();
+ put_client_write_cxx(
+ tools::getBlobPutField(blob::PutRequest::DataCase::kHolder),
+ holder.c_str());
+ put_client_blocking_read_cxx(); // todo this should be avoided
+ // (blocking); we should be able to
+ // ignore responses; we probably want to
+ // delegate performing ops to separate
+ // threads in the base reactors
+ put_client_write_cxx(
+ tools::getBlobPutField(blob::PutRequest::DataCase::kBlobHash),
+ newLogItem->getDataHash().c_str());
+ rust::String responseStr =
+ put_client_blocking_read_cxx(); // todo this should be avoided
+ // (blocking); we should be able to
+ // ignore responses; we probably want to
+ // delegate performing ops to separate
+ // threads in the base reactors
+ // data exists?
+ if (!(bool)tools::charPtrToInt(responseStr.c_str())) {
+ put_client_write_cxx(
+ tools::getBlobPutField(blob::PutRequest::DataCase::kDataChunk),
+ std::move(data).c_str());
+ put_client_blocking_read_cxx(); // todo this should be avoided
+ // (blocking); we should be able to
+ // ignore responses; we probably want to
+ // delegate performing ops to separate
+ // threads in the base reactors
+ }
+ put_client_terminate_cxx();
return newLogItem;
}

File Metadata

Mime Type
text/plain
Expires
Tue, Nov 26, 7:49 AM (20 h, 5 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2583931
Default Alt Text
D5018.id16355.diff (2 KB)

Event Timeline