Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 16:46:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

modify keep-alive example executable a bit, make it configurable

Browse Source
This commit is contained in:
Alexey Rybalchenko 2022-01-12 19:35:34 +01:00
parent a684a33f70
commit 881814910f
1 changed files with 77 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

118
examples/region/keep-alive.cxx
View File

@ -14,13 +14,18 @@
#include <fairlogger/Logger.h> #include <fairlogger/Logger.h>
#include <boost/algorithm/string.hpp>
#include <boost/program_options.hpp>
#include <csignal> #include <csignal>
#include <chrono> #include <chrono>
#include <map>
#include <string> #include <string>
#include <thread> #include <thread>
using namespace std; using namespace std;
using namespace boost::program_options;
namespace namespace
{ {
@ -32,19 +37,69 @@ void signalHandler(int /* signal */)
gStopping = 1; gStopping = 1;
} }
struct ShmRemover struct ShmManager
{ {
ShmRemover(std::string _shmId) : shmId(std::move(_shmId)) {} ShmManager(uint64_t _shmId, const vector<string>& _segments, const vector<string>& _regions)
~ShmRemover() : shmId(fair::mq::shmem::makeShmIdStr(_shmId))
{ {
// This will clean all segments, regions and any other shmem objects belonging to this shmId for (const auto& s : _segments) {
vector<string> segmentConf;
boost::algorithm::split(segmentConf, s, boost::algorithm::is_any_of(","));
if (segmentConf.size() != 2) {
LOG(error) << "incorrect format for --segments. Expecting pairs of <id>,<size>.";
fair::mq::shmem::Monitor::Cleanup(fair::mq::shmem::ShmId{shmId});
throw runtime_error("incorrect format for --segments. Expecting pairs of <id>,<size>.");
}
uint16_t id = stoi(segmentConf.at(0));
uint64_t size = stoull(segmentConf.at(1));
auto ret = segments.emplace(id, fair::mq::shmem::Segment(shmId, id, size, fair::mq::shmem::rbTreeBestFit));
fair::mq::shmem::Segment& segment = ret.first->second;
LOG(info) << "Created segment " << id << " of size " << segment.GetSize() << ", starting at " << segment.GetData() << ". Locking...";
segment.Lock();
LOG(info) << "Done.";
LOG(info) << "Zeroing...";
segment.Zero();
LOG(info) << "Done.";
}
for (const auto& r : _regions) {
vector<string> regionConf;
boost::algorithm::split(regionConf, r, boost::algorithm::is_any_of(","));
if (regionConf.size() != 2) {
LOG(error) << "incorrect format for --regions. Expecting pairs of <id>,<size>.";
fair::mq::shmem::Monitor::Cleanup(fair::mq::shmem::ShmId{shmId});
throw runtime_error("incorrect format for --regions. Expecting pairs of <id>,<size>.");
}
uint16_t id = stoi(regionConf.at(0));
uint64_t size = stoull(regionConf.at(1));
auto ret = regions.emplace(id, make_unique<fair::mq::shmem::UnmanagedRegion>(shmId, id, size));
fair::mq::shmem::UnmanagedRegion& region = *(ret.first->second);
LOG(info) << "Created unamanged region " << id << " of size " << region.GetSize() << ", starting at " << region.GetData() << ". Locking...";
region.Lock();
LOG(info) << "Done.";
LOG(info) << "Zeroing...";
region.Zero();
LOG(info) << "Done.";
}
}
void ResetContent()
{
fair::mq::shmem::Monitor::ResetContent(fair::mq::shmem::ShmId{shmId});
}
~ShmManager()
{
// clean all segments, regions and any other shmem objects belonging to this shmId
fair::mq::shmem::Monitor::Cleanup(fair::mq::shmem::ShmId{shmId}); fair::mq::shmem::Monitor::Cleanup(fair::mq::shmem::ShmId{shmId});
} }
std::string shmId; std::string shmId;
map<uint16_t, fair::mq::shmem::Segment> segments;
map<uint16_t, unique_ptr<fair::mq::shmem::UnmanagedRegion>> regions;
}; };
int main(int /* argc */, char** /* argv */) int main(int argc, char** argv)
{ {
fair::Logger::SetConsoleColor(true); fair::Logger::SetConsoleColor(true);
@ -52,47 +107,28 @@ int main(int /* argc */, char** /* argv */)
signal(SIGTERM, signalHandler); signal(SIGTERM, signalHandler);
try { try {
const string session = "default"; // to_string(fair::mq::tools::UuidHash()); uint64_t shmId = 0;
// generate shmId out of session id + user id (geteuid). vector<string> segments;
const string shmId = fair::mq::shmem::makeShmIdStr(session); vector<string> regions;
const uint16_t s1id = 0; options_description desc("Options");
const uint64_t s1size = 100000000; desc.add_options()
const uint16_t s2id = 1; ("shmid", value<uint64_t>(&shmId)->required(), "Shm id")
const uint64_t s2size = 200000000; ("segments", value<vector<string>>(&segments)->multitoken()->composing(), "Segments, as <id>,<size> <id>,<size> <id>,<size> ...")
("regions", value<vector<string>>(&regions)->multitoken()->composing(), "Regions, as <id>,<size> <id>,<size> <id>,<size> ...")
("help,h", "Print help");
const uint16_t r1id = 0; variables_map vm;
const uint64_t r1size = 100000000; store(parse_command_line(argc, argv, desc), vm);
const uint16_t r2id = 1;
const uint64_t r2size = 200000000;
// cleanup when done if (vm.count("help")) {
ShmRemover shmRemover(shmId); LOG(info) << "ShmManager" << "\n" << desc;
return 0;
}
// managed segments notify(vm);
fair::mq::shmem::Segment segment1(shmId, s1id, s1size, fair::mq::shmem::rbTreeBestFit);
segment1.Lock();
segment1.Zero();
LOG(info) << "Created segment " << s1id << " of size " << segment1.GetSize() << " starting at " << segment1.GetData();
fair::mq::shmem::Segment segment2(shmId, s2id, s2size, fair::mq::shmem::rbTreeBestFit); ShmManager shmManager(shmId, segments, regions);
segment2.Lock();
segment2.Zero();
LOG(info) << "Created segment " << s2id << " of size " << segment2.GetSize() << " starting at " << segment2.GetData();
// unmanaged regions
fair::mq::shmem::UnmanagedRegion region1(shmId, r1id, r1size);
region1.Lock();
region1.Zero();
LOG(info) << "Created region " << r1id << " of size " << region1.GetSize() << " starting at " << region1.GetData();
fair::mq::shmem::UnmanagedRegion region2(shmId, r2id, r2size);
region2.Lock();
region2.Zero();
LOG(info) << "Created region " << r2id << " of size " << region2.GetSize() << " starting at " << region2.GetData();
// for a "soft reset" call (shmem should not be in active use by (no messages in flight) devices during this call):
// fair::mq::shmem::Monitor::ResetContent(fair::mq::shmem::ShmId{shmId});
while (!gStopping) { while (!gStopping) {
std::this_thread::sleep_for(std::chrono::milliseconds(50)); std::this_thread::sleep_for(std::chrono::milliseconds(50));