Wrap ffi calls with catch_unwind. (#1083)

* Wrap ffi calls with catch_unwind.

* Add guard in case panic is change to abort.

* Add error logging while catching panics.

Author: hoolioh

Cargo.lock

@@ -15,7 +15,8 @@ crate-type = ["lib", "staticlib", "cdylib"]
 bench = false
 
 [features]
-default = ["cbindgen"]
+default = ["cbindgen", "catch_panic"]
+catch_panic = []
 cbindgen = ["build_common/cbindgen", "ddcommon-ffi/cbindgen"]
 
 [build-dependencies]
@@ -30,3 +31,4 @@ datadog-trace-utils = { path = "../datadog-trace-utils" }
 data-pipeline = { path = "../data-pipeline" }
 ddcommon-ffi = { path = "../ddcommon-ffi", default-features = false }
 tinybytes = { path = "../tinybytes" }
+tracing = { version = "0.1", default-features = false }

data-pipeline-ffi/Cargo.toml

@@ -33,6 +33,8 @@ pub enum ExporterErrorCode {
     Serde,
     TimedOut,
     Internal,
+    #[cfg(feature = "catch_panic")]
+    Panic,
 }
 
 impl Display for ExporterErrorCode {
@@ -59,6 +61,8 @@ impl Display for ExporterErrorCode {
             Self::Serde => write!(f, "Serialization/Deserialization error"),
             Self::TimedOut => write!(f, "Operation timed out"),
             Self::Internal => write!(f, "Internal error"),
+            #[cfg(feature = "catch_panic")]
+            Self::Panic => write!(f, "Operation panicked"),
         }
     }
 }