nanomsg.bindings

http://nanomsg.org

nanomsg is a socket library that provides several common communication patterns. It aims to make the networking layer fast, scalable, and easy to use. Implemented in C, it works on a wide range of operating systems with no further dependencies.

This module implements D bindings for nanomsg.

Members

Aliases

nn_fsm_fn
alias nn_fsm_fn = void function(nn_fsm*, int, int, void*)

Virtual function to be implemented by the derived class to handle the incoming events.

Enums

NN
enum NN

Generic socket options (NN_SOL_SOCKET level).

NN_HAUSNUMERO
enum NN_HAUSNUMERO

Errors: On some platforms some standard POSIX errnos are not defined

NN_NS
enum NN_NS

Constants that are returned in ns member of nn_symbol_properties:

NN_PIPE
enum NN_PIPE
NN_PIPEBASE
enum NN_PIPEBASE

Pipebase:

NN_STAT
enum NN_STAT
NN_TYPE
enum NN_TYPE

Constants that are returned in ns member of nn_symbol_properties

NN_UNIT
enum NN_UNIT

Constants that are returned in ns member of nn_symbol_properties

NN_VERSION_CURRENT
enum NN_VERSION_CURRENT

ABI versioning support: The current interface version.

Functions

NN_CMSG_ALIGN_
auto NN_CMSG_ALIGN_(long len)

rewritten from lambda syntax because libdparse does not recognise alias to a lambda and docs won't be built because adrdox depends on it

NN_CMSG_DATA
ubyte* NN_CMSG_DATA(T* cmsg)

posix-defined msghdr manipulation

NN_CMSG_FIRSTHDR
auto NN_CMSG_FIRSTHDR(T* mhdr)

posix-defined msghdr manipulation

NN_CMSG_LEN
auto NN_CMSG_LEN(size_t len)

Extension to POSIX defined by RFC 3542.

NN_CMSG_NXTHDR
auto NN_CMSG_NXTHDR(T* mhdr, U* cmsg)

posix-defined msghdr manipulation

NN_CMSG_SPACE
auto NN_CMSG_SPACE(size_t len)

Extension to POSIX defined by RFC 3542.

nn_allocmsg
void* nn_allocmsg(size_t size, int type)
nn_bind
int nn_bind(int s, const(char)* addr)
nn_close
int nn_close(int s)
nn_connect
int nn_connect(int s, const(char)* addr)
nn_device
int nn_device(int s1, int s2)

Built-in support for devices.

nn_epbase_clear_error
void nn_epbase_clear_error(nn_epbase* self)

Notifies a monitoring system that error is gone

nn_epbase_clear_error
void nn_epbase_clear_error(nn_epbase* self)
nn_epbase_getaddr
const(char*) nn_epbase_getaddr(nn_epbase* self)

Returns the address string associated with this endpoint.

nn_epbase_getaddr
char* nn_epbase_getaddr(nn_epbase* self)
nn_epbase_getctx
nn_ctx* nn_epbase_getctx(nn_epbase* self)

Returns the AIO context associated with the endpoint.

nn_epbase_getctx
nn_ctx* nn_epbase_getctx(nn_epbase* self)
nn_epbase_getopt
void nn_epbase_getopt(nn_epbase* self, int level, int option, void* optval, size_t* optvallen)

Retrieve value of a socket option.

nn_epbase_getopt
void nn_epbase_getopt(nn_epbase* self, int level, int option, void* optval, size_t* optvallen)
nn_epbase_init
void nn_epbase_init(nn_epbase* self, const(nn_epbase_vfptr)* vfptr, void* hint)

Creates a new endpoint. 'hint' parameter is an opaque value that was passed to transport's bind or connect function.

nn_epbase_init
void nn_epbase_init(nn_epbase* self, const nn_epbase_vfptr* vfptr, void* hint)

Creates a new endpoint. Parameters: hint = opaque value that was passed to transport's bind or connect function.

nn_epbase_ispeer
int nn_epbase_ispeer(nn_epbase* self, int socktype)
nn_epbase_ispeer
int nn_epbase_ispeer(nn_epbase* self, int socktype)
nn_epbase_set_error
void nn_epbase_set_error(nn_epbase* self, int errnum)

Notifies a monitoring system the error on this endpoint

nn_epbase_set_error
void nn_epbase_set_error(nn_epbase* self, int errnum)
nn_epbase_stat_increment
void nn_epbase_stat_increment(nn_epbase* self, int name, int increment)

Increments statistics counters in the socket structure

nn_epbase_stat_increment
void nn_epbase_stat_increment(nn_epbase* self, int name, int increment)
nn_epbase_stopped
void nn_epbase_stopped(nn_epbase* self)

Notify the user that stopping is done.

nn_epbase_stopped
void nn_epbase_stopped(nn_epbase* self)
nn_epbase_term
void nn_epbase_term(nn_epbase* self)

Terminate the epbase object.

nn_epbase_term
void nn_epbase_term(nn_epbase* self)
nn_errno
int nn_errno()

This function retrieves the errno as it is known to the library. The goal of this function is to make the code 100% portable, including where the library is compiled with certain CRT library (on Windows) and linked to an application that uses different CRT library.

nn_freemsg
int nn_freemsg(void* msg)
nn_fsm_action
void nn_fsm_action(nn_fsm*, int type)
nn_fsm_choose_worker
nn_worker* nn_fsm_choose_worker(nn_fsm*)
nn_fsm_event_active
int nn_fsm_event_active(nn_fsm_event* self)
nn_fsm_event_init
void nn_fsm_event_init(nn_fsm_event* self)
nn_fsm_event_process
void nn_fsm_event_process(nn_fsm_event* self)
nn_fsm_event_term
void nn_fsm_event_term(nn_fsm_event* self)
nn_fsm_feed
void nn_fsm_feed(nn_fsm*, int src, int type, void* srcptr)
nn_fsm_init
void nn_fsm_init(nn_fsm*, nn_fsm_fn fn, nn_fsm_fn shutdown_fn, int src, void* srcptr, nn_fsm* owner)
nn_fsm_init_root
void nn_fsm_init_root(nn_fsm* self, nn_fsm_fn fn, nn_fsm_fn shutdown_fn, nn_ctx* ctx)
nn_fsm_isidle
int nn_fsm_isidle(nn_fsm*)
nn_fsm_raise
void nn_fsm_raise(nn_fsm*, nn_fsm_event* event, int type)
nn_fsm_raiseto
void nn_fsm_raiseto(nn_fsm*, nn_fsm* dst, nn_fsm_event* event, int src, int type, void* srcptr)
nn_fsm_start
void nn_fsm_start(nn_fsm*)
nn_fsm_stop
void nn_fsm_stop(nn_fsm*)
nn_fsm_stopped
void nn_fsm_stopped(nn_fsm*, int type)
nn_fsm_stopped_noevent
void nn_fsm_stopped_noevent(nn_fsm*)
nn_fsm_swap_owner
void nn_fsm_swap_owner(nn_fsm*, nn_fsm_owner* owner)
nn_fsm_term
void nn_fsm_term(nn_fsm*)
nn_getsockopt
int nn_getsockopt(int s, int level, int option, void* optval, size_t* optvallen)
nn_list_begin
nn_list_item* nn_list_begin(nn_list*)
nn_list_empty
int nn_list_empty(nn_list*)
nn_list_end
nn_list_item* nn_list_end(nn_list*)
nn_list_erase
nn_list_item* nn_list_erase(nn_list*, nn_list_item*)
nn_list_init
void nn_list_init(nn_list*)

Initialise the list.

nn_list_insert
void nn_list_insert(nn_list*, nn_list_item*, nn_list_item*)
nn_list_item_init
void nn_list_item_init(nn_list_item*)
nn_list_item_isinlist
int nn_list_item_isinlist(nn_list_item*)
nn_list_item_term
void nn_list_item_term(nn_list_item*)
nn_list_next
nn_list_item* nn_list_next(nn_list*, nn_list_item*)
nn_list_prev
nn_list_item* nn_list_prev(nn_list*, nn_list_item*)
nn_list_term
void nn_list_term(nn_list*)
nn_pipe_getdata
void* nn_pipe_getdata(nn_pipe* self)
nn_pipe_getdata
void* nn_pipe_getdata(nn_pipe* self)
nn_pipe_getdata
void* nn_pipe_getdata(nn_pipe* self)

Retrieves the opaque pointer associated with the pipe.

nn_pipe_getopt
void nn_pipe_getopt(nn_pipe* self, int level, int option, void* optval, size_t* optvallen)
nn_pipe_getopt
void nn_pipe_getopt(nn_pipe* self, int level, int option, void* optval, size_t* optvallen)

Get option for pipe. Mostly useful for endpoint-specific options

nn_pipe_getopt
void nn_pipe_getopt(nn_pipe* self, int level, int option, void* optval, size_t* optvallen)
nn_pipe_recv
int nn_pipe_recv(nn_pipe* self, nn_msg* msg)
nn_pipe_recv
int nn_pipe_recv(nn_pipe* self, nn_msg* msg)

Receive a message from a pipe. 'msg' should not be initialised prior to the call. It will be initialised when the call succeeds.

nn_pipe_recv
int nn_pipe_recv(nn_pipe* self, nn_msg* msg)
nn_pipe_send
int nn_pipe_send(nn_pipe* self, nn_msg* msg)
nn_pipe_send
int nn_pipe_send(nn_pipe* self, nn_msg* msg)

Send the message to the pipe. If successful, pipe takes ownership of the messages.

nn_pipe_send
int nn_pipe_send(nn_pipe* self, nn_msg* msg)
nn_pipe_setdata
void nn_pipe_setdata(nn_pipe* self, void* data)
nn_pipe_setdata
void nn_pipe_setdata(nn_pipe* self, void* data)
nn_pipe_setdata
void nn_pipe_setdata(nn_pipe* self, void* data)

Associates opaque pointer to protocol-specific data with the pipe.

nn_pipebase_getopt
void nn_pipebase_getopt(nn_pipebase* self, int level, int option, void* optval, size_t* optvallen)

Retrieve value of a socket option.

nn_pipebase_getopt
void nn_pipebase_getopt(nn_pipebase*, int level, int option, void* optval, size_t* optvallen)
nn_pipebase_init
void nn_pipebase_init(nn_pipebase* self, const(nn_pipebase_vfptr)* vfptr, nn_epbase* epbase)

Initialise the pipe.

nn_pipebase_init
void nn_pipebase_init(nn_pipebase*, const(nn_pipebase_vfptr)* vfptr, nn_epbase* epbase)
nn_pipebase_ispeer
int nn_pipebase_ispeer(nn_pipebase* self, int socktype)

Returns 1 is the specified socket type is a valid peer for this socket, or 0 otherwise.

nn_pipebase_ispeer
int nn_pipebase_ispeer(nn_pipebase*, int socktype)
nn_pipebase_received
void nn_pipebase_received(nn_pipebase* self)

Call this function when new message was fully received.

nn_pipebase_received
void nn_pipebase_received(nn_pipebase*)
nn_pipebase_sent
void nn_pipebase_sent(nn_pipebase* self)

Call this function when current outgoing message was fully sent.

nn_pipebase_sent
void nn_pipebase_sent(nn_pipebase*)
nn_pipebase_start
int nn_pipebase_start(nn_pipebase* self)

Call this function once the connection is established.

nn_pipebase_start
int nn_pipebase_start(nn_pipebase*)
nn_pipebase_stop
void nn_pipebase_stop(nn_pipebase* self)

Call this function once the connection is broken.

nn_pipebase_stop
void nn_pipebase_stop(nn_pipebase*)
nn_pipebase_term
void nn_pipebase_term(nn_pipebase* self)

Terminate the pipe.

nn_pipebase_term
void nn_pipebase_term(nn_pipebase*)
nn_poll
int nn_poll(nn_pollfd* fds, int nfds, int timeout)
nn_queue_empty
int nn_queue_empty(nn_queue*)
nn_queue_init
void nn_queue_init(nn_queue*)
nn_queue_item_init
void nn_queue_item_init(nn_queue_item*)
nn_queue_item_isinqueue
int nn_queue_item_isinqueue(nn_queue_item*)
nn_queue_item_term
void nn_queue_item_term(nn_queue_item*)
nn_queue_pop
nn_queue_item* nn_queue_pop(nn_queue*)
nn_queue_push
void nn_queue_push(nn_queue*, nn_queue_item*)
nn_queue_term
void nn_queue_term(nn_queue*)
nn_reallocmsg
void* nn_reallocmsg(void* msg, size_t size)
nn_recv
int nn_recv(int s, void* buf, size_t len, int flags)
nn_recvmsg
int nn_recvmsg(int s, nn_msghdr* msghdr, int flags)
nn_req_recv
int nn_req_recv(int s, nn_req_handle* hndl, void* buf, size_t len, int flags)
nn_req_send
int nn_req_send(int s, nn_req_handle hndl, const(void)* buf, size_t len, int flags)
nn_send
int nn_send(int s, const(void)* buf, size_t len, int flags)
nn_sendmsg
int nn_sendmsg(int s, nn_msghdr* msghdr, int flags)
nn_sendmsg
int nn_sendmsg(int s, const(nn_msghdr)* msghdr, int flags)
nn_setsockopt
int nn_setsockopt(int s, int level, int option, const(void)* optval, size_t optvallen)
nn_shutdown
int nn_shutdown(int s, int how)
nn_sockbase_getctx
nn_ctx* nn_sockbase_getctx(nn_sockbase* self)

Returns the AIO context associated with the socket. This function is useful when socket type implementation needs to create async objects, such as timers.

nn_sockbase_getctx
nn_ctx* nn_sockbase_getctx(nn_sockbase* self)

Returns the AIO context associated with the socket. This function is useful when socket type implementation needs to create async objects, such as timers.

nn_sockbase_getopt
int nn_sockbase_getopt(nn_sockbase* self, int option, void* optval, size_t* optvallen)

Retrieve a NN_SOL_SOCKET-level option.

nn_sockbase_getopt
int nn_sockbase_getopt(nn_sockbase* self, int option, void* optval, size_t* optvallen)

Retrieve a NN_SOL_SOCKET-level option.

nn_sockbase_init
void nn_sockbase_init(nn_sockbase* self, const nn_sockbase_vfptr* vfptr, void* hint)

Initialise the socket base class. 'hint' is the opaque value passed to the nn_transport's 'create' function.

nn_sockbase_init
void nn_sockbase_init(nn_sockbase* self, const(nn_sockbase_vfptr)* vfptr, void* hint)

Base class for all socket types: */ /// Initialise the socket base class. 'hint' is the opaque value passed to the /// nn_transport's 'create' function

nn_sockbase_stat_increment
void nn_sockbase_stat_increment(nn_sockbase* self, int name, int increment)

Add some statistics for socket

nn_sockbase_stat_increment
void nn_sockbase_stat_increment(nn_sockbase* self, int name, int increment)

Add some statistics for socket

nn_sockbase_stopped
void nn_sockbase_stopped(nn_sockbase* self)

Call this function when stopping is done.

nn_sockbase_stopped
void nn_sockbase_stopped(nn_sockbase* self)

Call this function when stopping is done.

nn_sockbase_term
void nn_sockbase_term(nn_sockbase* self)

Terminate the socket base class.

nn_sockbase_term
void nn_sockbase_term(nn_sockbase* self)

Terminate the socket base class.

nn_socket
int nn_socket(int domain, int protocol)
nn_strerror
const(char)* nn_strerror(int errnum)

Resolves system errors and native errors to human-readable string.

nn_symbol
const(char)* nn_symbol(int i, int* value)

Returns the symbol name (e.g. "NN_REQ") and value at a specified index. If the index is out-of-range, returns null and sets errno to EINVAL General usage is to start at i=0 and iterate until null is returned.

nn_symbol
char* nn_symbol(int i, int* value)

Symbols: Returns the symbol name (e.g. "NN_REQ") and value at a specified index. If the index is out-of-range, returns 0 and sets errno to EINVAL General usage is to start at i=0 and iterate until 0 is returned.

nn_symbol_info
int nn_symbol_info(int i, nn_symbol_properties* buf, int buflen)

Fills in nn_symbol_properties structure and returns it's length If the index is out-of-range, returns 0 General usage is to start at i=0 and iterate until zero is returned.

nn_tcpmuxd
int nn_tcpmuxd(int port)

Built-in support for multiplexers.

nn_term
void nn_term()

Helper function for shutting down multi-threaded applications

Structs

nn_cmsghdr
struct nn_cmsghdr
nn_cp
struct nn_cp
nn_ctx
struct nn_ctx
nn_ep
struct nn_ep
nn_ep_options
struct nn_ep_options
nn_epbase
struct nn_epbase
nn_epbase_vfptr
struct nn_epbase_vfptr
nn_fsm
struct nn_fsm
nn_fsm_event
struct nn_fsm_event
nn_fsm_owner
struct nn_fsm_owner
nn_iovec
struct nn_iovec

Socket definition:

nn_list
struct nn_list
nn_list_item
struct nn_list_item
nn_msg
struct nn_msg
nn_msghdr
struct nn_msghdr

Message Header: */ //

nn_optset
struct nn_optset
nn_optset_vfptr
struct nn_optset_vfptr
nn_pipe
struct nn_pipe
nn_pipebase
struct nn_pipebase
nn_pipebase_vfptr
struct nn_pipebase_vfptr
nn_pollfd
struct nn_pollfd
nn_queue
struct nn_queue
nn_queue_item
struct nn_queue_item

Use for initialising a queue item statically.

nn_sock
struct nn_sock
nn_sockbase
struct nn_sockbase
nn_sockbase_vfptr
struct nn_sockbase_vfptr

To be implemented by individual socket types.

nn_socktype
struct nn_socktype

The socktype class: This structure defines a class factory for individual socket types.

nn_symbol_properties
struct nn_symbol_properties

Structure that is returned from nn_symbol

nn_transport
struct nn_transport

Transport: */ //

nn_worker
struct nn_worker

Unions

nn_req_handle
union nn_req_handle

Variables

AF_SP
auto AF_SP

SP address families: */ ////** SP address families: */ //

AF_SP_RAW
auto AF_SP_RAW
NN_BUS
auto NN_BUS
NN_DOMAIN
auto NN_DOMAIN

= NN.DOMAIN/// = NN.DOMAIN

NN_DONTWAIT
auto NN_DONTWAIT

Send/recv options./// Send/recv options.

NN_FSM_ACTION
auto NN_FSM_ACTION

Special source for actions. It's negative not to clash with user-defined sources. *//** Special source for actions. It's negative not to clash with user-defined sources.

NN_FSM_INCLUDED
auto NN_FSM_INCLUDED

FSM: *//** FSM:

NN_FSM_START
auto NN_FSM_START

Actions generated by fsm object. The values are negative not to clash with user-defined actions. *//** Actions generated by fsm object. The values are negative not to clash with user-defined actions.

NN_FSM_STOP
auto NN_FSM_STOP
NN_H_INCLUDED
auto NN_H_INCLUDED
NN_INPROC
auto NN_INPROC

INPROC: *//** INPROC:

NN_IPC
auto NN_IPC

IPC: *//** IPC:

NN_IPV4ONLY
auto NN_IPV4ONLY

= NN.IPV4ONLY/// = NN.IPV4ONLY

NN_LINGER
auto NN_LINGER

= NN.LINGER/// = NN.LINGER

NN_LIST_INCLUDED
auto NN_LIST_INCLUDED
NN_LIST_ITEM_INITIALIZER
typeof(NN_LIST_NOTINLIST)[2] NN_LIST_ITEM_INITIALIZER

Use for initializing a list item statically.

NN_LIST_NOTINLIST
auto NN_LIST_NOTINLIST

Undefined value for initializing a list item which is not part of a list./// Undefined value for initializing a list item which is not part of a list.

NN_MSG
auto NN_MSG

Zero-copy support: */ ////** Zero-copy support: */ //

NN_NS_DOMAIN
auto NN_NS_DOMAIN
NN_NS_ERROR
auto NN_NS_ERROR
NN_NS_EVENT
auto NN_NS_EVENT
NN_NS_FLAG
auto NN_NS_FLAG
NN_NS_LIMIT
auto NN_NS_LIMIT
NN_NS_NAMESPACE
auto NN_NS_NAMESPACE
NN_NS_OPTION_LEVEL
auto NN_NS_OPTION_LEVEL
NN_NS_OPTION_TYPE
auto NN_NS_OPTION_TYPE
NN_NS_OPTION_UNIT
auto NN_NS_OPTION_UNIT
NN_NS_PROTOCOL
auto NN_NS_PROTOCOL
NN_NS_SOCKET_OPTION
auto NN_NS_SOCKET_OPTION
NN_NS_TRANSPORT
auto NN_NS_TRANSPORT
NN_NS_TRANSPORT_OPTION
auto NN_NS_TRANSPORT_OPTION
NN_NS_VERSION
auto NN_NS_VERSION
NN_PAIR
auto NN_PAIR
NN_PIPEBASE_PARSED
auto NN_PIPEBASE_PARSED

Specifies that received message is already split into header and body. This flag is used only by inproc transport to avoid merging and re-splitting the messages passed with a single process. *//** Specifies that received message is already split into header and body. This flag is used only by inproc transport to avoid merging and re-splitting the messages passed with a single process.

NN_PIPEBASE_RELEASE
auto NN_PIPEBASE_RELEASE

The base class for pipes:

NN_PIPE_IN
auto NN_PIPE_IN
NN_PIPE_OUT
auto NN_PIPE_OUT
NN_PIPE_PARSED
auto NN_PIPE_PARSED
NN_PIPE_RELEASE
auto NN_PIPE_RELEASE
NN_POLLIN
auto NN_POLLIN

Socket multiplexing support: */ ////** Socket multiplexing support: */ //

NN_POLLOUT
auto NN_POLLOUT
NN_PROTOCOL
auto NN_PROTOCOL

= NN.PROTOCOL/// = NN.PROTOCOL

NN_PROTOCOL_INCLUDED
auto NN_PROTOCOL_INCLUDED
NN_PROTO_BUS
auto NN_PROTO_BUS

BUS: *//** BUS:

NN_PROTO_PAIR
auto NN_PROTO_PAIR
NN_PROTO_PIPELINE
auto NN_PROTO_PIPELINE

PIPELINE: */ ////** PIPELINE: */ //

NN_PROTO_PUBSUB
auto NN_PROTO_PUBSUB

PUBSUB: */ ////** PUBSUB: */ //

NN_PROTO_REQREP
auto NN_PROTO_REQREP
NN_PROTO_SURVEY
auto NN_PROTO_SURVEY
NN_PUB
auto NN_PUB
NN_PULL
auto NN_PULL
NN_PUSH
auto NN_PUSH
NN_QUEUE_INCLUDED
auto NN_QUEUE_INCLUDED

Queues: */ ////** Queues: */ //

NN_QUEUE_NOTINQUEUE
const(nn_queue_item)* NN_QUEUE_NOTINQUEUE

Undefined value for initialising a queue item which is not part of a queue.

NN_RCVBUF
auto NN_RCVBUF

= NN.RCVBUF/// = NN.RCVBUF

NN_RCVFD
auto NN_RCVFD

= NN.RCVFD/// = NN.RCVFD

NN_RCVMAXSIZE
auto NN_RCVMAXSIZE

= NN.RCVMAXSIZE/// = NN.RCVMAXSIZE

NN_RCVPRIO
auto NN_RCVPRIO

= NN.RCVPRIO/// = NN.RCVPRIO

NN_RCVTIMEO
auto NN_RCVTIMEO

= NN.RCVTIME0/// = NN.RCVTIME0

NN_RECONNECT_IVL
auto NN_RECONNECT_IVL

= NN.RECONNECT_IVL/// = NN.RECONNECT_IVL

NN_RECONNECT_IVL_MAX
auto NN_RECONNECT_IVL_MAX

= NN.RECONNECT_IVL_MAX/// = NN.RECONNECT_IVL_MAX

NN_REP
auto NN_REP
NN_REQ
auto NN_REQ
NN_REQ_RESEND_IVL
auto NN_REQ_RESEND_IVL
NN_RESPONDENT
auto NN_RESPONDENT
NN_SNDBUF
auto NN_SNDBUF

= NN.SNDBUF/// = NN.SNDBUF

NN_SNDFD
auto NN_SNDFD

= NN.SNDFD/// = NN.SNDFD

NN_SNDPRIO
auto NN_SNDPRIO

= NN.SNDPRIO/// = NN.SNDPRIO

NN_SNDTIMEO
auto NN_SNDTIMEO

= NN.SNDTIME0/// = NN.SNDTIME0

NN_SOCKADDR_MAX
auto NN_SOCKADDR_MAX

Max size of an SP address/// Max size of an SP address

NN_SOCKBASE_EVENT_IN
auto NN_SOCKBASE_EVENT_IN

Base class for all socket types:

NN_SOCKBASE_EVENT_OUT
auto NN_SOCKBASE_EVENT_OUT
NN_SOCKET_NAME
auto NN_SOCKET_NAME

= NN.SOCKET_NAME/// = NN.SOCKET_NAME

NN_SOCKTYPE_FLAG_NORECV
auto NN_SOCKTYPE_FLAG_NORECV

Specifies that the socket type can never be used to receive messages/// Specifies that the socket type can never be used to receive messages

NN_SOCKTYPE_FLAG_NOSEND
auto NN_SOCKTYPE_FLAG_NOSEND

Specifies that the socket type can never be used to send messages/// Specifies that the socket type can never be used to send messages

NN_SOL_SOCKET
auto NN_SOL_SOCKET

Socket options */ /// Socket option levels - Negative numbers are reserved for transports, positive for socket types./** Socket options */ /// Socket option levels - Negative numbers are reserved for transports, positive for socket types

NN_STAT_ACCEPTED_CONNECTIONS
auto NN_STAT_ACCEPTED_CONNECTIONS
NN_STAT_ACCEPT_ERRORS
auto NN_STAT_ACCEPT_ERRORS
NN_STAT_BIND_ERRORS
auto NN_STAT_BIND_ERRORS
NN_STAT_BROKEN_CONNECTIONS
auto NN_STAT_BROKEN_CONNECTIONS
NN_STAT_CONNECT_ERRORS
auto NN_STAT_CONNECT_ERRORS
NN_STAT_CURRENT_CONNECTIONS
auto NN_STAT_CURRENT_CONNECTIONS
NN_STAT_CURRENT_EP_ERRORS
auto NN_STAT_CURRENT_EP_ERRORS
NN_STAT_CURRENT_SND_PRIORITY
auto NN_STAT_CURRENT_SND_PRIORITY
NN_STAT_DROPPED_CONNECTIONS
auto NN_STAT_DROPPED_CONNECTIONS
NN_STAT_ESTABLISHED_CONNECTIONS
auto NN_STAT_ESTABLISHED_CONNECTIONS

Statistics: /// Statistics:

NN_STAT_INPROGRESS_CONNECTIONS
auto NN_STAT_INPROGRESS_CONNECTIONS
NN_SUB
auto NN_SUB
NN_SUB_SUBSCRIBE
auto NN_SUB_SUBSCRIBE
NN_SUB_UNSUBSCRIBE
auto NN_SUB_UNSUBSCRIBE
NN_SURVEYOR
auto NN_SURVEYOR
NN_SURVEYOR_DEADLINE
auto NN_SURVEYOR_DEADLINE
NN_TCP
auto NN_TCP
NN_TCPMUX
auto NN_TCPMUX

TCPMUX: *//** TCPMUX:

NN_TCPMUX_NODELAY
auto NN_TCPMUX_NODELAY
NN_TCP_NODELAY
auto NN_TCP_NODELAY
NN_TTL
auto NN_TTL

= NN.TTL/// = NN.TTL

NN_TYPE_INT
auto NN_TYPE_INT
NN_TYPE_NONE
auto NN_TYPE_NONE
NN_TYPE_STR
auto NN_TYPE_STR
NN_UNIT_BOOLEAN
auto NN_UNIT_BOOLEAN
NN_UNIT_BYTES
auto NN_UNIT_BYTES
NN_UNIT_MILLISECONDS
auto NN_UNIT_MILLISECONDS
NN_UNIT_NONE
auto NN_UNIT_NONE
NN_UNIT_PRIORITY
auto NN_UNIT_PRIORITY
NN_WS
auto NN_WS

WS: *//** WS:

NN_WS_MSG_TYPE
auto NN_WS_MSG_TYPE

websocket NN_WS level socket/cmsg option Note that only NN_WSMG_TYPE_TEXT and NN_WS_MSG_TYPE_BINARY messages are supported fully by this implementation. Attempting to set other message types is undefined./// websocket NN_WS level socket/cmsg option Note that only NN_WSMG_TYPE_TEXT and NN_WS_MSG_TYPE_BINARY messages are supported fully by this implementation. Attempting to set other message types is undefined.

NN_WS_MSG_TYPE_BINARY
auto NN_WS_MSG_TYPE_BINARY

websockets opcode constant as per RFC 6455 5.2 - binary/// websockets opcode constant as per RFC 6455 5.2 - binary

NN_WS_MSG_TYPE_TEXT
auto NN_WS_MSG_TYPE_TEXT

websockets opcode constant as per RFC 6455 5.2 - text/// websockets opcode constant as per RFC 6455 5.2 - text

PAIR_H_INCLUDED
auto PAIR_H_INCLUDED

PAIR: */ ////** PAIR: */ //

PIPELINE_H_INCLUDED
auto PIPELINE_H_INCLUDED
PROTO_SP
auto PROTO_SP
REQREP_H_INCLUDED
auto REQREP_H_INCLUDED

REQREP: *//** REQREP:

SP_HDR
auto SP_HDR
SURVEY_H_INCLUDED
auto SURVEY_H_INCLUDED

SURVEY: */ ////** SURVEY: */ //

TCP_H_INCLUDED
auto TCP_H_INCLUDED

*/ ////** */ //

Meta

Authors

Laeeth Isharc and Atila Neves (Kaleidic Associates Advisory Limited)

Date

Date: April 20, 2017 Written: 2014,2015,2016,2017

Caveat emptor.