feat(ext/net): Add Conn.setNoDelay and Conn.setKeepAlive

ext/net/01_net.js

@@ -58,6 +58,10 @@
     return core.opAsync("op_dns_resolve", { query, recordType, options });
   }
 
+  function opSetNoDelay(rid, noDelay) {
+    return core.opAsync("op_set_nodelay", { rid, noDelay });
+  }
+
   class Conn {
     #rid = 0;
     #remoteAddr = null;
@@ -95,6 +99,10 @@
     closeWrite() {
       return shutdown(this.rid);
     }
+
+    async setNoDelay(noDelay) {
+      return await opSetNoDelay(this.rid, noDelay);
+    }
   }
 
   class Listener {

ext/net/io.rs

@@ -118,6 +118,17 @@ impl Resource for TcpStreamResource {
   }
 }
 
+impl TcpStreamResource {
+  pub async fn set_nodelay(
+    self: Rc<Self>,
+    nodelay: bool,
+  ) -> Result<(), AnyError> {
+    let wr = self.wr_borrow_mut().await;
+    let stream = wr.as_ref().as_ref();
+    Ok(stream.set_nodelay(nodelay)?)
+  }
+}
+
 #[cfg(unix)]
 pub type UnixStreamResource =
   FullDuplexResource<unix::OwnedReadHalf, unix::OwnedWriteHalf>;

ext/net/lib.deno_net.d.ts

@@ -50,6 +50,8 @@ declare namespace Deno {
     /** Shuts down (`shutdown(2)`) the write side of the connection. Most
      * callers should just use `close()`. */
     closeWrite(): Promise<void>;
+    /** Enable/disable the use of Nagle's algorithm. */
+    setNoDelay(nodelay: boolean): Promise<void>;
   }
 
   // deno-lint-ignore no-empty-interface

ext/net/ops.rs

@@ -55,6 +55,7 @@ pub fn init<P: NetPermissions + 'static>() -> Vec<OpPair> {
     ("op_dgram_recv", op_async(op_dgram_recv)),
     ("op_dgram_send", op_async(op_dgram_send::<P>)),
     ("op_dns_resolve", op_async(op_dns_resolve::<P>)),
+    ("op_set_nodelay", op_async(op_set_nodelay::<P>)),
   ]
 }
 
@@ -665,6 +666,26 @@ where
   Ok(results)
 }
 
+pub async fn op_set_nodelay<NP>(
+  state: Rc<RefCell<OpState>>,
+  args: NoDelayArgs,
+  _: (),
+) -> Result<(), AnyError> {
+  let rid = args.rid;
+  let nodelay = args.nodelay;
+  let resource: Rc<TcpStreamResource> = state
+    .borrow_mut()
+    .resource_table
+    .get::<TcpStreamResource>(rid)?;
+  resource.set_nodelay(nodelay).await
+}
+
+#[derive(Deserialize)]
+pub struct NoDelayArgs {
+  rid: ResourceId,
+  nodelay: bool,
+}
+
 fn rdata_to_return_record(
   ty: RecordType,
 ) -> impl Fn(&RData) -> Option<DnsReturnRecord> {