// This file is under GNU General Public License 3.0 // see LICENSE.txt #include "Adapter.hh" #include #include #include using namespace std; namespace pEp { void throw_status(PEP_STATUS status) { if (status == PEP_STATUS_OK) return; if (status >= 0x400 && status <= 0x4ff) return; if (status == PEP_OUT_OF_MEMORY) throw bad_alloc(); if (status == PEP_ILLEGAL_VALUE) throw invalid_argument("illegal value"); stringstream build; build << setfill('0') << "p≡p 0x" << setw(4) << hex << status; throw RuntimeError(build.str(), status); } RuntimeError::RuntimeError(string _text, PEP_STATUS _status) : text(_text), runtime_error(text.c_str()), status(_status) { } namespace Adapter { static messageToSend_t _messageToSend = nullptr; static notifyHandshake_t _notifyHandshake = nullptr; static std::thread *_sync_thread = nullptr; static ::utility::locked_queue< SYNC_EVENT > q; static std::mutex m; static int _inject_sync_event(SYNC_EVENT ev, void *management) { if (is_sync_thread(session())) { PEP_STATUS status = do_sync_protocol_step(session(), nullptr, ev); return status == PEP_STATUS_OK ? 0 : 1; } try { q.push_front(ev); } catch (exception&) { return 1; } return 0; } static SYNC_EVENT _retrieve_next_sync_event(void *management, time_t threshold) { time_t started = time(nullptr); bool timeout = false; while (q.empty()) { int i = 0; ++i; if (i > 10) { if (time(nullptr) > started + threshold) { timeout = true; break; } i = 0; } #ifdef WIN32 const xtime xt[] = { { 0, 100000000L } }; _Thrd_sleep(xt); #else nanosleep((const struct timespec[]){{0, 100000000L}}, NULL); #endif } if (timeout) return new_sync_timeout_event(); return q.pop_front(); } template< class T > static void sync_thread(T *obj, function< int (T::*) > _startup) { PEP_STATUS status = register_sync_callbacks(session(), nullptr, _notifyHandshake, _retrieve_next_sync_event); throw_status(status); if (obj && startup) { _startup(obj); } do_sync_protocol(session(), (void *) obj); unregister_sync_callbacks(session()); session(release); } template< class T > void startup(messageToSend_t messageToSend, notifyHandshake_t notifyHandshake, T *obj, function< int ( T::* ) > _startup ) { if (messageToSend) _messageToSend = messageToSend; if (notifyHandshake) _notifyHandshake = notifyHandshake; session(); { lock_guard lock(m); if (!_sync_thread) _sync_thread = new thread(sync_thread, obj, _startup); } } PEP_SESSION session(session_action action) { lock_guard lock(m); thread_local static PEP_SESSION _session = nullptr; PEP_STATUS status = PEP_STATUS_OK; switch (action) { case release: if (_session) { ::release(_session); _session = nullptr; } break; case init: if (!_session) status = ::init(&_session, _messageToSend, _inject_sync_event); break; default: status = PEP_ILLEGAL_VALUE; } throw_status(status); return _session; } void shutdown() { if (_sync_thread) { _inject_sync_event(nullptr, nullptr); _sync_thread->join(); delete _sync_thread; _sync_thread = nullptr; } session(release); } } }