SivSerialReader.hpp

[詳解]

//
//    OpenSiv3D用 Serial 受信クラス
//
//    Copyright (c) 2022 udonrobo
//
//    Sender --[Serial]--> Receiver
//                       ^^^^^^^^
//
 
#pragma once
 
#include <Siv3D/Serial.hpp>
#include <Udon/Serializer/Serializer.hpp>
#include <Udon/Utility/Show.hpp>
 
namespace Udon
{

    template <typename Message>
    class SivSerialReader
    {
        static constexpr size_t Size = Udon::SerializedSize<Message>();
 
        s3d::Serial& serial;
 
        s3d::Array<uint8_t> buffer;
 
        std::mutex mutex;
 
        std::thread thread;
 
        std::atomic_bool isRunning;    // thread stop token
 
    public:
        using MessageType = Message;

        SivSerialReader(s3d::Serial& bus)
            : serial(bus)
            , buffer(Size)
            , thread([this]()
                     { receive(); })
            , isRunning(true)
        {
        }

        ~SivSerialReader()
        {
            isRunning = false;
            thread.join();
        }

        Udon::Optional<Message> getMessage() const
        {
            std::lock_guard lock(mutex);
            return Udon::Deserialize<Message>(buffer);
        }

        void show() const
        {
            if (const auto message = getMessage())
            {
                Udon::Show(*message);
                s3d::Print.writeln();
            }
            else
            {
                s3d::Print << U"receive failed!";
            }
        }
 
        void showRaw() const
        {
            s3d::Print << buffer;
        }
 
    private:
        void receive()
        {
            while (isRunning)
            {
                if (not serial)
                    continue;
 
                if (serial.available() < Size)
                    continue;
 
                s3d::Array<uint8> temp;
                if (serial.readBytes(temp) && temp.size() == Size)
                {
                    std::lock_guard lock(mutex);
                    buffer = std::move(temp);
                }
 
                serial.clearInput();
            }
        }
    };
}    // namespace Udon