/***
    Copyright (C) 2022 J Reece Wilson (a/k/a "Reece"). All rights reserved.

    File: IOProcessorItems.hpp
    Date: 2022-6-6
    Author: Reece
***/
#pragma once

namespace Aurora::IO
{
    struct IOProcessor;
    struct IOProcessorItem;

    struct IOProcessorItems
    {
        AuList<AuSPtr<IOProcessorItem>> allItems;
        AuList<AuSPtr<IOProcessorItem>> onTickReceivers;
        AuList<AuSPtr<IOProcessorItem>> onOtherReceivers;

        AuList<AuSPtr<IOProcessorItem>> registeredIO;

        AuThreadPrimitives::CriticalSectionUnique_t mutex;
        AuList<AuSPtr<IOProcessorItem>> workSignaled;
        AuThreadPrimitives::CriticalSectionUnique_t mutex2;
        AuList<AuSPtr<IOProcessorItem>> workSignaled2;

        AuList<AuSPtr<IOProcessorItem>> finalizeQueue;
        AuList<AuPair<AuSPtr<IOProcessorItem>, bool>> crossThreadAbort;

        bool Init();

        bool AddFrameTemp(const AuSPtr<IOProcessorItem> &item);
        bool AddFrameOrFallback(const AuSPtr<IOProcessorItem> &item);

        bool ScheduleFinish(const AuSPtr<IOProcessorItem> &item, bool unsafe);

        AuList<AuSPtr<IOProcessorItem>> GetBlockedSignals();
    };
}