MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-06-26 13:58:18 +02:00
Code Issues Releases Wiki Activity

ircd::ctx: Add custom refcnt to allow copyable promise.

Browse source
This commit is contained in:
Jason Volk 2017-12-29 15:32:08 -07:00
parent bede11ef6e
commit c77ee478e5
2 changed files with 32 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
include/ircd/ctx/promise.h
View file

@ -58,9 +58,7 @@ class ircd::ctx::promise
promise();
promise(promise &&o) noexcept = default;
promise(const promise &) = delete;
promise &operator=(promise &&o) noexcept = default;
promise &operator=(const promise &) = delete;
promise(const promise &);
~promise() noexcept;
};
@ -85,9 +83,7 @@ class ircd::ctx::promise<void>
promise();
promise(promise &&o) noexcept = default;
promise(const promise &) = delete;
promise &operator=(promise &&) noexcept = default;
promise &operator=(const promise &) = delete;
promise(const promise &);
~promise() noexcept;
};
@ -95,28 +91,52 @@ inline
ircd::ctx::promise<void>::promise()
:st{std::make_shared<shared_state<void>>()}
{
++st->promise_refcnt;
assert(st->promise_refcnt == 1);
}
template<class T>
ircd::ctx::promise<T>::promise()
:st{std::make_shared<shared_state<T>>()}
{
++st->promise_refcnt;
assert(st->promise_refcnt == 1);
}
inline
ircd::ctx::promise<void>::promise(const promise<void> &o)
:st{o.st}
{
++st->promise_refcnt;
assert(st->promise_refcnt > 1);
}
template<class T>
ircd::ctx::promise<T>::promise(const promise<T> &o)
:st{o.st}
{
++st->promise_refcnt;
assert(st->promise_refcnt > 1);
}
inline
ircd::ctx::promise<void>::~promise()
noexcept
{
if(valid() && !st->finished && !st.unique())
set_exception(std::make_exception_ptr(broken_promise()));
if(valid())
if(!--st->promise_refcnt)
if(!st->finished && !st.unique())
set_exception(std::make_exception_ptr(broken_promise()));
}
template<class T>
ircd::ctx::promise<T>::~promise()
noexcept
{
if(valid() && !st->finished && !st.unique())
set_exception(std::make_exception_ptr(broken_promise()));
if(valid())
if(!--st->promise_refcnt)
if(!st->finished && !st.unique())
set_exception(std::make_exception_ptr(broken_promise()));
}
inline void

3
include/ircd/ctx/shared_state.h
View file

@ -33,7 +33,8 @@ struct ircd::ctx::shared_state_base
{
dock cond;
std::exception_ptr eptr;
bool finished = false;
uint promise_refcnt {0};
bool finished {false};
void reset();
};