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.hpp118 std::string id = subValue->userSub->id; in initConfig()
131 if (subValue->userSub->sendHeartbeat) in initConfig()
247 if (entry->userSub->eventFormatType == eventFormatType) in updateNoOfSubscribersCount()
251 else if (entry->userSub->eventFormatType == metricReportFormatType) in updateNoOfSubscribersCount()
339 subValue->userSub->id = id; in addSubscriptionInternal()
342 .subscriptionsConfigMap.emplace(id, subValue->userSub); in addSubscriptionInternal()
449 .subscriptionsConfigMap.erase(entry->userSub->id); in deleteSseSubscription()
468 return (entry.second->userSub->subscriptionType == in getNumberOfSSESubscriptions()
600 if (!eventMatchesFilter(*entry->userSub, eventMessage, in sendEvent()
H A Dsubscription.hpp87 std::shared_ptr<persistent_data::UserSubscription> userSub; member in redfish::Subscription
/openbmc/bmcweb/redfish-core/src/
H A Dsubscription.cpp48 userSub{std::move(userSubIn)}, in Subscription()
51 userSub->destinationUrl = url;
58 userSub{std::make_shared<persistent_data::UserSubscription>()}, in Subscription()
75 if (userSub->retryPolicy != "TerminateAfterRetries") in resHandler()
85 userSub->id); in resHandler()
97 "/redfish/v1/EventService/Subscriptions/{}", userSub->id); in sendHeartbeatEvent()
119 hbTimer.expires_after(std::chrono::minutes(userSub->hbIntervalMinutes)); in scheduleNextHeartbeatEvent()
128 if (userSub->sendHeartbeat) in heartbeatParametersChanged()
179 boost::beast::http::fields httpHeadersCopy(userSub->httpHeaders); in sendEventToSubscriber()
183 std::move(msg), userSub->destinationUrl, in sendEventToSubscriber()
[all …]
/openbmc/bmcweb/redfish-core/lib/
H A Devent_service.hpp507 subValue->userSub->subscriptionType = *subscriptionType; in requestRoutesEventDestinationCollection()
512 subValue->userSub->subscriptionType = "RedfishEvent"; in requestRoutesEventDestinationCollection()
521 subValue->userSub->protocol = protocol; in requestRoutesEventDestinationCollection()
525 subValue->userSub->verifyCertificate = *verifyCertificate; in requestRoutesEventDestinationCollection()
538 subValue->userSub->eventFormatType = *eventFormatType2; in requestRoutesEventDestinationCollection()
543 subValue->userSub->eventFormatType = "Event"; in requestRoutesEventDestinationCollection()
556 subValue->userSub->customText = *context; in requestRoutesEventDestinationCollection()
589 subValue->userSub->httpHeaders.set(item.first, *value); in requestRoutesEventDestinationCollection()
606 subValue->userSub->registryPrefixes = *regPrefixes; in requestRoutesEventDestinationCollection()
611 subValue->userSub->originResources = *originResources; in requestRoutesEventDestinationCollection()
[all …]
H A Deventservice_sse.hpp59 if (subValue->userSub == nullptr) in createSubscription()
67 subValue->userSub->subscriptionType = redfish::subscriptionTypeSSE; in createSubscription()
69 subValue->userSub->protocol = "Redfish"; in createSubscription()
70 subValue->userSub->retryPolicy = "TerminateAfterRetries"; in createSubscription()
71 subValue->userSub->eventFormatType = "Event"; in createSubscription()