-
Notifications
You must be signed in to change notification settings - Fork 2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
4a2d6e9
commit 91d4722
Showing
5 changed files
with
215 additions
and
50 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,39 @@ | ||
/* | ||
* | ||
* Copyright (c) 2023 Project CHIP Authors | ||
* All rights reserved. | ||
* | ||
* 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. | ||
*/ | ||
#pragma once | ||
|
||
#include <functional> | ||
|
||
namespace chip { | ||
namespace MainLoopWork { | ||
|
||
/** | ||
* Executes the given function in the CHIP main loop if one exists. | ||
* | ||
* If chip stack locking is available, this will lock the chip stack | ||
* and execute `f`. | ||
* | ||
* If chip stack locking is not available: | ||
* - if already in the chip main loop, this will execute `f` right away | ||
* - if main loop running, this will schedule and WAIT for `f` to execute | ||
* - if main loop is stopped, this will execute `f` right away | ||
*/ | ||
void ExecuteInMainLoop(std::function<void()> f); | ||
|
||
} // namespace MainLoopWork | ||
} // namespace chip |
43 changes: 43 additions & 0 deletions
43
src/controller/python/chip/native/ChipMainLoopWork_StackLock.cpp
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,43 @@ | ||
/* | ||
* | ||
* Copyright (c) 2023 Project CHIP Authors | ||
* All rights reserved. | ||
* | ||
* 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 "ChipMainLoopWork.h" | ||
|
||
#include <platform/PlatformManager.h> | ||
|
||
namespace chip { | ||
namespace MainLoopWork { | ||
namespace { | ||
|
||
using chip::DeviceLayer::PlatformMgr; | ||
|
||
class ScopedStackLock | ||
{ | ||
public: | ||
ScopedStackLock() { PlatformMgr().LockChipStack(); } | ||
~ScopedStackLock() { PlatformMgr().UnlockChipStack(); } | ||
}; | ||
|
||
} // namespace | ||
|
||
void ExecuteInMainLoop(std::function<void()> f) { | ||
ScopedStackLock lock; | ||
f(); | ||
} | ||
|
||
} // namespace MainLoopWork | ||
} // namespace chip |
83 changes: 83 additions & 0 deletions
83
src/controller/python/chip/native/ChipMainLoopWork_WorkSchedule.cpp
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,83 @@ | ||
/* | ||
* | ||
* Copyright (c) 2023 Project CHIP Authors | ||
* All rights reserved. | ||
* | ||
* 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 "ChipMainLoopWork.h" | ||
|
||
#include <platform/CHIPDeviceLayer.h> | ||
#include <semaphore.h> | ||
|
||
namespace chip { | ||
namespace MainLoopWork { | ||
namespace { | ||
|
||
struct WorkData | ||
{ | ||
std::function<void()> callback; | ||
sem_t done; | ||
|
||
WorkData() { sem_init(&done, 0 /* shared */, 0); } | ||
~WorkData() { sem_destroy(&done); } | ||
void Post() { sem_post(&done); } | ||
void Wait() { sem_wait(&done); } | ||
}; | ||
|
||
void PerformWork(intptr_t arg) | ||
{ | ||
WorkData * work = reinterpret_cast<WorkData *>(arg); | ||
|
||
work->callback(); | ||
work->Post(); | ||
} | ||
|
||
|
||
} // namespace | ||
|
||
void ExecuteInMainLoop(std::function<void()> f) { | ||
|
||
#if CHIP_STACK_LOCK_TRACKING_ENABLED | ||
if (chip::DeviceLayer::PlatformMgr().IsChipStackLockedByCurrentThread()) { | ||
f(); | ||
return; | ||
} | ||
#endif | ||
|
||
#if defined(__APPLE__) | ||
if (chip::DeviceLayer::PlatformManagerImpl()::IsWorkQueueCurrentQueue()) { | ||
f(); | ||
return; | ||
} | ||
#endif | ||
|
||
|
||
// NOTE: the code below assumes that chip main loop is running. | ||
// if it does not, this will deadlock. | ||
// | ||
// When CHIP_STACK_LOCK_TRACKING_ENABLED, stack locking will detect | ||
// main event loop not running, so this will not run when chip event | ||
// loop is stopped | ||
// | ||
// The cases when this will deadlock is: | ||
// - chip stack lock tracking is disabled | ||
// - main chip loop is not started (or stopped already) | ||
WorkData workdata; | ||
workdata.callback = f; | ||
chip::DeviceLayer::PlatformMgr().ScheduleWork(PerformWork, reinterpret_cast<intptr_t>(&workdata)); | ||
workdata.Wait(); | ||
} | ||
|
||
} // namespace MainLoopWork | ||
} // namespace chip |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters