File unbufpubsub.c

Definition (unbufpubsub.c)

• Program Listing for File unbufpubsub.c

Includes

• assert.h

• log.h

• netdb.h

• netio/netio.h

• netio/netio_tcp.h

• stdio.h

• string.h

• sys/socket.h

Functions

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

• Function fetch_completion_object

• Function increment_completion_object

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

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

• Function on_unbuffered_send_connection_closed

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

• Function print_completion_objects

• Function pubsocket_on_connection_closed(struct netio_send_socket *)

• Function pubsocket_on_connection_established(struct netio_send_socket *)

• Function pubsocket_on_send_completed

• Function release_completion_object

• Function remove_tag_to_subscribe(struct netio_unbuffered_subscribe_socket *, netio_tag_t)

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

• 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_unbuffered_publish_socket *, struct netio_recv_socket *, void *, size_t, int, netio_tag_t)

• Function subscribe_socket_on_connection_closed(struct netio_recv_socket *)

• Function subscribe_socket_on_connection_established(struct netio_recv_socket *)

• 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_error_connection_refused(struct netio_send_socket *)

• Function subsocket_on_send_completed(struct netio_send_socket *, uint64_t)

• 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_send_socket *)

• Function table_remove_subscription(struct netio_unbuffered_publish_socket *, struct netio_send_socket *, netio_tag_t, uint8_t)

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

Defines

• Define log_dbg

• Define log_trc

• Define PUBLISH_SOCKET_MAX_COMPLETIONS