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.hpp36 inline bool eventMatchesFilter(const persistent_data::UserSubscription& userSub, in eventMatchesFilter() argument
41 if (!userSub.resourceTypes.empty()) in eventMatchesFilter()
45 userSub.resourceTypes, [resType](const std::string& rtEntry) { in eventMatchesFilter()
48 if (resourceTypeIndex == userSub.resourceTypes.end()) in eventMatchesFilter()
59 if (!userSub.registryPrefixes.empty()) in eventMatchesFilter()
79 auto obj = std::ranges::find(userSub.registryPrefixes, registry); in eventMatchesFilter()
80 if (obj == userSub.registryPrefixes.end()) in eventMatchesFilter()
86 if (!userSub.originResources.empty()) in eventMatchesFilter()
103 std::ranges::find(userSub.originResources, *originOfCondition); in eventMatchesFilter()
105 if (obj == userSub.originResources.end()) in eventMatchesFilter()
[all …]
H A Devent_service_manager.hpp128 std::string id = subValue->userSub->id; in initConfig()
141 if (subValue->userSub->sendHeartbeat) in initConfig()
356 if (entry->userSub->eventFormatType == eventFormatType) in updateNoOfSubscribersCount()
360 else if (entry->userSub->eventFormatType == metricReportFormatType) in updateNoOfSubscribersCount()
448 subValue->userSub->id = id; in addSubscriptionInternal()
451 .subscriptionsConfigMap.emplace(id, subValue->userSub); in addSubscriptionInternal()
558 .subscriptionsConfigMap.erase(entry->userSub->id); in deleteSseSubscription()
577 return (entry.second->userSub->subscriptionType == in getNumberOfSSESubscriptions()
709 if (!eventMatchesFilter(*entry->userSub, eventMessage, in sendEvent()
H A Dsubscription.hpp97 std::shared_ptr<persistent_data::UserSubscription> userSub; member in redfish::Subscription
/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()
112 std::format("/redfish/v1/EventService/Subscriptions/{}", userSub->id); in sendHeartbeatEvent()
134 hbTimer.expires_after(std::chrono::minutes(userSub->hbIntervalMinutes)); in scheduleNextHeartbeatEvent()
143 if (userSub->sendHeartbeat) in heartbeatParametersChanged()
194 boost::beast::http::fields httpHeadersCopy(userSub->httpHeaders); in sendEventToSubscriber()
198 std::move(msg), userSub->destinationUrl, in sendEventToSubscriber()
[all …]
/openbmc/bmcweb/redfish-core/lib/
H A Devent_service.hpp510 subValue->userSub->subscriptionType = *subscriptionType; in requestRoutesEventDestinationCollection()
515 subValue->userSub->subscriptionType = "RedfishEvent"; in requestRoutesEventDestinationCollection()
524 subValue->userSub->protocol = protocol; in requestRoutesEventDestinationCollection()
528 subValue->userSub->verifyCertificate = *verifyCertificate; in requestRoutesEventDestinationCollection()
541 subValue->userSub->eventFormatType = *eventFormatType2; in requestRoutesEventDestinationCollection()
546 subValue->userSub->eventFormatType = "Event"; in requestRoutesEventDestinationCollection()
559 subValue->userSub->customText = *context; in requestRoutesEventDestinationCollection()
592 subValue->userSub->httpHeaders.set(item.first, *value); in requestRoutesEventDestinationCollection()
609 subValue->userSub->registryPrefixes = *regPrefixes; in requestRoutesEventDestinationCollection()
614 subValue->userSub->originResources = *originResources; in requestRoutesEventDestinationCollection()
[all …]
H A Deventservice_sse.hpp58 if (subValue->userSub == nullptr) in createSubscription()
66 subValue->userSub->subscriptionType = redfish::subscriptionTypeSSE; in createSubscription()
68 subValue->userSub->protocol = "Redfish"; in createSubscription()
69 subValue->userSub->retryPolicy = "TerminateAfterRetries"; in createSubscription()
70 subValue->userSub->eventFormatType = "Event"; in createSubscription()