Function connect

github-actions/bazel/configure-remote/configure-remote.js:8101–8211

(client)

            });
          });
        }
      };
      var createRedirectInterceptor = require_redirect_interceptor();
      function onError(client, err) {
        if (client[kRunning] === 0 && err.code !== "UND_ERR_INFO" && err.code !== "UND_ERR_SOCKET") {
          assert(client[kPendingIdx] === client[kRunningIdx]);
          const requests = client[kQueue].splice(client[kRunningIdx]);
          for (let i = 0; i < requests.length; i++) {
            const request = requests[i];
            util.errorRequest(client, request, err);
          }
          assert(client[kSize] === 0);
        }
      }
      function connect(client) {
        return __async(this, null, function* () {
          var _a, _b, _c;
          assert(!client[kConnecting]);
          assert(!client[kHTTPContext]);
          let { host, hostname, protocol, port } = client[kUrl];
          if (hostname[0] === "[") {
            const idx = hostname.indexOf("]");
            assert(idx !== -1);
            const ip = hostname.substring(1, idx);
            assert(net.isIP(ip));
            hostname = ip;
          }
          client[kConnecting] = true;
          if (channels.beforeConnect.hasSubscribers) {
            channels.beforeConnect.publish({
              connectParams: {
                host,
                hostname,
                protocol,
                port,
                version: (_a = client[kHTTPContext]) == null ? void 0 : _a.version,
                servername: client[kServerName],
                localAddress: client[kLocalAddress]
              },
              connector: client[kConnector]
            });
          }
          try {
            const socket = yield new Promise((resolve2, reject) => {
              client[kConnector]({
                host,
                hostname,
                protocol,
                port,
                servername: client[kServerName],
                localAddress: client[kLocalAddress]
              }, (err, socket2) => {
                if (err) {
                  reject(err);
                } else {
                  resolve2(socket2);
                }
              });