Struct rusteron_media_driver::bindings::aeron_driver_context_stct

source · 
#[repr(C)]
pub struct aeron_driver_context_stct {
Show 150 fields
    pub aeron_dir: *mut c_char,
    pub threading_mode: aeron_threading_mode_t,
    pub receiver_group_consideration: aeron_inferable_boolean_t,
    pub dirs_delete_on_start: bool,
    pub dirs_delete_on_shutdown: bool,
    pub warn_if_dirs_exist: bool,
    pub term_buffer_sparse_file: bool,
    pub perform_storage_checks: bool,
    pub spies_simulate_connection: bool,
    pub print_configuration_on_start: bool,
    pub reliable_stream: bool,
    pub tether_subscriptions: bool,
    pub rejoin_stream: bool,
    pub ats_enabled: bool,
    pub connect_enabled: bool,
    pub driver_timeout_ms: u64,
    pub client_liveness_timeout_ns: u64,
    pub publication_linger_timeout_ns: u64,
    pub status_message_timeout_ns: u64,
    pub image_liveness_timeout_ns: u64,
    pub publication_unblock_timeout_ns: u64,
    pub publication_connection_timeout_ns: u64,
    pub timer_interval_ns: u64,
    pub counter_free_to_reuse_ns: u64,
    pub untethered_window_limit_timeout_ns: u64,
    pub untethered_resting_timeout_ns: u64,
    pub retransmit_unicast_delay_ns: u64,
    pub retransmit_unicast_linger_ns: u64,
    pub nak_unicast_delay_ns: u64,
    pub nak_unicast_retry_delay_ratio: u64,
    pub nak_multicast_max_backoff_ns: u64,
    pub re_resolution_check_interval_ns: u64,
    pub low_file_store_warning_threshold: u64,
    pub to_driver_buffer_length: usize,
    pub to_clients_buffer_length: usize,
    pub counters_values_buffer_length: usize,
    pub error_buffer_length: usize,
    pub term_buffer_length: usize,
    pub ipc_term_buffer_length: usize,
    pub mtu_length: usize,
    pub ipc_mtu_length: usize,
    pub ipc_publication_window_length: usize,
    pub publication_window_length: usize,
    pub socket_rcvbuf: usize,
    pub socket_sndbuf: usize,
    pub send_to_sm_poll_ratio: usize,
    pub initial_window_length: usize,
    pub loss_report_length: usize,
    pub file_page_size: usize,
    pub nak_multicast_group_size: usize,
    pub publication_reserved_session_id_low: i32,
    pub publication_reserved_session_id_high: i32,
    pub multicast_ttl: u8,
    pub receiver_io_vector_capacity: u32,
    pub sender_io_vector_capacity: u32,
    pub network_publication_max_messages_per_send: u32,
    pub resource_free_limit: u32,
    pub async_executor_threads: u32,
    pub max_resend: u32,
    pub conductor_cpu_affinity_no: i32,
    pub receiver_cpu_affinity_no: i32,
    pub sender_cpu_affinity_no: i32,
    pub stream_session_limit: i32,
    pub enable_experimental_features: bool,
    pub receiver_group_tag: aeron_driver_context_stct__bindgen_ty_1,
    pub flow_control: aeron_driver_context_stct__bindgen_ty_2,
    pub cnc_map: aeron_mapped_file_t,
    pub loss_report: aeron_mapped_file_t,
    pub to_driver_buffer: *mut u8,
    pub to_clients_buffer: *mut u8,
    pub counters_values_buffer: *mut u8,
    pub counters_metadata_buffer: *mut u8,
    pub error_buffer: *mut u8,
    pub nano_clock: aeron_clock_func_t,
    pub epoch_clock: aeron_clock_func_t,
    pub cached_clock: *mut aeron_clock_cache_t,
    pub sender_cached_clock: *mut aeron_clock_cache_t,
    pub receiver_cached_clock: *mut aeron_clock_cache_t,
    pub sender_command_queue: aeron_mpsc_rb_t,
    pub receiver_command_queue: aeron_mpsc_rb_t,
    pub conductor_command_queue: aeron_mpsc_rb_t,
    pub agent_on_start_func: aeron_agent_on_start_func_t,
    pub agent_on_start_state: *mut c_void,
    pub conductor_idle_strategy_func: aeron_idle_strategy_func_t,
    pub conductor_idle_strategy_state: *mut c_void,
    pub conductor_idle_strategy_init_args: *mut c_char,
    pub conductor_idle_strategy_name: *const c_char,
    pub shared_idle_strategy_func: aeron_idle_strategy_func_t,
    pub shared_idle_strategy_state: *mut c_void,
    pub shared_idle_strategy_init_args: *mut c_char,
    pub shared_idle_strategy_name: *const c_char,
    pub shared_network_idle_strategy_func: aeron_idle_strategy_func_t,
    pub shared_network_idle_strategy_state: *mut c_void,
    pub shared_network_idle_strategy_init_args: *mut c_char,
    pub shared_network_idle_strategy_name: *const c_char,
    pub sender_idle_strategy_func: aeron_idle_strategy_func_t,
    pub sender_idle_strategy_state: *mut c_void,
    pub sender_idle_strategy_init_args: *mut c_char,
    pub sender_idle_strategy_name: *const c_char,
    pub receiver_idle_strategy_func: aeron_idle_strategy_func_t,
    pub receiver_idle_strategy_state: *mut c_void,
    pub receiver_idle_strategy_init_args: *mut c_char,
    pub receiver_idle_strategy_name: *const c_char,
    pub usable_fs_space_func: aeron_usable_fs_space_func_t,
    pub raw_log_map_func: aeron_raw_log_map_func_t,
    pub raw_log_close_func: aeron_raw_log_close_func_t,
    pub raw_log_free_func: aeron_raw_log_free_func_t,
    pub unicast_flow_control_supplier_func: aeron_flow_control_strategy_supplier_func_t,
    pub multicast_flow_control_supplier_func: aeron_flow_control_strategy_supplier_func_t,
    pub congestion_control_supplier_func: aeron_congestion_control_strategy_supplier_func_t,
    pub conductor_proxy: *mut aeron_driver_conductor_proxy_t,
    pub sender_proxy: *mut aeron_driver_sender_proxy_t,
    pub receiver_proxy: *mut aeron_driver_receiver_proxy_t,
    pub counters_manager: *mut aeron_counters_manager_t,
    pub system_counters: *mut aeron_system_counters_t,
    pub error_log: *mut aeron_distinct_error_log_t,
    pub log: aeron_driver_context_stct__bindgen_ty_3,
    pub termination_validator_func: aeron_driver_termination_validator_func_t,
    pub termination_validator_state: *mut c_void,
    pub termination_hook_func: aeron_driver_termination_hook_func_t,
    pub termination_hook_state: *mut c_void,
    pub udp_channel_transport_bindings: *mut aeron_udp_channel_transport_bindings_t,
    pub conductor_udp_channel_transport_bindings: *mut aeron_udp_channel_transport_bindings_t,
    pub udp_channel_outgoing_interceptor_bindings: *mut aeron_udp_channel_interceptor_bindings_t,
    pub udp_channel_incoming_interceptor_bindings: *mut aeron_udp_channel_interceptor_bindings_t,
    pub next_receiver_id: i64,
    pub unicast_delay_feedback_generator: aeron_feedback_delay_generator_state_t,
    pub multicast_delay_feedback_generator: aeron_feedback_delay_generator_state_t,
    pub resolver_name: *const c_char,
    pub resolver_interface: *const c_char,
    pub resolver_bootstrap_neighbor: *const c_char,
    pub name_resolver_init_args: *const c_char,
    pub name_resolver_supplier_func: aeron_name_resolver_supplier_func_t,
    pub driver_name_resolver_bootstrap_resolver_supplier_func: aeron_name_resolver_supplier_func_t,
    pub conductor_duty_cycle_tracker: *mut aeron_duty_cycle_tracker_t,
    pub sender_duty_cycle_tracker: *mut aeron_duty_cycle_tracker_t,
    pub receiver_duty_cycle_tracker: *mut aeron_duty_cycle_tracker_t,
    pub name_resolver_time_tracker: *mut aeron_duty_cycle_tracker_t,
    pub conductor_duty_cycle_stall_tracker: aeron_duty_cycle_stall_tracker_t,
    pub sender_duty_cycle_stall_tracker: aeron_duty_cycle_stall_tracker_t,
    pub receiver_duty_cycle_stall_tracker: aeron_duty_cycle_stall_tracker_t,
    pub name_resolver_time_stall_tracker: aeron_duty_cycle_stall_tracker_t,
    pub sender_port_manager: *mut aeron_port_manager_t,
    pub receiver_port_manager: *mut aeron_port_manager_t,
    pub sender_wildcard_port_manager: aeron_wildcard_port_manager_t,
    pub receiver_wildcard_port_manager: aeron_wildcard_port_manager_t,
    pub dynamic_libs: *mut aeron_dl_loaded_libs_state_t,
    pub bindings_clientd_entries: *mut aeron_driver_context_bindings_clientd_entry_t,
    pub num_bindings_clientd_entries: usize,
    pub os_buffer_lengths: aeron_driver_context_stct__bindgen_ty_4,

}

Fields§

§aeron_dir: *mut c_char§threading_mode: aeron_threading_mode_t§receiver_group_consideration: aeron_inferable_boolean_t§dirs_delete_on_start: bool§dirs_delete_on_shutdown: bool§warn_if_dirs_exist: bool§term_buffer_sparse_file: bool§perform_storage_checks: bool§spies_simulate_connection: bool§print_configuration_on_start: bool§reliable_stream: bool§tether_subscriptions: bool§rejoin_stream: bool§ats_enabled: bool§connect_enabled: bool§driver_timeout_ms: u64§client_liveness_timeout_ns: u64§publication_linger_timeout_ns: u64§status_message_timeout_ns: u64§image_liveness_timeout_ns: u64§publication_unblock_timeout_ns: u64§publication_connection_timeout_ns: u64§timer_interval_ns: u64§counter_free_to_reuse_ns: u64§untethered_window_limit_timeout_ns: u64§untethered_resting_timeout_ns: u64§retransmit_unicast_delay_ns: u64§retransmit_unicast_linger_ns: u64§nak_unicast_delay_ns: u64§nak_unicast_retry_delay_ratio: u64§nak_multicast_max_backoff_ns: u64§re_resolution_check_interval_ns: u64§low_file_store_warning_threshold: u64§to_driver_buffer_length: usize§to_clients_buffer_length: usize§counters_values_buffer_length: usize§error_buffer_length: usize§term_buffer_length: usize§ipc_term_buffer_length: usize§mtu_length: usize§ipc_mtu_length: usize§ipc_publication_window_length: usize§publication_window_length: usize§socket_rcvbuf: usize§socket_sndbuf: usize§send_to_sm_poll_ratio: usize§initial_window_length: usize§loss_report_length: usize§file_page_size: usize§nak_multicast_group_size: usize§publication_reserved_session_id_low: i32§publication_reserved_session_id_high: i32§multicast_ttl: u8§receiver_io_vector_capacity: u32§sender_io_vector_capacity: u32§network_publication_max_messages_per_send: u32§resource_free_limit: u32§async_executor_threads: u32§max_resend: u32§conductor_cpu_affinity_no: i32§receiver_cpu_affinity_no: i32§sender_cpu_affinity_no: i32§stream_session_limit: i32§enable_experimental_features: bool§receiver_group_tag: aeron_driver_context_stct__bindgen_ty_1§flow_control: aeron_driver_context_stct__bindgen_ty_2§cnc_map: aeron_mapped_file_t§loss_report: aeron_mapped_file_t§to_driver_buffer: *mut u8§to_clients_buffer: *mut u8§counters_values_buffer: *mut u8§counters_metadata_buffer: *mut u8§error_buffer: *mut u8§nano_clock: aeron_clock_func_t§epoch_clock: aeron_clock_func_t§cached_clock: *mut aeron_clock_cache_t§sender_cached_clock: *mut aeron_clock_cache_t§receiver_cached_clock: *mut aeron_clock_cache_t§sender_command_queue: aeron_mpsc_rb_t§receiver_command_queue: aeron_mpsc_rb_t§conductor_command_queue: aeron_mpsc_rb_t§agent_on_start_func: aeron_agent_on_start_func_t§agent_on_start_state: *mut c_void§conductor_idle_strategy_func: aeron_idle_strategy_func_t§conductor_idle_strategy_state: *mut c_void§conductor_idle_strategy_init_args: *mut c_char§conductor_idle_strategy_name: *const c_char§shared_idle_strategy_func: aeron_idle_strategy_func_t§shared_idle_strategy_state: *mut c_void§shared_idle_strategy_init_args: *mut c_char§shared_idle_strategy_name: *const c_char§shared_network_idle_strategy_func: aeron_idle_strategy_func_t§shared_network_idle_strategy_state: *mut c_void§shared_network_idle_strategy_init_args: *mut c_char§shared_network_idle_strategy_name: *const c_char§sender_idle_strategy_func: aeron_idle_strategy_func_t§sender_idle_strategy_state: *mut c_void§sender_idle_strategy_init_args: *mut c_char§sender_idle_strategy_name: *const c_char§receiver_idle_strategy_func: aeron_idle_strategy_func_t§receiver_idle_strategy_state: *mut c_void§receiver_idle_strategy_init_args: *mut c_char§receiver_idle_strategy_name: *const c_char§usable_fs_space_func: aeron_usable_fs_space_func_t§raw_log_map_func: aeron_raw_log_map_func_t§raw_log_close_func: aeron_raw_log_close_func_t§raw_log_free_func: aeron_raw_log_free_func_t§unicast_flow_control_supplier_func: aeron_flow_control_strategy_supplier_func_t§multicast_flow_control_supplier_func: aeron_flow_control_strategy_supplier_func_t§congestion_control_supplier_func: aeron_congestion_control_strategy_supplier_func_t§conductor_proxy: *mut aeron_driver_conductor_proxy_t§sender_proxy: *mut aeron_driver_sender_proxy_t§receiver_proxy: *mut aeron_driver_receiver_proxy_t§counters_manager: *mut aeron_counters_manager_t§system_counters: *mut aeron_system_counters_t§error_log: *mut aeron_distinct_error_log_t§log: aeron_driver_context_stct__bindgen_ty_3§termination_validator_func: aeron_driver_termination_validator_func_t§termination_validator_state: *mut c_void§termination_hook_func: aeron_driver_termination_hook_func_t§termination_hook_state: *mut c_void§udp_channel_transport_bindings: *mut aeron_udp_channel_transport_bindings_t§conductor_udp_channel_transport_bindings: *mut aeron_udp_channel_transport_bindings_t§udp_channel_outgoing_interceptor_bindings: *mut aeron_udp_channel_interceptor_bindings_t§udp_channel_incoming_interceptor_bindings: *mut aeron_udp_channel_interceptor_bindings_t§next_receiver_id: i64§unicast_delay_feedback_generator: aeron_feedback_delay_generator_state_t§multicast_delay_feedback_generator: aeron_feedback_delay_generator_state_t§resolver_name: *const c_char§resolver_interface: *const c_char§resolver_bootstrap_neighbor: *const c_char§name_resolver_init_args: *const c_char§name_resolver_supplier_func: aeron_name_resolver_supplier_func_t§driver_name_resolver_bootstrap_resolver_supplier_func: aeron_name_resolver_supplier_func_t§conductor_duty_cycle_tracker: *mut aeron_duty_cycle_tracker_t§sender_duty_cycle_tracker: *mut aeron_duty_cycle_tracker_t§receiver_duty_cycle_tracker: *mut aeron_duty_cycle_tracker_t§name_resolver_time_tracker: *mut aeron_duty_cycle_tracker_t§conductor_duty_cycle_stall_tracker: aeron_duty_cycle_stall_tracker_t§sender_duty_cycle_stall_tracker: aeron_duty_cycle_stall_tracker_t§receiver_duty_cycle_stall_tracker: aeron_duty_cycle_stall_tracker_t§name_resolver_time_stall_tracker: aeron_duty_cycle_stall_tracker_t§sender_port_manager: *mut aeron_port_manager_t§receiver_port_manager: *mut aeron_port_manager_t§sender_wildcard_port_manager: aeron_wildcard_port_manager_t§receiver_wildcard_port_manager: aeron_wildcard_port_manager_t§dynamic_libs: *mut aeron_dl_loaded_libs_state_t§bindings_clientd_entries: *mut aeron_driver_context_bindings_clientd_entry_t§num_bindings_clientd_entries: usize§os_buffer_lengths: aeron_driver_context_stct__bindgen_ty_4

Trait Implementations§

source§

impl Clone for aeron_driver_context_stct

source§

fn clone(&self) -> aeron_driver_context_stct

Returns a copy of the value. Read more
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl Debug for aeron_driver_context_stct

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
source§

impl From<aeron_driver_context_stct> for AeronDriverContext

source§

fn from(value: aeron_driver_context_t) -> Self

Converts to this type from the input type.
source§

impl Copy for aeron_driver_context_stct

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> CloneToUninit for T
where T: Clone,

source§

unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> ToOwned for T
where T: Clone,

source§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

source§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.