mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

thrift: add foreign_ptr<> variant to complete()

Browse Source 
Some calls will return complex types, so allow them to return a foreign_ptr<>
to ensure cleanup will happen in the correct place.
This commit is contained in:
Avi Kivity
2015-02-22 17:50:09 +02:00
parent 6f7dff825c
commit 0db67ff121
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
thrift/handler.cc
View File

@@ -65,6 +65,18 @@ void complete(future<T...>& fut,
}
}
template <typename T>
void complete(future<foreign_ptr<lw_shared_ptr<T>>>& fut,
const tcxx::function<void (const T&)>& cob,
const tcxx::function<void (::apache::thrift::TDelayedException* _throw)>& exn_cob) {
try {
cob(*std::get<0>(fut.get()));
} catch (...) {
delayed_exception_wrapper dew(std::current_exception());
exn_cob(&dew);
}
}
class CassandraAsyncHandler : public CassandraCobSvIf {
distributed<database>& _db;
keyspace* _ks = nullptr; // FIXME: reference counting for in-use detection?