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!(), + }, } }