feedc0de/sdbus-cpp
1
0
Fork 0
forked from Kistler-Group/sdbus-cpp
Code Pull Requests Activity

Play with sync call data

Browse Source
This commit is contained in:
sangelovic
2020-01-18 01:08:38 +01:00
parent 9bd37d2227
commit 9bbb27f14d
2 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/Proxy.cpp
View File

@ -149,13 +149,13 @@ MethodReply Proxy::callMethodWithAsyncReplyBlocking(const MethodCall& message, u
// VARIANT 3: USING CLASSIC ASYNC APPROACH // VARIANT 3: USING CLASSIC ASYNC APPROACH
// TODO: Try with thread local std::function // TODO: Try with thread local std::function
// thread_local async_reply_handler asyncReplyCallback = [](MethodReply& reply, const Error* error) // /*thread_local*/ SyncCallReplyData syncCallReplyData;
// {
// auto& syncCallReplyData = getSyncCallReplyData();
// async_reply_handler asyncReplyCallback = [&syncCallReplyData](MethodReply& reply, const Error* error)
// {
// std::unique_lock<std::mutex> lock(syncCallReplyData.mutex); // std::unique_lock<std::mutex> lock(syncCallReplyData.mutex);
// syncCallReplyData.error = nullptr; // //syncCallReplyData.error = nullptr;
// if (error == nullptr) // if (error == nullptr)
// syncCallReplyData.reply = std::move(reply); // syncCallReplyData.reply = std::move(reply);
// else // else
@ -166,14 +166,13 @@ MethodReply Proxy::callMethodWithAsyncReplyBlocking(const MethodCall& message, u
// syncCallReplyData.cond.notify_one(); // syncCallReplyData.cond.notify_one();
// }; // };
// AsyncCalls::CallData callData{*this, /*std::move(*/asyncReplyCallback/*)*/, {}}; // AsyncCalls::CallData callData{*this, std::move(asyncReplyCallback), {}};
// message.sendWithAsyncReply((void*)&Proxy::sdbus_async_reply_handler, &callData, timeout); // message.sendWithAsyncReply((void*)&Proxy::sdbus_async_reply_handler, &callData, timeout);
// auto& syncCallReplyData = getSyncCallReplyData();
// std::unique_lock<std::mutex> lock(syncCallReplyData.mutex); // std::unique_lock<std::mutex> lock(syncCallReplyData.mutex);
// syncCallReplyData.cond.wait(lock, [&syncCallReplyData](){ return syncCallReplyData.arrived; }); // syncCallReplyData.cond.wait(lock, [&syncCallReplyData](){ return syncCallReplyData.arrived; });
// syncCallReplyData.arrived = false; // //syncCallReplyData.arrived = false;
// if (syncCallReplyData.error) // if (syncCallReplyData.error)
// throw *syncCallReplyData.error; // throw *syncCallReplyData.error;

2
src/Proxy.h
View File

@ -140,7 +140,7 @@ namespace internal {
{ {
std::mutex mutex; std::mutex mutex;
std::condition_variable cond; std::condition_variable cond;
bool arrived; bool arrived{};
MethodReply reply; MethodReply reply;
std::unique_ptr<Error> error; std::unique_ptr<Error> error;
}; };