| 73 | } |
| 74 | |
| 75 | void post_message(MessageQueue* messageQueue, Isolate* isolate, Local<Value> messageObject) { |
| 76 | Local<String> result = JSON::Stringify(isolate->GetCurrentContext(), messageObject).ToLocalChecked(); |
| 77 | |
| 78 | WorkerMessage message; |
| 79 | message.length = result->Length(); |
| 80 | message.message = new char[message.length]; |
| 81 | result->WriteUtf8(isolate, message.message, message.length); |
| 82 | |
| 83 | kinc_mutex_lock(&messageQueue->messageMutex); |
| 84 | messageQueue->messages.push_back(message); |
| 85 | kinc_mutex_unlock(&messageQueue->messageMutex); |
| 86 | } |
| 87 | |
| 88 | void handle_message_queue(Isolate* isolate, const Global<Context>& context, MessageQueue* messageQueue) { |
| 89 | if (messageQueue->messageFunc.IsEmpty()) { |
no test coverage detected