summaryrefslogtreecommitdiff
path: root/src/ops.rs
diff options
context:
space:
mode:
authorF001 <changchun.fan@qq.com>2018-11-30 11:03:00 +0800
committerRyan Dahl <ry@tinyclouds.org>2018-11-29 19:03:00 -0800
commitb6fda735ee0106b72500d927b9695a27ecd519f3 (patch)
tree25b176f3120b1fd7387cc350e86cb24b82eea15e /src/ops.rs
parent286e76d8c1da135cf159218fe3808fda7405301a (diff)
Replace mutex by atomics (#1238)
Diffstat (limited to 'src/ops.rs')
-rw-r--r--src/ops.rs11
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,