Function createCloseHttp2SessionsByHttp2Server

lib/server.js:403–441

* @param {http2.Http2Server} http2Server * @returns {() => void}

(http2Server)

 * @returns {() => void}
 */
function createCloseHttp2SessionsByHttp2Server (http2Server) {
  /**
   * @type {Set<http2.Http2Session>}
   */
  http2Server[kHttp2ServerSessions] = new Set()

  http2Server.on(class="st">'session', function (session) {
    session.once(class="st">'connect', function () {
      http2Server[kHttp2ServerSessions].add(session)
    })

    session.once(class="st">'close', function () {
      http2Server[kHttp2ServerSessions].delete(session)
    })

    session.once(class="st">'frameError', function (type, code, streamId) {
      if (streamId === 0) {
        class="cm">// The stream ID is 0, which means that the error is related to the session itself.
        class="cm">// If the event is not associated with a stream, the Http2Session will be shut down immediately
        http2Server[kHttp2ServerSessions].delete(session)
      }
    })

    session.once(class="st">'goaway', function () {
      class="cm">// The Http2Session instance will be shut down automatically when the class="st">'goaway' event is emitted.
      http2Server[kHttp2ServerSessions].delete(session)
    })
  })

  return function closeHttp2Sessions () {
    if (http2Server[kHttp2ServerSessions].size === 0) {
      return
    }

    for (const session of http2Server[kHttp2ServerSessions]) {
      session.close()
    }
  }
}