| /** |
| * |
| * Copyright (c) 2021 Project CHIP Authors |
| * Copyright (c) 2015-2017 Nest Labs, Inc. |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| #include <access/AccessControl.h> |
| #include <access/RequestPath.h> |
| #include <access/SubjectDescriptor.h> |
| #include <app/EventManagement.h> |
| #include <app/InteractionModelEngine.h> |
| #include <app/RequiredPrivilege.h> |
| #include <assert.h> |
| #include <inttypes.h> |
| #include <lib/core/CHIPEventLoggingConfig.h> |
| #include <lib/core/CHIPTLVUtilities.hpp> |
| #include <lib/support/CodeUtils.h> |
| #include <lib/support/ErrorStr.h> |
| #include <lib/support/logging/CHIPLogging.h> |
| |
| using namespace chip::TLV; |
| |
| namespace chip { |
| namespace app { |
| static EventManagement sInstance; |
| |
| /** |
| * @brief |
| * A TLVReader backed by CircularEventBuffer |
| */ |
| class CircularEventReader : public TLV::TLVReader |
| { |
| public: |
| /** |
| * @brief |
| * Initializes a TLVReader object backed by CircularEventBuffer |
| * |
| * Reading begins in the CircularTLVBuffer belonging to this |
| * CircularEventBuffer. When the reader runs out of data, it begins |
| * to read from the previous CircularEventBuffer. |
| * |
| * @param[in] apBuf A pointer to a fully initialized CircularEventBuffer |
| * |
| */ |
| void Init(CircularEventBufferWrapper * apBuf); |
| |
| virtual ~CircularEventReader() = default; |
| }; |
| |
| EventManagement & EventManagement::GetInstance(void) |
| { |
| return sInstance; |
| } |
| |
| struct ReclaimEventCtx |
| { |
| CircularEventBuffer * mpEventBuffer = nullptr; |
| size_t mSpaceNeededForMovedEvent = 0; |
| }; |
| |
| /** |
| * @brief |
| * Internal structure for traversing event list. |
| */ |
| struct CopyAndAdjustDeltaTimeContext |
| { |
| CopyAndAdjustDeltaTimeContext(TLVWriter * aWriter, EventLoadOutContext * inContext) : mpWriter(aWriter), mpContext(inContext) {} |
| |
| TLV::TLVWriter * mpWriter = nullptr; |
| EventLoadOutContext * mpContext = nullptr; |
| }; |
| |
| void EventManagement::InitializeCounter(Platform::PersistedStorage::Key * apCounterKey, uint32_t aCounterEpoch, |
| PersistedCounter * apPersistedCounter) |
| { |
| PersistedCounter * eventNumberCounter = nullptr; |
| if (apPersistedCounter != nullptr && apCounterKey != nullptr && aCounterEpoch != 0) |
| { |
| eventNumberCounter = |
| (apPersistedCounter->Init(*apCounterKey, aCounterEpoch) == CHIP_NO_ERROR) ? apPersistedCounter : nullptr; |
| } |
| |
| if (eventNumberCounter == nullptr) |
| { |
| mNonPersistedCounter.Init(0); |
| mpEventNumberCounter = &(mNonPersistedCounter); |
| } |
| else |
| { |
| mpEventNumberCounter = eventNumberCounter; |
| } |
| mLastEventNumber = mpEventNumberCounter->GetValue(); |
| } |
| |
| void EventManagement::Init(Messaging::ExchangeManager * apExchangeManager, uint32_t aNumBuffers, |
| CircularEventBuffer * apCircularEventBuffer, const LogStorageResources * const apLogStorageResources, |
| Platform::PersistedStorage::Key * apCounterKey, uint32_t aCounterEpoch, |
| PersistedCounter * apPersistedCounter) |
| { |
| CircularEventBuffer * current = nullptr; |
| CircularEventBuffer * prev = nullptr; |
| CircularEventBuffer * next = nullptr; |
| |
| if (aNumBuffers == 0) |
| { |
| ChipLogError(EventLogging, "Invalid aNumBuffers"); |
| return; |
| } |
| |
| if (mState != EventManagementStates::Shutdown) |
| { |
| ChipLogError(EventLogging, "Invalid EventManagement State"); |
| return; |
| } |
| mpExchangeMgr = apExchangeManager; |
| |
| for (uint32_t bufferIndex = 0; bufferIndex < aNumBuffers; bufferIndex++) |
| { |
| next = (bufferIndex < aNumBuffers - 1) ? &apCircularEventBuffer[bufferIndex + 1] : nullptr; |
| |
| current = &apCircularEventBuffer[bufferIndex]; |
| current->Init(apLogStorageResources[bufferIndex].mpBuffer, apLogStorageResources[bufferIndex].mBufferSize, prev, next, |
| apLogStorageResources[bufferIndex].mPriority); |
| |
| prev = current; |
| |
| current->mProcessEvictedElement = nullptr; |
| current->mAppData = nullptr; |
| } |
| |
| InitializeCounter(apCounterKey, aCounterEpoch, apPersistedCounter); |
| |
| mpEventBuffer = apCircularEventBuffer; |
| mState = EventManagementStates::Idle; |
| mBytesWritten = 0; |
| |
| #if !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| CHIP_ERROR err = chip::System::Mutex::Init(mAccessLock); |
| if (err != CHIP_NO_ERROR) |
| { |
| ChipLogError(EventLogging, "mutex init fails with error %s", ErrorStr(err)); |
| } |
| #endif // !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| } |
| |
| CHIP_ERROR EventManagement::CopyToNextBuffer(CircularEventBuffer * apEventBuffer) |
| { |
| CircularTLVWriter writer; |
| CircularTLVReader reader; |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| CircularEventBuffer * nextBuffer = apEventBuffer->GetNextCircularEventBuffer(); |
| if (nextBuffer == nullptr) |
| { |
| return CHIP_ERROR_INVALID_ARGUMENT; |
| } |
| CircularEventBuffer backup = *nextBuffer; |
| |
| // Set up the next buffer s.t. it fails if needs to evict an element |
| nextBuffer->mProcessEvictedElement = AlwaysFail; |
| |
| writer.Init(*nextBuffer); |
| |
| // Set up the reader s.t. it is positioned to read the head event |
| reader.Init(*apEventBuffer); |
| |
| err = reader.Next(); |
| SuccessOrExit(err); |
| |
| err = writer.CopyElement(reader); |
| SuccessOrExit(err); |
| |
| err = writer.Finalize(); |
| SuccessOrExit(err); |
| |
| ChipLogDetail(EventLogging, "Copy Event to next buffer with priority %u", static_cast<unsigned>(nextBuffer->GetPriority())); |
| exit: |
| if (err != CHIP_NO_ERROR) |
| { |
| *nextBuffer = backup; |
| } |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::EnsureSpaceInCircularBuffer(size_t aRequiredSpace) |
| { |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| size_t requiredSpace = aRequiredSpace; |
| CircularEventBuffer * eventBuffer = mpEventBuffer; |
| ReclaimEventCtx ctx; |
| |
| // check whether we actually need to do anything, exit if we don't |
| VerifyOrExit(requiredSpace > eventBuffer->AvailableDataLength(), err = CHIP_NO_ERROR); |
| |
| while (true) |
| { |
| // check that the request can ultimately be satisfied. |
| VerifyOrExit(requiredSpace <= eventBuffer->GetTotalDataLength(), err = CHIP_ERROR_BUFFER_TOO_SMALL); |
| |
| if (requiredSpace > eventBuffer->AvailableDataLength()) |
| { |
| ctx.mpEventBuffer = eventBuffer; |
| ctx.mSpaceNeededForMovedEvent = 0; |
| |
| eventBuffer->mProcessEvictedElement = EvictEvent; |
| eventBuffer->mAppData = &ctx; |
| err = eventBuffer->EvictHead(); |
| |
| // one of two things happened: either the element was evicted immediately if the head's priority is same as current |
| // buffer(final one), or we figured out how much space we need to evict it into the next buffer, the check happens in |
| // EvictEvent function |
| |
| if (err != CHIP_NO_ERROR) |
| { |
| VerifyOrExit(ctx.mSpaceNeededForMovedEvent != 0, /* no-op, return err */); |
| VerifyOrExit(eventBuffer->GetNextCircularEventBuffer() != nullptr, err = CHIP_ERROR_INCORRECT_STATE); |
| if (ctx.mSpaceNeededForMovedEvent <= eventBuffer->GetNextCircularEventBuffer()->AvailableDataLength()) |
| { |
| // we can copy the event outright. copy event and |
| // subsequently evict head s.t. evicting the head |
| // element always succeeds. |
| // Since we're calling CopyElement and we've checked |
| // that there is space in the next buffer, we don't expect |
| // this to fail. |
| err = CopyToNextBuffer(eventBuffer); |
| SuccessOrExit(err); |
| // success; evict head unconditionally |
| eventBuffer->mProcessEvictedElement = nullptr; |
| err = eventBuffer->EvictHead(); |
| // if unconditional eviction failed, this |
| // means that we have no way of further |
| // clearing the buffer. fail out and let the |
| // caller know that we could not honor the |
| // request |
| SuccessOrExit(err); |
| continue; |
| } |
| // we cannot copy event outright. We remember the |
| // current required space in mRequiredSpaceForEvicted, we note the |
| // space requirements for the event in the current |
| // buffer and make that space in the next buffer. |
| eventBuffer->SetRequiredSpaceforEvicted(requiredSpace); |
| eventBuffer = eventBuffer->GetNextCircularEventBuffer(); |
| |
| // Sanity check: return error here on null event buffer. If |
| // eventBuffer->mpNext were null, then the `EvictBuffer` |
| // would have succeeded -- the event was |
| // already in the final buffer. |
| VerifyOrExit(eventBuffer != nullptr, err = CHIP_ERROR_INCORRECT_STATE); |
| requiredSpace = ctx.mSpaceNeededForMovedEvent; |
| } |
| } |
| else |
| { |
| // this branch is only taken when we go back in the buffer chain since we have free/spare enough space in next buffer, |
| // and need to retry to copy event from current buffer to next buffer, and free space for current buffer |
| if (eventBuffer == mpEventBuffer) |
| break; |
| eventBuffer = eventBuffer->GetPreviousCircularEventBuffer(); |
| requiredSpace = eventBuffer->GetRequiredSpaceforEvicted(); |
| err = CHIP_NO_ERROR; |
| } |
| } |
| |
| mpEventBuffer->mProcessEvictedElement = nullptr; |
| mpEventBuffer->mAppData = nullptr; |
| |
| exit: |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::CalculateEventSize(EventLoggingDelegate * apDelegate, const EventOptions * apOptions, |
| uint32_t & requiredSize) |
| { |
| System::PacketBufferTLVWriter writer; |
| EventLoadOutContext ctxt = EventLoadOutContext(writer, apOptions->mPriority, GetLastEventNumber()); |
| System::PacketBufferHandle buf = System::PacketBufferHandle::New(kMaxEventSizeReserve); |
| if (buf.IsNull()) |
| { |
| return CHIP_ERROR_NO_MEMORY; |
| } |
| writer.Init(std::move(buf)); |
| |
| ctxt.mCurrentEventNumber = mLastEventNumber; |
| ctxt.mCurrentTime = mLastEventTimestamp; |
| CHIP_ERROR err = ConstructEvent(&ctxt, apDelegate, apOptions); |
| if (err == CHIP_NO_ERROR) |
| { |
| requiredSize = writer.GetLengthWritten(); |
| } |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::ConstructEvent(EventLoadOutContext * apContext, EventLoggingDelegate * apDelegate, |
| const EventOptions * apOptions) |
| { |
| VerifyOrReturnError(apContext->mCurrentEventNumber >= apContext->mStartingEventNumber, CHIP_NO_ERROR |
| /* no-op: don't write event, but advance current event Number */); |
| |
| VerifyOrReturnError(apOptions != nullptr, CHIP_ERROR_INVALID_ARGUMENT); |
| |
| EventReportIB::Builder eventReportBuilder; |
| ReturnErrorOnFailure(eventReportBuilder.Init(&(apContext->mWriter))); |
| EventDataIB::Builder & eventDataIBBuilder = eventReportBuilder.CreateEventData(); |
| ReturnErrorOnFailure(eventReportBuilder.GetError()); |
| EventPathIB::Builder & eventPathBuilder = eventDataIBBuilder.CreatePath(); |
| ReturnErrorOnFailure(eventDataIBBuilder.GetError()); |
| |
| eventPathBuilder.Endpoint(apOptions->mPath.mEndpointId) |
| .Cluster(apOptions->mPath.mClusterId) |
| .Event(apOptions->mPath.mEventId) |
| .EndOfEventPathIB(); |
| ReturnErrorOnFailure(eventPathBuilder.GetError()); |
| eventDataIBBuilder.EventNumber(apContext->mCurrentEventNumber).Priority(chip::to_underlying(apContext->mPriority)); |
| ReturnErrorOnFailure(eventDataIBBuilder.GetError()); |
| |
| if (apOptions->mTimestamp.IsSystem()) |
| { |
| eventDataIBBuilder.SystemTimestamp(apOptions->mTimestamp.mValue); |
| } |
| else |
| { |
| eventDataIBBuilder.EpochTimestamp(apOptions->mTimestamp.mValue); |
| } |
| |
| ReturnErrorOnFailure(eventDataIBBuilder.GetError()); |
| |
| // Callback to write the EventData |
| ReturnErrorOnFailure(apDelegate->WriteEvent(apContext->mWriter)); |
| |
| // The fabricIndex profile tag is internal use only for fabric filtering when retrieving event from circular event buffer, |
| // and would not go on the wire. |
| if (apOptions->mFabricIndex != kUndefinedFabricIndex) |
| { |
| apContext->mWriter.Put(TLV::ProfileTag(kEventManagementProfile, kFabricIndexTag), apOptions->mFabricIndex); |
| } |
| eventDataIBBuilder.EndOfEventDataIB(); |
| ReturnErrorOnFailure(eventDataIBBuilder.GetError()); |
| eventReportBuilder.EndOfEventReportIB(); |
| ReturnErrorOnFailure(eventReportBuilder.GetError()); |
| ReturnErrorOnFailure(apContext->mWriter.Finalize()); |
| apContext->mFirst = false; |
| return CHIP_NO_ERROR; |
| } |
| |
| void EventManagement::CreateEventManagement(Messaging::ExchangeManager * apExchangeManager, uint32_t aNumBuffers, |
| CircularEventBuffer * apCircularEventBuffer, |
| const LogStorageResources * const apLogStorageResources, |
| Platform::PersistedStorage::Key * apCounterKey, uint32_t aCounterEpoch, |
| PersistedCounter * apPersistedCounter) |
| { |
| |
| sInstance.Init(apExchangeManager, aNumBuffers, apCircularEventBuffer, apLogStorageResources, apCounterKey, aCounterEpoch, |
| apPersistedCounter); |
| } |
| |
| /** |
| * @brief Perform any actions we need to on shutdown. |
| */ |
| void EventManagement::DestroyEventManagement() |
| { |
| #if !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| ScopedLock lock(sInstance); |
| #endif // !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| sInstance.mState = EventManagementStates::Shutdown; |
| sInstance.mpEventBuffer = nullptr; |
| sInstance.mpExchangeMgr = nullptr; |
| } |
| |
| CircularEventBuffer * EventManagement::GetPriorityBuffer(PriorityLevel aPriority) const |
| { |
| CircularEventBuffer * buf = mpEventBuffer; |
| while (!buf->IsFinalDestinationForPriority(aPriority)) |
| { |
| buf = buf->GetNextCircularEventBuffer(); |
| assert(buf != nullptr); |
| // code guarantees that every PriorityLevel has a buffer destination. |
| } |
| return buf; |
| } |
| |
| CHIP_ERROR EventManagement::CopyAndAdjustDeltaTime(const TLVReader & aReader, size_t aDepth, void * apContext) |
| { |
| CopyAndAdjustDeltaTimeContext * ctx = static_cast<CopyAndAdjustDeltaTimeContext *>(apContext); |
| TLVReader reader(aReader); |
| |
| if (aReader.GetTag() == TLV::ProfileTag(kEventManagementProfile, kFabricIndexTag)) |
| { |
| // Does not go on the wire. |
| return CHIP_NO_ERROR; |
| } |
| if ((aReader.GetTag() == TLV::ContextTag(to_underlying(EventDataIB::Tag::kSystemTimestamp))) && !(ctx->mpContext->mFirst)) |
| { |
| return ctx->mpWriter->Put(TLV::ContextTag(to_underlying(EventDataIB::Tag::kDeltaSystemTimestamp)), |
| ctx->mpContext->mCurrentTime.mValue - ctx->mpContext->mPreviousTime.mValue); |
| } |
| if ((aReader.GetTag() == TLV::ContextTag(to_underlying(EventDataIB::Tag::kEpochTimestamp))) && !(ctx->mpContext->mFirst)) |
| { |
| return ctx->mpWriter->Put(TLV::ContextTag(to_underlying(EventDataIB::Tag::kDeltaEpochTimestamp)), |
| ctx->mpContext->mCurrentTime.mValue - ctx->mpContext->mPreviousTime.mValue); |
| } |
| |
| return ctx->mpWriter->CopyElement(reader); |
| } |
| |
| void EventManagement::VendEventNumber() |
| { |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| // Now advance the counter. |
| err = mpEventNumberCounter->Advance(); |
| if (err != CHIP_NO_ERROR) |
| { |
| ChipLogError(EventLogging, "%s Advance() failed with %" CHIP_ERROR_FORMAT, __FUNCTION__, err.Format()); |
| } |
| |
| // Assign event Number to the buffer's counter's value. |
| mLastEventNumber = static_cast<EventNumber>(mpEventNumberCounter->GetValue()); |
| } |
| |
| CHIP_ERROR EventManagement::LogEvent(EventLoggingDelegate * apDelegate, const EventOptions & aEventOptions, |
| EventNumber & aEventNumber) |
| { |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| { |
| #if !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| ScopedLock lock(sInstance); |
| #endif // !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| |
| VerifyOrExit(mState != EventManagementStates::Shutdown, err = CHIP_ERROR_INCORRECT_STATE); |
| err = LogEventPrivate(apDelegate, aEventOptions, aEventNumber); |
| } |
| exit: |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::LogEventPrivate(EventLoggingDelegate * apDelegate, const EventOptions & aEventOptions, |
| EventNumber & aEventNumber) |
| { |
| CircularTLVWriter writer; |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| uint32_t requestSize = 0; |
| aEventNumber = 0; |
| CircularTLVWriter checkpoint = writer; |
| CircularEventBuffer * buffer = nullptr; |
| EventLoadOutContext ctxt = EventLoadOutContext(writer, aEventOptions.mPriority, mLastEventNumber); |
| EventOptions opts; |
| #if CHIP_CONFIG_EVENT_LOGGING_UTC_TIMESTAMPS & CHIP_SYSTEM_CONFIG_PLATFORM_PROVIDES_TIME |
| Timestamp timestamp; |
| System::Clock::Timestamp utc_time; |
| |
| err = System::SystemClock().GetClock_RealTimeMS(utc_time); |
| SuccessOrExit(err); |
| timestamp = Timestamp::Epoch(utc_time); |
| #else |
| Timestamp timestamp(System::SystemClock().GetMonotonicTimestamp()); |
| #endif |
| |
| opts = EventOptions(timestamp); |
| // Start the event container (anonymous structure) in the circular buffer |
| writer.Init(*mpEventBuffer); |
| |
| opts.mPriority = aEventOptions.mPriority; |
| // Create all event specific data |
| // Timestamp; encoded as a delta time |
| |
| opts.mPath = aEventOptions.mPath; |
| opts.mFabricIndex = aEventOptions.mFabricIndex; |
| |
| ctxt.mCurrentEventNumber = mLastEventNumber; |
| ctxt.mCurrentTime.mValue = mLastEventTimestamp.mValue; |
| |
| err = CalculateEventSize(apDelegate, &opts, requestSize); |
| SuccessOrExit(err); |
| |
| // Ensure we have space in the in-memory logging queues |
| err = EnsureSpaceInCircularBuffer(requestSize); |
| SuccessOrExit(err); |
| |
| err = ConstructEvent(&ctxt, apDelegate, &opts); |
| SuccessOrExit(err); |
| |
| // Check the number of bytes written. If the event is too large |
| // to be evicted from subsequent buffers, drop it now. |
| buffer = mpEventBuffer; |
| while (true) |
| { |
| VerifyOrExit(buffer->GetTotalDataLength() >= writer.GetLengthWritten(), err = CHIP_ERROR_BUFFER_TOO_SMALL); |
| if (buffer->IsFinalDestinationForPriority(opts.mPriority)) |
| { |
| break; |
| } |
| |
| buffer = buffer->GetNextCircularEventBuffer(); |
| assert(buffer != nullptr); |
| // code guarantees that every PriorityLevel has a buffer destination. |
| } |
| |
| mBytesWritten += writer.GetLengthWritten(); |
| |
| exit: |
| if (err != CHIP_NO_ERROR) |
| { |
| ChipLogError(EventLogging, "Log event with error %s", ErrorStr(err)); |
| writer = checkpoint; |
| } |
| else if (opts.mPriority >= CHIP_CONFIG_EVENT_GLOBAL_PRIORITY) |
| { |
| aEventNumber = mLastEventNumber; |
| VendEventNumber(); |
| mLastEventTimestamp = timestamp; |
| #if CHIP_CONFIG_EVENT_LOGGING_VERBOSE_DEBUG_LOGS |
| ChipLogDetail(EventLogging, |
| "LogEvent event number: 0x" ChipLogFormatX64 " priority: %u, endpoint id: 0x%" PRIx16 |
| " cluster id: " ChipLogFormatMEI " event id: 0x%" PRIx32 " %s timestamp: 0x" ChipLogFormatX64, |
| ChipLogValueX64(aEventNumber), static_cast<unsigned>(opts.mPriority), opts.mPath.mEndpointId, |
| ChipLogValueMEI(opts.mPath.mClusterId), opts.mPath.mEventId, |
| opts.mTimestamp.mType == Timestamp::Type::kSystem ? "Sys" : "Epoch", ChipLogValueX64(opts.mTimestamp.mValue)); |
| #endif // CHIP_CONFIG_EVENT_LOGGING_VERBOSE_DEBUG_LOGS |
| |
| err = InteractionModelEngine::GetInstance()->GetReportingEngine().ScheduleEventDelivery(opts.mPath, mBytesWritten); |
| } |
| |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::CopyEvent(const TLVReader & aReader, TLVWriter & aWriter, EventLoadOutContext * apContext) |
| { |
| TLVReader reader; |
| TLVType containerType; |
| TLVType containerType1; |
| CopyAndAdjustDeltaTimeContext context(&aWriter, apContext); |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| |
| reader.Init(aReader); |
| ReturnErrorOnFailure(reader.EnterContainer(containerType)); |
| ReturnErrorOnFailure(aWriter.StartContainer(AnonymousTag(), kTLVType_Structure, containerType)); |
| |
| ReturnErrorOnFailure(reader.Next()); |
| ReturnErrorOnFailure(reader.EnterContainer(containerType1)); |
| ReturnErrorOnFailure( |
| aWriter.StartContainer(TLV::ContextTag(to_underlying(EventReportIB::Tag::kEventData)), kTLVType_Structure, containerType1)); |
| err = TLV::Utilities::Iterate(reader, CopyAndAdjustDeltaTime, &context, false /*recurse*/); |
| if (err == CHIP_END_OF_TLV) |
| { |
| err = CHIP_NO_ERROR; |
| } |
| ReturnErrorOnFailure(err); |
| ReturnErrorOnFailure(aWriter.EndContainer(containerType1)); |
| ReturnErrorOnFailure(aWriter.EndContainer(containerType)); |
| ReturnErrorOnFailure(aWriter.Finalize()); |
| return CHIP_NO_ERROR; |
| } |
| |
| CHIP_ERROR EventManagement::WriteEventStatusIB(TLVWriter & aWriter, const ConcreteEventPath & aEvent, StatusIB aStatus) |
| { |
| TLVType containerType; |
| ReturnErrorOnFailure(aWriter.StartContainer(AnonymousTag(), kTLVType_Structure, containerType)); |
| |
| EventStatusIB::Builder builder; |
| builder.Init(&aWriter, to_underlying(EventReportIB::Tag::kEventStatus)); |
| |
| ReturnErrorOnFailure(builder.CreatePath() |
| .Endpoint(aEvent.mEndpointId) |
| .Cluster(aEvent.mClusterId) |
| .Event(aEvent.mEventId) |
| .EndOfEventPathIB() |
| .GetError()); |
| |
| ReturnErrorOnFailure(builder.CreateErrorStatus().EncodeStatusIB(aStatus).GetError()); |
| |
| ReturnErrorOnFailure(builder.EndOfEventStatusIB().GetError()); |
| |
| ReturnErrorOnFailure(aWriter.EndContainer(containerType)); |
| ReturnErrorOnFailure(aWriter.Finalize()); |
| return CHIP_NO_ERROR; |
| } |
| |
| CHIP_ERROR EventManagement::CheckEventContext(EventLoadOutContext * eventLoadOutContext, |
| const EventManagement::EventEnvelopeContext & event) |
| { |
| if (eventLoadOutContext->mCurrentEventNumber < eventLoadOutContext->mStartingEventNumber) |
| { |
| return CHIP_ERROR_UNEXPECTED_EVENT; |
| } |
| |
| if (event.mFabricIndex != kUndefinedFabricIndex && eventLoadOutContext->mSubjectDescriptor.fabricIndex != event.mFabricIndex) |
| { |
| return CHIP_ERROR_UNEXPECTED_EVENT; |
| } |
| |
| ConcreteEventPath path(event.mEndpointId, event.mClusterId, event.mEventId); |
| CHIP_ERROR ret = CHIP_ERROR_UNEXPECTED_EVENT; |
| |
| bool eventReadViaConcretePath = false; |
| |
| for (auto * interestedPath = eventLoadOutContext->mpInterestedEventPaths; interestedPath != nullptr; |
| interestedPath = interestedPath->mpNext) |
| { |
| if (interestedPath->mValue.IsEventPathSupersetOf(path)) |
| { |
| ret = CHIP_NO_ERROR; |
| if (!interestedPath->mValue.HasEventWildcard()) |
| { |
| eventReadViaConcretePath = true; |
| break; |
| } |
| } |
| } |
| |
| ReturnErrorOnFailure(ret); |
| |
| Access::RequestPath requestPath{ .cluster = event.mClusterId, .endpoint = event.mEndpointId }; |
| Access::Privilege requestPrivilege = RequiredPrivilege::ForReadEvent(path); |
| CHIP_ERROR accessControlError = |
| Access::GetAccessControl().Check(eventLoadOutContext->mSubjectDescriptor, requestPath, requestPrivilege); |
| |
| if (accessControlError != CHIP_NO_ERROR) |
| { |
| ReturnErrorCodeIf(accessControlError != CHIP_ERROR_ACCESS_DENIED, accessControlError); |
| if (eventReadViaConcretePath) |
| { |
| ret = CHIP_ERROR_ACCESS_DENIED; |
| } |
| else |
| { |
| ret = CHIP_ERROR_UNEXPECTED_EVENT; |
| } |
| } |
| |
| return ret; |
| } |
| |
| CHIP_ERROR EventManagement::EventIterator(const TLVReader & aReader, size_t aDepth, EventLoadOutContext * apEventLoadOutContext, |
| EventEnvelopeContext * event) |
| { |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| TLVReader innerReader; |
| TLVType tlvType; |
| TLVType tlvType1; |
| |
| innerReader.Init(aReader); |
| VerifyOrDie(event != nullptr); |
| ReturnErrorOnFailure(innerReader.EnterContainer(tlvType)); |
| ReturnErrorOnFailure(innerReader.Next()); |
| |
| ReturnErrorOnFailure(innerReader.EnterContainer(tlvType1)); |
| err = TLV::Utilities::Iterate(innerReader, FetchEventParameters, event, false /*recurse*/); |
| |
| if (event->mFieldsToRead != kRequiredEventField) |
| { |
| return CHIP_ERROR_INVALID_ARGUMENT; |
| } |
| |
| if (err == CHIP_END_OF_TLV) |
| { |
| err = CHIP_NO_ERROR; |
| } |
| ReturnErrorOnFailure(err); |
| |
| apEventLoadOutContext->mCurrentTime = event->mCurrentTime; |
| apEventLoadOutContext->mCurrentEventNumber = event->mEventNumber; |
| |
| err = CheckEventContext(apEventLoadOutContext, *event); |
| if (err == CHIP_NO_ERROR) |
| { |
| err = CHIP_EVENT_ID_FOUND; |
| } |
| else if (err == CHIP_ERROR_UNEXPECTED_EVENT) |
| { |
| err = CHIP_NO_ERROR; |
| } |
| |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::CopyEventsSince(const TLVReader & aReader, size_t aDepth, void * apContext) |
| { |
| EventLoadOutContext * const loadOutContext = static_cast<EventLoadOutContext *>(apContext); |
| EventEnvelopeContext event; |
| CHIP_ERROR err = EventIterator(aReader, aDepth, loadOutContext, &event); |
| if (err == CHIP_EVENT_ID_FOUND) |
| { |
| // checkpoint the writer |
| TLV::TLVWriter checkpoint = loadOutContext->mWriter; |
| |
| err = CopyEvent(aReader, loadOutContext->mWriter, loadOutContext); |
| |
| // CHIP_NO_ERROR and CHIP_END_OF_TLV signify a |
| // successful copy. In all other cases, roll back the |
| // writer state back to the checkpoint, i.e., the state |
| // before we began the copy operation. |
| if ((err != CHIP_NO_ERROR) && (err != CHIP_END_OF_TLV)) |
| { |
| loadOutContext->mWriter = checkpoint; |
| return err; |
| } |
| |
| loadOutContext->mPreviousTime.mValue = loadOutContext->mCurrentTime.mValue; |
| loadOutContext->mFirst = false; |
| loadOutContext->mEventCount++; |
| } |
| else if (err == CHIP_ERROR_ACCESS_DENIED) |
| { |
| // checkpoint the writer |
| TLV::TLVWriter checkpoint = loadOutContext->mWriter; |
| |
| err = WriteEventStatusIB(loadOutContext->mWriter, ConcreteEventPath(event.mEndpointId, event.mClusterId, event.mEventId), |
| StatusIB(Protocols::InteractionModel::Status::UnsupportedAccess)); |
| |
| if (err != CHIP_NO_ERROR) |
| { |
| loadOutContext->mWriter = checkpoint; |
| return err; |
| } |
| |
| loadOutContext->mPreviousTime.mValue = loadOutContext->mCurrentTime.mValue; |
| loadOutContext->mFirst = false; |
| loadOutContext->mEventCount++; |
| } |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::FetchEventsSince(TLVWriter & aWriter, const ObjectList<EventPathParams> * apEventPathList, |
| EventNumber & aEventMin, size_t & aEventCount, |
| const Access::SubjectDescriptor & aSubjectDescriptor) |
| { |
| // TODO: Add particular set of event Paths in FetchEventsSince so that we can filter the interested paths |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| const bool recurse = false; |
| TLVReader reader; |
| CircularEventBufferWrapper bufWrapper; |
| EventLoadOutContext context(aWriter, PriorityLevel::Invalid, aEventMin); |
| |
| #if !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| ScopedLock lock(sInstance); |
| #endif // !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| |
| context.mSubjectDescriptor = aSubjectDescriptor; |
| context.mpInterestedEventPaths = apEventPathList; |
| err = GetEventReader(reader, PriorityLevel::Critical, &bufWrapper); |
| SuccessOrExit(err); |
| |
| err = TLV::Utilities::Iterate(reader, CopyEventsSince, &context, recurse); |
| if (err == CHIP_END_OF_TLV) |
| { |
| err = CHIP_NO_ERROR; |
| } |
| |
| exit: |
| if (err == CHIP_ERROR_BUFFER_TOO_SMALL || err == CHIP_ERROR_NO_MEMORY) |
| { |
| // We failed to fetch the current event because the buffer is too small, we will start from this one the next time. |
| aEventMin = context.mCurrentEventNumber; |
| } |
| else |
| { |
| // For all other cases, continue from the next event. |
| aEventMin = context.mCurrentEventNumber + 1; |
| } |
| aEventCount += context.mEventCount; |
| return err; |
| } |
| |
| CHIP_ERROR EventManagement::GetEventReader(TLVReader & aReader, PriorityLevel aPriority, CircularEventBufferWrapper * apBufWrapper) |
| { |
| CircularEventBuffer * buffer = GetPriorityBuffer(aPriority); |
| VerifyOrReturnError(buffer != nullptr, CHIP_ERROR_INVALID_ARGUMENT); |
| apBufWrapper->mpCurrent = buffer; |
| |
| CircularEventReader reader; |
| reader.Init(apBufWrapper); |
| aReader.Init(reader); |
| |
| return CHIP_NO_ERROR; |
| } |
| |
| CHIP_ERROR EventManagement::FetchEventParameters(const TLVReader & aReader, size_t aDepth, void * apContext) |
| { |
| EventEnvelopeContext * const envelope = static_cast<EventEnvelopeContext *>(apContext); |
| TLVReader reader; |
| reader.Init(aReader); |
| |
| if (reader.GetTag() == TLV::ContextTag(to_underlying(EventDataIB::Tag::kPath))) |
| { |
| EventPathIB::Parser path; |
| ReturnErrorOnFailure(path.Init(aReader)); |
| ReturnErrorOnFailure(path.GetEndpoint(&(envelope->mEndpointId))); |
| ReturnErrorOnFailure(path.GetCluster(&(envelope->mClusterId))); |
| ReturnErrorOnFailure(path.GetEvent(&(envelope->mEventId))); |
| envelope->mFieldsToRead |= 1 << to_underlying(EventDataIB::Tag::kPath); |
| } |
| |
| if (reader.GetTag() == TLV::ContextTag(to_underlying(EventDataIB::Tag::kPriority))) |
| { |
| uint16_t extPriority; // Note: the type here matches the type case in EventManagement::LogEvent, priority section |
| ReturnErrorOnFailure(reader.Get(extPriority)); |
| envelope->mPriority = static_cast<PriorityLevel>(extPriority); |
| envelope->mFieldsToRead |= 1 << to_underlying(EventDataIB::Tag::kPriority); |
| } |
| |
| if (reader.GetTag() == TLV::ContextTag(to_underlying(EventDataIB::Tag::kEventNumber))) |
| { |
| ReturnErrorOnFailure(reader.Get(envelope->mEventNumber)); |
| } |
| |
| if (reader.GetTag() == TLV::ContextTag(to_underlying(EventDataIB::Tag::kSystemTimestamp))) |
| { |
| uint64_t systemTime; |
| ReturnErrorOnFailure(reader.Get(systemTime)); |
| envelope->mCurrentTime.mType = Timestamp::Type::kSystem; |
| envelope->mCurrentTime.mValue = systemTime; |
| } |
| |
| if (reader.GetTag() == TLV::ContextTag(to_underlying(EventDataIB::Tag::kEpochTimestamp))) |
| { |
| uint64_t epochTime; |
| ReturnErrorOnFailure(reader.Get(epochTime)); |
| envelope->mCurrentTime.mType = Timestamp::Type::kEpoch; |
| envelope->mCurrentTime.mValue = epochTime; |
| } |
| |
| if (reader.GetTag() == TLV::ProfileTag(kEventManagementProfile, kFabricIndexTag)) |
| { |
| ReturnErrorOnFailure(reader.Get(envelope->mFabricIndex)); |
| } |
| return CHIP_NO_ERROR; |
| } |
| |
| CHIP_ERROR EventManagement::EvictEvent(CHIPCircularTLVBuffer & apBuffer, void * apAppData, TLVReader & aReader) |
| { |
| // pull out the delta time, pull out the priority |
| ReturnErrorOnFailure(aReader.Next()); |
| |
| TLVType containerType; |
| TLVType containerType1; |
| ReturnErrorOnFailure(aReader.EnterContainer(containerType)); |
| ReturnErrorOnFailure(aReader.Next()); |
| |
| ReturnErrorOnFailure(aReader.EnterContainer(containerType1)); |
| EventEnvelopeContext context; |
| constexpr bool recurse = false; |
| CHIP_ERROR err = TLV::Utilities::Iterate(aReader, FetchEventParameters, &context, recurse); |
| if (err == CHIP_END_OF_TLV) |
| { |
| err = CHIP_NO_ERROR; |
| } |
| ReturnErrorOnFailure(err); |
| |
| ReturnErrorOnFailure(aReader.ExitContainer(containerType1)); |
| ReturnErrorOnFailure(aReader.ExitContainer(containerType)); |
| const PriorityLevel imp = static_cast<PriorityLevel>(context.mPriority); |
| |
| ReclaimEventCtx * const ctx = static_cast<ReclaimEventCtx *>(apAppData); |
| CircularEventBuffer * const eventBuffer = ctx->mpEventBuffer; |
| if (eventBuffer->IsFinalDestinationForPriority(imp)) |
| { |
| ChipLogProgress(EventLogging, |
| "Dropped 1 event from buffer with priority %u and event number 0x" ChipLogFormatX64 |
| " due to overflow: event priority_level: %u", |
| static_cast<unsigned>(eventBuffer->GetPriority()), ChipLogValueX64(context.mEventNumber), |
| static_cast<unsigned>(imp)); |
| ctx->mSpaceNeededForMovedEvent = 0; |
| return CHIP_NO_ERROR; |
| } |
| |
| // event is not getting dropped. Note how much space it requires, and return. |
| ctx->mSpaceNeededForMovedEvent = aReader.GetLengthRead(); |
| return CHIP_END_OF_TLV; |
| } |
| |
| void EventManagement::SetScheduledEventInfo(EventNumber & aEventNumber, uint32_t & aInitialWrittenEventBytes) const |
| { |
| #if !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| ScopedLock lock(sInstance); |
| #endif // !CHIP_SYSTEM_CONFIG_NO_LOCKING |
| |
| aEventNumber = mLastEventNumber; |
| aInitialWrittenEventBytes = mBytesWritten; |
| } |
| |
| void CircularEventBuffer::Init(uint8_t * apBuffer, uint32_t aBufferLength, CircularEventBuffer * apPrev, |
| CircularEventBuffer * apNext, PriorityLevel aPriorityLevel) |
| { |
| CHIPCircularTLVBuffer::Init(apBuffer, aBufferLength); |
| mpPrev = apPrev; |
| mpNext = apNext; |
| mPriority = aPriorityLevel; |
| mpEventNumberCounter = nullptr; |
| } |
| |
| bool CircularEventBuffer::IsFinalDestinationForPriority(PriorityLevel aPriority) const |
| { |
| return !((mpNext != nullptr) && (mpNext->mPriority <= aPriority)); |
| } |
| |
| void CircularEventReader::Init(CircularEventBufferWrapper * apBufWrapper) |
| { |
| CircularEventBuffer * prev; |
| |
| if (apBufWrapper->mpCurrent == nullptr) |
| return; |
| |
| TLVReader::Init(*apBufWrapper, apBufWrapper->mpCurrent->DataLength()); |
| mMaxLen = apBufWrapper->mpCurrent->DataLength(); |
| for (prev = apBufWrapper->mpCurrent->GetPreviousCircularEventBuffer(); prev != nullptr; |
| prev = prev->GetPreviousCircularEventBuffer()) |
| { |
| CircularEventBufferWrapper bufWrapper; |
| bufWrapper.mpCurrent = prev; |
| mMaxLen += prev->DataLength(); |
| } |
| } |
| |
| CHIP_ERROR CircularEventBufferWrapper::GetNextBuffer(TLVReader & aReader, const uint8_t *& aBufStart, uint32_t & aBufLen) |
| { |
| CHIP_ERROR err = CHIP_NO_ERROR; |
| mpCurrent->GetNextBuffer(aReader, aBufStart, aBufLen); |
| SuccessOrExit(err); |
| |
| if ((aBufLen == 0) && (mpCurrent->GetPreviousCircularEventBuffer() != nullptr)) |
| { |
| mpCurrent = mpCurrent->GetPreviousCircularEventBuffer(); |
| aBufStart = nullptr; |
| err = GetNextBuffer(aReader, aBufStart, aBufLen); |
| } |
| |
| exit: |
| return err; |
| } |
| } // namespace app |
| } // namespace chip |
