 |
TSDuck v3.45-4766
MPEG Transport Stream Toolkit
|
|
TSDuck v3.45-4766
MPEG Transport Stream Toolkit
|
This is the complete list of members for ts::ReactiveTCPConnection, including all inherited members.
| activateAsynchronousIO() | ts::ReactiveDevice | protected |
| activateReadReady() | ts::ReactiveDevice | protected |
| activateWriteReady() | ts::ReactiveDevice | protected |
| addSubscription(SubscriptionHandlerInterface *handler) | ts::SubscriptionBase | |
| callSubscribers(F &&func) | ts::SubscriptionBase | inlineprotected |
| cancelAndWaitAsynchronousIO(NonBlockingDevice::IOSB &iosb, bool silent) | ts::ReactiveDevice | protected |
| cancelAsynchronousIO(bool silent) | ts::ReactiveDevice | protected |
| cancelQueue(IOQueue &inqueue, IOQueue &outqueue) | ts::ReactiveDevice | protected |
| cancelReadWriteStream(bool silent=false) | ts::ReactiveStream | virtual |
| cancelSubscription(SubscriptionHandlerInterface *handler) | ts::SubscriptionBase | |
| createSignalQueuedOperations() | ts::ReactiveBase | protected |
| deactivateAll(bool silent) | ts::ReactiveDevice | protected |
| deactivateAsynchronousIO(bool silent) | ts::ReactiveDevice | protected |
| deactivateQueuedOperations(bool silent) | ts::ReactiveBase | protected |
| deactivateReadReady(bool silent) | ts::ReactiveDevice | protected |
| deactivateWriteReady(bool silent) | ts::ReactiveDevice | protected |
| DEFAULT_RECEIVE_BUFFER_SIZE | ts::ReactiveStream | static |
| device() | ts::ReactiveDevice | inline |
| enqueueCompletedIO(const std::shared_ptr< IOSB > &iosb, bool in_reactor) | ts::ReactiveStream | protected |
| handleAsynchronousIO(Reactor &, EventId, IOSB &, size_t) override | ts::ReactiveTCPConnection | protectedvirtual |
| handleBroadcastEvent(Reactor &reactor, int error_code, const ObjectPtr &user_data) | ts::ReactorHandlerInterface | protectedvirtual |
| handleProcessTermination(Reactor &reactor, EventId id, int pid) | ts::ReactorHandlerInterface | protectedvirtual |
| handleReadReady(Reactor &, EventId, int) override | ts::ReactiveStream | protectedvirtual |
| HandlerType typedef | ts::ReactiveTCPConnection | protected |
| handleTimer(Reactor &reactor, EventId id) | ts::ReactorHandlerInterface | protectedvirtual |
| handleUserEvent(Reactor &, EventId) override | ts::ReactiveBase | protectedvirtual |
| handleWriteReady(Reactor &, EventId, int) override | ts::ReactiveTCPConnection | protectedvirtual |
| hasPendingIO() | ts::ReactiveStream | protectedvirtual |
| IOQueue typedef | ts::ReactiveDevice | protected |
| IOSB typedef | ts::ReactiveDevice | protected |
| IOSet typedef | ts::ReactiveDevice | protected |
| isOpen() const | ts::ReactiveTCPConnection | inline |
| muteReport(bool mute) | ts::ReporterBase | |
| needsWriteReady() | ts::ReactiveStream | protectedvirtual |
| processCloseWriteStream(bool silent) override | ts::ReactiveTCPConnection | protectedvirtual |
| processQueuedOperations() override | ts::ReactiveTCPConnection | protectedvirtual |
| processReceiveBuffer(ByteBlock &data, ReactiveInputControl &control, ReactiveStreamHandlerInterface *handler, int error_code, const ObjectPtr &user_data) | ts::ReactiveStream | protected |
| ReactiveBase(Reactor &reactor) | ts::ReactiveBase | explicit |
| ReactiveDevice(Reactor &reactor, NonBlockingDevice &device) | ts::ReactiveDevice | |
| ReactiveStream(Reactor &reactor, NonBlockingDevice &device, StreamInterface &stream) | ts::ReactiveStream | |
| ReactiveTCPConnection(Reactor &reactor, TCPConnection &socket) | ts::ReactiveTCPConnection | |
| reactor() | ts::ReactiveBase | inline |
| removeFromQueue(IOQueue &queue, IOSB *iosb) | ts::ReactiveDevice | protected |
| report() const override | ts::ReporterBase | virtual |
| ReporterBase(Report *report) | ts::ReporterBase | inlineexplicit |
| ReporterBase(ReporterBase *delegate) | ts::ReporterBase | inlineexplicit |
| setReport(Report *report) | ts::ReporterBase | |
| setReport(ReporterBase *delegate) | ts::ReporterBase | |
| signalQueuedOperations() | ts::ReactiveBase | |
| SilentLevel(bool silent, int default_severity=Severity::Error) | ts::ReporterBase | inlinestatic |
| socket() | ts::ReactiveTCPConnection | inline |
| startClose(ReactiveTCPConnectionHandlerInterface *handler, bool silent=false, const ObjectPtr &user_data=ObjectPtr()) | ts::ReactiveTCPConnection | virtual |
| startCloseWriter(ReactiveStreamHandlerInterface *handler, bool silent=false, const ObjectPtr &user_data=ObjectPtr()) | ts::ReactiveTCPConnection | virtual |
| startCloseWriteStream(ReactiveStreamHandlerInterface *handler, bool silent, const ObjectPtr &user_data) | ts::ReactiveStream | protectedvirtual |
| startConnect(ReactiveTCPConnectionHandlerInterface *handler, const IPSocketAddress &addr, const ObjectPtr &user_data=ObjectPtr()) | ts::ReactiveTCPConnection | virtual |
| startReadStream(ReactiveStreamHandlerInterface *handler, size_t buffer_size=DEFAULT_RECEIVE_BUFFER_SIZE, const ObjectPtr &user_data=ObjectPtr()) | ts::ReactiveStream | virtual |
| startWriteStream(ReactiveStreamHandlerInterface *handler, const void *data, size_t size, const ObjectPtr &user_data=ObjectPtr()) | ts::ReactiveStream | virtual |
| stream() | ts::ReactiveStream | inline |
| SubscriptionBase()=default | ts::SubscriptionBase | |
| tryCompletedIO(const std::shared_ptr< IOSB > &iosb) override | ts::ReactiveTCPConnection | protectedvirtual |
| uncheckedSignalQueuedOperations() | ts::ReactiveBase | protected |
| whenAccepted(ReactiveTCPConnectionHandlerInterface *handler, const ObjectPtr &user_data=ObjectPtr()) | ts::ReactiveTCPConnection | virtual |
| ~ReactiveBase() override | ts::ReactiveBase | virtual |
| ~ReactiveDevice() override | ts::ReactiveDevice | virtual |
| ~ReactiveTCPConnection() override | ts::ReactiveTCPConnection | virtual |
| ~ReporterBase() override | ts::ReporterBase | virtual |
| ~SubscriptionBase() | ts::SubscriptionBase | virtual |
1.9.8