Skip to content

Commit 51fe03d

Browse files
committed
refactor: firstly listen tcp port
Signed-off-by: tison <wander4096@gmail.com>
1 parent db91177 commit 51fe03d

File tree

2 files changed

+15
-16
lines changed

2 files changed

+15
-16
lines changed

client/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,9 @@ repository.workspace = true
2626

2727
[package.metadata.release]
2828
pre-release-commit-message = "chore: Release {{crate_name}} version {{version}}"
29-
tag-message = "chore: Release {{crate_name}} version {{version}}"
3029
sign-commit = true
3130
sign-tag = true
31+
tag-message = "chore: Release {{crate_name}} version {{version}}"
3232

3333
[dependencies]
3434
reqwest = { workspace = true }

cmd/percas/src/start.rs

Lines changed: 14 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)