@@ -159,22 +159,8 @@ async fn run_server(
159159) -> Result < ( ) , Error > {
160160 let make_error = || Error ( "failed to start server" . to_string ( ) ) ;
161161
162- let engine = FoyerEngine :: try_new (
163- & config. storage . data_dir ,
164- config. storage . memory_capacity ,
165- config. storage . disk_capacity ,
166- config. storage . disk_throttle ,
167- Some ( OpenTelemetryMetricsRegistry :: new (
168- GlobalMetrics :: get ( ) . meter . clone ( ) ,
169- ) ) ,
170- )
171- . await
172- . or_raise ( make_error) ?;
173-
174- let ( shutdown_tx, shutdown_rx) = mea:: shutdown:: new_pair ( ) ;
175- let ctx = Arc :: new ( PercasContext { engine } ) ;
176-
177162 let flatten_config = FlattenConfig :: from ( & config. server ) ;
163+ let ( shutdown_tx, shutdown_rx) = mea:: shutdown:: new_pair ( ) ;
178164
179165 let ( acceptor, advertise_addr) = make_acceptor_and_advertise_addr (
180166 flatten_config. listen_addr . as_str ( ) ,
@@ -200,6 +186,19 @@ async fn run_server(
200186 }
201187 } ;
202188
189+ let engine = FoyerEngine :: try_new (
190+ config. storage . data_dir . as_path ( ) ,
191+ config. storage . memory_capacity ,
192+ config. storage . disk_capacity ,
193+ config. storage . disk_throttle ,
194+ Some ( OpenTelemetryMetricsRegistry :: new (
195+ GlobalMetrics :: get ( ) . meter . clone ( ) ,
196+ ) ) ,
197+ )
198+ . await
199+ . or_raise ( make_error) ?;
200+ let ctx = Arc :: new ( PercasContext { engine } ) ;
201+
203202 let server = percas_server:: server:: start_server (
204203 server_rt,
205204 shutdown_rx,
0 commit comments