NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
CoordinatorRPCServer.cpp File Reference
#include <Catalogs/Exceptions/InvalidQueryStateException.hpp>
#include <Catalogs/Query/QueryCatalog.hpp>
#include <Catalogs/Topology/Topology.hpp>
#include <Components/NesCoordinator.hpp>
#include <Configurations/WorkerConfigurationKeys.hpp>
#include <Configurations/WorkerPropertyKeys.hpp>
#include <GRPC/CoordinatorRPCServer.hpp>
#include <Monitoring/Metrics/Gauge/RegistrationMetrics.hpp>
#include <Monitoring/Metrics/Metric.hpp>
#include <Monitoring/MonitoringManager.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPAddLinkEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPRemoveLinkEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPRequest.hpp>
#include <RequestProcessor/RequestTypes/SourceCatalog/SourceCatalogEvents/AddPhysicalSourcesEvent.hpp>
#include <Runtime/OpenCLManager.hpp>
#include <Services/CoordinatorHealthCheckService.hpp>
#include <Services/QueryParsingService.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/Mobility/ReconnectPoint.hpp>
#include <Util/Mobility/SpatialTypeUtility.hpp>
#include <utility>
Include dependency graph for CoordinatorRPCServer.cpp:

Functions

void deserializeOpenCLDeviceInfo (std::any &property, const google::protobuf::RepeatedPtrField< SerializedOpenCLDeviceInfo > &serializedDeviceInfos)
 

Function Documentation

◆ deserializeOpenCLDeviceInfo()

void deserializeOpenCLDeviceInfo ( std::any &  property,
const google::protobuf::RepeatedPtrField< SerializedOpenCLDeviceInfo > &  serializedDeviceInfos 
)

References NES_WARNING.

Referenced by NES::CoordinatorRPCServer::RegisterWorker().

Here is the caller graph for this function: