diff options
author | F001 <changchun.fan@qq.com> | 2018-11-30 11:03:00 +0800 |
---|---|---|
committer | Ryan Dahl <ry@tinyclouds.org> | 2018-11-29 19:03:00 -0800 |
commit | b6fda735ee0106b72500d927b9695a27ecd519f3 (patch) | |
tree | 25b176f3120b1fd7387cc350e86cb24b82eea15e /src/ops.rs | |
parent | 286e76d8c1da135cf159218fe3808fda7405301a (diff) |
Replace mutex by atomics (#1238)
Diffstat (limited to 'src/ops.rs')
-rw-r--r-- | src/ops.rs | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/src/ops.rs b/src/ops.rs index f8e3c9dc1..a0761fc84 100644 --- a/src/ops.rs +++ b/src/ops.rs @@ -23,6 +23,7 @@ use remove_dir_all::remove_dir_all; use repl; use resources::table_entries; use std; +use std::convert::From; use std::fs; use std::net::{Shutdown, SocketAddr}; #[cfg(unix)] @@ -1291,18 +1292,10 @@ fn op_metrics( assert_eq!(data.len(), 0); let cmd_id = base.cmd_id(); - let metrics = state.metrics.lock().unwrap(); - let builder = &mut FlatBufferBuilder::new(); let inner = msg::MetricsRes::create( builder, - &msg::MetricsResArgs { - ops_dispatched: metrics.ops_dispatched, - ops_completed: metrics.ops_completed, - bytes_sent_control: metrics.bytes_sent_control, - bytes_sent_data: metrics.bytes_sent_data, - bytes_received: metrics.bytes_received, - }, + &msg::MetricsResArgs::from(&state.metrics), ); ok_future(serialize_response( cmd_id, |