summaryrefslogtreecommitdiff
path: root/runtime/ops/signal.rs
diff options
context:
space:
mode:
authorcrowlKats <13135287+crowlKats@users.noreply.github.com>2021-03-18 19:42:01 +0100
committerGitHub <noreply@github.com>2021-03-18 14:42:01 -0400
commitb59151f39eba2ddcfe9448dfecd043046d7a0852 (patch)
tree06591bbf8e26910f808f20c4bbeaf9eaf764339c /runtime/ops/signal.rs
parent62716422b9f57b11f3a0afb01f5011b63702226d (diff)
move runtime ops to serde ops (#9828)
Diffstat (limited to 'runtime/ops/signal.rs')
-rw-r--r--runtime/ops/signal.rs16
1 files changed, 6 insertions, 10 deletions
diff --git a/runtime/ops/signal.rs b/runtime/ops/signal.rs
index 2f5383525..86eb91c1b 100644
--- a/runtime/ops/signal.rs
+++ b/runtime/ops/signal.rs
@@ -11,8 +11,6 @@ use std::rc::Rc;
#[cfg(unix)]
use deno_core::error::bad_resource_id;
#[cfg(unix)]
-use deno_core::serde_json;
-#[cfg(unix)]
use deno_core::serde_json::json;
#[cfg(unix)]
use deno_core::AsyncRefCell;
@@ -58,24 +56,24 @@ impl Resource for SignalStreamResource {
#[cfg(unix)]
#[derive(Deserialize)]
-struct BindSignalArgs {
+pub struct BindSignalArgs {
signo: i32,
}
#[cfg(unix)]
#[derive(Deserialize)]
-struct SignalArgs {
+pub struct SignalArgs {
rid: i32,
}
#[cfg(unix)]
+#[allow(clippy::unnecessary_wraps)]
fn op_signal_bind(
state: &mut OpState,
- args: Value,
+ args: BindSignalArgs,
_zero_copy: &mut [ZeroCopyBuf],
) -> Result<Value, AnyError> {
super::check_unstable(state, "Deno.signal");
- let args: BindSignalArgs = serde_json::from_value(args)?;
let resource = SignalStreamResource {
signal: AsyncRefCell::new(
signal(SignalKind::from_raw(args.signo)).expect(""),
@@ -91,11 +89,10 @@ fn op_signal_bind(
#[cfg(unix)]
async fn op_signal_poll(
state: Rc<RefCell<OpState>>,
- args: Value,
+ args: SignalArgs,
_zero_copy: BufVec,
) -> Result<Value, AnyError> {
super::check_unstable2(&state, "Deno.signal");
- let args: SignalArgs = serde_json::from_value(args)?;
let rid = args.rid as u32;
let resource = state
@@ -115,11 +112,10 @@ async fn op_signal_poll(
#[cfg(unix)]
pub fn op_signal_unbind(
state: &mut OpState,
- args: Value,
+ args: SignalArgs,
_zero_copy: &mut [ZeroCopyBuf],
) -> Result<Value, AnyError> {
super::check_unstable(state, "Deno.signal");
- let args: SignalArgs = serde_json::from_value(args)?;
let rid = args.rid as u32;
state
.resource_table