Skip to content

Commit

Permalink
Mapped c_network_observer [UNTESTED]
Browse files Browse the repository at this point in the history 
Added more function as comments
  • Loading branch information
@twist84
twist84 committed Jan 23, 2025
1 parent 21e03ee commit 78a5039
Show file tree
Hide file tree
Showing 2 changed files with 244 additions and 116 deletions.
67 changes: 43 additions & 24 deletions game/source/networking/session/network_observer.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,23 @@ void c_network_observer::destroy_observer()
INVOKE_CLASS_MEMBER(0x00446190, c_network_observer, destroy_observer);
}

//.text:004463A0 ; bool c_network_channel::established() const
//.text:004463B0 ; c_network_observer::s_channel_observer const* c_network_observer::find_observer_by_channel(c_network_channel const*) const
//.text:004463C0 ; c_network_observer::s_channel_observer* c_network_observer::find_observer_by_channel(c_network_channel const*)
//.text:004463D0 ; long c_network_observer::find_observer_index_by_channel(c_network_channel const*) const
//.text:004463F0 ; bool c_network_observer::get_bandwidth_results(long*, real*, long*) const
//.text:00446490 ;
//.text:004464A0 ;
//.text:004464B0 ; long c_network_observer::get_estimated_bandwidth() const
//.text:004464C0 ; dword c_network_channel::get_identifier() const
//.text:004464D0 ; bool c_network_observer::get_is_estimated_bandwidth_reliable() const
//.text:004464E0 ; long c_network_observer::get_latency_to_simulation_authority() const
//.text:00446520 ;
//.text:00446530 ;
//.text:00446540 ; c_network_observer::s_channel_observer* c_network_observer::get_observer(e_network_observer_owner, long)
//.text:00446560 ;
//.text:00446570 ; bool c_network_channel::get_remote_address(transport_address*) const
//.text:004465C0 ; dword c_network_channel::get_remote_identifier() const
//.text:004465D0 ; e_transport_secure_connection c_network_observer::get_secure_connection_status(long) const
//.text:00446610 ; bool c_network_observer::get_simple_status(long, long*, real*, long*, long*)

Expand All @@ -42,13 +59,14 @@ bool c_network_observer::initialize_observer(c_network_link* link, c_network_mes

//.text:00446D90 ; bool c_network_observer::is_bandwidth_stable()
//.text:00446DA0 ; bool c_network_channel::is_empty() const
//.text:00446DC0 ;

void c_network_observer::monitor()
{
INVOKE_CLASS_MEMBER(0x00446DD0, c_network_observer, monitor);
}

//.text:00446ED0 ;
//.text:00446ED0 ; void c_network_observer::notify_channel_packet_received(c_network_channel const*, long)
//.text:00446EF0 ; void c_network_observer::notify_channel_packet_sent(c_network_channel*, long, bool, long, long, long)
//.text:00446F60 ; bool c_network_observer::observer_channel_backlogged(e_network_observer_owner, long, e_network_message_type) const
//.text:00446FE0 ; bool c_network_observer::observer_channel_currently_alive(e_network_observer_owner, long) const
Expand All @@ -74,44 +92,45 @@ long c_network_observer::observer_channel_find_by_network_channel(long owner_typ
//.text:004471A0 ; void c_network_observer::observer_channel_get_bandwidth_events(e_network_observer_owner, long, long, long*) const
//.text:004471E0 ; bool c_network_observer::observer_channel_get_last_receive_activity(e_network_observer_owner, long, dword*) const
//.text:00447220 ; c_network_channel* c_network_observer::observer_channel_get_network_channel(e_network_observer_owner, long)
//.text:00447240 ; c_network_observer::s_channel_observer const* c_network_observer::get_observer(e_network_observer_owner, long) const
//.text:00447240 ; c_network_channel const* c_network_observer::observer_channel_get_network_channel(e_network_observer_owner, long) const
//.text:00447260 ; void c_network_observer::observer_channel_get_secure_address(e_network_observer_owner, long, s_transport_secure_address*) const
//.text:00447290 ;
//.text:00447290 ; bool c_network_observer::observer_channel_get_waiting_on_backlog(e_network_observer_owner, long, e_network_message_type)
//.text:004472E0 ; void c_network_observer::observer_channel_initiate_connection(e_network_observer_owner, long)
//.text:00447340 ;
//.text:00447340 ; long c_network_observer::observer_channel_iterate(e_network_observer_owner, long) const
//.text:004473A0 ; void c_network_observer::observer_channel_release(e_network_observer_owner, long)
//.text:004473D0 ; long c_network_observer::observer_channel_request(e_network_observer_owner, s_transport_secure_address const*)
//.text:004473E0 ; void c_network_observer::observer_channel_reset(e_network_observer_owner, long)
//.text:00447420 ; void c_network_observer::observer_channel_reset_security(e_network_observer_owner, long)
//.text:004474B0 ; bool c_network_observer::observer_channel_secure_connection_established(e_network_observer_owner, long) const

void c_network_observer::observer_channel_send_message(long owner_type, long observer_index, bool a3, e_network_message_type message_type, long data_size, void const* data)
void c_network_observer::observer_channel_send_message(long owner_type, long observer_channel_index, bool out_of_band, e_network_message_type message_type, long message_size, void const* message_payload)
{
INVOKE_CLASS_MEMBER(0x004474F0, c_network_observer, observer_channel_send_message, owner_type, observer_index, a3, message_type, data_size, data);
INVOKE_CLASS_MEMBER(0x004474F0, c_network_observer, observer_channel_send_message, owner_type, observer_channel_index, out_of_band, message_type, message_size, message_payload);
}

//.text:00447660 ; void c_network_observer::observer_channel_set_observer_is_bad_client(e_network_observer_owner, long, bool)
//.text:00447690 ;
//.text:00447690 ; void c_network_observer::observer_channel_set_remote_machine_bandwidth(e_network_observer_owner, long, long, long)
//.text:004476C0 ; void c_network_observer::observer_channel_set_waiting_on_backlog(e_network_observer_owner, long, e_network_message_type)
//.text:00447740 ;
//.text:00447740 ; void c_network_observer::observer_clear_security_flags()
//.text:00447760 ; bool c_network_observer::observer_desires_heartbeat(long) const

void c_network_observer::observer_prioritize_upload_bandwidth(bool prioritize_upload_bandwidth)
void c_network_observer::observer_prioritize_upload_bandwidth(bool prioritize)
{
//INVOKE_CLASS_MEMBER(0x004477E0, c_network_observer, observer_prioritize_upload_bandwidth, prioritize_upload_bandwidth);
//INVOKE_CLASS_MEMBER(0x004477E0, c_network_observer, observer_prioritize_upload_bandwidth, prioritize);

if (m_prioritize_upload_bandwidth != prioritize_upload_bandwidth)
if (m_prioritize_upload_bandwidth != prioritize)
{
m_prioritize_upload_bandwidth = prioritize_upload_bandwidth;
__unknown23F00 = true;
__unknown23F01 = true;
event(_event_message, "networking:observer:stream: rebalance stream for upload bandwidth prioritzation=%d", prioritize_upload_bandwidth);
m_prioritize_upload_bandwidth = prioritize;
m_stream_needs_rebalancing = true;
m_stream_abort_growth = true;
event(_event_message, "networking:observer:stream: rebalance stream for upload bandwidth prioritzation=%d", prioritize);
}
}

//.text:00447820 ;
//.text:004478E0 ;
//.text:00447AA0 ;
//.text:00447820 ; real c_network_observer::packet_rate_get_maximum_given_bandwidth_bps(long, bool, bool) const
//.text:004478E0 ; real c_network_observer::packet_rate_increase(real, bool) const
//.text:00447A10 ; bool c_network_observer::packet_rate_is_limiting(real, bool, bool, bool) const
//.text:00447AA0 ; void __cdecl quality_record_bit(qword*,long,long)
//.text:00447B10 ; bool c_network_observer::quality_statistics_are_set() const
//.text:00447B20 ; c_network_oberserver::quality_statistics_report_badness
//.text:00447B60 ; s_network_quality_statistics* c_network_observer::quality_statistics_get()
Expand All @@ -120,13 +139,13 @@ void c_network_observer::observer_prioritize_upload_bandwidth(bool prioritize_up
//.text:00447D90 ; void c_network_observer::quality_statistics_notify_peer_left_gracefully(e_network_observer_owner, long)
//.text:00447DE0 ; void c_network_observer::quality_statistics_report_badness(long, bool, char const*)
//.text:00447F60 ; void c_network_observer::quality_statistics_set(s_network_quality_statistics const*)
//.text:00447F90 ;
//.text:00447F90 ; void c_network_observer::record_congestion_bandwidth(long, bool)
//.text:00447FE0 ; void c_network_observer::record_throughput_bandwidth(long, long, long, long)
//.text:004481C0 ; void c_network_observer::recreate_channels()
//.text:00448250 ; void c_network_observer::register_owner(e_network_observer_owner, c_network_channel_owner*)
//.text:00448270 ; void c_network_observer::release_observer(long)
//.text:00448370 ; void c_network_observer::reset_bandwidth()
//.text:004484E0 ;
//.text:004484E0 ; void c_network_observer::reset_congestion_bandwidth()
//.text:004484F0 ; void c_network_channel::set_connection_packet_timeout(long)
//.text:00448500 ; void c_network_observer::set_estimated_bandwidth(long, bool, bool)

Expand All @@ -146,10 +165,10 @@ void c_network_observer::set_online_network_environment(bool online_network_envi
//.text:004492D0 ; void c_network_observer::stream_dispose(long)
//.text:00449330 ; long c_network_observer::stream_get_current_latency_threshold(long, bool)
//.text:00449370 ; c_network_observer::stream_set_bandwidth
//.text:004495F0 ;
//.text:00449610 ;
//.text:00449650 ;
//.text:004496C0 ;
//.text:004495F0 ; void c_network_observer::stream_packet_bandwidth_restricted(long)
//.text:00449610 ; void c_network_observer::stream_packet_sent(long, long, long, long, long)
//.text:00449650 ; void c_network_observer::stream_set_bandwidth(long, long)
//.text:004496C0 ; void c_network_observer::stream_set_parameters(long, long, real)
//.text:00449770 ; void c_network_observer::stream_update()
//.text:0044BE90 ; void c_network_observer::update_observer_connection_initiation(long)
//.text:0044C2A0 ; void c_network_observer::update_observer_connection_state(long)
Expand Down
Loading

0 comments on commit 78a5039

Please sign in to comment.