NetIO-next
Contents:
Introduction
Software Architecture
Unbuffered RDMA Communication
Buffered RDMA Communication
Ibverbs Error Codes
Library API
File Hierarchy
Full API
Functions
Function _socket_connect
Function _socket_init_domain
Function _socket_init_info
Function add_closed_fd
Function add_open_fd
Function add_polled_fid
Function check_and_trigger
Function check_fd_is_closed
Function check_open_fd_exists
Function cmp_subscription(const void *, const void *)
Function cmp_subscription(const void *, const void *)
Function fetch_completion_object
Function flush
Function flush_cb
Function generic_sendmsg
Function increment_completion_object
Function init_bufferstack
Function init_openfds
Function init_polled_fids
Function lookup_tag(struct netio_subscription_table *, netio_tag_t, unsigned *)
Function lookup_tag(struct netio_subscription_table *, netio_tag_t, unsigned *)
Function lookup_tag_cached(struct netio_subscription_table *, netio_tag_t, struct netio_subscription_cache *, unsigned *)
Function lookup_tag_cached(struct netio_subscription_table *, netio_tag_t, struct netio_subscription_cache *, unsigned *)
Function lsocket_on_connection_established(struct netio_recv_socket *)
Function lsocket_on_connection_established(struct netio_recv_socket *)
Function lsocket_on_msg_received(struct netio_recv_socket *, struct netio_buffer *, void *, size_t)
Function lsocket_on_msg_received(struct netio_recv_socket *, struct netio_buffer *, void *, size_t)
Function netio_buffered_connect
Function netio_buffered_connect_rawaddr
Function netio_buffered_flush
Function netio_buffered_listen
Function netio_buffered_listen_socket_init
Function netio_buffered_listen_socket_init_and_listen
Function netio_buffered_listen_tcp
Function netio_buffered_listen_tcp_socket_init
Function netio_buffered_publish
Function netio_buffered_publish_flush
Function netio_buffered_publishi
Function netio_buffered_publishv
Function netio_buffered_recv_socket_init
Function netio_buffered_recv_tcp_socket_init
Function netio_buffered_remove_recv_socket
Function netio_buffered_send
Function netio_buffered_send_socket_init
Function netio_buffered_send_socket_init_and_connect
Function netio_buffered_send_tcp_socket_init
Function netio_buffered_sendv
Function netio_bufferstack_close
Function netio_bufferstack_pop
Function netio_bufferstack_push
Function netio_bufferstack_send_init
Function netio_close_socket
Function netio_connect
Function netio_connect_domain
Function netio_connect_rawaddr
Function netio_connect_rawaddr_domain
Function netio_connection_shutdown
Function netio_disconnect
Function netio_domain_name_lookup
Function netio_error_bind_refused_callback
Function netio_error_bind_refused_fire
Function netio_error_connection_refused_callback
Function netio_error_connection_refused_fire
Function netio_eventloop_init
Function netio_hostname
Function netio_init
Function netio_init_listen_socket
Function netio_init_recv_socket
Function netio_init_send_socket
Function netio_listen
Function netio_listen_socket_endpoint
Function netio_listen_socket_init_and_listen
Function netio_post_recv
Function netio_protocol
Function netio_publish_libfabric_socket_init
Function netio_publish_socket_init
Function netio_publish_tcp_socket_init
Function netio_pubsocket_get_available_co
Function netio_pubsocket_get_minimum_pages
Function netio_register_read_fd
Function netio_register_read_tcp_fd
Function netio_register_recv_buffer
Function netio_register_send_buffer
Function netio_register_write_tcp_fd
Function netio_remove_recv_socket
Function netio_run
Function netio_semaphore_increment
Function netio_semaphore_init
Function netio_semphore_set_threshold
Function netio_send
Function netio_send_buffer
Function netio_send_imm
Function netio_send_inline_buffer
Function netio_send_socket_init_and_connect
Function netio_sendv
Function netio_sendv_imm
Function netio_set_debug_level
Function netio_signal_callback
Function netio_signal_close
Function netio_signal_fire
Function netio_signal_init
Function netio_signal_no_semaphore_init
Function netio_stop
Function netio_subscribe
Function netio_subscribe_libfabric_socket_init
Function netio_subscribe_socket_init
Function netio_subscribe_tcp_socket_init
Function netio_subscription_cache_init
Function netio_subscription_table_init
Function netio_tcp_mode
Function netio_terminate
Function netio_terminate_signal
Function netio_timer_callback
Function netio_timer_close
Function netio_timer_init
Function netio_timer_start_ms
Function netio_timer_start_ns
Function netio_timer_start_s
Function netio_timer_start_us
Function netio_timer_stop
Function netio_unbuffered_publish_libfabric_socket_init
Function netio_unbuffered_publish_socket_init
Function netio_unbuffered_publish_tcp_socket_init
Function netio_unbuffered_publishv
Function netio_unbuffered_publishv_usr
Function netio_unbuffered_send_socket_init
Function netio_unbuffered_subscribe
Function netio_unbuffered_subscribe_libfabric_socket_init
Function netio_unbuffered_subscribe_socket_init
Function netio_unbuffered_subscribe_tcp_socket_init
Function netio_unbuffered_unsubscribe
Function netio_unsubscribe
Function on_buf_send_socket_connection_closed
Function on_buffer_available
Function on_buffered_msg_received
Function on_completion_trigger
Function on_connect
Function on_error_connection_refused
Function on_send_completed
Function on_unbuffered_send_connection_closed
Function parse_subscription_message(struct netio_publish_socket *, struct netio_subscription_message *, struct netio_recv_socket *)
Function parse_subscription_message(struct netio_unbuffered_publish_socket *, struct netio_subscription_message *, struct netio_recv_socket *)
Function print_completion_objects
Function print_openfds
Function print_polled_fids
Function process_event
Function pubsocket_on_connection_closed(struct netio_buffered_send_socket *)
Function pubsocket_on_connection_closed(struct netio_send_socket *)
Function pubsocket_on_connection_established(struct netio_buffered_send_socket *)
Function pubsocket_on_connection_established(struct netio_send_socket *)
Function pubsocket_on_send_completed
Function register_fd
Function release_completion_object
Function remove_open_fd
Function remove_polled_fid
Function remove_tag_to_subscribe(struct netio_subscribe_socket *, netio_tag_t)
Function remove_tag_to_subscribe(struct netio_unbuffered_subscribe_socket *, netio_tag_t)
Function reset_closed_fds
Function send_subscription_message(struct netio_subscribe_socket *, netio_tag_t, int)
Function send_subscription_message(struct netio_unbuffered_subscribe_socket *, netio_tag_t, int)
Function 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 socket_list_add_or_lookup(struct netio_unbuffered_publish_socket *, struct netio_socket_list **, void *, size_t, int, struct netio_context *)
Function subscribe(struct netio_publish_socket *, struct netio_recv_socket *, void *, size_t, int, netio_tag_t)
Function subscribe(struct netio_unbuffered_publish_socket *, struct netio_recv_socket *, void *, size_t, int, netio_tag_t)
Function subscribe_socket_on_connection_closed(struct netio_buffered_recv_socket *)
Function subscribe_socket_on_connection_closed(struct netio_recv_socket *)
Function subscribe_socket_on_connection_established(struct netio_buffered_recv_socket *)
Function subscribe_socket_on_connection_established(struct netio_recv_socket *)
Function subscribe_socket_on_msg_received(struct netio_buffered_recv_socket *, void *, size_t)
Function subscribe_socket_on_msg_received(struct netio_recv_socket *, struct netio_buffer *, void *, size_t)
Function subsocket_on_connection_closed
Function subsocket_on_connection_established(struct netio_send_socket *)
Function subsocket_on_connection_established(struct netio_send_socket *)
Function subsocket_on_error_connection_refused(struct netio_send_socket *)
Function subsocket_on_error_connection_refused(struct netio_send_socket *)
Function subsocket_on_send_completed(struct netio_send_socket *, uint64_t)
Function subsocket_on_send_completed(struct netio_send_socket *, uint64_t)
Function subsocket_on_send_connection_closed
Function table_add_subscription(struct netio_subscription_table *, netio_tag_t, struct netio_buffered_send_socket *)
Function table_add_subscription(struct netio_subscription_table *, netio_tag_t, struct netio_send_socket *)
Function table_get_subs_by_socket(struct netio_subscription_table *, struct netio_buffered_send_socket *)
Function table_get_subs_by_socket(struct netio_subscription_table *, struct netio_send_socket *)
Function table_remove_subscription(struct netio_subscription_table *, struct netio_buffered_send_socket *, netio_tag_t, uint8_t)
Function table_remove_subscription(struct netio_unbuffered_publish_socket *, struct netio_send_socket *, netio_tag_t, uint8_t)
Function unsubscribe(struct netio_publish_socket *, void *, size_t, int, netio_tag_t)
Function unsubscribe(struct netio_unbuffered_publish_socket *, void *, size_t, int, netio_tag_t)
Variables
Defines
Typedefs
NetIO-next
Library API
Function remove_tag_to_subscribe(struct netio_subscribe_socket *, netio_tag_t)
View page source
Function remove_tag_to_subscribe(struct netio_subscribe_socket *, netio_tag_t)
Defined in
File pubsub.c
Function Documentation
static
int
remove_tag_to_subscribe
(
struct
netio_subscribe_socket
*
socket
,
netio_tag_t
tag
)