CDRIVER-6080 track client streams in connection counting tests

.evergreen/scripts/run-tests.sh

@@ -110,7 +110,12 @@ fi
 
 # Sanitizer environment variables.
 export ASAN_OPTIONS="detect_leaks=1 abort_on_error=1 symbolize=1"
-export ASAN_SYMBOLIZER_PATH="/opt/mongodbtoolchain/v3/bin/llvm-symbolizer"
+export ASAN_SYMBOLIZER_PATH
+if command -v "/opt/mongodbtoolchain/v4/bin/llvm-symbolizer" > /dev/null; then
+  ASAN_SYMBOLIZER_PATH="/opt/mongodbtoolchain/v4/bin/llvm-symbolizer"
+elif command -v "/opt/mongodbtoolchain/v3/bin/llvm-symbolizer" > /dev/null; then
+  ASAN_SYMBOLIZER_PATH="/opt/mongodbtoolchain/v3/bin/llvm-symbolizer"
+fi
 export TSAN_OPTIONS="suppressions=.tsan-suppressions"
 
 ubsan_opts=(

src/libmongoc/CMakeLists.txt

@@ -1032,6 +1032,7 @@ set (test-libmongoc-sources
    ${PROJECT_SOURCE_DIR}/tests/mock_server/mock-server.c
    ${PROJECT_SOURCE_DIR}/tests/mock_server/request.c
    ${PROJECT_SOURCE_DIR}/tests/mock_server/sync-queue.c
+   ${PROJECT_SOURCE_DIR}/tests/stream-tracker.c
    ${PROJECT_SOURCE_DIR}/tests/test-conveniences.c
    ${PROJECT_SOURCE_DIR}/tests/test-happy-eyeballs.c
    ${PROJECT_SOURCE_DIR}/tests/test-libmongoc.c

src/libmongoc/tests/TestSuite.c

@@ -1232,35 +1232,3 @@ test_bulkwriteexception_str(const mongoc_bulkwriteexception_t *bwe)
                   tmp_json(mongoc_bulkwriteexception_writeconcernerrors(bwe)),
                   tmp_json(mongoc_bulkwriteexception_errorreply(bwe)));
 }
-
-int32_t
-get_current_connection_count(const char *host_and_port)
-{
-   char *uri_str = bson_strdup_printf("mongodb://%s", host_and_port);
-   char *uri_str_with_auth = test_framework_add_user_password_from_env(uri_str);
-   mongoc_client_t *client = mongoc_client_new(uri_str_with_auth);
-   test_framework_set_ssl_opts(client);
-   bson_t *cmd = BCON_NEW("serverStatus", BCON_INT32(1));
-   bson_t reply;
-   bson_error_t error;
-   bool ok = mongoc_client_command_simple(client, "admin", cmd, NULL, &reply, &error);
-   if (!ok) {
-      printf("serverStatus failed: %s\n", error.message);
-      abort();
-   }
-   int32_t conns;
-   // Get `connections.current` from the reply.
-   {
-      bson_iter_t iter;
-      BSON_ASSERT(bson_iter_init_find(&iter, &reply, "connections"));
-      BSON_ASSERT(bson_iter_recurse(&iter, &iter));
-      BSON_ASSERT(bson_iter_find(&iter, "current"));
-      conns = bson_iter_int32(&iter);
-   }
-   bson_destroy(&reply);
-   bson_destroy(cmd);
-   mongoc_client_destroy(client);
-   bson_free(uri_str_with_auth);
-   bson_free(uri_str);
-   return conns;
-}

src/libmongoc/tests/TestSuite.h

@@ -623,43 +623,6 @@ test_bulkwriteexception_str(const mongoc_bulkwriteexception_t *bwe);
    } else                                                                 \
       (void)0
 
-// `get_current_connection_count` returns the server reported connection count.
-int32_t
-get_current_connection_count(const char *host_and_port);
-
-#define ASSERT_CONN_COUNT(host, expect)                          \
-   if (1) {                                                      \
-      int32_t _got = get_current_connection_count(host);         \
-      if (_got != expect) {                                      \
-         test_error("Got unexpected connection count to %s:\n"   \
-                    "  Expected %" PRId32 ", got %" PRId32 "\n", \
-                    host,                                        \
-                    expect,                                      \
-                    _got);                                       \
-      }                                                          \
-   } else                                                        \
-      (void)0
-
-#define ASSERT_EVENTUAL_CONN_COUNT(host, expect)                                  \
-   if (1) {                                                                       \
-      int64_t _start = bson_get_monotonic_time();                                 \
-      while (true) {                                                              \
-         int32_t _got = get_current_connection_count(host);                       \
-         if (_got == expect) {                                                    \
-            break;                                                                \
-         }                                                                        \
-         int64_t _now = bson_get_monotonic_time();                                \
-         if (_now - _start > 5 * 1000 * 1000 /* five seconds */) {                \
-            test_error("Timed out waiting for expected connection count to %s:\n" \
-                       "  Expected %" PRId32 ", got %" PRId32 "\n",               \
-                       host,                                                      \
-                       expect,                                                    \
-                       _got);                                                     \
-         }                                                                        \
-      }                                                                           \
-   } else                                                                         \
-      (void)0
-
 #define MAX_TEST_NAME_LENGTH 500
 #define MAX_TEST_CHECK_FUNCS 10