Skip to content

Commit

Permalink
Add federation senders to instance map
Browse files Browse the repository at this point in the history
  • Loading branch information
David Robertson committed Feb 24, 2023
1 parent d1c931a commit 21a38a5
Showing 1 changed file with 14 additions and 1 deletion.
15 changes: 14 additions & 1 deletion lib/SyTest/Homeserver/Synapse.pm
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,8 @@ sub _init
appservice_metrics => main::alloc_port( "appservice[$idx].metrics" ),
appservice_manhole => main::alloc_port( "appservice[$idx].manhole" ),

federation_sender_metrics => main::alloc_port( "federation_sender1[$idx].metrics" ),
federation_sender => main::alloc_port( "federation_sender[$idx]" ),
federation_sender_metrics => main::alloc_port( "federation_sender[$idx].metrics" ),
federation_sender_manhole => main::alloc_port( "federation_sender[$idx].manhole" ),

client_reader => main::alloc_port( "client_reader[$idx]" ),
Expand Down Expand Up @@ -325,8 +326,14 @@ sub start
host => "$bind_host",
port => $self->{ports}{stream_writer},
},
"federation_sender" => {
host => "$bind_host",
port => $self->{ports}{federation_sender},
},
},

federation_sender_instances => ["federation_sender"],

stream_writers => {
events => $self->{redis_host} ne '' ? [ "event_persister1", "event_persister2" ] : "master",

Expand Down Expand Up @@ -736,6 +743,12 @@ sub _start_synapse
port => $self->{ports}{federation_sender_metrics},
bind_address => $bind_host,
},
{
type => "http",
resources => [{ names => ["replication"] }],
port => $self->{ports}{federation_sender},
bind_address => $bind_host,
},
],
};

Expand Down

0 comments on commit 21a38a5

Please sign in to comment.