|
| constexpr | BasicNetlinkEndpoint () noexcept |
| | default constructor.
|
| |
| | BasicNetlinkEndpoint (const struct sockaddr *addr, socklen_t len) noexcept |
| | create instance using socket address.
|
| |
| | BasicNetlinkEndpoint (const Protocol &protocol, uint32_t pid, uint32_t groups) noexcept |
| | create instance using netlink groups.
|
| |
| | BasicNetlinkEndpoint (uint32_t pid, uint32_t groups) noexcept |
| | create instance using netlink groups.
|
| |
| | BasicNetlinkEndpoint (const Protocol &protocol, uint32_t groups) noexcept |
| | create instance using netlink groups.
|
| |
| | BasicNetlinkEndpoint (uint32_t groups) noexcept |
| | create instance using netlink groups.
|
| |
| Protocol | protocol () const noexcept |
| | get endpoint protocol.
|
| |
| constexpr socklen_t | length () const noexcept |
| | get socket address length.
|
| |
| void | pid (uint32_t pid) noexcept |
| | set process id.
|
| |
| uint32_t | pid () const noexcept |
| | get process id.
|
| |
| void | groups (uint32_t groups) noexcept |
| | set netlink groups.
|
| |
| uint32_t | groups () const noexcept |
| | get netlink groups.
|
| |
| std::string | device () const |
| | get device name (not applicable for netlink).
|
| |
| constexpr | BasicEndpoint () noexcept |
| | default constructor.
|
| |
| | BasicEndpoint (const struct sockaddr *addr, socklen_t len) noexcept |
| | create instance using socket address.
|
| |
| | BasicEndpoint (Side side, const std::string &name, uint64_t elementSize=1472, uint64_t capacity=144) |
| | create instance.
|
| |
| | BasicEndpoint (const BasicEndpoint &other)=delete |
| | copy constructor.
|
| |
| struct sockaddr * | addr () noexcept |
| | get socket address.
|
| |
| const struct sockaddr * | addr () const noexcept |
| | get socket address.
|
| |
| BasicEndpoint & | operator= (const BasicEndpoint &other)=delete |
| | copy assignment operator.
|
| |
| | ~BasicEndpoint () |
| | destroy the instance.
|
| |
| int | open () |
| | open the channel endpoint.
|
| |
| void | close () |
| | close the channel endpoint.
|
| |
| bool | opened () const |
| | check if the endpoint is open.
|
| |
| int | trySend (const void *element) |
| | try to send a message to the peer (non blocking).
|
| |
| int | send (const void *element) |
| | send a message to the peer (blocking).
|
| |
| int | timedSend (const void *element, std::chrono::duration< Rep, Period > timeout) |
| | send a message to the peer with timeout (blocking).
|
| |
| int | tryReceive (void *element) |
| | try to receive a message from the peer (non blocking).
|
| |
| int | receive (void *element) |
| | receive a message from the peer (blocking).
|
| |
| int | timedReceive (void *element, std::chrono::duration< Rep, Period > timeout) |
| | receive a message from the peer with timeout (blocking).
|
| |
| uint64_t | available () const |
| | get number of available slots for sending.
|
| |
| bool | full () const |
| | check if outbound queue is full.
|
| |
| uint64_t | pending () const |
| | get number of pending messages.
|
| |
| bool | empty () const |
| | check if inbound queue is empty.
|
| |
| Side | side () const |
| | get the side this endpoint represents.
|
| |
| const std::string & | name () const |
| | get the channel name.
|
| |
| uint64_t | elementSize () const |
| | get the element size.
|
| |
| uint64_t | capacity () const |
| | get the buffer capacity.
|
| |
template<class Protocol>
class join::BasicNetlinkEndpoint< Protocol >
basic netlink endpoint class.