nvflare.fuel.f3.comm_config module

class CommConfigurator[source]

Bases: object

allow_adhoc_connections(default)[source]

get_adhoc_connection_scheme(default)[source]

get_backbone_connection_generation(default)[source]

get_bool_var(name: str, default=None)[source]

get_comm_driver_path(default)[source]

get_config()[source]

get_float_var(name: str, default=None)[source]

get_heartbeat_interval(default)[source]

get_int_var(name: str, default=None)[source]

get_internal_connection_scheme(default)[source]

get_max_message_size()[source]

get_sfm_close_stalled_connection(default=False)[source]

get_sfm_send_stall_consecutive_checks(default=3)[source]

get_sfm_send_stall_timeout(default)[source]

get_str_var(name: str, default=None)[source]

get_streaming_ack_interval(default)[source]

get_streaming_ack_progress_check_interval(default)[source]

get_streaming_ack_progress_timeout(default)[source]

get_streaming_ack_wait(default)[source]

get_streaming_chunk_size(default)[source]

get_streaming_max_out_seq_chunks(default)[source]

get_streaming_read_timeout(default)[source]

get_streaming_send_timeout(default)[source]

get_streaming_window_size(default)[source]

get_subnet_heartbeat_interval(default)[source]

get_subnet_trouble_threshold(default)[source]

static reset()[source]

Reset the configurator to allow reloading config files.

Returns:

use_aio_grpc(default)[source]

class VarName[source]

Bases: object

ADHOC_CONN_SCHEME = 'adhoc_conn_scheme'

ALLOW_ADHOC_CONNS = 'allow_adhoc_conns'

BACKBONE_CONN_GEN = 'backbone_conn_gen'

COMM_DRIVER_PATH = 'comm_driver_path'

HEARTBEAT_INTERVAL = 'heartbeat_interval'

INTERNAL_CONN_SCHEME = 'internal_conn_scheme'

MAX_MESSAGE_SIZE = 'max_message_size'

SFM_CLOSE_STALLED_CONNECTION = 'sfm_close_stalled_connection'

SFM_SEND_STALL_CONSECUTIVE_CHECKS = 'sfm_send_stall_consecutive_checks'

SFM_SEND_STALL_TIMEOUT = 'sfm_send_stall_timeout'

STREAMING_ACK_INTERVAL = 'streaming_ack_interval'

STREAMING_ACK_PROGRESS_CHECK_INTERVAL = 'streaming_ack_progress_check_interval'

STREAMING_ACK_PROGRESS_TIMEOUT = 'streaming_ack_progress_timeout'

STREAMING_ACK_WAIT = 'streaming_ack_wait'

STREAMING_CHUNK_SIZE = 'streaming_chunk_size'

STREAMING_MAX_OUT_SEQ_CHUNKS = 'streaming_max_out_seq_chunks'

STREAMING_READ_TIMEOUT = 'streaming_read_timeout'

STREAMING_SEND_TIMEOUT = 'streaming_send_timeout'

STREAMING_WINDOW_SIZE = 'streaming_window_size'

SUBNET_HEARTBEAT_INTERVAL = 'subnet_heartbeat_interval'

SUBNET_TROUBLE_THRESHOLD = 'subnet_trouble_threshold'

USE_AIO_GRPC_VAR_NAME = 'use_aio_grpc'