Add local/remote presence and configurable cloud request execution

CMakeLists.txt

@@ -62,6 +62,7 @@ option(AE_BUILD_TOOLS "Build tools" ${AE_ROOT_PORJECT})
 option(AE_BUILD_EXAMPLES "Build examples" ${AE_ROOT_PORJECT})
 option(AE_BUILD_TESTS "Build tests" ${AE_ROOT_PORJECT})
 option(AE_BUILD_ANDROID_SMOKE "Build Android NDK smoke shared library and runner" Off)
+option(AE_ENABLE_PRIVILEGED_NETWORK_TESTS "Enable Administrator/network live tests" Off)
 option(AE_ADDRESS_SANITIZE "Enable address sanitizer" Off)
 
 set(UTM_ID "0" CACHE STRING "User Tracking Measurement ID, must be a uint32 value")
@@ -320,6 +321,7 @@ target_compile_options(${TARGET_NAME} PRIVATE
       /w15262 #implisitfallthrough
       /wd4388 #Wno-sign-compare
       /wd4389 #Wno-sign-compare
+      /wd4702 # unreachable in ae-numeric FixedPoint/Exponential templates
       /Zc:preprocessor
       >
 )
@@ -344,6 +346,7 @@ if(AE_BUILD_EXAMPLES)
   add_subdirectory(examples/common)
   add_subdirectory(examples/cloud)
   add_subdirectory(examples/a_b_message_exchange)
+  add_subdirectory(examples/remote_presence_live)
   add_subdirectory(examples/message_server)
   add_subdirectory(examples/capi/oddity)
   add_subdirectory(examples/benches/send_message_delays)

aether/CMakeLists.txt

@@ -53,7 +53,8 @@ list(APPEND aether_srcs
             "ae_actions/ping.cpp"
             "ae_actions/check_access_for_send_message.cpp"
             "ae_actions/telemetry.cpp"
-            "ae_actions/select_client.cpp")
+            "ae_actions/select_client.cpp"
+            "ae_actions/query_peer_presence.cpp")
 
 list(APPEND aether_srcs
             "registration/api/client_reg_api_unsafe.cpp"
@@ -173,6 +174,7 @@ list(APPEND aether_srcs
             "cloud_connections/cloud_server_connection.cpp"
             "cloud_connections/cloud_server_connections.cpp"
             "cloud_connections/ping_cloud_servers.cpp"
+            "cloud_connections/local_presence_machine.cpp"
             "cloud_connections/cloud_subscription.cpp"
             "cloud_connections/cloud_request.cpp")
 
@@ -184,6 +186,7 @@ list(APPEND aether_srcs
             "server_connections/server_connection.cpp")
 
 list(APPEND aether_srcs
+            "connection_manager/connectivity_policy.cpp"
             "connection_manager/get_cloud_aether.cpp"
             "connection_manager/client_cloud_manager.cpp"
             "connection_manager/server_connection_manager.cpp")

aether/ae_actions/ping.h

@@ -48,6 +48,8 @@ class Ping {
   Ping(AeContext const& ae_context,
        CloudServerConnection& cloud_server_connection, Duration next_ping_hint,
        Duration rx_window, Duration timeout);
+  // `timeout` is the hard wait for a Pong (cleanup). Local Presence retry
+  // deadlines (pXX) are owned by LocalPresenceMachine, not this timer.
 
   AE_CLASS_NO_COPY_MOVE(Ping);