Function resumeH1

github-actions/browserstack/set-browserstack-env.js:6584–6631

(client)

        socket[kIdleSocketValidationTimeout] = setImmediate(() => {
          socket[kIdleSocketValidationTimeout] = null;
          socket[kIdleSocketValidation] = 2;
          if (client[kSocket] === socket && !socket.destroyed) {
            client[kResume]();
          }
        });
      }
      function resumeH1(client) {
        const socket = client[kSocket];
        if (socket && !socket.destroyed) {
          if (client[kSize] === 0) {
            if (!socket[kNoRef] && socket.unref) {
              socket.unref();
              socket[kNoRef] = true;
            }
          } else if (socket[kNoRef] && socket.ref) {
            socket.ref();
            socket[kNoRef] = false;
          }
          if (client[kRunning] === 0 && client[kPending] > 0 && socket[kSocketUsed]) {
            if (socket[kIdleSocketValidation] === 0) {
              scheduleIdleSocketValidation(client, socket);
              socket[kParser].readMore();
              if (socket.destroyed) {
                return;
              }
              return;
            }
            if (socket[kIdleSocketValidation] === 1) {
              socket[kParser].readMore();
              if (socket.destroyed) {
                return;
              }
              return;
            }
          }
          if (client[kRunning] === 0) {
            socket[kParser].readMore();
            if (socket.destroyed) {
              return;
            }
          }
          if (client[kSize] === 0) {
            if (socket[kParser].timeoutType !== TIMEOUT_KEEP_ALIVE) {
              socket[kParser].setTimeout(client[kKeepAliveTimeoutValue], TIMEOUT_KEEP_ALIVE);
            }
          } else if (client[kRunning] > 0 && socket[kParser].statusCode < 200) {
            if (socket[kParser].timeoutType !== TIMEOUT_HEADERS) {
              const request = client[kQueue][client[kRunningIdx]];
              const headersTimeout = request.headersTimeout != null ? request.headersTimeout : client[kHeadersTimeout];
              socket[kParser].setTimeout(headersTimeout, TIMEOUT_HEADERS);
            }