Home
last modified time | relevance | path

Searched refs:userSub (Results 1 – 6 of 6) sorted by relevance

/openbmc/bmcweb/redfish-core/include/
H A Devent_matches_filter.hpp35 inline bool eventMatchesFilter(const persistent_data::UserSubscription& userSub, in eventMatchesFilter() argument
40 if (!userSub.resourceTypes.empty()) in eventMatchesFilter()
44 userSub.resourceTypes, [resType](const std::string& rtEntry) { in eventMatchesFilter()
47 if (resourceTypeIndex == userSub.resourceTypes.end()) in eventMatchesFilter()
58 if (!userSub.registryPrefixes.empty()) in eventMatchesFilter()
78 auto obj = std::ranges::find(userSub.registryPrefixes, registry); in eventMatchesFilter()
79 if (obj == userSub.registryPrefixes.end()) in eventMatchesFilter()
85 if (!userSub.originResources.empty()) in eventMatchesFilter()
102 std::ranges::find(userSub.originResources, *originOfCondition); in eventMatchesFilter()
104 if (obj == userSub.originResources.end()) in eventMatchesFilter()
[all …]
H A Devent_service_manager.hpp126 std::string id = subValue->userSub->id; in initConfig()
139 if (subValue->userSub->sendHeartbeat) in initConfig()
354 if (entry->userSub->eventFormatType == eventFormatType) in updateNoOfSubscribersCount()
358 else if (entry->userSub->eventFormatType == metricReportFormatType) in updateNoOfSubscribersCount()
446 subValue->userSub->id = id; in addSubscriptionInternal()
449 .subscriptionsConfigMap.emplace(id, subValue->userSub); in addSubscriptionInternal()
548 .subscriptionsConfigMap.erase(entry->userSub->id); in deleteSseSubscription()
567 return (entry.second->userSub->subscriptionType == in getNumberOfSSESubscriptions()
635 if (!eventMatchesFilter(*entry->userSub, eventMessage, in sendEvent()
H A Dsubscription.hpp107 std::shared_ptr<persistent_data::UserSubscription> userSub; member in redfish::Subscription
/openbmc/bmcweb/redfish-core/lib/
H A Devent_service.hpp486 subValue->userSub->subscriptionType = *subscriptionType; in requestRoutesEventDestinationCollection()
491 subValue->userSub->subscriptionType = "RedfishEvent"; in requestRoutesEventDestinationCollection()
500 subValue->userSub->protocol = protocol; in requestRoutesEventDestinationCollection()
504 subValue->userSub->verifyCertificate = *verifyCertificate; in requestRoutesEventDestinationCollection()
517 subValue->userSub->eventFormatType = *eventFormatType2; in requestRoutesEventDestinationCollection()
522 subValue->userSub->eventFormatType = "Event"; in requestRoutesEventDestinationCollection()
535 subValue->userSub->customText = *context; in requestRoutesEventDestinationCollection()
568 subValue->userSub->httpHeaders.set(item.first, *value); in requestRoutesEventDestinationCollection()
585 subValue->userSub->registryPrefixes = *regPrefixes; in requestRoutesEventDestinationCollection()
590 subValue->userSub->originResources = *originResources; in requestRoutesEventDestinationCollection()
[all …]
H A Deventservice_sse.hpp52 if (subValue->userSub == nullptr) in createSubscription()
60 subValue->userSub->subscriptionType = redfish::subscriptionTypeSSE; in createSubscription()
62 subValue->userSub->protocol = "Redfish"; in createSubscription()
63 subValue->userSub->retryPolicy = "TerminateAfterRetries"; in createSubscription()
64 subValue->userSub->eventFormatType = "Event"; in createSubscription()
/openbmc/bmcweb/redfish-core/src/
H A Dsubscription.cpp64 userSub{std::move(userSubIn)}, in Subscription()
67 userSub->destinationUrl = url;
74 userSub{std::make_shared<persistent_data::UserSubscription>()}, in Subscription()
90 if (userSub->retryPolicy != "TerminateAfterRetries") in resHandler()
100 userSub->id); in resHandler()
115 std::format("/redfish/v1/EventService/Subscriptions/{}", userSub->id); in sendHeartbeatEvent()
135 hbTimer.expires_after(std::chrono::minutes(userSub->hbIntervalMinutes)); in scheduleNextHeartbeatEvent()
144 if (userSub->sendHeartbeat) in heartbeatParametersChanged()
195 boost::beast::http::fields httpHeadersCopy(userSub->httpHeaders); in sendEventToSubscriber()
199 std::move(msg), userSub->destinationUrl, in sendEventToSubscriber()
[all …]