1 files changed, 95 insertions, 0 deletions
diff --git a/test/parallel/test-http2-perf_hooks.js b/test/parallel/test-http2-perf_hooks.js
new file mode 100644
index 0000000000..f2ef29cec2
--- /dev/null
+++ b/test/parallel/test-http2-perf_hooks.js
@@ -0,0 +1,95 @@
+'use strict';
+
+const common = require('../common');
+if (!common.hasCrypto)
+  common.skip('missing crypto');
+const assert = require('assert');
+const h2 = require('http2');
+
+const { PerformanceObserver } = require('perf_hooks');
+
+const obs = new PerformanceObserver((items) => {
+  const entry = items.getEntries()[0];
+  assert.strictEqual(entry.entryType, 'http2');
+  assert.strictEqual(typeof entry.startTime, 'number');
+  assert.strictEqual(typeof entry.duration, 'number');
+  switch (entry.name) {
+    case 'Http2Session':
+      assert.strictEqual(typeof entry.pingRTT, 'number');
+      assert.strictEqual(typeof entry.streamAverageDuration, 'number');
+      assert.strictEqual(typeof entry.streamCount, 'number');
+      assert.strictEqual(typeof entry.framesReceived, 'number');
+      switch (entry.type) {
+        case 'server':
+          assert.strictEqual(entry.streamCount, 1);
+          assert.strictEqual(entry.framesReceived, 5);
+          break;
+        case 'client':
+          assert.strictEqual(entry.streamCount, 1);
+          assert.strictEqual(entry.framesReceived, 8);
+          break;
+        default:
+          assert.fail('invalid Http2Session type');
+      }
+      break;
+    case 'Http2Stream':
+      assert.strictEqual(typeof entry.timeToFirstByte, 'number');
+      assert.strictEqual(typeof entry.timeToFirstHeader, 'number');
+      break;
+    default:
+      assert.fail('invalid entry name');
+  }
+});
+obs.observe({ entryTypes: ['http2'] });
+
+const body =
+  '<html><head></head><body><h1>this is some data</h2></body></html>';
+
+const server = h2.createServer();
+
+// we use the lower-level API here
+server.on('stream', common.mustCall(onStream));
+
+function onStream(stream, headers, flags) {
+  assert.strictEqual(headers[':scheme'], 'http');
+  assert.ok(headers[':authority']);
+  assert.strictEqual(headers[':method'], 'GET');
+  assert.strictEqual(flags, 5);
+  stream.respond({
+    'content-type': 'text/html',
+    ':status': 200
+  });
+  stream.write(body.slice(0, 20));
+  stream.end(body.slice(20));
+}
+
+server.on('session', common.mustCall((session) => {
+  session.ping(common.mustCall());
+}));
+
+server.listen(0);
+
+server.on('listening', common.mustCall(() => {
+
+  const client = h2.connect(`http://localhost:${server.address().port}`);
+
+  client.on('connect', common.mustCall(() => {
+    client.ping(common.mustCall());
+  }));
+
+  const req = client.request();
+
+  req.on('response', common.mustCall());
+
+  let data = '';
+  req.setEncoding('utf8');
+  req.on('data', (d) => data += d);
+  req.on('end', common.mustCall(() => {
+    assert.strictEqual(body, data);
+  }));
+  req.on('close', common.mustCall(() => {
+    client.close();
+    server.close();
+  }));
+
+}));