diff options
Diffstat (limited to 'cli/tests/unit')
-rw-r--r-- | cli/tests/unit/net_test.ts | 99 | ||||
-rw-r--r-- | cli/tests/unit/tls_test.ts | 51 |
2 files changed, 150 insertions, 0 deletions
diff --git a/cli/tests/unit/net_test.ts b/cli/tests/unit/net_test.ts index eeaada05e..d2beb5566 100644 --- a/cli/tests/unit/net_test.ts +++ b/cli/tests/unit/net_test.ts @@ -906,3 +906,102 @@ Deno.test({ ); listener.close(); }); + +Deno.test({ permissions: { net: true } }, async function netTcpReuseAddr() { + const listener1 = Deno.listen({ + hostname: "127.0.0.1", + port: 3500, + }); + listener1.accept().then( + (conn) => { + conn.close(); + }, + ); + + const conn1 = await Deno.connect({ hostname: "127.0.0.1", port: 3500 }); + const buf1 = new Uint8Array(1024); + await conn1.read(buf1); + listener1.close(); + conn1.close(); + + const listener2 = Deno.listen({ + hostname: "127.0.0.1", + port: 3500, + }); + + listener2.accept().then( + (conn) => { + conn.close(); + }, + ); + + const conn2 = await Deno.connect({ hostname: "127.0.0.1", port: 3500 }); + const buf2 = new Uint8Array(1024); + await conn2.read(buf2); + + listener2.close(); + conn2.close(); +}); + +Deno.test( + { permissions: { net: true } }, + async function netUdpReuseAddr() { + const sender = Deno.listenDatagram({ + port: 4002, + transport: "udp", + }); + const listener1 = Deno.listenDatagram({ + port: 4000, + transport: "udp", + reuseAddress: true, + }); + const listener2 = Deno.listenDatagram({ + port: 4000, + transport: "udp", + reuseAddress: true, + }); + + const sent = new Uint8Array([1, 2, 3]); + await sender.send(sent, listener1.addr); + await Promise.any([listener1.receive(), listener2.receive()]).then( + ([recvd, remote]) => { + assert(remote.transport === "udp"); + assertEquals(recvd.length, 3); + assertEquals(1, recvd[0]); + assertEquals(2, recvd[1]); + assertEquals(3, recvd[2]); + }, + ); + sender.close(); + listener1.close(); + listener2.close(); + }, +); + +Deno.test( + { permissions: { net: true } }, + function netUdpNoReuseAddr() { + let listener1; + try { + listener1 = Deno.listenDatagram({ + port: 4001, + transport: "udp", + reuseAddress: false, + }); + } catch (err) { + assert(err); + assert(err instanceof Deno.errors.AddrInUse); // AddrInUse from previous test + } + + assertThrows(() => { + Deno.listenDatagram({ + port: 4001, + transport: "udp", + reuseAddress: false, + }); + }, Deno.errors.AddrInUse); + if (typeof listener1 !== "undefined") { + listener1.close(); + } + }, +); diff --git a/cli/tests/unit/tls_test.ts b/cli/tests/unit/tls_test.ts index 860965e49..df82f6ef6 100644 --- a/cli/tests/unit/tls_test.ts +++ b/cli/tests/unit/tls_test.ts @@ -1376,3 +1376,54 @@ Deno.test( await Promise.all([server(), startTlsClient()]); }, ); + +Deno.test( + { permissions: { read: false, net: true } }, + async function listenTlsWithReuseAddr() { + const resolvable1 = deferred(); + const hostname = "localhost"; + const port = 3500; + + const listener1 = Deno.listenTls({ hostname, port, cert, key }); + + const response1 = encoder.encode( + "HTTP/1.1 200 OK\r\nContent-Length: 12\r\n\r\nHello World\n", + ); + + listener1.accept().then( + async (conn) => { + await conn.write(response1); + setTimeout(() => { + conn.close(); + resolvable1.resolve(); + }, 0); + }, + ); + + const conn1 = await Deno.connectTls({ hostname, port, caCerts }); + conn1.close(); + listener1.close(); + await resolvable1; + + const resolvable2 = deferred(); + const listener2 = Deno.listenTls({ hostname, port, cert, key }); + const response2 = encoder.encode( + "HTTP/1.1 200 OK\r\nContent-Length: 12\r\n\r\nHello World\n", + ); + + listener2.accept().then( + async (conn) => { + await conn.write(response2); + setTimeout(() => { + conn.close(); + resolvable2.resolve(); + }, 0); + }, + ); + + const conn2 = await Deno.connectTls({ hostname, port, caCerts }); + conn2.close(); + listener2.close(); + await resolvable2; + }, +); |