From b6fda735ee0106b72500d927b9695a27ecd519f3 Mon Sep 17 00:00:00 2001 From: F001 Date: Fri, 30 Nov 2018 11:03:00 +0800 Subject: Replace mutex by atomics (#1238) --- src/msg.rs | 14 ++++++++++++++ 1 file changed, 14 insertions(+) (limited to 'src/msg.rs') diff --git a/src/msg.rs b/src/msg.rs index 9c8095e8f..b47d588bd 100644 --- a/src/msg.rs +++ b/src/msg.rs @@ -2,6 +2,20 @@ #![allow(dead_code)] #![cfg_attr(feature = "cargo-clippy", allow(clippy, pedantic))] use flatbuffers; +use std::sync::atomic::Ordering; + // GN_OUT_DIR is set either by build.rs (for the Cargo build), or by // build_extra/rust/run.py (for the GN+Ninja build). include!(concat!(env!("GN_OUT_DIR"), "/gen/msg_generated.rs")); + +impl<'a> From<&'a super::isolate::Metrics> for MetricsResArgs { + fn from(m: &'a super::isolate::Metrics) -> Self { + MetricsResArgs { + ops_dispatched: m.ops_dispatched.load(Ordering::SeqCst) as u64, + ops_completed: m.ops_completed.load(Ordering::SeqCst) as u64, + bytes_sent_control: m.bytes_sent_control.load(Ordering::SeqCst) as u64, + bytes_sent_data: m.bytes_sent_data.load(Ordering::SeqCst) as u64, + bytes_received: m.bytes_received.load(Ordering::SeqCst) as u64, + } + } +} -- cgit v1.2.3