#include <Connection.h>
|
| ~Connection () |
|
Client & | client () const |
|
void | setOnlySendMessagesAsDispatchWhenWaitingForSyncReplyWhenProcessingSuchAMessage (bool) |
|
void | setShouldExitOnSyncMessageSendFailure (bool shouldExitOnSyncMessageSendFailure) |
|
void | setDidCloseOnConnectionWorkQueueCallback (DidCloseOnConnectionWorkQueueCallback callback) |
|
void | addWorkQueueMessageReceiver (StringReference messageReceiverName, WorkQueue &, WorkQueueMessageReceiver *) |
|
void | removeWorkQueueMessageReceiver (StringReference messageReceiverName) |
|
bool | open () |
|
void | invalidate () |
|
void | markCurrentlyDispatchedMessageAsInvalid () |
|
void | postConnectionDidCloseOnConnectionWorkQueue () |
|
template<typename T > |
bool | send (T &&message, uint64_t destinationID, OptionSet< SendOption > sendOptions={ }) |
|
template<typename T > |
void | sendWithReply (T &&message, uint64_t destinationID, FunctionDispatcher &replyDispatcher, Function< void(std::optional< typename CodingType< typename T::Reply >::Type >)> &&replyHandler) |
|
template<typename T > |
bool | sendSync (T &&message, typename T::Reply &&reply, uint64_t destinationID, Seconds timeout=Seconds::infinity(), OptionSet< SendSyncOption > sendSyncOptions={ }) |
|
template<typename T > |
bool | waitForAndDispatchImmediately (uint64_t destinationID, Seconds timeout, OptionSet< WaitForOption > waitForOptions={ }) |
|
bool | sendMessage (std::unique_ptr< Encoder >, OptionSet< SendOption > sendOptions) |
|
void | sendMessageWithReply (uint64_t requestID, std::unique_ptr< Encoder >, FunctionDispatcher &replyDispatcher, Function< void(std::unique_ptr< Decoder >)> &&replyHandler) |
|
std::unique_ptr< Encoder > | createSyncMessageEncoder (StringReference messageReceiverName, StringReference messageName, uint64_t destinationID, uint64_t &syncRequestID) |
|
std::unique_ptr< Decoder > | sendSyncMessage (uint64_t syncRequestID, std::unique_ptr< Encoder >, Seconds timeout, OptionSet< SendSyncOption > sendSyncOptions) |
|
bool | sendSyncReply (std::unique_ptr< Encoder >) |
|
void | wakeUpRunLoop () |
|
void | incrementDispatchMessageMarkedDispatchWhenWaitingForSyncReplyCount () |
|
void | decrementDispatchMessageMarkedDispatchWhenWaitingForSyncReplyCount () |
|
bool | inSendSync () const |
|
Identifier | identifier () const |
|
bool | isValid () const |
|
uint64_t | installIncomingSyncMessageCallback (std::function< void()>) |
|
void | uninstallIncomingSyncMessageCallback (uint64_t) |
|
bool | hasIncomingSyncMessage () |
|
void | allowFullySynchronousModeForTesting () |
|
void | ignoreTimeoutsForTesting () |
|
◆ DidCloseOnConnectionWorkQueueCallback
◆ ~Connection()
IPC::Connection::~Connection |
( |
| ) |
|
◆ addWorkQueueMessageReceiver()
◆ allowFullySynchronousModeForTesting()
void IPC::Connection::allowFullySynchronousModeForTesting |
( |
| ) |
|
|
inline |
◆ client()
Client& IPC::Connection::client |
( |
| ) |
const |
|
inline |
◆ createClientConnection()
Ref< Connection > IPC::Connection::createClientConnection |
( |
Identifier |
identifier, |
|
|
Client & |
client |
|
) |
| |
|
static |
◆ createServerConnection()
Ref< Connection > IPC::Connection::createServerConnection |
( |
Identifier |
identifier, |
|
|
Client & |
client |
|
) |
| |
|
static |
◆ createSyncMessageEncoder()
◆ decrementDispatchMessageMarkedDispatchWhenWaitingForSyncReplyCount()
void IPC::Connection::decrementDispatchMessageMarkedDispatchWhenWaitingForSyncReplyCount |
( |
| ) |
|
|
inline |
◆ hasIncomingSyncMessage()
bool IPC::Connection::hasIncomingSyncMessage |
( |
| ) |
|
◆ identifier()
IPC::Connection::Identifier IPC::Connection::identifier |
( |
| ) |
const |
◆ ignoreTimeoutsForTesting()
void IPC::Connection::ignoreTimeoutsForTesting |
( |
| ) |
|
|
inline |
◆ incrementDispatchMessageMarkedDispatchWhenWaitingForSyncReplyCount()
void IPC::Connection::incrementDispatchMessageMarkedDispatchWhenWaitingForSyncReplyCount |
( |
| ) |
|
|
inline |
◆ inSendSync()
bool IPC::Connection::inSendSync |
( |
| ) |
const |
|
inline |
◆ installIncomingSyncMessageCallback()
◆ invalidate()
void IPC::Connection::invalidate |
( |
| ) |
|
◆ isValid()
bool IPC::Connection::isValid |
( |
| ) |
const |
|
inline |
◆ markCurrentlyDispatchedMessageAsInvalid()
void IPC::Connection::markCurrentlyDispatchedMessageAsInvalid |
( |
| ) |
|
◆ open()
bool IPC::Connection::open |
( |
| ) |
|
◆ postConnectionDidCloseOnConnectionWorkQueue()
void IPC::Connection::postConnectionDidCloseOnConnectionWorkQueue |
( |
| ) |
|
◆ removeWorkQueueMessageReceiver()
◆ send()
template<typename T >
bool IPC::Connection::send |
( |
T && |
message, |
|
|
uint64_t |
destinationID, |
|
|
OptionSet< SendOption > |
sendOptions = { } |
|
) |
| |
◆ sendMessage()
bool IPC::Connection::sendMessage |
( |
std::unique_ptr< Encoder > |
encoder, |
|
|
OptionSet< SendOption > |
sendOptions |
|
) |
| |
◆ sendMessageWithReply()
void IPC::Connection::sendMessageWithReply |
( |
uint64_t |
requestID, |
|
|
std::unique_ptr< Encoder > |
encoder, |
|
|
FunctionDispatcher & |
replyDispatcher, |
|
|
Function< void(std::unique_ptr< Decoder >)> && |
replyHandler |
|
) |
| |
◆ sendSync()
template<typename T >
bool IPC::Connection::sendSync |
( |
T && |
message, |
|
|
typename T::Reply && |
reply, |
|
|
uint64_t |
destinationID, |
|
|
Seconds |
timeout = Seconds::infinity() , |
|
|
OptionSet< SendSyncOption > |
sendSyncOptions = { } |
|
) |
| |
◆ sendSyncMessage()
std::unique_ptr< Decoder > IPC::Connection::sendSyncMessage |
( |
uint64_t |
syncRequestID, |
|
|
std::unique_ptr< Encoder > |
encoder, |
|
|
Seconds |
timeout, |
|
|
OptionSet< SendSyncOption > |
sendSyncOptions |
|
) |
| |
◆ sendSyncReply()
bool IPC::Connection::sendSyncReply |
( |
std::unique_ptr< Encoder > |
encoder | ) |
|
◆ sendWithReply()
◆ setDidCloseOnConnectionWorkQueueCallback()
◆ setOnlySendMessagesAsDispatchWhenWaitingForSyncReplyWhenProcessingSuchAMessage()
void IPC::Connection::setOnlySendMessagesAsDispatchWhenWaitingForSyncReplyWhenProcessingSuchAMessage |
( |
bool |
flag | ) |
|
◆ setShouldExitOnSyncMessageSendFailure()
void IPC::Connection::setShouldExitOnSyncMessageSendFailure |
( |
bool |
shouldExitOnSyncMessageSendFailure | ) |
|
◆ uninstallIncomingSyncMessageCallback()
void IPC::Connection::uninstallIncomingSyncMessageCallback |
( |
uint64_t |
callbackID | ) |
|
◆ waitForAndDispatchImmediately()
template<typename T >
bool IPC::Connection::waitForAndDispatchImmediately |
( |
uint64_t |
destinationID, |
|
|
Seconds |
timeout, |
|
|
OptionSet< WaitForOption > |
waitForOptions = { } |
|
) |
| |
◆ wakeUpRunLoop()
void IPC::Connection::wakeUpRunLoop |
( |
| ) |
|
The documentation for this class was generated from the following files: