cppcon_add_library(service LIBRARIES Asio::asio) add_subdirectory(tests)

nodes that can ○ publish data to topics, subscribe to topics to receive data, act as a service client, act as a service server, act as an action client, or act as an action serverWhat is ROS 2? ● has a nodes that can ○ publish data to topics, subscribe to topics to receive data, act as a service client, act as a service server, act as an action client, or act as an action server ○ provide configurable nodes that can ○ publish data to topics, subscribe to topics to receive data, act as a service client, act as a service server, act as an action client, or act as an action server ○ provide configurable

CommWrapper { enum { SERVICE_ID = 249409 }; public : CommWrapper(int service_id = SERVICE_ID); Response send(const Request& req); private: TcpClient raw_client; }; Bloomberg 14 struct Service { static CommWrapper CommWrapper& comms=Service::comm_) Bloomberg 15 // New wrapper class to replace singleton CommWrapper.h class CommWrapper { enum { SERVICE_ID = 249409 }; public : CommWrapper(int service_id = SERVICE_ID); Response replace singleton CommWrapper.h class CommWrapper { enum { SERVICE_ID = 249409 }; public : CommWrapper(int service_id = SERVICE_ID):raw_client(service_id){...}; virtual Response send(const Request& req);

I/O objects) is a useful pattern 19Service Named Type Requirement Service objects own completion handlers thereby breaking the potential ownership cycle Service objects are owned by an ExecutionContext handlers) as its lifetime ends 20Service Named Type Requirement struct my_service : std::net::execution_context::service { using key_type = my_service; explicit my_service(std::net::execution_context& }; 21Service::shutdown 22Service Access & Creation templateService> typename Service::key_type& use_service(execution_context& e); template Service, typename... Args> Service& ma

asynchronous APIs as the default Asynchronous APIs in Adaptive Autosar ara::com::FindServiceHandle find_service_handle = RadarServiceProxy::StartFindService( [](ara::com::ServiceHandleContainer }); // ... RadarServiceProxy::StopFindService(find_service_handle); Asynchronous APIs in Adaptive Autosar ara::com::FindServiceHandle find_service_handle = RadarServiceProxy::StartFindService( []( RadarServiceProxy service(handles.front()); ara::core::Future fut = service.UpdateRate.Get(); // ... }); // ... RadarServiceProxy::StopFindService(find_service_handle); Asynchronous

Server::Dual; void clientFunc(Channel chan) { cout << "Choose service (0-add, 1-div): "; int service; cin >> service; if (service == 0) { auto c1 = chan.sel0(); cout << "First num: Chan, CommType> loop(); 81using Service = Recv>>>; using Server = Loop<Service>; using Client = Server::Dual; void serverFunc(Channel take<1>(o1).close(); break; } } } 82using Service = Recv>>>; using Server = Loop<Service>; using Client = Server::Dual; void clientFunc(Channel

App running as medium Integrity Level • Service running as high Integrity Level • Cloud Service to handle the AI OCR processing UI App [Medium IL] Service [High IL] Serialized Data Cloud AI OCR OCR Processing Serialized DataAdversary Perspective UI App [Medium IL] Service [High IL] Serialized Data Cloud AI OCR Processing File Input Validation Maliciously crafted file Loaded Resource Execution Who: •Advanced adversaries How: •Deserialization •Client-Server interfaces Denial of Service Who: •Hacktivists •Script Kiddies •Game hackers How: •Client-Server interfaces Medium Effort

Finance L.P. All rights reserved. © 2024 Bloomberg Finance L.P. All rights reserved. A growing service architecture 12© 2018 Bloomberg Finance L.P. All rights reserved. 13 For nearly 20 years, there developed a huge vocabulary of these types, held in thousands of libraries, many outside of the service network.© 2018 Bloomberg Finance L.P. All rights reserved. 15 For services, impressive flexibility one another. ● “Types” libraries contain value semantic types. Used within and outside of the service network, these generated types have evolved into a massive vocabulary that is shared across teams

What’s that alarm? Consequences: ● Swap: performance degradation ● Out-of-memory (OOM) killer: service disruption ● Multi-tenant environment: resources are shared by different processes🚨 90% Memory Fragmentation = 1 - LargestAllocableBlock / TotalFreeMemory mallinfo(3) mallinfo(3) mallinfo service A: Total bytes (arena): 244 355 072 Total in-use allocations: 31 650 352 Total 63 248 External Fragmentation = 0.9997How to estimate Fragmentation? mallinfo(3) mallinfo service B: Total bytes (arena): 33 292 288 Total in-use allocations: 30 316 416 Total free

dispatch service requests concurrently onto various service providers. ▪ For each supported service type implement an event handler that fulfils the specific client request. ▪ Register this service handler incoming events. ▪ When an event arrives, the Reactor is notified and dispatches it to the specific service.ReactorReactor Advantages: ▪ A clear separation of framework and application logic. ▪ The Reactor