Merge pull request apache#16 from dahlbaek/forbid-unsafe

laysakura · web-flow · commit 67fbc432deab · 2023-05-09T13:14:22.000+09:00
Forbid unsafe code
diff --git a/sdks/rust/src/lib.rs b/sdks/rust/src/lib.rs
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+#![forbid(unsafe_code)]
+
 pub mod coders;
 pub mod elem_types;
 pub mod internals;
diff --git a/sdks/rust/src/worker/operators.rs b/sdks/rust/src/worker/operators.rs
@@ -411,14 +411,12 @@ impl OperatorI for RecordingOperator {
     }
 
     fn process(&self, value: DynamicWindowedValue) {
-        unsafe {
-            let mut log = RECORDING_OPERATOR_LOGS.lock().unwrap();
-            log.push(format!(
-                "{}.process({:?})",
-                self.transform_id,
-                value.downcast_ref::<String>().value
-            ));
-        }
+        let mut log = RECORDING_OPERATOR_LOGS.lock().unwrap();
+        log.push(format!(
+            "{}.process({:?})",
+            self.transform_id,
+            value.downcast_ref::<String>().value
+        ));
 
         for rec in self.receivers.iter() {
             rec.receive(value);
