File pubsub.c

Definition (pubsub.c)

• Program Listing for File pubsub.c

Includes

• assert.h

• log.h

• netdb.h

• netio/netio.h

• netio/netio_tcp.h

• stdio.h

• string.h

Functions

• Function cmp_subscription(const void *, const void *)

• 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 lsocket_on_connection_established(struct netio_recv_socket *)

• Function lsocket_on_msg_received(struct netio_recv_socket *, struct netio_buffer *, void *, size_t)

• Function netio_buffered_publish

• Function netio_buffered_publish_flush

• Function netio_buffered_publishi

• Function netio_buffered_publishv

• Function netio_domain_name_lookup

• Function netio_publish_libfabric_socket_init

• Function netio_publish_socket_init

• Function netio_publish_tcp_socket_init

• Function netio_pubsocket_get_minimum_pages

• 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_unsubscribe

• Function on_buffer_available

• Function parse_subscription_message(struct netio_publish_socket *, struct netio_subscription_message *, struct netio_recv_socket *)

• Function pubsocket_on_connection_closed(struct netio_buffered_send_socket *)

• Function pubsocket_on_connection_established(struct netio_buffered_send_socket *)

• Function remove_tag_to_subscribe(struct netio_subscribe_socket *, netio_tag_t)

• Function send_subscription_message(struct netio_subscribe_socket *, netio_tag_t, int)

• 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 subscribe(struct netio_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_established(struct netio_buffered_recv_socket *)

• Function subscribe_socket_on_msg_received(struct netio_buffered_recv_socket *, void *, size_t)

• Function subsocket_on_connection_established(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_connection_closed

• Function table_add_subscription(struct netio_subscription_table *, netio_tag_t, struct netio_buffered_send_socket *)

• Function table_get_subs_by_socket(struct netio_subscription_table *, struct netio_buffered_send_socket *)

• Function table_remove_subscription(struct netio_subscription_table *, struct netio_buffered_send_socket *, netio_tag_t, uint8_t)

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

Defines

• Define log_dbg

• Define log_trc