Skip to content

Commit effe733

Browse files
committed
Fix push-mode address configuration regressions
1 parent e47a1e8 commit effe733

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ async fn main() -> Result<(), Error> {
196196
let config = config.clone();
197197

198198
async move {
199-
let addr = format!("0.0.0.0:{}", config.grpc_port)
199+
let addr = format!("{}:{}", config.grpc_addr, config.grpc_port)
200200
.parse()
201201
.expect("Failed to parse address");
202202

src/push.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,11 +57,11 @@ impl PushPool {
5757
pub async fn start(&self) -> Result<()> {
5858
let mut handles = vec![];
5959

60-
for _ in 0..self.config.push_threads {
60+
for _ in 0..self.config.push_threads.max(1) {
6161
let endpoint = self.config.worker_endpoint.clone();
6262

6363
let callback_url = format!(
64-
"{}:{}",
64+
"http://{}:{}",
6565
self.config.callback_addr, self.config.callback_port
6666
);
6767

0 commit comments

Comments
 (0)