From 8e7567008f13e544d286752eef1fb90bd246b8c8 Mon Sep 17 00:00:00 2001 From: Dominik Werder Date: Wed, 6 Sep 2023 14:07:05 +0200 Subject: [PATCH] Trigger build --- .github/workflows/build-rhel7.yml | 6 +++--- netfetch/src/ca/connset.rs | 11 ++++++++++- 2 files changed, 13 insertions(+), 4 deletions(-) diff --git a/.github/workflows/build-rhel7.yml b/.github/workflows/build-rhel7.yml index 0d7bc29..ab16610 100644 --- a/.github/workflows/build-rhel7.yml +++ b/.github/workflows/build-rhel7.yml @@ -1,8 +1,8 @@ name: build-daqingest-rhel7 on: - # push: - # tags: - # - buildaction + push: + tags: + - buildaction workflow_dispatch: inputs: flags: diff --git a/netfetch/src/ca/connset.rs b/netfetch/src/ca/connset.rs index a20899b..7ed2cf9 100644 --- a/netfetch/src/ca/connset.rs +++ b/netfetch/src/ca/connset.rs @@ -143,7 +143,16 @@ impl CaConnSet { Ok(()) } }, - CaConnSetEvent::CaConnEvent((addr, ev)) => todo!(), + CaConnSetEvent::CaConnEvent((addr, ev)) => match ev.value { + CaConnEventValue::None => Ok(()), + CaConnEventValue::EchoTimeout => todo!(), + CaConnEventValue::ConnCommandResult(_) => todo!(), + CaConnEventValue::QueryItem(item) => { + self.storage_insert_tx.send(item).await?; + Ok(()) + } + CaConnEventValue::EndOfStream => todo!(), + }, } }