libzypp 17.32.5
|
#include <zypp-core/zyppng/thread/asyncqueue.h>
Static Public Member Functions | |
static std::shared_ptr< AsyncQueueWatch > | create (std::shared_ptr< AsyncQueueBase > queue) |
![]() | |
template<typename Obj , typename Functor > | |
static decltype(auto) | make_base_slot (Obj *o, Functor &&f) |
template<typename SenderFunc , typename ReceiverFunc > | |
static auto | connect (typename internal::MemberFunction< SenderFunc >::ClassType &s, SenderFunc &&sFun, typename internal::MemberFunction< ReceiverFunc >::ClassType &recv, ReceiverFunc &&rFunc) |
template<typename SenderFunc , typename ReceiverFunc , typename ... Tracker> | |
static auto | connectFunc (typename internal::MemberFunction< SenderFunc >::ClassType &s, SenderFunc &&sFun, ReceiverFunc &&rFunc, const Tracker &...trackers) |
Protected Member Functions | |
AsyncQueueWatch (std::shared_ptr< AsyncQueueBase > &&queue) | |
AsyncQueueWatch (AsyncQueueWatchPrivate &dd) | |
![]() | |
void | updateFdWatch (int fd, int mode) |
void | removeFdWatch (int fd) |
![]() | |
Base (BasePrivate &dd) | |
Additional Inherited Members | |
![]() | |
enum | EventTypes { Read = 0x01 , Write = 0x02 , Exception = 0x04 , Error = 0x08 } |
![]() | |
using | Ptr = std::shared_ptr<Base> |
using | WeakPtr = std::weak_ptr<Base> |
![]() | |
std::unique_ptr< BasePrivate > | d_ptr |
Definition at line 147 of file asyncqueue.h.
|
override |
Definition at line 70 of file asyncqueue.cc.
|
protected |
|
protected |
Definition at line 57 of file asyncqueue.cc.
|
static |
Definition at line 61 of file asyncqueue.cc.
void zyppng::AsyncQueueWatch::postNotifyEvent | ( | ) |
Definition at line 78 of file asyncqueue.cc.
SignalProxy< void()> zyppng::AsyncQueueWatch::sigMessageAvailable | ( | ) |
Definition at line 89 of file asyncqueue.cc.
|
overridevirtual |
Called by the
Implements zyppng::AbstractEventSource.
Definition at line 94 of file asyncqueue.cc.
|
overridevirtual |
Called when a event source has registered to receive unix signals
Implements zyppng::AbstractEventSource.
Definition at line 104 of file asyncqueue.cc.