diff options
| author | Ryan Dahl <ry@tinyclouds.org> | 2019-03-18 19:06:48 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-03-18 19:06:48 -0400 |
| commit | 34a2aa4de6cfe334cf0d26620d244d5c66a976a4 (patch) | |
| tree | bda898bc079aa7abb5c1d8c2406b1cbd07a87f49 /src/ops.rs | |
| parent | e98d3391de9abf6be0c2be18651611c66eec4073 (diff) | |
Remove Eager read, write, accept (#1959)
Removing this reduces tail latency in test/http_bench.ts by half.
Diffstat (limited to 'src/ops.rs')
| -rw-r--r-- | src/ops.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/ops.rs b/src/ops.rs index 33a7d7cdd..c6b9fe84a 100644 --- a/src/ops.rs +++ b/src/ops.rs @@ -18,6 +18,7 @@ use crate::resources; use crate::resources::table_entries; use crate::resources::Resource; use crate::tokio_util; +use crate::tokio_write; use crate::version; use deno_core::deno_buf; use deno_core::JSError; @@ -918,7 +919,7 @@ fn op_read( match resources::lookup(rid) { None => odd_future(errors::bad_resource()), Some(resource) => { - let op = resources::eager_read(resource, data) + let op = tokio::io::read(resource, data) .map_err(DenoError::from) .and_then(move |(_resource, _buf, nread)| { let builder = &mut FlatBufferBuilder::new(); @@ -956,7 +957,7 @@ fn op_write( match resources::lookup(rid) { None => odd_future(errors::bad_resource()), Some(resource) => { - let op = resources::eager_write(resource, data) + let op = tokio_write::write(resource, data) .map_err(DenoError::from) .and_then(move |(_resource, _buf, nwritten)| { let builder = &mut FlatBufferBuilder::new(); @@ -1551,7 +1552,7 @@ fn op_accept( match resources::lookup(server_rid) { None => odd_future(errors::bad_resource()), Some(server_resource) => { - let op = resources::eager_accept(server_resource) + let op = tokio_util::accept(server_resource) .map_err(DenoError::from) .and_then(move |(tcp_stream, _socket_addr)| { new_conn(cmd_id, tcp_stream) |