Skip to content

Commit

Permalink
add counters reader
Browse files Browse the repository at this point in the history
  • Loading branch information
JPWatson committed Sep 4, 2016
1 parent 9a4ddc4 commit 52c8ddc
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 1 deletion.
2 changes: 1 addition & 1 deletion RELEASE.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
#### Port
Aeron.NET has been ported against Java version:
- Agrona: 8a6cee2
- Aeron: 649ec42
- Aeron: 6b52dd9
10 changes: 10 additions & 0 deletions src/Adaptive.Aeron/Aeron.cs
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
using Adaptive.Agrona.Concurrent;
using Adaptive.Agrona.Concurrent.Broadcast;
using Adaptive.Agrona.Concurrent.RingBuffer;
using Adaptive.Agrona.Concurrent.Status;
using Adaptive.Agrona.Util;

namespace Adaptive.Aeron
Expand Down Expand Up @@ -133,6 +134,15 @@ public Subscription AddSubscription(string channel, int streamId)
return _conductor.AddSubscription(channel, streamId);
}

/// <summary>
/// Create and returns a <see cref="CountersReader"/> for the Aeron media driver counters.
/// </summary>
/// <returns> new <see cref="CountersReader"/> for the Aeron media driver in use.</returns>
public CountersReader CountersReader()
{
return new CountersReader(_ctx.CountersMetaDataBuffer(), _ctx.CountersValuesBuffer());
}

private Aeron Start()
{
AgentRunner.StartOnThread(_conductorRunner, _ctx.ThreadFactory());
Expand Down

0 comments on commit 52c8ddc

Please sign in to comment.