Skip to content

Commit 47a8199

Browse files
committed
proxy: fix typos
1 parent 6382038 commit 47a8199

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

scylla-proxy/src/proxy.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1361,7 +1361,7 @@ impl ProxyWorker {
13611361
event_registered_flag: Arc<AtomicBool>,
13621362
) {
13631363
let shard = self.shard;
1364-
self.run_until_interrupted("request_processor", |driver_addr, _, real_addr| async move {
1364+
self.run_until_interrupted("response_processor", |driver_addr, _, real_addr| async move {
13651365
'mainloop: loop {
13661366
match responses_rx.recv().await {
13671367
Some(response) => {
@@ -1374,7 +1374,7 @@ impl ProxyWorker {
13741374
let mut guard = response_rules.lock().unwrap();
13751375
'_ruleloop: for (i, response_rule) in guard.iter_mut().enumerate() {
13761376
if response_rule.0.eval(&ctx) {
1377-
info!("Applying rule no={} to request ({} -> {} ({})).", i, DisplayableRealAddrOption(real_addr), driver_addr, DisplayableShard(shard));
1377+
info!("Applying rule no={} to response ({} -> {} ({})).", i, DisplayableRealAddrOption(real_addr), driver_addr, DisplayableShard(shard));
13781378
debug!("-> Applied rule: {:?}", response_rule);
13791379
debug!("-> To response: {:?}", ctx.opcode);
13801380
trace!("{:?}", response);

0 commit comments

Comments
 (0)