diff --git a/ingest-linux/Cargo.toml b/ingest-linux/Cargo.toml index f8ea59d..28e6e89 100644 --- a/ingest-linux/Cargo.toml +++ b/ingest-linux/Cargo.toml @@ -2,13 +2,10 @@ name = "ingest-linux" version = "0.0.1" authors = ["Dominik Werder "] -edition = "2021" +edition = "2024" [dependencies] libc = "0.2" -thiserror = "=0.0.1" +autoerr = "0.0.3" log = { path = "../log" } taskrun = { path = "../../daqbuffer/crates/taskrun" } - -[patch.crates-io] -thiserror = { git = "https://github.com/dominikwerder/thiserror.git", branch = "cstm" } diff --git a/ingest-linux/src/net.rs b/ingest-linux/src/net.rs index a752a15..ed6ac5d 100644 --- a/ingest-linux/src/net.rs +++ b/ingest-linux/src/net.rs @@ -1,14 +1,14 @@ use std::ffi::CStr; use taskrun::tokio; -use thiserror::Error; use tokio::net::TcpStream; -#[derive(Debug, Error)] -#[error("{self}")] -pub enum Error { - SocketOptionSet, - SocketOptionGet, -} +autoerr::create_error_v1!( + name(Error, "LinuxNetError"), + enum variants { + SocketOptionSet, + SocketOptionGet, + }, +); pub fn local_hostname() -> String { let mut buf = vec![0u8; 128]; diff --git a/ingest-linux/src/signal.rs b/ingest-linux/src/signal.rs index 70bacb0..ee39997 100644 --- a/ingest-linux/src/signal.rs +++ b/ingest-linux/src/signal.rs @@ -1,13 +1,13 @@ use std::ffi::CStr; use std::mem::MaybeUninit; -use thiserror::Error; -#[derive(Debug, Error)] -#[cstm(name = "LinuxSignal")] -pub enum Error { - SignalHandlerSet, - SignalHandlerUnset, -} +autoerr::create_error_v1!( + name(Error, "LinuxSignalError"), + enum variants { + SignalHandlerSet, + SignalHandlerUnset, + }, +); pub fn set_signal_handler( signum: libc::c_int, diff --git a/netfetch/Cargo.toml b/netfetch/Cargo.toml index 549c329..59cbd6a 100644 --- a/netfetch/Cargo.toml +++ b/netfetch/Cargo.toml @@ -44,7 +44,6 @@ serieswriter = { path = "../serieswriter" } stats = { path = "../stats" } scywr = { path = "../scywr" } dbpg = { path = "../dbpg" } -serde_helper = { path = "../serde_helper" } ingest-linux = { path = "../ingest-linux" } err = { path = "../../daqbuf-err", package = "daqbuf-err" } netpod = { path = "../../daqbuf-netpod", package = "daqbuf-netpod" } @@ -53,12 +52,10 @@ items_2 = { path = "../../daqbuf-items-2", package = "daqbuf-items-2" } streams = { path = "../../daqbuf-streams", package = "daqbuf-streams" } ca_proto = { path = "../../daqbuf-ca-proto", package = "daqbuf-ca-proto" } ca-proto-tokio = { path = "../../daqbuf-ca-proto-tokio", package = "daqbuf-ca-proto-tokio" } +serde-helper = { path = "../../daqbuf-serde-helper", package = "daqbuf-serde-helper" } taskrun = { path = "../../daqbuffer/crates/taskrun" } mrucache = { path = "../mrucache" } batchtools = { path = "../batchtools" } -[patch.crates-io] -thiserror = { git = "https://github.com/dominikwerder/thiserror.git", branch = "cstm" } - [features] disabled = [] diff --git a/serde_helper/Cargo.toml b/serde_helper/Cargo.toml deleted file mode 100644 index b6a0cdc..0000000 --- a/serde_helper/Cargo.toml +++ /dev/null @@ -1,8 +0,0 @@ -[package] -name = "serde_helper" -version = "0.0.1" -authors = ["Dominik Werder "] -edition = "2021" - -[dependencies] -serde = { version = "1.0", features = ["derive"] } diff --git a/serde_helper/src/lib.rs b/serde_helper/src/lib.rs deleted file mode 100644 index 3164c32..0000000 --- a/serde_helper/src/lib.rs +++ /dev/null @@ -1,2 +0,0 @@ -pub mod serde_dummy; -pub mod serde_instant; diff --git a/serde_helper/src/serde_dummy.rs b/serde_helper/src/serde_dummy.rs deleted file mode 100644 index ffbc0eb..0000000 --- a/serde_helper/src/serde_dummy.rs +++ /dev/null @@ -1,12 +0,0 @@ -#[allow(non_snake_case)] -pub mod serde_dummy { - use serde::Serializer; - - #[allow(unused)] - pub fn serialize(val: &T, ser: S) -> Result - where - S: Serializer, - { - ser.serialize_str("DUMMY") - } -} diff --git a/serde_helper/src/serde_instant.rs b/serde_helper/src/serde_instant.rs deleted file mode 100644 index 384b553..0000000 --- a/serde_helper/src/serde_instant.rs +++ /dev/null @@ -1,14 +0,0 @@ -#[allow(non_snake_case)] -pub mod serde_Instant_elapsed_ms { - use serde::Serializer; - use std::time::Instant; - - #[allow(unused)] - pub fn serialize(val: &Instant, ser: S) -> Result - where - S: Serializer, - { - let dur = val.elapsed(); - ser.serialize_u64(dur.as_secs() * 1000 + dur.subsec_millis() as u64) - } -}