summaryrefslogtreecommitdiff
path: root/runtime
diff options
context:
space:
mode:
Diffstat (limited to 'runtime')
-rw-r--r--runtime/js/30_net.js19
-rw-r--r--runtime/js/90_deno_ns.js1
-rw-r--r--runtime/ops/net.rs10
3 files changed, 3 insertions, 27 deletions
diff --git a/runtime/js/30_net.js b/runtime/js/30_net.js
index 1a5f5116d..db00f5a2b 100644
--- a/runtime/js/30_net.js
+++ b/runtime/js/30_net.js
@@ -5,19 +5,8 @@
const { errors } = window.__bootstrap.errors;
const { read, write } = window.__bootstrap.io;
- const ShutdownMode = {
- // See http://man7.org/linux/man-pages/man2/shutdown.2.html
- // Corresponding to SHUT_RD, SHUT_WR, SHUT_RDWR
- 0: "Read",
- 1: "Write",
- 2: "ReadWrite",
- Read: 0, // TODO: nonsense, remove me.
- Write: 1,
- ReadWrite: 2, // unused
- };
-
- function shutdown(rid, how) {
- return core.jsonOpAsync("op_shutdown", { rid, how });
+ function shutdown(rid) {
+ return core.jsonOpAsync("op_shutdown", { rid });
}
function opAccept(rid, transport) {
@@ -78,9 +67,8 @@
core.close(this.rid);
}
- // TODO(lucacasonato): make this unavailable in stable
closeWrite() {
- shutdown(this.rid, ShutdownMode.Write);
+ shutdown(this.rid);
}
}
@@ -221,7 +209,6 @@
opListen,
Listener,
shutdown,
- ShutdownMode,
Datagram,
};
})(this);
diff --git a/runtime/js/90_deno_ns.js b/runtime/js/90_deno_ns.js
index 7cc7b543b..c4205a1a9 100644
--- a/runtime/js/90_deno_ns.js
+++ b/runtime/js/90_deno_ns.js
@@ -111,7 +111,6 @@
applySourceMap: __bootstrap.errorStack.opApplySourceMap,
formatDiagnostics: __bootstrap.errorStack.opFormatDiagnostics,
shutdown: __bootstrap.net.shutdown,
- ShutdownMode: __bootstrap.net.ShutdownMode,
listen: __bootstrap.netUnstable.listen,
connect: __bootstrap.netUnstable.connect,
listenDatagram: __bootstrap.netUnstable.listenDatagram,
diff --git a/runtime/ops/net.rs b/runtime/ops/net.rs
index dea7ffe51..caf1ef0d3 100644
--- a/runtime/ops/net.rs
+++ b/runtime/ops/net.rs
@@ -24,7 +24,6 @@ use deno_core::ZeroCopyBuf;
use serde::Deserialize;
use std::borrow::Cow;
use std::cell::RefCell;
-use std::net::Shutdown;
use std::net::SocketAddr;
use std::rc::Rc;
use tokio::io::AsyncWriteExt;
@@ -331,7 +330,6 @@ async fn op_connect(
#[derive(Deserialize)]
struct ShutdownArgs {
rid: i32,
- how: i32,
}
async fn op_shutdown(
@@ -344,14 +342,6 @@ async fn op_shutdown(
let args: ShutdownArgs = serde_json::from_value(args)?;
let rid = args.rid as u32;
- let how = args.how;
-
- // TODO(bartlomieju): no longer needed after Tokio 1.0 upgrade
- let _shutdown_mode = match how {
- 0 => Shutdown::Read, // TODO: nonsense, remove me.
- 1 => Shutdown::Write,
- _ => unimplemented!(),
- };
let resource = state
.borrow()