Mirror/Momentum-Firmware
1
0
Fork 0
mirror of https://github.com/Next-Flip/Momentum-Firmware.git synced 2026-05-13 02:08:35 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'dev' of https://github.com/flipperdevices/flipperzero-firmware into mntm-dev

Browse Source
This commit is contained in:
Willy-JL
2024-03-20 01:48:10 +00:00
parent f723eb400e bcde0aefbd
commit 06aea09169
588 changed files with 3875 additions and 2957 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
applications/services/rpc/rpc.c
View File

@@ -94,7 +94,7 @@ struct Rpc {
};
RpcOwner rpc_session_get_owner(RpcSession* session) {
furi_assert(session);
furi_check(session);
return session->owner;
}
@@ -115,7 +115,7 @@ static void rpc_close_session_process(const PB_Main* request, void* context) {
}
void rpc_session_set_context(RpcSession* session, void* context) {
furi_assert(session);
furi_check(session);
furi_mutex_acquire(session->callbacks_mutex, FuriWaitForever);
session->context = context;
@@ -123,7 +123,7 @@ void rpc_session_set_context(RpcSession* session, void* context) {
}
void rpc_session_set_close_callback(RpcSession* session, RpcSessionClosedCallback callback) {
furi_assert(session);
furi_check(session);
furi_mutex_acquire(session->callbacks_mutex, FuriWaitForever);
session->closed_callback = callback;
@@ -131,7 +131,7 @@ void rpc_session_set_close_callback(RpcSession* session, RpcSessionClosedCallbac
}
void rpc_session_set_send_bytes_callback(RpcSession* session, RpcSendBytesCallback callback) {
furi_assert(session);
furi_check(session);
furi_mutex_acquire(session->callbacks_mutex, FuriWaitForever);
session->send_bytes_callback = callback;
@@ -141,7 +141,7 @@ void rpc_session_set_send_bytes_callback(RpcSession* session, RpcSendBytesCallba
void rpc_session_set_buffer_is_empty_callback(
RpcSession* session,
RpcBufferIsEmptyCallback callback) {
furi_assert(session);
furi_check(session);
furi_mutex_acquire(session->callbacks_mutex, FuriWaitForever);
session->buffer_is_empty_callback = callback;
@@ -151,7 +151,7 @@ void rpc_session_set_buffer_is_empty_callback(
void rpc_session_set_terminated_callback(
RpcSession* session,
RpcSessionTerminatedCallback callback) {
furi_assert(session);
furi_check(session);
furi_mutex_acquire(session->callbacks_mutex, FuriWaitForever);
session->terminated_callback = callback;
@@ -169,8 +169,8 @@ size_t rpc_session_feed(
const uint8_t* encoded_bytes,
size_t size,
uint32_t timeout) {
furi_assert(session);
furi_assert(encoded_bytes);
furi_check(session);
furi_check(encoded_bytes);
if(!size) return 0;
@@ -182,7 +182,7 @@ size_t rpc_session_feed(
}
size_t rpc_session_get_available_size(RpcSession* session) {
furi_assert(session);
furi_check(session);
return furi_stream_buffer_spaces_available(session->stream);
}
@@ -388,7 +388,7 @@ RpcSession* rpc_session_open(Rpc* rpc, RpcOwner owner) {
!momentum_settings.allow_locked_rpc_commands)
return NULL;
furi_assert(rpc);
furi_check(rpc);
RpcSession* session = malloc(sizeof(RpcSession));
session->callbacks_mutex = furi_mutex_alloc(FuriMutexTypeNormal);
@@ -428,8 +428,8 @@ RpcSession* rpc_session_open(Rpc* rpc, RpcOwner owner) {
}
void rpc_session_close(RpcSession* session) {
furi_assert(session);
furi_assert(session->rpc);
furi_check(session);
furi_check(session->rpc);
session->rpc->sessions_count--;