Library API

File Hierarchy

Full API

Functions

Function _socket_connect
- Function Documentation
  - _socket_connect()

Function _socket_init_domain
- Function Documentation
  - _socket_init_domain()

Function _socket_init_info
- Function Documentation
  - _socket_init_info()

Function add_closed_fd
- Function Documentation
  - add_closed_fd()

Function add_open_fd
- Function Documentation
  - add_open_fd()

Function add_polled_fid
- Function Documentation
  - add_polled_fid()

Function check_and_trigger
- Function Documentation
  - check_and_trigger()

Function check_fd_is_closed
- Function Documentation
  - check_fd_is_closed()

Function check_open_fd_exists
- Function Documentation
  - check_open_fd_exists()

Function cmp_subscription(const void *, const void *)
- Function Documentation

Function cmp_subscription(const void *, const void *)
- Function Documentation

Function fetch_completion_object
- Function Documentation
  - fetch_completion_object()

Function flush
- Function Documentation
  - flush()

Function flush_cb
- Function Documentation
  - flush_cb()

Function generic_sendmsg
- Function Documentation
  - generic_sendmsg()

Function increment_completion_object
- Function Documentation
  - increment_completion_object()

Function init_bufferstack
- Function Documentation
  - init_bufferstack()

Function init_openfds
- Function Documentation
  - init_openfds()

Function init_polled_fids
- Function Documentation
  - init_polled_fids()

Function lookup_tag(struct netio_subscription_table *, netio_tag_t, unsigned *)
- Function Documentation

Function lookup_tag(struct netio_subscription_table *, netio_tag_t, unsigned *)
- Function Documentation

Function lookup_tag_cached(struct netio_subscription_table *, netio_tag_t, struct netio_subscription_cache *, unsigned *)
- Function Documentation

Function lookup_tag_cached(struct netio_subscription_table *, netio_tag_t, struct netio_subscription_cache *, unsigned *)
- Function Documentation

Function lsocket_on_connection_established(struct netio_recv_socket *)
- Function Documentation

Function lsocket_on_connection_established(struct netio_recv_socket *)
- Function Documentation

Function lsocket_on_msg_received(struct netio_recv_socket *, struct netio_buffer *, void *, size_t)
- Function Documentation

Function lsocket_on_msg_received(struct netio_recv_socket *, struct netio_buffer *, void *, size_t)
- Function Documentation

Function netio_buffered_connect
- Function Documentation
  - netio_buffered_connect()

Function netio_buffered_connect_rawaddr
- Function Documentation
  - netio_buffered_connect_rawaddr()

Function netio_buffered_flush
- Function Documentation
  - netio_buffered_flush()

Function netio_buffered_listen
- Function Documentation
  - netio_buffered_listen()

Function netio_buffered_listen_socket_init
- Function Documentation
  - netio_buffered_listen_socket_init()

Function netio_buffered_listen_socket_init_and_listen
- Function Documentation
  - netio_buffered_listen_socket_init_and_listen()

Function netio_buffered_listen_tcp
- Function Documentation
  - netio_buffered_listen_tcp()

Function netio_buffered_listen_tcp_socket_init
- Function Documentation
  - netio_buffered_listen_tcp_socket_init()

Function netio_buffered_publish
- Function Documentation
  - netio_buffered_publish()

Function netio_buffered_publish_flush
- Function Documentation
  - netio_buffered_publish_flush()

Function netio_buffered_publishi
- Function Documentation
  - netio_buffered_publishi()

Function netio_buffered_publishv
- Function Documentation
  - netio_buffered_publishv()

Function netio_buffered_recv_socket_init
- Function Documentation
  - netio_buffered_recv_socket_init()

Function netio_buffered_recv_tcp_socket_init
- Function Documentation
  - netio_buffered_recv_tcp_socket_init()

Function netio_buffered_remove_recv_socket
- Function Documentation
  - netio_buffered_remove_recv_socket()

Function netio_buffered_send
- Function Documentation
  - netio_buffered_send()

Function netio_buffered_send_socket_init
- Function Documentation
  - netio_buffered_send_socket_init()

Function netio_buffered_send_socket_init_and_connect
- Function Documentation
  - netio_buffered_send_socket_init_and_connect()

Function netio_buffered_send_tcp_socket_init
- Function Documentation
  - netio_buffered_send_tcp_socket_init()

Function netio_buffered_sendv
- Function Documentation
  - netio_buffered_sendv()

Function netio_bufferstack_close
- Function Documentation
  - netio_bufferstack_close()

Function netio_bufferstack_pop
- Function Documentation
  - netio_bufferstack_pop()

Function netio_bufferstack_push
- Function Documentation
  - netio_bufferstack_push()

Function netio_bufferstack_send_init
- Function Documentation
  - netio_bufferstack_send_init()

Function netio_close_socket
- Function Documentation
  - netio_close_socket()

Function netio_connect
- Function Documentation
  - netio_connect()

Function netio_connect_domain
- Function Documentation
  - netio_connect_domain()

Function netio_connect_rawaddr
- Function Documentation
  - netio_connect_rawaddr()

Function netio_connect_rawaddr_domain
- Function Documentation
  - netio_connect_rawaddr_domain()

Function netio_connection_shutdown
- Function Documentation
  - netio_connection_shutdown()

Function netio_disconnect
- Function Documentation
  - netio_disconnect()

Function netio_domain_name_lookup
- Function Documentation
  - netio_domain_name_lookup()

Function netio_error_bind_refused_callback
- Function Documentation
  - netio_error_bind_refused_callback()

Function netio_error_bind_refused_fire
- Function Documentation
  - netio_error_bind_refused_fire()

Function netio_error_connection_refused_callback
- Function Documentation
  - netio_error_connection_refused_callback()

Function netio_error_connection_refused_fire
- Function Documentation
  - netio_error_connection_refused_fire()

Function netio_eventloop_init
- Function Documentation
  - netio_eventloop_init()

Function netio_hostname
- Function Documentation
  - netio_hostname()

Function netio_init
- Function Documentation
  - netio_init()

Function netio_init_listen_socket
- Function Documentation
  - netio_init_listen_socket()

Function netio_init_recv_socket
- Function Documentation
  - netio_init_recv_socket()

Function netio_init_send_socket
- Function Documentation
  - netio_init_send_socket()

Function netio_listen
- Function Documentation
  - netio_listen()

Function netio_listen_socket_endpoint
- Function Documentation
  - netio_listen_socket_endpoint()

Function netio_listen_socket_init_and_listen
- Function Documentation
  - netio_listen_socket_init_and_listen()

Function netio_post_recv
- Function Documentation
  - netio_post_recv()

Function netio_protocol
- Function Documentation
  - netio_protocol()

Function netio_publish_libfabric_socket_init
- Function Documentation
  - netio_publish_libfabric_socket_init()

Function netio_publish_socket_init
- Function Documentation
  - netio_publish_socket_init()

Function netio_publish_tcp_socket_init
- Function Documentation
  - netio_publish_tcp_socket_init()

Function netio_pubsocket_get_available_co
- Function Documentation
  - netio_pubsocket_get_available_co()

Function netio_pubsocket_get_minimum_pages
- Function Documentation
  - netio_pubsocket_get_minimum_pages()

Function netio_register_read_fd
- Function Documentation
  - netio_register_read_fd()

Function netio_register_read_tcp_fd
- Function Documentation
  - netio_register_read_tcp_fd()

Function netio_register_recv_buffer
- Function Documentation
  - netio_register_recv_buffer()

Function netio_register_send_buffer
- Function Documentation
  - netio_register_send_buffer()

Function netio_register_write_tcp_fd
- Function Documentation
  - netio_register_write_tcp_fd()

Function netio_remove_recv_socket
- Function Documentation
  - netio_remove_recv_socket()

Function netio_run
- Function Documentation
  - netio_run()

Function netio_semaphore_increment
- Function Documentation
  - netio_semaphore_increment()

Function netio_semaphore_init
- Function Documentation
  - netio_semaphore_init()

Function netio_semphore_set_threshold
- Function Documentation
  - netio_semphore_set_threshold()

Function netio_send
- Function Documentation
  - netio_send()

Function netio_send_buffer
- Function Documentation
  - netio_send_buffer()

Function netio_send_imm
- Function Documentation
  - netio_send_imm()

Function netio_send_inline_buffer
- Function Documentation
  - netio_send_inline_buffer()

Function netio_send_socket_init_and_connect
- Function Documentation
  - netio_send_socket_init_and_connect()

Function netio_sendv
- Function Documentation
  - netio_sendv()

Function netio_sendv_imm
- Function Documentation
  - netio_sendv_imm()

Function netio_set_debug_level
- Function Documentation
  - netio_set_debug_level()

Function netio_signal_callback
- Function Documentation
  - netio_signal_callback()

Function netio_signal_close
- Function Documentation
  - netio_signal_close()

Function netio_signal_fire
- Function Documentation
  - netio_signal_fire()

Function netio_signal_init
- Function Documentation
  - netio_signal_init()

Function netio_signal_no_semaphore_init
- Function Documentation
  - netio_signal_no_semaphore_init()

Function netio_stop
- Function Documentation
  - netio_stop()

Function netio_subscribe
- Function Documentation
  - netio_subscribe()

Function netio_subscribe_libfabric_socket_init
- Function Documentation
  - netio_subscribe_libfabric_socket_init()

Function netio_subscribe_socket_init
- Function Documentation
  - netio_subscribe_socket_init()

Function netio_subscribe_tcp_socket_init
- Function Documentation
  - netio_subscribe_tcp_socket_init()

Function netio_subscription_cache_init
- Function Documentation
  - netio_subscription_cache_init()

Function netio_subscription_table_init
- Function Documentation
  - netio_subscription_table_init()

Function netio_tcp_mode
- Function Documentation
  - netio_tcp_mode()

Function netio_terminate
- Function Documentation
  - netio_terminate()

Function netio_terminate_signal
- Function Documentation
  - netio_terminate_signal()

Function netio_timer_callback
- Function Documentation
  - netio_timer_callback()

Function netio_timer_close
- Function Documentation
  - netio_timer_close()

Function netio_timer_init
- Function Documentation
  - netio_timer_init()

Function netio_timer_start_ms
- Function Documentation
  - netio_timer_start_ms()

Function netio_timer_start_ns
- Function Documentation
  - netio_timer_start_ns()

Function netio_timer_start_s
- Function Documentation
  - netio_timer_start_s()

Function netio_timer_start_us
- Function Documentation
  - netio_timer_start_us()

Function netio_timer_stop
- Function Documentation
  - netio_timer_stop()

Function netio_unbuffered_publish_libfabric_socket_init
- Function Documentation
  - netio_unbuffered_publish_libfabric_socket_init()

Function netio_unbuffered_publish_socket_init
- Function Documentation
  - netio_unbuffered_publish_socket_init()

Function netio_unbuffered_publish_tcp_socket_init
- Function Documentation
  - netio_unbuffered_publish_tcp_socket_init()

Function netio_unbuffered_publishv
- Function Documentation
  - netio_unbuffered_publishv()

Function netio_unbuffered_publishv_usr
- Function Documentation
  - netio_unbuffered_publishv_usr()

Function netio_unbuffered_send_socket_init
- Function Documentation
  - netio_unbuffered_send_socket_init()

Function netio_unbuffered_subscribe
- Function Documentation
  - netio_unbuffered_subscribe()

Function netio_unbuffered_subscribe_libfabric_socket_init
- Function Documentation
  - netio_unbuffered_subscribe_libfabric_socket_init()

Function netio_unbuffered_subscribe_socket_init
- Function Documentation
  - netio_unbuffered_subscribe_socket_init()

Function netio_unbuffered_subscribe_tcp_socket_init
- Function Documentation
  - netio_unbuffered_subscribe_tcp_socket_init()

Function netio_unbuffered_unsubscribe
- Function Documentation
  - netio_unbuffered_unsubscribe()

Function netio_unsubscribe
- Function Documentation
  - netio_unsubscribe()

Function on_buf_send_socket_connection_closed
- Function Documentation
  - on_buf_send_socket_connection_closed()

Function on_buffer_available
- Function Documentation
  - on_buffer_available()

Function on_buffered_msg_received
- Function Documentation
  - on_buffered_msg_received()

Function on_completion_trigger
- Function Documentation
  - on_completion_trigger()

Function on_connect
- Function Documentation
  - on_connect()

Function on_error_connection_refused
- Function Documentation
  - on_error_connection_refused()

Function on_send_completed
- Function Documentation
  - on_send_completed()

Function on_unbuffered_send_connection_closed
- Function Documentation
  - on_unbuffered_send_connection_closed()

Function parse_subscription_message(struct netio_publish_socket *, struct netio_subscription_message *, struct netio_recv_socket *)
- Function Documentation
  - parse_subscription_message()

Function parse_subscription_message(struct netio_unbuffered_publish_socket *, struct netio_subscription_message *, struct netio_recv_socket *)
- Function Documentation
  - parse_subscription_message()

Function print_completion_objects
- Function Documentation
  - print_completion_objects()

Function print_openfds
- Function Documentation
  - print_openfds()

Function print_polled_fids
- Function Documentation
  - print_polled_fids()

Function process_event
- Function Documentation
  - process_event()

Function pubsocket_on_connection_closed(struct netio_buffered_send_socket *)
- Function Documentation
  - pubsocket_on_connection_closed()

Function pubsocket_on_connection_closed(struct netio_send_socket *)
- Function Documentation
  - pubsocket_on_connection_closed()

Function pubsocket_on_connection_established(struct netio_buffered_send_socket *)
- Function Documentation
  - pubsocket_on_connection_established()

Function pubsocket_on_connection_established(struct netio_send_socket *)
- Function Documentation
  - pubsocket_on_connection_established()

Function pubsocket_on_send_completed
- Function Documentation
  - pubsocket_on_send_completed()

Function register_fd
- Function Documentation
  - register_fd()

Function release_completion_object
- Function Documentation
  - release_completion_object()

Function remove_open_fd
- Function Documentation
  - remove_open_fd()

Function remove_polled_fid
- Function Documentation
  - remove_polled_fid()

Function remove_tag_to_subscribe(struct netio_subscribe_socket *, netio_tag_t)
- Function Documentation
  - remove_tag_to_subscribe()

Function remove_tag_to_subscribe(struct netio_unbuffered_subscribe_socket *, netio_tag_t)
- Function Documentation
  - remove_tag_to_subscribe()

Function reset_closed_fds
- Function Documentation
  - reset_closed_fds()

Function send_subscription_message(struct netio_subscribe_socket *, netio_tag_t, int)
- Function Documentation
  - send_subscription_message()

Function send_subscription_message(struct netio_unbuffered_subscribe_socket *, netio_tag_t, int)
- Function Documentation
  - send_subscription_message()

Function set_timerfd
- Function Documentation
  - set_timerfd()

Function socket_list_add_or_lookup(struct netio_publish_socket *, struct netio_socket_list **, void *, size_t, int, struct netio_context *, struct netio_buffered_socket_attr *)
- Function Documentation
  - socket_list_add_or_lookup()

Function socket_list_add_or_lookup(struct netio_unbuffered_publish_socket *, struct netio_socket_list **, void *, size_t, int, struct netio_context *)
- Function Documentation
  - socket_list_add_or_lookup()

Function subscribe(struct netio_publish_socket *, struct netio_recv_socket *, void *, size_t, int, netio_tag_t)
- Function Documentation
  - subscribe()

Function subscribe(struct netio_unbuffered_publish_socket *, struct netio_recv_socket *, void *, size_t, int, netio_tag_t)
- Function Documentation
  - subscribe()

Function subscribe_socket_on_connection_closed(struct netio_buffered_recv_socket *)
- Function Documentation
  - subscribe_socket_on_connection_closed()

Function subscribe_socket_on_connection_closed(struct netio_recv_socket *)
- Function Documentation
  - subscribe_socket_on_connection_closed()

Function subscribe_socket_on_connection_established(struct netio_buffered_recv_socket *)
- Function Documentation
  - subscribe_socket_on_connection_established()

Function subscribe_socket_on_connection_established(struct netio_recv_socket *)
- Function Documentation
  - subscribe_socket_on_connection_established()

Function subscribe_socket_on_msg_received(struct netio_buffered_recv_socket *, void *, size_t)
- Function Documentation
  - subscribe_socket_on_msg_received()

Function subscribe_socket_on_msg_received(struct netio_recv_socket *, struct netio_buffer *, void *, size_t)
- Function Documentation
  - subscribe_socket_on_msg_received()

Function subsocket_on_connection_closed
- Function Documentation
  - subsocket_on_connection_closed()

Function subsocket_on_connection_established(struct netio_send_socket *)
- Function Documentation

Function subsocket_on_connection_established(struct netio_send_socket *)
- Function Documentation

Function subsocket_on_error_connection_refused(struct netio_send_socket *)
- Function Documentation

Function subsocket_on_error_connection_refused(struct netio_send_socket *)
- Function Documentation

Function subsocket_on_send_completed(struct netio_send_socket *, uint64_t)
- Function Documentation

Function subsocket_on_send_completed(struct netio_send_socket *, uint64_t)
- Function Documentation

Function subsocket_on_send_connection_closed
- Function Documentation
  - subsocket_on_send_connection_closed()

Function table_add_subscription(struct netio_subscription_table *, netio_tag_t, struct netio_buffered_send_socket *)
- Function Documentation
  - table_add_subscription()

Function table_add_subscription(struct netio_subscription_table *, netio_tag_t, struct netio_send_socket *)
- Function Documentation
  - table_add_subscription()

Function table_get_subs_by_socket(struct netio_subscription_table *, struct netio_buffered_send_socket *)
- Function Documentation
  - table_get_subs_by_socket()

Function table_get_subs_by_socket(struct netio_subscription_table *, struct netio_send_socket *)
- Function Documentation
  - table_get_subs_by_socket()

Function table_remove_subscription(struct netio_subscription_table *, struct netio_buffered_send_socket *, netio_tag_t, uint8_t)
- Function Documentation
  - table_remove_subscription()

Function table_remove_subscription(struct netio_unbuffered_publish_socket *, struct netio_send_socket *, netio_tag_t, uint8_t)
- Function Documentation
  - table_remove_subscription()

Function unsubscribe(struct netio_publish_socket *, void *, size_t, int, netio_tag_t)
- Function Documentation
  - unsubscribe()

Function unsubscribe(struct netio_unbuffered_publish_socket *, void *, size_t, int, netio_tag_t)
- Function Documentation
  - unsubscribe()

Variables

Variable resource_name
- Variable Documentation
  - resource_name

Variable socket_name
- Variable Documentation
  - socket_name

Defines

Define ERROR_LOG
- Define Documentation
  - ERROR_LOG

Define FATAL
- Define Documentation
  - FATAL

Define log_dbg
- Define Documentation
  - log_dbg

Define log_dbg
- Define Documentation
  - log_dbg

Define log_dbg
- Define Documentation
  - log_dbg

Define log_dbg
- Define Documentation
  - log_dbg

Define log_dbg
- Define Documentation
  - log_dbg

Define log_dbg
- Define Documentation
  - log_dbg

Define log_trc
- Define Documentation
  - log_trc

Define log_trc
- Define Documentation
  - log_trc

Define log_trc
- Define Documentation
  - log_trc

Define log_trc
- Define Documentation
  - log_trc

Define log_trc
- Define Documentation
  - log_trc

Define log_trc
- Define Documentation
  - log_trc

Define ON_ERROR_BIND_REFUSED
- Define Documentation
  - ON_ERROR_BIND_REFUSED

Define ON_ERROR_CONNECTION_REFUSED
- Define Documentation
  - ON_ERROR_CONNECTION_REFUSED

Define PUBLISH_SOCKET_MAX_COMPLETIONS
- Define Documentation
  - PUBLISH_SOCKET_MAX_COMPLETIONS

Typedefs

Typedef msg_size_t
- Typedef Documentation
  - msg_size_t