[browser][event-pipe] EventPipe diagnostic server TypeScript for CoreCLR (#126830)

Author: pavelsavara

src/mono/browser/runtime/cwraps.ts

@@ -41,7 +41,7 @@ const fn_signatures: SigLine[] = [
     [true, "mono_wasm_parse_runtime_options", null, ["number", "number"]],
     [true, "mono_wasm_strdup", "number", ["string"]],
     [true, "mono_background_exec", null, []],
-    [true, "mono_wasm_ds_exec", null, []],
+    [true, "SystemJS_ExecuteDiagnosticServerCallback", null, []],
     [true, "mono_wasm_execute_timer", null, []],
     [true, "wasm_load_icu_data", "number", ["number"]],
     [false, "mono_wasm_add_assembly", "number", ["string", "number", "number"]],
@@ -168,7 +168,7 @@ export interface t_Cwraps {
     mono_wasm_strdup(value: string): number;
     mono_wasm_parse_runtime_options(length: number, argv: VoidPtr): void;
     mono_background_exec(): void;
-    mono_wasm_ds_exec(): void;
+    SystemJS_ExecuteDiagnosticServerCallback(): void;
     mono_wasm_execute_timer(): void;
     wasm_load_icu_data(offset: VoidPtr): number;
     mono_wasm_add_assembly(name: string, data: VoidPtr, size: number): number;

src/mono/browser/runtime/diagnostics/client-commands.ts

@@ -66,7 +66,7 @@ export function commandGcHeapDump (options:DiagnosticCommandOptions) {
                     // GC_KEYWORD                            0x0000001
                 ],
                 logLevel: 5,
-                provider_name: "Microsoft-Windows-DotNETRuntime",
+                providerName: "Microsoft-Windows-DotNETRuntime",
                 arguments: null
             },
             ...options.extraProviders || [],
@@ -89,7 +89,7 @@ export function commandCounters (options:DiagnosticCommandOptions) {
             {
                 keywords: [0, Keywords.GCHandle],
                 logLevel: 4,
-                provider_name: "System.Diagnostics.Metrics",
+                providerName: "System.Diagnostics.Metrics",
                 arguments: `SessionId=SHARED;Metrics=System.Runtime;RefreshInterval=${options.intervalSeconds || 1};MaxTimeSeries=1000;MaxHistograms=10;ClientId=${uuidv4()};`,
             },
             ...options.extraProviders || [],
@@ -109,7 +109,7 @@ export function commandSampleProfiler (options:DiagnosticCommandOptions) {
                     0x0000_0000,
                 ],
                 logLevel: 4,
-                provider_name: "Microsoft-DotNETCore-SampleProfiler",
+                providerName: "Microsoft-DotNETCore-SampleProfiler",
                 arguments: null
             },
             ...options.extraProviders || [],
@@ -130,7 +130,7 @@ function commandCollectTracing2 (payload2:PayloadV2) {
     for (const provider of payload2.providers) {
         message.push(...serializeUint64(provider.keywords));
         message.push(...serializeUint32(provider.logLevel));
-        message.push(...serializeString(provider.provider_name));
+        message.push(...serializeString(provider.providerName));
         message.push(...serializeString(provider.arguments));
     }
     return Uint8Array.from(message);
@@ -199,7 +199,7 @@ const enum Keywords {
     Exception = 0x8000,
     //
     // Summary:
-    //     Log events associated with the threadpoo, and other threading events.
+    //     Log events associated with the threadpool, and other threading events.
     Threading = 0x10000,
     //
     // Summary:
@@ -259,7 +259,7 @@ const enum Keywords {
     //     This suppresses NGEN events on V4.0 (where you have NGEN PDBs), but not on V2.0
     //     (which does not know about this bit and also does not have NGEN PDBS).
     // eslint-disable-next-line @typescript-eslint/no-duplicate-enum-values
-    SupressNGen = 0x40000,
+    SuppressNGen = 0x40000,
     //
     // Summary:
     //     TODO document
@@ -427,7 +427,7 @@ function computeCollectTracing2PayloadByteLength (payload2:PayloadV2) {
     for (const provider of payload2.providers) {
         len += 8; // keywords
         len += 4; // level
-        len += computeStringByteLength(provider.provider_name);
+        len += computeStringByteLength(provider.providerName);
         len += computeStringByteLength(provider.arguments);
     }
     return len;
@@ -436,7 +436,7 @@ function computeCollectTracing2PayloadByteLength (payload2:PayloadV2) {
 type ProviderV2 ={
     keywords: [ number, Keywords ],
     logLevel: number,
-    provider_name: string,
+    providerName: string,
     arguments: string|null
 }
 

src/mono/browser/runtime/diagnostics/common.ts

@@ -16,7 +16,7 @@ export function diagnosticServerEventLoop () {
     if (loaderHelpers.is_runtime_running()) {
         try {
             runtimeHelpers.mono_background_exec();// give GC chance to run
-            runtimeHelpers.mono_wasm_ds_exec();
+            runtimeHelpers.SystemJS_ExecuteDiagnosticServerCallback();
             scheduleDiagnosticServerEventLoop(100);
         } catch (ex) {
             loaderHelpers.mono_exit(1, ex);

src/mono/browser/runtime/diagnostics/diagnostics-ws.ts

@@ -27,7 +27,7 @@ class DiagnosticConnectionWS extends DiagnosticConnectionBase implements IDiagno
         };
         ws.addEventListener("open", () => {
             for (const data of this.messagesToSend) {
-                ws.send(data);
+                ws.send(data as any);
             }
             this.messagesToSend = [];
             diagnosticServerEventLoop();
@@ -49,7 +49,7 @@ class DiagnosticConnectionWS extends DiagnosticConnectionBase implements IDiagno
             return super.store(message);
         }
 
-        this.ws!.send(message);
+        this.ws!.send(message as any);
 
         return message.length;
     }

src/mono/browser/runtime/dotnet.d.ts

@@ -718,7 +718,7 @@ type DiagnosticsAPIType = {
 type DiagnosticCommandProviderV2 = {
     keywords: [number, number];
     logLevel: number;
-    provider_name: string;
+    providerName: string;
     arguments: string | null;
 };
 type DiagnosticCommandOptions = {

src/mono/browser/runtime/exports.ts

@@ -44,7 +44,7 @@ function initializeExports (globalObjects: GlobalObjects): RuntimeAPI {
         utf8ToString,
         SystemJS_GetCurrentProcessId,
         mono_background_exec: () => tcwraps.mono_background_exec(),
-        mono_wasm_ds_exec: () => tcwraps.mono_wasm_ds_exec(),
+        SystemJS_ExecuteDiagnosticServerCallback: () => tcwraps.SystemJS_ExecuteDiagnosticServerCallback(),
     };
     if (WasmEnableThreads) {
         rh.dumpThreads = mono_wasm_dump_threads;

src/mono/browser/runtime/types/index.ts

@@ -703,7 +703,7 @@ export type DiagnosticsAPIType = {
 export type DiagnosticCommandProviderV2 = {
     keywords: [ number, number ],
     logLevel: number,
-    provider_name: string,
+    providerName: string,
     arguments: string|null
 }
 

src/mono/browser/runtime/types/internal.ts

@@ -240,7 +240,7 @@ export type RuntimeHelpers = {
     mono_wasm_print_thread_dump: () => void,
     utf8ToString: (ptr: CharPtr) => string,
     mono_background_exec: () => void,
-    mono_wasm_ds_exec: () => void,
+    SystemJS_ExecuteDiagnosticServerCallback: () => void,
     SystemJS_GetCurrentProcessId: () => number,
 }
 

src/mono/mono/eventpipe/ep-rt-mono.h

@@ -1011,7 +1011,7 @@ ep_rt_queue_job (
 	// see if it's done or needs to be scheduled again
 	if (!done) {
 		// self schedule again
-		mono_schedule_ds_job (cb, params);
+		SystemJS_DiagnosticServerQueueJob (cb, params);
 	}
 
 	return true;
@@ -1045,7 +1045,7 @@ ep_rt_thread_sleep (uint64_t ns)
 		g_usleep ((gulong)(ns / 1000));
 		MONO_EXIT_GC_SAFE;
 	}
-#endif
+#endif // PERFTRACING_DISABLE_THREADS
 }
 
 static

src/mono/mono/mini/mini-wasm.c

@@ -453,7 +453,7 @@ G_BEGIN_DECLS
 #ifdef DISABLE_THREADS
 EMSCRIPTEN_KEEPALIVE void mono_wasm_execute_timer (void);
 EMSCRIPTEN_KEEPALIVE void mono_background_exec (void);
-EMSCRIPTEN_KEEPALIVE void mono_wasm_ds_exec (void);
+EMSCRIPTEN_KEEPALIVE void SystemJS_ExecuteDiagnosticServerCallback (void);
 extern void SystemJS_ScheduleTimerImpl (int shortestDueTimeMs);
 #else
 extern void SystemJS_ScheduleSynchronizationContext(MonoNativeThreadId target_thread);