mirror of
https://github.com/zeldaret/tp
synced 2026-05-23 15:01:53 -04:00
Pheenoh
a61e3491f7
* initial freezard actor struct + setActionMode OK * daE_FZ_Draw * setReflectAngle * mBoundSoundset * daE_FZ_Execute & execute * demoDelete * daE_FZ_Delete & _delete * CreateHeap * useHeapInit * cc_set * mtx_set * action WIP * way_gake_check * executeRollMove * executeMove * draw WIP * executeDamage * checkpoint * create * checkpoint * daE_FZ_c::executeWait * checkpoint * daE_FZ_c::damage_check almost done * rm asm * rm headers * setup_profile WIP + doxygen update * fix merge issues * docs fix? * fix2 * doxygen updates * setup g_profile_E_FZ, profile setup script WIP * update github actions * update progress.md
92 lines
2.5 KiB
C
92 lines
2.5 KiB
C
#include "dolphin/os/OSMessage.h"
|
|
|
|
/* 8033E994-8033E9F4 3392D4 0060+00 0/0 13/13 5/5 .text OSInitMessageQueue */
|
|
void OSInitMessageQueue(OSMessageQueue* mq, OSMessage* msgArray, s32 msgCount) {
|
|
OSInitThreadQueue(&mq->sending_queue);
|
|
OSInitThreadQueue(&mq->receiving_queue);
|
|
mq->message_array = msgArray;
|
|
mq->num_messages = msgCount;
|
|
mq->first_index = 0;
|
|
mq->num_used = 0;
|
|
}
|
|
|
|
/* 8033E9F4-8033EABC 339334 00C8+00 0/0 21/21 9/9 .text OSSendMessage */
|
|
BOOL OSSendMessage(OSMessageQueue* mq, OSMessage msg, s32 flags) {
|
|
BOOL enabled;
|
|
s32 lastIndex;
|
|
|
|
enabled = OSDisableInterrupts();
|
|
|
|
while (mq->num_messages <= mq->num_used) {
|
|
if (!(flags & OS_MESSAGE_BLOCK)) {
|
|
OSRestoreInterrupts(enabled);
|
|
return FALSE;
|
|
} else {
|
|
OSSleepThread(&mq->sending_queue);
|
|
}
|
|
}
|
|
|
|
lastIndex = (mq->first_index + mq->num_used) % mq->num_messages;
|
|
mq->message_array[lastIndex] = msg;
|
|
mq->num_used++;
|
|
|
|
OSWakeupThread(&mq->receiving_queue);
|
|
|
|
OSRestoreInterrupts(enabled);
|
|
return TRUE;
|
|
}
|
|
|
|
/* 8033EABC-8033EB98 3393FC 00DC+00 0/0 15/15 9/9 .text OSReceiveMessage */
|
|
BOOL OSReceiveMessage(OSMessageQueue* mq, OSMessage* msg, s32 flags) {
|
|
BOOL enabled;
|
|
|
|
enabled = OSDisableInterrupts();
|
|
|
|
while (mq->num_used == 0) {
|
|
if (!(flags & OS_MESSAGE_BLOCK)) {
|
|
OSRestoreInterrupts(enabled);
|
|
return FALSE;
|
|
} else {
|
|
OSSleepThread(&mq->receiving_queue);
|
|
}
|
|
}
|
|
|
|
if (msg != NULL) {
|
|
*msg = mq->message_array[mq->first_index];
|
|
}
|
|
mq->first_index = (mq->first_index + 1) % mq->num_messages;
|
|
mq->num_used--;
|
|
|
|
OSWakeupThread(&mq->sending_queue);
|
|
|
|
OSRestoreInterrupts(enabled);
|
|
return TRUE;
|
|
}
|
|
|
|
/* 8033EB98-8033EC6C 3394D8 00D4+00 0/0 1/1 0/0 .text OSJamMessage */
|
|
BOOL OSJamMessage(OSMessageQueue* queue, void* msg, s32 flags) {
|
|
s32 lastMesg;
|
|
u32 interrupt;
|
|
|
|
interrupt = OSDisableInterrupts();
|
|
|
|
while (queue->num_messages <= queue->num_used) {
|
|
if (!(flags & OS_MSG_PERSISTENT)) {
|
|
OSRestoreInterrupts(interrupt);
|
|
return FALSE;
|
|
}
|
|
|
|
OSSleepThread(&queue->sending_queue);
|
|
}
|
|
|
|
// Find last position in queue
|
|
lastMesg = (queue->first_index + queue->num_messages - 1) % queue->num_messages;
|
|
queue->first_index = lastMesg;
|
|
queue->message_array[queue->first_index] = msg;
|
|
queue->num_used++;
|
|
|
|
OSWakeupThread(&queue->receiving_queue);
|
|
OSRestoreInterrupts(interrupt);
|
|
return TRUE;
|
|
}
|