Index

_

_GNU_SOURCE (C macro)

B

base64_maps_rfc4648 (C++ member)

C

cache_remove_impl (C++ function) cache_type (C++ type)

cmp_canonical_path_prefix (C++ function) concat_str (C++ function)

D

data_ready_rpc (C++ function) dyad::basic_fstream_dyad (C++ class) dyad::basic_fstream_dyad::basic_fstream_dyad (C++ function), [1], [2] dyad::basic_fstream_dyad::close (C++ function) dyad::basic_fstream_dyad::core (C++ function) dyad::basic_fstream_dyad::get_stream (C++ function) dyad::basic_fstream_dyad::init (C++ function) dyad::basic_fstream_dyad::is_open (C++ function) dyad::basic_fstream_dyad::open (C++ function) dyad::basic_fstream_dyad::rdbuf (C++ function) dyad::basic_fstream_dyad::~basic_fstream_dyad (C++ function) dyad::basic_ifstream_dyad (C++ class) dyad::basic_ifstream_dyad::basic_ifstream_dyad (C++ function), [1], [2] dyad::basic_ifstream_dyad::close (C++ function) dyad::basic_ifstream_dyad::core (C++ function) dyad::basic_ifstream_dyad::get_stream (C++ function) dyad::basic_ifstream_dyad::init (C++ function) dyad::basic_ifstream_dyad::is_open (C++ function) dyad::basic_ifstream_dyad::open (C++ function) dyad::basic_ifstream_dyad::rdbuf (C++ function) dyad::basic_ifstream_dyad::~basic_ifstream_dyad (C++ function) dyad::basic_ofstream_dyad (C++ class) dyad::basic_ofstream_dyad::basic_ofstream_dyad (C++ function), [1], [2] dyad::basic_ofstream_dyad::close (C++ function) dyad::basic_ofstream_dyad::core (C++ function) dyad::basic_ofstream_dyad::get_stream (C++ function) dyad::basic_ofstream_dyad::init (C++ function) dyad::basic_ofstream_dyad::is_open (C++ function) dyad::basic_ofstream_dyad::open (C++ function) dyad::basic_ofstream_dyad::rdbuf (C++ function) dyad::basic_ofstream_dyad::~basic_ofstream_dyad (C++ function) dyad::dyad_stream_core (C++ class) dyad::dyad_stream_core::chk_fsync_write (C++ function) dyad::dyad_stream_core::chk_initialized (C++ function) dyad::dyad_stream_core::close_sync (C++ function) dyad::dyad_stream_core::cmp_canonical_path_prefix (C++ function) dyad::dyad_stream_core::dyad_stream_core (C++ function) dyad::dyad_stream_core::file_lock_exclusive (C++ function) dyad::dyad_stream_core::file_lock_shared (C++ function) dyad::dyad_stream_core::file_unlock (C++ function) dyad::dyad_stream_core::finalize (C++ function) dyad::dyad_stream_core::get_upath (C++ function) dyad::dyad_stream_core::init (C++ function), [1] dyad::dyad_stream_core::is_dyad_consumer (C++ function) dyad::dyad_stream_core::is_dyad_producer (C++ function) dyad::dyad_stream_core::log_info (C++ function) dyad::dyad_stream_core::open_sync (C++ function) dyad::dyad_stream_core::set_initialized (C++ function) dyad::dyad_stream_core::~dyad_stream_core (C++ function) dyad::fstream_dyad (C++ type) dyad::ifstream_dyad (C++ type) dyad::ofstream_dyad (C++ type) dyad::wfstream_dyad (C++ type) dyad::wifstream_dyad (C++ type) dyad::wofstream_dyad (C++ type) dyad_clear (C++ function) dyad_commit (C++ function) dyad_cons_store (C++ function) dyad_consume (C++ function) dyad_consume_w_metadata (C++ function) dyad_core_return_codes (C++ enum) dyad_core_return_codes::DYAD_RC_BAD_B64DECODE (C++ enumerator) dyad_core_return_codes::DYAD_RC_BAD_CLI_ARG_DEF (C++ enumerator) dyad_core_return_codes::DYAD_RC_BAD_CLI_PARSE (C++ enumerator) dyad_core_return_codes::DYAD_RC_BAD_COMM_MODE (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADBUF (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADCOMMIT (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADDTLMODE (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADFETCH (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADFIO (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADMANAGEDPATH (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADMETADATA (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADPACK (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADRPC (C++ enumerator) dyad_core_return_codes::DYAD_RC_BADUNPACK (C++ enumerator) dyad_core_return_codes::DYAD_RC_FLUXFAIL (C++ enumerator) dyad_core_return_codes::DYAD_RC_MARGO_BAD_PROTO (C++ enumerator) dyad_core_return_codes::DYAD_RC_MARGOINIT_FAIL (C++ enumerator) dyad_core_return_codes::DYAD_RC_NOCTX (C++ enumerator) dyad_core_return_codes::DYAD_RC_NOTFOUND (C++ enumerator) dyad_core_return_codes::DYAD_RC_OK (C++ enumerator) dyad_core_return_codes::DYAD_RC_RPC_FINISHED (C++ enumerator) dyad_core_return_codes::DYAD_RC_SYSFAIL (C++ enumerator) dyad_core_return_codes::DYAD_RC_UCXCOMM_FAIL (C++ enumerator) dyad_core_return_codes::DYAD_RC_UCXEP_FAIL (C++ enumerator)

dyad_core_return_codes::DYAD_RC_UCXINIT_FAIL (C++ enumerator) dyad_core_return_codes::DYAD_RC_UCXMMAP_FAIL (C++ enumerator) dyad_core_return_codes::DYAD_RC_UCXRKEY_PACK_FAILED (C++ enumerator) dyad_core_return_codes::DYAD_RC_UCXRKEY_UNPACK_FAILED (C++ enumerator) dyad_core_return_codes::DYAD_RC_UCXWAIT_FAIL (C++ enumerator) dyad_core_return_codes::DYAD_RC_UNTRACKED (C++ enumerator) dyad_ctx_fini (C++ function) dyad_ctx_get (C++ function) dyad_ctx_init (C++ function) dyad_dtl_finalize (C++ function) dyad_dtl_flux_close_connection (C++ function) dyad_dtl_flux_establish_connection (C++ function) dyad_dtl_flux_finalize (C++ function) dyad_dtl_flux_get_buffer (C++ function) dyad_dtl_flux_init (C++ function) dyad_dtl_flux_recv (C++ function) dyad_dtl_flux_return_buffer (C++ function) dyad_dtl_flux_rpc_pack (C++ function) dyad_dtl_flux_rpc_recv_response (C++ function) dyad_dtl_flux_rpc_respond (C++ function) dyad_dtl_flux_rpc_unpack (C++ function) dyad_dtl_flux_send (C++ function) dyad_dtl_init (C++ function) dyad_dtl_margo_close_connection (C++ function) dyad_dtl_margo_establish_connection (C++ function) dyad_dtl_margo_finalize (C++ function) dyad_dtl_margo_get_buffer (C++ function) dyad_dtl_margo_init (C++ function) dyad_dtl_margo_recv (C++ function) dyad_dtl_margo_return_buffer (C++ function) dyad_dtl_margo_rpc_pack (C++ function) dyad_dtl_margo_rpc_recv_response (C++ function) dyad_dtl_margo_rpc_respond (C++ function) dyad_dtl_margo_rpc_unpack (C++ function) dyad_dtl_margo_send (C++ function) dyad_dtl_ucx_close_connection (C++ function) dyad_dtl_ucx_establish_connection (C++ function) dyad_dtl_ucx_finalize (C++ function) dyad_dtl_ucx_get_buffer (C++ function) dyad_dtl_ucx_init (C++ function) dyad_dtl_ucx_recv (C++ function) dyad_dtl_ucx_return_buffer (C++ function) dyad_dtl_ucx_rpc_pack (C++ function) dyad_dtl_ucx_rpc_recv_response (C++ function) dyad_dtl_ucx_rpc_respond (C++ function) dyad_dtl_ucx_rpc_unpack (C++ function) dyad_dtl_ucx_send (C++ function) dyad_excl_flock (C++ function) dyad_fetch_metadata (C++ function) dyad_fetch_request_cb (C++ function) dyad_finalize (C++ function) dyad_free_metadata (C++ function) dyad_get_data (C++ function) dyad_get_metadata (C++ function) dyad_init (C++ function) dyad_init_env (C++ function) DYAD_IS_ERROR (C macro) dyad_kvs_commit (C++ function) dyad_kvs_read (C++ function) dyad_mod_ctx (C++ struct) dyad_mod_ctx::ctx (C++ member) dyad_mod_ctx::handlers (C++ member) dyad_mod_ctx_default (C++ member) dyad_mod_ctx_t (C++ type) dyad_mod_fini (C++ function) dyad_module_ctx_init (C++ function) DYAD_PATH_DELIM (C macro) dyad_produce (C++ function) dyad_release_flock (C++ function) dyad_send_callback (C++ function) dyad_set_cons_path (C++ function) dyad_set_prod_path (C++ function) dyad_shared_flock (C++ function) dyad_sync_directory (C++ function) dyad_ucx_ep_cache_finalize (C++ function) dyad_ucx_ep_cache_find (C++ function) dyad_ucx_ep_cache_init (C++ function) dyad_ucx_ep_cache_insert (C++ function) dyad_ucx_ep_cache_remove (C++ function) dyad_ucx_ep_err_handler (C++ function) dyad_ucx_request_init (C++ function) dyad_ucx_request_t (C++ type) dyad_ucx_request_wait (C++ function) DYAD_UCX_TAG_MASK (C macro) DYAD_UTIL_LOGGER (C macro)

E

extract_user_path (C++ function)

F

freectx (C++ function)

future_cleanup_cb (C++ function)

G

gen_path_key (C++ function) get_file_size (C++ function)

get_mod_ctx (C++ function) get_path (C++ function)

H

hash_path_prefix (C++ function)

hash_str (C++ function) htab (C++ member)

I

is_fd_dir (C++ function)

is_path_dir (C++ function)

K

key_type (C++ type)

M

mkdir_as_needed (C++ function)

mkpath (C++ function) mod_main (C++ function)

O

opt_parse (C++ function) opt_parse_out (C++ struct) opt_parse_out::debug (C++ member)

opt_parse_out::dtl_mode (C++ member) opt_parse_out::prod_managed_path (C++ member) opt_parse_out::showed_help (C++ member) opt_parse_out_t (C++ type)

P

print_mdata (C++ function)

publish_via_flux (C++ function)

S

show_help (C++ function)

sync_containing_dir (C++ function)

T

TIME_DIFF (C macro)

U

ucx_allocate_buffer (C++ function) ucx_connect (C++ function) ucx_disconnect (C++ function) ucx_free_buffer (C++ function) UCX_MAX_TRANSFER_SIZE (C macro)

ucx_recv_no_wait (C++ function) ucx_request (C++ struct) ucx_request::completed (C++ member) ucx_send_no_wait (C++ function) ucx_warmup (C++ function)

V

validate_margo_protocol (C++ function)