| action_on_receive_notification(NotificationData notif) override | dunedaq::snbmodules::TransferClient | privatevirtual |
| cancel_transfer(const std::string &transfer_id) | dunedaq::snbmodules::TransferClient | |
| create_metadata_from_file(const std::filesystem::path &src) | dunedaq::snbmodules::TransferClient | private |
| create_new_transfer(const std::string &transfer_id, const std::string &protocol, const std::set< std::string > &dest_clients, const std::set< std::filesystem::path > &files, const nlohmann::json &protocol_options=nlohmann::json()) | dunedaq::snbmodules::TransferClient | |
| create_session(GroupMetadata transfer_options, e_session_type type, std::string id, const std::filesystem::path &work_dir, IPFormat ip=IPFormat(), const std::set< std::string > &dest_clients=std::set< std::string >()) | dunedaq::snbmodules::TransferClient | |
| do_work(std::atomic< bool > &running_flag) | dunedaq::snbmodules::TransferClient | |
| generate_session_id(const std::string &transferid, const std::string &dest="") | dunedaq::snbmodules::TransferClient | private |
| get_bookkeepers_conn() const | dunedaq::snbmodules::NotificationInterface | inline |
| get_client_id() const | dunedaq::snbmodules::TransferClient | inline |
| get_clients_conn() const | dunedaq::snbmodules::NotificationInterface | inline |
| get_ip() const | dunedaq::snbmodules::TransferClient | inline |
| get_listening_dir() const | dunedaq::snbmodules::TransferClient | inline |
| get_my_conn() | dunedaq::snbmodules::TransferClient | |
| get_session(std::string transfer_id) | dunedaq::snbmodules::TransferClient | |
| get_sessions() | dunedaq::snbmodules::TransferClient | inline |
| get_sessions() const | dunedaq::snbmodules::TransferClient | inline |
| listen_for_notification(const std::string &id, const std::string &expected_from="", int timeout=-1, int tries=-1) | dunedaq::snbmodules::NotificationInterface | |
| lookups_connections() | dunedaq::snbmodules::NotificationInterface | inline |
| m_available_files | dunedaq::snbmodules::TransferClient | private |
| m_bookkeepers_conn | dunedaq::snbmodules::NotificationInterface | private |
| m_client_id | dunedaq::snbmodules::TransferClient | private |
| m_clients_conn | dunedaq::snbmodules::NotificationInterface | private |
| m_connection_prefix | dunedaq::snbmodules::NotificationInterface | private |
| m_listening_dir | dunedaq::snbmodules::TransferClient | private |
| m_listening_ip | dunedaq::snbmodules::TransferClient | private |
| m_max_tries | dunedaq::snbmodules::NotificationInterface | private |
| m_my_conn | dunedaq::snbmodules::TransferClient | private |
| m_sessions | dunedaq::snbmodules::TransferClient | private |
| m_timeout_receive | dunedaq::snbmodules::NotificationInterface | private |
| m_timeout_send | dunedaq::snbmodules::NotificationInterface | private |
| NotificationInterface(std::string connection_prefix="snbmodules", int timeout_send=10, int timeout_receive=100) | dunedaq::snbmodules::NotificationInterface | inlineexplicit |
| NotificationInterface(std::vector< std::string > bk_conn, std::set< std::string > client_conn, const std::string &connection_prefix="snbmodules", int timeout_send=10, int timeout_receive=100) | dunedaq::snbmodules::NotificationInterface | inline |
| pause_transfer(const std::string &transfer_id) | dunedaq::snbmodules::TransferClient | |
| remove_session(const std::string &session_id) | dunedaq::snbmodules::TransferClient | private |
| resume_transfer(const std::string &transfer_id) | dunedaq::snbmodules::TransferClient | |
| scan_available_files(std::set< std::filesystem::path > &previous_scan, bool nested=false, std::filesystem::path folder=std::filesystem::path()) | dunedaq::snbmodules::TransferClient | |
| send_notification(const notification_type::e_notification_type ¬if, const std::string &src, const std::string &dst, const std::string &id_conn, const std::string &data="", int tries=-1) | dunedaq::snbmodules::NotificationInterface | |
| set_client_id(std::string client_id) | dunedaq::snbmodules::TransferClient | inline |
| set_ip(const std::string &ip) | dunedaq::snbmodules::TransferClient | inline |
| set_listening_dir(const std::filesystem::path &listening_dir) | dunedaq::snbmodules::TransferClient | inline |
| set_port(int port) | dunedaq::snbmodules::TransferClient | inline |
| share_available_files(const std::set< std::filesystem::path > &to_share, const std::string &dest) | dunedaq::snbmodules::TransferClient | private |
| start(int timeout) | dunedaq::snbmodules::TransferClient | |
| start_transfer(const std::string &transfer_id) | dunedaq::snbmodules::TransferClient | |
| TransferClient(const IPFormat &listening_ip, const std::string &client_id, const std::filesystem::path &listening_dir, const std::string &connection_prefix="snbmodules", int timeout_send=10, int timeout_receive=100) | dunedaq::snbmodules::TransferClient | |
| ~NotificationInterface()=default | dunedaq::snbmodules::NotificationInterface | virtual |
| ~TransferClient() | dunedaq::snbmodules::TransferClient | |
1.12.0