1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
using System.Collections;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.Diagnostics.Tracing;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.DotNet.RemoteExecutor;
using Xunit;
using Xunit.Abstractions;
namespace System.Net.Sockets.Tests
{
public class TelemetryTest
{
public readonly ITestOutputHelper _output;
public TelemetryTest(ITestOutputHelper output)
{
_output = output;
}
[Fact]
public static void EventSource_ExistsWithCorrectId()
{
Type esType = typeof(Socket).Assembly.GetType("System.Net.Sockets.SocketsTelemetry", throwOnError: true, ignoreCase: false);
Assert.NotNull(esType);
Assert.Equal("System.Net.Sockets", EventSource.GetName(esType));
Assert.Equal(Guid.Parse("d5b2e7d4-b6ec-50ae-7cde-af89427ad21f"), EventSource.GetGuid(esType));
Assert.NotEmpty(EventSource.GenerateManifest(esType, esType.Assembly.Location));
}
[OuterLoop]
[ConditionalFact(typeof(RemoteExecutor), nameof(RemoteExecutor.IsSupported))]
public void EventSource_EventsRaisedAsExpected()
{
RemoteExecutor.Invoke(() =>
{
using (var listener = new TestEventListener("System.Net.Sockets", EventLevel.Verbose, 0.1))
{
var events = new ConcurrentQueue<EventWrittenEventArgs>();
listener.RunWithCallbackAsync(events.Enqueue, async () =>
{
// Invoke several tests to execute code paths while tracing is enabled
await new SendReceiveSync(null).SendRecv_Stream_TCP(IPAddress.Loopback, false).ConfigureAwait(false);
await new SendReceiveSync(null).SendRecv_Stream_TCP(IPAddress.Loopback, true).ConfigureAwait(false);
await new SendReceiveTask(null).SendRecv_Stream_TCP(IPAddress.Loopback, false).ConfigureAwait(false);
await new SendReceiveTask(null).SendRecv_Stream_TCP(IPAddress.Loopback, true).ConfigureAwait(false);
await new SendReceiveEap(null).SendRecv_Stream_TCP(IPAddress.Loopback, false).ConfigureAwait(false);
await new SendReceiveEap(null).SendRecv_Stream_TCP(IPAddress.Loopback, true).ConfigureAwait(false);
await new SendReceiveApm(null).SendRecv_Stream_TCP(IPAddress.Loopback, false).ConfigureAwait(false);
await new SendReceiveApm(null).SendRecv_Stream_TCP(IPAddress.Loopback, true).ConfigureAwait(false);
await new SendReceiveUdpClient().SendToRecvFromAsync_Datagram_UDP_UdpClient(IPAddress.Loopback).ConfigureAwait(false);
await new SendReceiveUdpClient().SendToRecvFromAsync_Datagram_UDP_UdpClient(IPAddress.Loopback).ConfigureAwait(false);
await new NetworkStreamTest().CopyToAsync_AllDataCopied(4096, true).ConfigureAwait(false);
await new NetworkStreamTest().Timeout_ValidData_Roundtrips().ConfigureAwait(false);
await Task.Delay(300).ConfigureAwait(false);
}).Wait();
Assert.DoesNotContain(events, ev => ev.EventId == 0); // errors from the EventSource itself
VerifyEvents(events, "ConnectStart", 10);
VerifyEvents(events, "ConnectStop", 10);
Dictionary<string, double> eventCounters = events.Where(e => e.EventName == "EventCounters").Select(e => (IDictionary<string, object>) e.Payload.Single())
.GroupBy(d => (string)d["Name"], d => (double)d["Mean"], (k, v) => new { Name = k, Value = v.Sum() })
.ToDictionary(p => p.Name, p => p.Value);
VerifyEventCounter("incoming-connections-established", eventCounters);
VerifyEventCounter("outgoing-connections-established", eventCounters);
VerifyEventCounter("bytes-received", eventCounters);
VerifyEventCounter("bytes-sent", eventCounters);
VerifyEventCounter("datagrams-received", eventCounters);
VerifyEventCounter("datagrams-sent", eventCounters);
}
}).Dispose();
}
private static void VerifyEvents(IEnumerable<EventWrittenEventArgs> events, string eventName, int expectedCount)
{
EventWrittenEventArgs[] starts = events.Where(e => e.EventName == eventName).ToArray();
Assert.Equal(expectedCount, starts.Length);
}
private static void VerifyEventCounter(string name, Dictionary<string, double> eventCounters)
{
Assert.True(eventCounters.ContainsKey(name));
Assert.True(eventCounters[name] > 0);
}
}
}
|
