Coldwave Documentation

Appearance

class flake::Transport ​

#include </Users/ios_developer/workspace/coldwave-os/build/_deps/flake-src/protocol/Transport.h>

Inherits from AtomicRef

Public Functions ​

Name
[int]sendRequest(Message * message, ConfirmationSink * sink, [uint32_t] timeout_ms, [bool] wait)
[int]sendIndication(Message * message, ResponseSink * sink, [uint32_t] timeout_ms, ResponseContext * ctx =[nullptr])
[int]reply(Message * message)
[void]processResponse(Message * message)
Message *receive()
[TransportState]state() const
Wire *wire() const
[int]startup()
[void]shutdown()
virtual [void]onWireDisconnect()
virtual [void]onWireUnavailable()
virtual [void]onWireConnect()
[uint32_t]lastMessageTimestamp() const
[void]linkServerConnection(ServerConnection * c)
ServerConnection *linkedServerConnection() const
virtual [void]setMTU([uint16_t] mtu)
virtual [uint16_t]getMTU() const

Protected Functions ​

Name
Transport(Wire * w, WireConnectionSink * wireSink, [ThreadQueue]< Message * > * inQueue, ServerConnection * serverConnection)
virtual~Transport() override

Friends ​

Name
[class]Router(Router )
[class]Message(Message )

Public Functions Documentation ​

function sendRequest ​

cpp
int sendRequest(
    Message * message,
    ConfirmationSink * sink,
    uint32_t timeout_ms,
    bool wait
)

function sendIndication ​

cpp
int sendIndication(
    Message * message,
    ResponseSink * sink,
    uint32_t timeout_ms,
    ResponseContext * ctx =nullptr
)

function reply ​

cpp
int reply(
    Message * message
)

function processResponse ​

cpp
void processResponse(
    Message * message
)

function receive ​

cpp
Message * receive()

function state ​

cpp
TransportState state() const

function wire ​

cpp
Wire * wire() const

function startup ​

cpp
int startup()

function shutdown ​

cpp
void shutdown()

function onWireDisconnect ​

cpp
virtual void onWireDisconnect()

function onWireUnavailable ​

cpp
virtual void onWireUnavailable()

function onWireConnect ​

cpp
virtual void onWireConnect()

function lastMessageTimestamp ​

cpp
uint32_t lastMessageTimestamp() const

function linkServerConnection ​

cpp
void linkServerConnection(
    ServerConnection * c
)

function linkedServerConnection ​

cpp
ServerConnection * linkedServerConnection() const

function setMTU ​

cpp
virtual void setMTU(
    uint16_t mtu
)

function getMTU ​

cpp
virtual uint16_t getMTU() const

Protected Functions Documentation ​

function Transport ​

cpp
Transport(
    Wire * w,
    WireConnectionSink * wireSink,
    ThreadQueue< Message * > * inQueue,
    ServerConnection * serverConnection
)

function ~Transport ​

cpp
virtual ~Transport() override

Friends ​

friend Router ​

cpp
friend class Router(
    Router 
);

friend Message ​

cpp
friend class Message(
    Message 
);