Skip to content

PLAT-1601: port AeronCounters changes for Aeron 1.52.2 (C1) #156

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ablackadaptive wants to merge 1 commit into
base: master
Choose a base branch
from
Open

PLAT-1601: port AeronCounters changes for Aeron 1.52.2 (C1) #156

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 22 additions & 2 deletions src/Adaptive.Aeron/AeronCounters.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -272,10 +272,10 @@ public static class AeronCounters
public const int SYSTEM_COUNTER_ID_STATUS_MESSAGES_REJECTED = 44;

/// <summary>
/// Counter id for failed offers to the async executor proxy.
/// Counter id for failed offers to the native resource agent proxy.
/// </summary>
/// <remarks>Since 1.51.0</remarks>
public const int SYSTEM_COUNTER_ID_ASYNC_EXECUTOR_PROXY_FAILS = 45;
public const int SYSTEM_COUNTER_ID_NATIVE_RESOURCE_AGENT_PROXY_FAILS = 45;

// Client/driver counters

Expand Down Expand Up @@ -1052,6 +1052,26 @@ public static class AeronCounters
/// </summary>
public const int SEQUENCER_REPLAY_INDEX_INITIAL_SEQUENCE_LOG_POSITION_COUNTER_TYPE_ID = 525;

/// <summary>
/// Counter id used for keeping track of the max duty cycle time of the replay-service agent.
/// </summary>
public const int SEQUENCER_REPLAY_SERVICE_MAX_CYCLE_TIME_COUNTER_TYPE_ID = 545;

/// <summary>
/// Counter id used for keeping track of the count of cycle time threshold exceeded of a replay-service agent.
/// </summary>
public const int SEQUENCER_REPLAY_SERVICE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID = 546;

/// <summary>
/// Counter id used for keeping track of the max duty cycle time of the snapshot-service agent.
/// </summary>
public const int SEQUENCER_SNAPSHOT_SERVICE_MAX_CYCLE_TIME_COUNTER_TYPE_ID = 547;

/// <summary>
/// Counter id used for keeping track of the count of cycle time threshold exceeded of a snapshot-service agent.
/// </summary>
public const int SEQUENCER_SNAPSHOT_SERVICE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID = 548;

/// <summary>
/// Checks that the counter specified by {@code counterId} has the counterTypeId that matches the specified
/// value. If not it will throw a <seealso cref="ConfigurationException"/> .
Expand Down
6 changes: 5 additions & 1 deletion src/Adaptive.Aeron/PublicAPI.Unshipped.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,11 @@ const Adaptive.Aeron.AeronCounters.SELECTOR_CLIENTS_COUNTER_TYPE_ID = 300 -> int
const Adaptive.Aeron.AeronCounters.SELECTOR_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID = 303 -> int
const Adaptive.Aeron.AeronCounters.SELECTOR_MAX_CYCLE_TIME_TYPE_ID = 302 -> int
const Adaptive.Aeron.AeronCounters.SELECTOR_SUBSCRIPTIONS_COUNTER_TYPE_ID = 301 -> int
const Adaptive.Aeron.AeronCounters.SYSTEM_COUNTER_ID_ASYNC_EXECUTOR_PROXY_FAILS = 45 -> int
const Adaptive.Aeron.AeronCounters.SYSTEM_COUNTER_ID_NATIVE_RESOURCE_AGENT_PROXY_FAILS = 45 -> int
const Adaptive.Aeron.AeronCounters.SEQUENCER_REPLAY_SERVICE_MAX_CYCLE_TIME_COUNTER_TYPE_ID = 545 -> int
const Adaptive.Aeron.AeronCounters.SEQUENCER_REPLAY_SERVICE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID = 546 -> int
const Adaptive.Aeron.AeronCounters.SEQUENCER_SNAPSHOT_SERVICE_MAX_CYCLE_TIME_COUNTER_TYPE_ID = 547 -> int
const Adaptive.Aeron.AeronCounters.SEQUENCER_SNAPSHOT_SERVICE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID = 548 -> int
const Adaptive.Aeron.AeronCounters.SYSTEM_COUNTER_ID_STATUS_MESSAGES_REJECTED = 44 -> int
const Adaptive.Aeron.AeronCounters.VMA_RX_DATA_COPY_BYTES_TYPE_ID = 63 -> int
const Adaptive.Aeron.AeronCounters.VMA_RX_ZERO_COPY_BYTES_TYPE_ID = 62 -> int
Expand Down
Loading