Add local/remote presence and configurable cloud request execution by NikolayChirkov · Pull Request #550 · aethernetio/aether-client-cpp

NikolayChirkov · 2026-09-03T18:15:15Z

Summary

Add production Local and Remote Presence, together with a configurable per-request cloud execution policy.

Local Presence

Maintain independent Ping schedules per selected server.
Confirm schedules only after Pong.
Use pXX RTT-based prefix retries and continue recovery after the client is classified offline.
Aggregate local connectivity with OR semantics: one reachable selected server is sufficient.
Support runtime interval, receive-window, and RTT-reliability configuration.

Remote Presence

Add asynchronous QueryPeerPresence with ONLINE / OFFLINE / UNKNOWN results.
Query only the peer Personal Cloud; there is no fallback to the observer cloud.
Aggregate authoritative server results with AND semantics: any usable server reporting OFFLINE makes the peer OFFLINE; all usable servers must report ONLINE for ONLINE; incomplete or unavailable evidence is UNKNOWN.
Preserve late responses from earlier attempts.

Cloud request execution policy

Add runtime policy controls for new CloudRequest operations:

fixed-point percentile from aethernet-numeric;
one-byte fixed-point timeout multiplier;
retry count (0..31 retries after the initial attempt);
number of following servers activated as hedged requests.

A soft timeout triggers retry/hedging without Restream. A server is quarantined for no response only after its retry budget is exhausted. Authenticated API errors prove that the server is alive and do not consume the no-response budget.

Additional changes

Add integer/fixed-point percentile selection to StatisticsCounter.
Add Local/Remote Presence and CloudRequest deterministic suites.
Add the remote_presence_live and privileged firewall validation harnesses.
Fix pending response-pool handling after rebasing onto the current object-system split.

Dependency

Depends on aethernetio/aethernet-numeric#14.

Validation

Ordinary client ctest: 26/26 PASS
Local Presence: 37/37 PASS, false OFFLINE: 0
CloudRequest: 16/16 PASS
Remote Presence unit coverage: PASS
Runtime floating point on the percentile/timeout hot path: none
Server repository and wire protocol: unchanged

Live fault tests were not rerun after the final numeric representation correction; the included harnesses remain available for elevated validation.

Confirm receive schedules only after Pong, keep ONLINE until the last confirmed window closes, and retry at 1.5R/0.5R plus a 30ms guard. Co-authored-by: Cursor <cursoragent@cursor.com>

Co-authored-by: Cursor <cursoragent@cursor.com>

…e Pong handling. Keep RX blockers on the current promised window only, project openings from selected RTT, and bound outstanding Ping attempts so a late Pong still confirms the cycle. Privileged firewall tests are opt-in. Co-authored-by: Cursor <cursoragent@cursor.com>

…regation. Local ONLINE uses expected_open + offline_detection_timeout (not rx_window). QueryPeerPresence aggregates get_client_timing over peer/observer usable servers with Offline-any / Online-all / Unknown otherwise. Co-authored-by: Cursor <cursoragent@cursor.com>

…e set. QueryPeerPresence now returns UNKNOWN when the peer Personal Cloud is unavailable, aggregates only over selected_servers() (same Local Presence contract), and re-queries recovered servers fresh. Adds unit coverage and a live A/B harness. Co-authored-by: Cursor <cursoragent@cursor.com>

Replace fixed CloudRequest timeouts and Restream-on-timeout with a runtime snapshot policy (pXX RTT x factor, retry_count, hedge_next_servers), quarantine only after attempt exhaustion, and accept late responses. QueryPeerPresence uses the client policy; Local Presence is unchanged. Co-authored-by: Cursor <cursoragent@cursor.com>

Cap retry_count to 0..31, subscribe once per server to channel_changed, and treat authenticated API errors as alive (no no-response quarantine). Co-authored-by: Cursor <cursoragent@cursor.com>

Isolate peer A via a copied exe firewall block, run 10 Local/Remote fault cycles, and poll S1 quarantine for the one-server CloudRequest path. Co-authored-by: Cursor <cursoragent@cursor.com>

…tor. Keep CloudRequestExecutionPolicy and Local/Remote Presence on top of main. Co-authored-by: Cursor <cursoragent@cursor.com>

Evict until registry and pool both have capacity; raise AE_API_PROTOCOL_MAX_PENDING_RESPONSES to 32. Co-authored-by: Cursor <cursoragent@cursor.com>

Pin ae-numeric to percentile8-tail-v1; replace permille/integer percentile with 1-byte fixed types and integer-only rank math. Co-authored-by: Cursor <cursoragent@cursor.com>

Pin ae-numeric 3ab9e73; store percentile tail as FixedPoint<uint16_t,100> and drop Exponential wire codes from policy/Presence paths. Co-authored-by: Cursor <cursoragent@cursor.com>

BartolomeyKant · 2026-09-04T04:55:21Z

Every ae_action should be as minimal as possible. ae_action is a piece of aether busyness logic.
So for query_peer_presence you must run on already resolved cloud and per individual server.
query_peer_presence must be on lower level of this logic hierarchy.

BartolomeyKant · 2026-09-04T04:57:02Z

+    : ae_context_{ae_context}, client_{&client}, peer_uid_{peer_uid} {
+  static_cast<void>(AllowObserverCloudFallbackForPeerPresence());
+
+  auto cached = client_->cloud_manager()->GetCachedCloud(peer_uid_);


GetCachedCloud are usefull if you only need cached cloud.
Use GetCloud on every other cases - it also look in the cache first and then make requests for a new cloud.

BartolomeyKant · 2026-09-04T05:03:31Z

+}
+
+Duration QueryPeerPresence::OfflineTimeout() const noexcept {
+  auto policy = client_->connectivity_policy();


do not copy

BartolomeyKant · 2026-09-04T05:04:51Z

+
+Duration QueryPeerPresence::OfflineTimeout() const noexcept {
+  auto policy = client_->connectivity_policy();
+  if (!policy) {


use

if(auto ptr = policy.Load(); ptr) { // use ptr } else { return default }

BartolomeyKant · 2026-09-04T05:13:14Z

+  // keep draining until both the registry and the pool have capacity.
+  auto spins = kMaxPendingResponses * 2U;
+  while ((pending_responses_.full() ||
+          pending_response_pool_.available() == 0U) &&


available() == 0U literally means full()

BartolomeyKant · 2026-09-04T05:27:39Z

-  std::size_t max_retries_;
-  Duration request_timeout_;
-  TaskSubscription task_sub_;
+  // Snapshot at construction ? runtime policy changes do not affect this op.


why do request policy may be changed during runtime?

BartolomeyKant · 2026-09-04T05:43:26Z

  void Restream();

+  /**
+   * \brief Quarantine a server after CloudRequest response-retry exhaustion.


Quarantine should be only on server connection failure. What's why Restream is called on request failed. Restream - means something might be wrong with stream and must be fixed.
For server connection this means, probably, we can't be sure if this channel is working and try the next is a good idea. Or if we are sure this channel worked or if we tried all channels in a list, gave up and emit server error. Server error means there is nothing we can do on our level right now, it means highly likely the server doesn't work right now.

BartolomeyKant · 2026-09-04T05:48:26Z

+   * compile-time template overload. Integer-only rank (no float/ceil).
+   */
+  [[nodiscard]] TValue PercentileValue(std::size_t percentile) const {
+    assert(percentile <= 100);


You forget about assert comment!

BartolomeyKant · 2026-09-04T06:57:08Z

+  /**
+   * \brief Percentile accessor. Rank uses integer/fixed tail math only.
+   */
+  [[nodiscard]] TValue PercentileValue(Percentile percentile) const {


Why do we need a special Percentile type?
We can make this function template
template parameter T must be comparable to 100 and 0 must be multiplied by size_t and divided by 100.

NikolayChirkov and others added 12 commits September 2, 2026 16:02

Add per-server local presence windows with prefix retries.

f34dc7f

Confirm receive schedules only after Pong, keep ONLINE until the last confirmed window closes, and retry at 1.5R/0.5R plus a 30ms guard. Co-authored-by: Cursor <cursoragent@cursor.com>

Add 1s/1s local presence timings and a Windows Firewall live test.

2a2f523

Co-authored-by: Cursor <cursoragent@cursor.com>

Fix CloudRequestExecutionPolicy edge cases before merge.

60f7e42

Cap retry_count to 0..31, subscribe once per server to channel_changed, and treat authenticated API errors as alive (no no-response quarantine). Co-authored-by: Cursor <cursoragent@cursor.com>

Add multi-process elevated fault/recovery live harness.

f6559e8

Isolate peer A via a copied exe firewall block, run 10 Local/Remote fault cycles, and poll S1 quarantine for the one-server CloudRequest path. Co-authored-by: Cursor <cursoragent@cursor.com>

Merge origin/main: aether-objects external repo + stdexec cloud refac…

e0646d6

…tor. Keep CloudRequestExecutionPolicy and Local/Remote Presence on top of main. Co-authored-by: Cursor <cursoragent@cursor.com>

Fix pending response pool exhaustion under concurrent API calls.

072fe00

Evict until registry and pool both have capacity; raise AE_API_PROTOCOL_MAX_PENDING_RESPONSES to 32. Co-authored-by: Cursor <cursoragent@cursor.com>

Migrate CloudRequest/Presence to Percentile8 and TimeoutFactor8.

9e92335

Pin ae-numeric to percentile8-tail-v1; replace permille/integer percentile with 1-byte fixed types and integer-only rank math. Co-authored-by: Cursor <cursoragent@cursor.com>

Migrate Percentile8 to 16-bit FixedPoint Percentile.

0b0e3b5

Pin ae-numeric 3ab9e73; store percentile tail as FixedPoint<uint16_t,100> and drop Exponential wire codes from policy/Presence paths. Co-authored-by: Cursor <cursoragent@cursor.com>

NikolayChirkov requested a review from BartolomeyKant September 3, 2026 18:15

BartolomeyKant requested changes Sep 4, 2026

View reviewed changes

BartolomeyKant assigned NikolayChirkov Sep 4, 2026

Navigation Menu

Uh oh!

Add local/remote presence and configurable cloud request execution - #550

Add local/remote presence and configurable cloud request execution#550
NikolayChirkov wants to merge 12 commits into
mainfrom
feature/percentile8-policy-v1

NikolayChirkov commented Sep 3, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

BartolomeyKant Sep 4, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

Uh oh!

Conversation

NikolayChirkov commented Sep 3, 2026

Summary

Local Presence

Remote Presence

Cloud request execution policy

Additional changes

Dependency

Validation

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants