Skip to content

Commit

Permalink
[Core] Prevent further infinite recursion when printing errors
Browse files Browse the repository at this point in the history
  • Loading branch information
AThousandShips committed Mar 14, 2024
1 parent da945ce commit 14897f6
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions core/object/message_queue.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -183,7 +183,7 @@ Error CallQueue::push_notification(ObjectID p_id, int p_notification) {

if ((page_bytes[pages_used - 1] + room_needed) > uint32_t(PAGE_SIZE_BYTES)) {
if (pages_used == max_pages) {
fprintf(stderr, "Failed notification: %s target ID: %s. Message queue out of memory. %s\n", itos(p_notification).utf8().get_data(), itos(p_id).utf8().get_data(), error_text.utf8().get_data());
fprintf(stderr, "Failed notification: %d target ID: %s. Message queue out of memory. %s\n", p_notification, itos(p_id).utf8().get_data(), error_text.utf8().get_data());
statistics();
UNLOCK_MUTEX;
return ERR_OUT_OF_MEMORY;
Expand Down Expand Up @@ -256,7 +256,7 @@ Error CallQueue::_transfer_messages_to_main_queue() {
// Any other possibly existing source page needs to be added.

if (mq->pages_used + (pages_used - src_page) > mq->max_pages) {
ERR_PRINT("Failed appending thread queue. Message queue out of memory. " + mq->error_text);
fprintf(stderr, "Failed appending thread queue. Message queue out of memory. %s\n", mq->error_text.utf8().get_data());
mq->statistics();
mq->mutex.unlock();
return ERR_OUT_OF_MEMORY;
Expand Down Expand Up @@ -462,8 +462,8 @@ void CallQueue::statistics() {
} break;
}
if (null_target) {
//object was deleted
print_line("Object was deleted while awaiting a callback");
// Object was deleted.
fprintf(stdout, "Object was deleted while awaiting a callback.\n");

null_count++;
}
Expand All @@ -481,19 +481,19 @@ void CallQueue::statistics() {
}
}

print_line("TOTAL PAGES: " + itos(pages_used) + " (" + itos(pages_used * PAGE_SIZE_BYTES) + " bytes).");
print_line("NULL count: " + itos(null_count));
fprintf(stdout, "TOTAL PAGES: %d (%d bytes).\n", pages_used, pages_used * PAGE_SIZE_BYTES);
fprintf(stdout, "NULL count: %d.\n", null_count);

for (const KeyValue<StringName, int> &E : set_count) {
print_line("SET " + E.key + ": " + itos(E.value));
fprintf(stdout, "SET %s: %d.\n", String(E.key).utf8().get_data(), E.value);
}

for (const KeyValue<Callable, int> &E : call_count) {
print_line("CALL " + E.key + ": " + itos(E.value));
fprintf(stdout, "CALL %s: %d.\n", String(E.key).utf8().get_data(), E.value);
}

for (const KeyValue<int, int> &E : notify_count) {
print_line("NOTIFY " + itos(E.key) + ": " + itos(E.value));
fprintf(stdout, "NOTIFY %d: %d.\n", E.key, E.value);
}

UNLOCK_MUTEX;
Expand Down

0 comments on commit 14897f6

Please sign in to comment.