From 91ca58fb2639a791237570e4f1fadda9eeb8c0bc Mon Sep 17 00:00:00 2001 From: Divy Srivastava Date: Fri, 19 Mar 2021 22:55:37 +0530 Subject: chores: enforce type ResourceId across codebase (#9837) --- core/examples/http_bench_bin_ops.rs | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) (limited to 'core') diff --git a/core/examples/http_bench_bin_ops.rs b/core/examples/http_bench_bin_ops.rs index cde25800c..bc4ca4dce 100644 --- a/core/examples/http_bench_bin_ops.rs +++ b/core/examples/http_bench_bin_ops.rs @@ -12,6 +12,7 @@ use deno_core::Op; use deno_core::OpState; use deno_core::RcRef; use deno_core::Resource; +use deno_core::ResourceId; use deno_core::ZeroCopyBuf; use futures::future::FutureExt; use futures::future::TryFuture; @@ -122,7 +123,7 @@ impl From for TcpStream { #[derive(Copy, Clone, Debug, PartialEq)] struct Record { promise_id: u32, - rid: u32, + rid: ResourceId, result: i32, } @@ -162,7 +163,7 @@ fn create_js_runtime() -> JsRuntime { fn op_listen( state: &mut OpState, - _rid: u32, + _rid: ResourceId, _bufs: &mut [ZeroCopyBuf], ) -> Result { debug!("listen"); @@ -176,7 +177,7 @@ fn op_listen( fn op_close( state: &mut OpState, - rid: u32, + rid: ResourceId, _bufs: &mut [ZeroCopyBuf], ) -> Result { debug!("close rid={}", rid); @@ -189,7 +190,7 @@ fn op_close( async fn op_accept( state: Rc>, - rid: u32, + rid: ResourceId, _bufs: BufVec, ) -> Result { debug!("accept rid={}", rid); @@ -206,7 +207,7 @@ async fn op_accept( async fn op_read( state: Rc>, - rid: u32, + rid: ResourceId, mut bufs: BufVec, ) -> Result { assert_eq!(bufs.len(), 1, "Invalid number of arguments"); @@ -222,7 +223,7 @@ async fn op_read( async fn op_write( state: Rc>, - rid: u32, + rid: ResourceId, bufs: BufVec, ) -> Result { assert_eq!(bufs.len(), 1, "Invalid number of arguments"); -- cgit v1.2.3