Skip to content
Snippets Groups Projects
Commit b82406cc authored by Sergey Yakubov's avatar Sergey Yakubov
Browse files

astyle

parent da3aceb7
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
docs/site/examples/frozen_versions/21.06.0/getting_started/cpp/consume.cpp
+ 6
− 4
View file @ b82406cc
......@@ -14,11 +14,13 @@ int main(int argc, char* argv[]) {
auto endpoint = "localhost:8400"; // // or your endpoint
auto beamtime = "asapo_test";
auto token = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjk1NzE3MTAyMTYsImp0aSI6ImMzaXFhbGpmNDNhbGZwOHJua20wIiwic3ViIjoiYnRfYXNhcG9fdGVzdCIsIkV4dHJhQ2xhaW1zIjp7IkFjY2Vzc1R5cGVzIjpbIndyaXRlIiwicmVhZCJdfX0.dkWupPO-ysI4t-jtWiaElAzDyJF6T7hu_Wz_Au54mYU";
auto token =
"eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjk1NzE3MTAyMTYsImp0aSI6ImMzaXFhbGpmNDNhbGZwOHJua20wIiwic3ViIjoiYnRfYXNhcG9fdGVzdCIsIkV4dHJhQ2xhaW1zIjp7IkFjY2Vzc1R5cGVzIjpbIndyaXRlIiwicmVhZCJdfX0.dkWupPO-ysI4t-jtWiaElAzDyJF6T7hu_Wz_Au54mYU";
auto path_to_files = "/var/tmp/asapo/global_shared/data/test_facility/gpfs/test/2019/data/asapo_test"; //set it according to your configuration.
auto path_to_files =
"/var/tmp/asapo/global_shared/data/test_facility/gpfs/test/2019/data/asapo_test"; //set it according to your configuration.
auto consumer = asapo::ConsumerFactory::CreateConsumer(endpoint, path_to_files, true, asapo::SourceCredentials{asapo::SourceType::kProcessed,beamtime, "", "test_source", token}, &err);
auto consumer = asapo::ConsumerFactory::CreateConsumer(endpoint, path_to_files, true, asapo::SourceCredentials{asapo::SourceType::kProcessed, beamtime, "", "test_source", token}, &err);
exit_if_error("Cannot create consumer", err);
consumer->SetTimeout((uint64_t) 5000);
......@@ -27,7 +29,7 @@ int main(int argc, char* argv[]) {
asapo::MessageMeta mm;
asapo::MessageData data;
err = consumer->GetNext(group_id, &mm, &data,"default");
err = consumer->GetNext(group_id, &mm, &data, "default");
exit_if_error("Cannot get next record", err);
std::cout << "id: " << mm.id << std::endl;
......
docs/site/examples/frozen_versions/21.06.0/getting_started/cpp/produce.cpp
+ 3
− 3
View file @ b82406cc
......@@ -25,14 +25,14 @@ int main(int argc, char* argv[]) {
auto endpoint = "localhost:8400"; // or your endpoint
auto beamtime = "asapo_test";
auto producer = asapo::Producer::Create(endpoint, 1,asapo::RequestHandlerType::kTcp,
asapo::SourceCredentials{asapo::SourceType::kProcessed,beamtime, "", "test_source", ""}, 60000, &err);
auto producer = asapo::Producer::Create(endpoint, 1, asapo::RequestHandlerType::kTcp,
asapo::SourceCredentials{asapo::SourceType::kProcessed, beamtime, "", "test_source", ""}, 60000, &err);
exit_if_error("Cannot start producer", err);
std::string to_send = "hello";
auto send_size = to_send.size() + 1;
auto buffer = asapo::MessageData(new uint8_t[send_size]);
memcpy(buffer.get(),to_send.c_str(),send_size);
memcpy(buffer.get(), to_send.c_str(), send_size);
asapo::MessageHeader message_header{1, send_size, "processed/test_file"};
err = producer->Send(message_header, std::move(buffer), asapo::kDefaultIngestMode, "default", &ProcessAfterSend);
......
docs/site/examples/getting_started/cpp/consume.cpp
+ 6
− 4
View file @ b82406cc
......@@ -14,11 +14,13 @@ int main(int argc, char* argv[]) {
auto endpoint = "localhost:8400"; // // or your endpoint
auto beamtime = "asapo_test";
auto token = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjk1NzE3MTAyMTYsImp0aSI6ImMzaXFhbGpmNDNhbGZwOHJua20wIiwic3ViIjoiYnRfYXNhcG9fdGVzdCIsIkV4dHJhQ2xhaW1zIjp7IkFjY2Vzc1R5cGVzIjpbIndyaXRlIiwicmVhZCJdfX0.dkWupPO-ysI4t-jtWiaElAzDyJF6T7hu_Wz_Au54mYU";
auto token =
"eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjk1NzE3MTAyMTYsImp0aSI6ImMzaXFhbGpmNDNhbGZwOHJua20wIiwic3ViIjoiYnRfYXNhcG9fdGVzdCIsIkV4dHJhQ2xhaW1zIjp7IkFjY2Vzc1R5cGVzIjpbIndyaXRlIiwicmVhZCJdfX0.dkWupPO-ysI4t-jtWiaElAzDyJF6T7hu_Wz_Au54mYU";
auto path_to_files = "/var/tmp/asapo/global_shared/data/test_facility/gpfs/test/2019/data/asapo_test"; //set it according to your configuration.
auto path_to_files =
"/var/tmp/asapo/global_shared/data/test_facility/gpfs/test/2019/data/asapo_test"; //set it according to your configuration.
auto consumer = asapo::ConsumerFactory::CreateConsumer(endpoint, path_to_files, true, asapo::SourceCredentials{asapo::SourceType::kProcessed,beamtime, "", "test_source", token}, &err);
auto consumer = asapo::ConsumerFactory::CreateConsumer(endpoint, path_to_files, true, asapo::SourceCredentials{asapo::SourceType::kProcessed, beamtime, "", "test_source", token}, &err);
exit_if_error("Cannot create consumer", err);
consumer->SetTimeout((uint64_t) 5000);
......@@ -27,7 +29,7 @@ int main(int argc, char* argv[]) {
asapo::MessageMeta mm;
asapo::MessageData data;
err = consumer->GetNext(group_id, &mm, &data,"default");
err = consumer->GetNext(group_id, &mm, &data, "default");
exit_if_error("Cannot get next record", err);
std::cout << "id: " << mm.id << std::endl;
......
docs/site/examples/getting_started/cpp/produce.cpp
+ 3
− 3
View file @ b82406cc
......@@ -25,14 +25,14 @@ int main(int argc, char* argv[]) {
auto endpoint = "localhost:8400"; // or your endpoint
auto beamtime = "asapo_test";
auto producer = asapo::Producer::Create(endpoint, 1,asapo::RequestHandlerType::kTcp,
asapo::SourceCredentials{asapo::SourceType::kProcessed,beamtime, "", "test_source", ""}, 60000, &err);
auto producer = asapo::Producer::Create(endpoint, 1, asapo::RequestHandlerType::kTcp,
asapo::SourceCredentials{asapo::SourceType::kProcessed, beamtime, "", "test_source", ""}, 60000, &err);
exit_if_error("Cannot start producer", err);
std::string to_send = "hello";
auto send_size = to_send.size() + 1;
auto buffer = asapo::MessageData(new uint8_t[send_size]);
memcpy(buffer.get(),to_send.c_str(),send_size);
memcpy(buffer.get(), to_send.c_str(), send_size);
asapo::MessageHeader message_header{1, send_size, "processed/test_file"};
err = producer->Send(message_header, std::move(buffer), asapo::kDefaultIngestMode, "default", &ProcessAfterSend);
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment

imprint | privacy | Conditions of Use