3 files changed, 95 insertions, 0 deletions

diff --git a/test/core/util/BUILD b/test/core/util/BUILD
index 886cfddf86..366cf05690 100644
--- a/test/core/util/BUILD
+++ b/test/core/util/BUILD
@@ -51,6 +51,7 @@ grpc_cc_library(
 grpc_cc_library(
     name = "grpc_test_util_base",
     srcs = [
+        "channel_tracing_utils.cc",
         "cmdline.cc",
         "grpc_profiler.cc",
         "histogram.cc",
@@ -69,6 +70,7 @@ grpc_cc_library(
         "trickle_endpoint.cc",
     ],
     hdrs = [
+        "channel_tracing_utils.h",
         "cmdline.h",
         "grpc_profiler.h",
         "histogram.h",
@@ -103,6 +105,8 @@ grpc_cc_library(
     ],
 )
 
+
+
 grpc_cc_library(
     name = "grpc_test_util_unsecure",
     srcs = [],
diff --git a/test/core/util/channel_tracing_utils.cc b/test/core/util/channel_tracing_utils.cc
new file mode 100644
index 0000000000..a2449cc4bd
--- /dev/null
+++ b/test/core/util/channel_tracing_utils.cc
@@ -0,0 +1,60 @@
+/*
+ *
+ * Copyright 2017 gRPC authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+#include <stdlib.h>
+#include <string.h>
+
+#include <grpc/support/log.h>
+#include "src/core/lib/channel/channel_tracer.h"
+#include "src/core/lib/gpr/useful.h"
+#include "src/core/lib/json/json.h"
+
+static grpc_json* get_json_child(grpc_json* parent, const char* key) {
+  GPR_ASSERT(parent != nullptr);
+  for (grpc_json* child = parent->child; child != nullptr;
+       child = child->next) {
+    if (child->key != nullptr && strcmp(child->key, key) == 0) return child;
+  }
+  return nullptr;
+}
+
+void validate_json_array_size(grpc_json* json, const char* key,
+                              size_t expected_size) {
+  grpc_json* arr = get_json_child(json, key);
+  GPR_ASSERT(arr);
+  GPR_ASSERT(arr->type == GRPC_JSON_ARRAY);
+  size_t count = 0;
+  for (grpc_json* child = arr->child; child != nullptr; child = child->next) {
+    ++count;
+  }
+  GPR_ASSERT(count == expected_size);
+}
+
+void validate_channel_trace_data(grpc_json* json,
+                                 size_t num_events_logged_expected,
+                                 size_t actual_num_events_expected) {
+  GPR_ASSERT(json);
+  grpc_json* num_events_logged_json = get_json_child(json, "num_events_logged");
+  GPR_ASSERT(num_events_logged_json);
+  grpc_json* start_time = get_json_child(json, "creation_time");
+  GPR_ASSERT(start_time);
+  size_t num_events_logged =
+      (size_t)strtol(num_events_logged_json->value, nullptr, 0);
+  GPR_ASSERT(num_events_logged == num_events_logged_expected);
+  validate_json_array_size(json, "events", actual_num_events_expected);
+}
diff --git a/test/core/util/channel_tracing_utils.h b/test/core/util/channel_tracing_utils.h
new file mode 100644
index 0000000000..fc04d8bae6
--- /dev/null
+++ b/test/core/util/channel_tracing_utils.h
@@ -0,0 +1,31 @@
+/*
+ *
+ * Copyright 2017 gRPC authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+#ifndef GRPC_TEST_CORE_UTIL_CHANNEL_TRACING_UTILS_H
+#define GRPC_TEST_CORE_UTIL_CHANNEL_TRACING_UTILS_H
+
+#include "src/core/lib/channel/channel_tracer.h"
+
+void validate_json_array_size(grpc_json* json, const char* key,
+                              size_t expected_size);
+
+void validate_channel_trace_data(grpc_json* json,
+                                 size_t num_events_logged_expected,
+                                 size_t actual_num_events_expected);
+
+#endif /* GRPC_TEST_CORE_UTIL_CHANNEL_TRACING_UTILS_H */