MayaFlux 0.5.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ register_backend_service()

void MayaFlux::Core::NetworkSubsystem::register_backend_service ( )
private

Definition at line 379 of file NetworkSubsystem.cpp.

380{
381 auto& registry = Registry::BackendRegistry::instance();
382
383 auto service = std::make_shared<Registry::Service::NetworkService>();
384
385 service->open_endpoint = [this](const EndpointInfo& info) {
386 return open_endpoint(info);
387 };
388
389 service->close_endpoint = [this](uint64_t id) {
390 close_endpoint(id);
391 };
392
393 service->send = [this](uint64_t id, const uint8_t* data, size_t size) {
394 return send(id, data, size);
395 };
396
397 service->send_to = [this](uint64_t id, const uint8_t* data, size_t size,
398 const std::string& addr, uint16_t port) {
399 return send_to(id, data, size, addr, port);
400 };
401
402 service->get_endpoint_state = [this](uint64_t id) {
403 return get_endpoint_state(id);
404 };
405
406 service->set_endpoint_receive_callback = [this](uint64_t id, NetworkReceiveCallback cb) {
407 set_endpoint_receive_callback(id, std::move(cb));
408 };
409
410 service->get_all_endpoints = [this]() {
411 return get_all_endpoints();
412 };
413
414 m_network_service = service;
415
416 registry.register_service<Registry::Service::NetworkService>(
417 [service]() -> void* {
418 return service.get();
419 });
420}
uint64_t open_endpoint(const EndpointInfo &info)
Open an endpoint on the backend matching info.transport.
std::vector< EndpointInfo > get_all_endpoints() const
List all open endpoints across all backends.
void set_endpoint_receive_callback(uint64_t endpoint_id, NetworkReceiveCallback callback)
Register a per-endpoint receive callback.
void close_endpoint(uint64_t endpoint_id)
Close an endpoint.
bool send(uint64_t endpoint_id, const uint8_t *data, size_t size)
Send data through an endpoint.
EndpointState get_endpoint_state(uint64_t endpoint_id) const
Query endpoint state.
bool send_to(uint64_t endpoint_id, const uint8_t *data, size_t size, const std::string &address, uint16_t port)
Send data to a specific address.
std::shared_ptr< Registry::Service::NetworkService > m_network_service
static BackendRegistry & instance()
Get the global registry instance.
std::function< void(uint64_t endpoint_id, const uint8_t *data, size_t size, std::string_view sender_addr)> NetworkReceiveCallback
Callback signature for inbound data on an endpoint.

References MayaFlux::Registry::BackendRegistry::instance().

Referenced by initialize().

+ Here is the call graph for this function:
+ Here is the caller graph for this function: